Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-23425

The impact of cpu cores on test results for StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup

    XMLWordPrintableJSON

Details

    Description

      By default, LocalStreamEnvironment will use the number of cpu cores(Runtime.getRuntime().availableProcessors()) as the default parallelism;

      In our company, we will use a 1-core docker container to run the test.

      Then StreamingJobGraphGeneratorTest#testSlotSharingResourceConfigurationWithDefaultSlotSharingGroup failed.

      because the parallelism of map operator is 1, so the number of Vertex is 1, not expected 2 anymore.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              tartarus tartarus
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated: