Python: comm.Scatterv() in mpi4py, why the value changes after scattering












0















I want scatter different length np.array to different ranks, but I find the value changed and I do not know why.
I tried many times and simplified my code as below.



import numpy as np
import random
from random import seed
from mpi4py import MPI
comm = MPI.COMM_WORLD
size = comm.Get_size()
rank = comm.Get_rank()

num = 4
N = num // size + (num % size > rank)

position_x = np.zeros(num,dtype=float)

seed(10059)
for i in range(num):

position_x[i] = round(random.uniform(-5,5),3)


print(position_x)

if rank == 0:
share1 = position_x

else:
share1 = None


count =
for i in range(size):
if i <= num%size-1:
count += [num//size + 1]
else:
count += [num//size]

pos1 = np.zeros(N, dtype='f')

comm.Scatterv([share1, count, MPI.FLOAT], pos1, root=0)

print(pos1,'from ',rank)


The result of 3 processes is shown below.



[-2.275  4.238 -1.637  0.981]
[5177.344] from 1
[-2.275 4.238 -1.637 0.981]
[ 4.172325e-08 -2.034375e+00] from 0
[-2.275 4.238 -1.637 0.981]
[2.264875] from 2


I cannot understand where the strange numbers come from. The result should be [-2.275 4.238] from 0, [-1.637] from 1, [0.981] from 2 if right.
Does anyone have an idea? Thank you very much.



————————————————————————————————————————————



Update:



I find if the numbers in np.array are float, it will have this problem. I try to change the DATATYPE to MPI.INT or MPI.F_FLOAT, but it still doesn't work.



It seems caused by random, but I need to randomly generate the position.
I really do not know how to correct it.










share|improve this question





























    0















    I want scatter different length np.array to different ranks, but I find the value changed and I do not know why.
    I tried many times and simplified my code as below.



    import numpy as np
    import random
    from random import seed
    from mpi4py import MPI
    comm = MPI.COMM_WORLD
    size = comm.Get_size()
    rank = comm.Get_rank()

    num = 4
    N = num // size + (num % size > rank)

    position_x = np.zeros(num,dtype=float)

    seed(10059)
    for i in range(num):

    position_x[i] = round(random.uniform(-5,5),3)


    print(position_x)

    if rank == 0:
    share1 = position_x

    else:
    share1 = None


    count =
    for i in range(size):
    if i <= num%size-1:
    count += [num//size + 1]
    else:
    count += [num//size]

    pos1 = np.zeros(N, dtype='f')

    comm.Scatterv([share1, count, MPI.FLOAT], pos1, root=0)

    print(pos1,'from ',rank)


    The result of 3 processes is shown below.



    [-2.275  4.238 -1.637  0.981]
    [5177.344] from 1
    [-2.275 4.238 -1.637 0.981]
    [ 4.172325e-08 -2.034375e+00] from 0
    [-2.275 4.238 -1.637 0.981]
    [2.264875] from 2


    I cannot understand where the strange numbers come from. The result should be [-2.275 4.238] from 0, [-1.637] from 1, [0.981] from 2 if right.
    Does anyone have an idea? Thank you very much.



    ————————————————————————————————————————————



    Update:



    I find if the numbers in np.array are float, it will have this problem. I try to change the DATATYPE to MPI.INT or MPI.F_FLOAT, but it still doesn't work.



    It seems caused by random, but I need to randomly generate the position.
    I really do not know how to correct it.










    share|improve this question



























      0












      0








      0








      I want scatter different length np.array to different ranks, but I find the value changed and I do not know why.
      I tried many times and simplified my code as below.



      import numpy as np
      import random
      from random import seed
      from mpi4py import MPI
      comm = MPI.COMM_WORLD
      size = comm.Get_size()
      rank = comm.Get_rank()

      num = 4
      N = num // size + (num % size > rank)

      position_x = np.zeros(num,dtype=float)

      seed(10059)
      for i in range(num):

      position_x[i] = round(random.uniform(-5,5),3)


      print(position_x)

      if rank == 0:
      share1 = position_x

      else:
      share1 = None


      count =
      for i in range(size):
      if i <= num%size-1:
      count += [num//size + 1]
      else:
      count += [num//size]

      pos1 = np.zeros(N, dtype='f')

      comm.Scatterv([share1, count, MPI.FLOAT], pos1, root=0)

      print(pos1,'from ',rank)


      The result of 3 processes is shown below.



      [-2.275  4.238 -1.637  0.981]
      [5177.344] from 1
      [-2.275 4.238 -1.637 0.981]
      [ 4.172325e-08 -2.034375e+00] from 0
      [-2.275 4.238 -1.637 0.981]
      [2.264875] from 2


      I cannot understand where the strange numbers come from. The result should be [-2.275 4.238] from 0, [-1.637] from 1, [0.981] from 2 if right.
      Does anyone have an idea? Thank you very much.



      ————————————————————————————————————————————



      Update:



      I find if the numbers in np.array are float, it will have this problem. I try to change the DATATYPE to MPI.INT or MPI.F_FLOAT, but it still doesn't work.



      It seems caused by random, but I need to randomly generate the position.
      I really do not know how to correct it.










      share|improve this question
















      I want scatter different length np.array to different ranks, but I find the value changed and I do not know why.
      I tried many times and simplified my code as below.



      import numpy as np
      import random
      from random import seed
      from mpi4py import MPI
      comm = MPI.COMM_WORLD
      size = comm.Get_size()
      rank = comm.Get_rank()

      num = 4
      N = num // size + (num % size > rank)

      position_x = np.zeros(num,dtype=float)

      seed(10059)
      for i in range(num):

      position_x[i] = round(random.uniform(-5,5),3)


      print(position_x)

      if rank == 0:
      share1 = position_x

      else:
      share1 = None


      count =
      for i in range(size):
      if i <= num%size-1:
      count += [num//size + 1]
      else:
      count += [num//size]

      pos1 = np.zeros(N, dtype='f')

      comm.Scatterv([share1, count, MPI.FLOAT], pos1, root=0)

      print(pos1,'from ',rank)


      The result of 3 processes is shown below.



      [-2.275  4.238 -1.637  0.981]
      [5177.344] from 1
      [-2.275 4.238 -1.637 0.981]
      [ 4.172325e-08 -2.034375e+00] from 0
      [-2.275 4.238 -1.637 0.981]
      [2.264875] from 2


      I cannot understand where the strange numbers come from. The result should be [-2.275 4.238] from 0, [-1.637] from 1, [0.981] from 2 if right.
      Does anyone have an idea? Thank you very much.



      ————————————————————————————————————————————



      Update:



      I find if the numbers in np.array are float, it will have this problem. I try to change the DATATYPE to MPI.INT or MPI.F_FLOAT, but it still doesn't work.



      It seems caused by random, but I need to randomly generate the position.
      I really do not know how to correct it.







      python numpy mpi4py






      share|improve this question















      share|improve this question













      share|improve this question




      share|improve this question








      edited Nov 20 '18 at 6:39







      Running

















      asked Nov 19 '18 at 14:36









      RunningRunning

      12




      12
























          0






          active

          oldest

          votes











          Your Answer






          StackExchange.ifUsing("editor", function () {
          StackExchange.using("externalEditor", function () {
          StackExchange.using("snippets", function () {
          StackExchange.snippets.init();
          });
          });
          }, "code-snippets");

          StackExchange.ready(function() {
          var channelOptions = {
          tags: "".split(" "),
          id: "1"
          };
          initTagRenderer("".split(" "), "".split(" "), channelOptions);

          StackExchange.using("externalEditor", function() {
          // Have to fire editor after snippets, if snippets enabled
          if (StackExchange.settings.snippets.snippetsEnabled) {
          StackExchange.using("snippets", function() {
          createEditor();
          });
          }
          else {
          createEditor();
          }
          });

          function createEditor() {
          StackExchange.prepareEditor({
          heartbeatType: 'answer',
          autoActivateHeartbeat: false,
          convertImagesToLinks: true,
          noModals: true,
          showLowRepImageUploadWarning: true,
          reputationToPostImages: 10,
          bindNavPrevention: true,
          postfix: "",
          imageUploader: {
          brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
          contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
          allowUrls: true
          },
          onDemand: true,
          discardSelector: ".discard-answer"
          ,immediatelyShowMarkdownHelp:true
          });


          }
          });














          draft saved

          draft discarded


















          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53376875%2fpython-comm-scatterv-in-mpi4py-why-the-value-changes-after-scattering%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown

























          0






          active

          oldest

          votes








          0






          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes
















          draft saved

          draft discarded




















































          Thanks for contributing an answer to Stack Overflow!


          • Please be sure to answer the question. Provide details and share your research!

          But avoid



          • Asking for help, clarification, or responding to other answers.

          • Making statements based on opinion; back them up with references or personal experience.


          To learn more, see our tips on writing great answers.




          draft saved


          draft discarded














          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53376875%2fpython-comm-scatterv-in-mpi4py-why-the-value-changes-after-scattering%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown





















































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown

































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown







          Popular posts from this blog

          Biblatex bibliography style without URLs when DOI exists (in Overleaf with Zotero bibliography)

          ComboBox Display Member on multiple fields

          Is it possible to collect Nectar points via Trainline?