Skip to content

[prism] Support interval windows/prep for custom windows. #1978

[prism] Support interval windows/prep for custom windows.

[prism] Support interval windows/prep for custom windows. #1978

GitHub Actions / Test Results failed Aug 15, 2024 in 0s

6 fail, 49 skipped, 158 pass in 13m 51s

213 tests   158 ✅  13m 51s ⏱️
  1 suites   49 💤
  1 files      6 ❌

Results for commit c197e4f.

Annotations

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_expand_kafka_read (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 21s]
Raw output
AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
Pipeline test_expand_kafka_read_1723743241.407319_63711457-cbbf-438c-ba53-4a51cc09643e failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=19-1 --provision_endpoint=localhost:45353'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest testMethod=test_expand_kafka_read>

    def test_expand_kafka_read(self):
      # We expect to fail here because we do not have a Kafka cluster handy.
      # Nevertheless, we check that the transform is expanded by the
      # ExpansionService and that the pipeline fails during execution.
      with self.assertRaises(Exception) as ctx:
        self.enable_commit = True
        with self.create_pipeline() as p:
          # pylint: disable=expression-not-assigned
          (
              p
              | ReadFromKafka(
                  consumer_config={
                      'bootstrap.servers': 'notvalid1:7777, notvalid2:3531',
                      'group.id': 'any_group'
                  },
                  topics=['topic1', 'topic2'],
                  key_deserializer='org.apache.kafka.'
                  'common.serialization.'
                  'ByteArrayDeserializer',
                  value_deserializer='org.apache.kafka.'
                  'common.serialization.'
                  'LongDeserializer',
                  commit_offset_in_finalize=True,
                  timestamp_policy=ReadFromKafka.create_time_policy,
                  redistribute=False,
                  redistribute_num_keys=0,
                  allow_duplicates=False,
                  expansion_service=self.get_expansion_service()))
>     self.assertTrue(
          'No resolvable bootstrap urls given in bootstrap.servers' in str(
              ctx.exception),
          'Expected to fail due to invalid bootstrap.servers, but '
          'failed due to:\n%s' % str(ctx.exception))
E     AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
E     Pipeline test_expand_kafka_read_1723743241.407319_63711457-cbbf-438c-ba53-4a51cc09643e failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=19-1 --provision_endpoint=localhost:45353'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/flink_runner_test.py:259: AssertionError

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_external_transform (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 12s]
Raw output
RuntimeError: Pipeline test_external_transform_1723743266.3366387_fd567497-c81f-4843-a6b9-8cacf5fb94fd failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=20-1 --provision_endpoint=localhost:46297'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest testMethod=test_external_transform>

    def test_external_transform(self):
>     with self.create_pipeline() as p:

apache_beam/runners/portability/flink_runner_test.py:223: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/pipeline.py:614: in __exit__
    self.result.wait_until_finish()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.portability.portable_runner.PipelineResult object at 0x7d63b064a960>
duration = None

    def wait_until_finish(self, duration=None):
      """
      :param duration: The maximum time in milliseconds to wait for the result of
      the execution. If None or zero, will wait until the pipeline finishes.
      :return: The result of the pipeline, i.e. PipelineResult.
      """
      def read_messages() -> None:
        previous_state = -1
        for message in self._message_stream:
          if message.HasField('message_response'):
            logging.log(
                MESSAGE_LOG_LEVELS[message.message_response.importance],
                "%s",
                message.message_response.message_text)
          else:
            current_state = message.state_response.state
            if current_state != previous_state:
              _LOGGER.info(
                  "Job state changed to %s",
                  self.runner_api_state_to_pipeline_state(current_state))
              previous_state = current_state
          self._messages.append(message)
    
      message_thread = threading.Thread(
          target=read_messages, name='wait_until_finish_read')
      message_thread.daemon = True
      message_thread.start()
    
      if duration:
        state_thread = threading.Thread(
            target=functools.partial(self._observe_state, message_thread),
            name='wait_until_finish_state_observer')
        state_thread.daemon = True
        state_thread.start()
        start_time = time.time()
        duration_secs = duration / 1000
        while (time.time() - start_time < duration_secs and
               state_thread.is_alive()):
          time.sleep(1)
      else:
        self._observe_state(message_thread)
    
      if self._runtime_exception:
>       raise self._runtime_exception
E       RuntimeError: Pipeline test_external_transform_1723743266.3366387_fd567497-c81f-4843-a6b9-8cacf5fb94fd failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=20-1 --provision_endpoint=localhost:46297'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/portable_runner.py:568: RuntimeError

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_sql (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 10s]
Raw output
RuntimeError: Pipeline test_sql_1723743454.8206627_5c946fc6-0105-454e-9093-3482c1823807 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=71-2 --provision_endpoint=localhost:38011'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest testMethod=test_sql>

    def test_sql(self):
>     with self.create_pipeline() as p:

apache_beam/runners/portability/flink_runner_test.py:286: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/pipeline.py:614: in __exit__
    self.result.wait_until_finish()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.portability.portable_runner.PipelineResult object at 0x7d63b04c3bc0>
duration = None

    def wait_until_finish(self, duration=None):
      """
      :param duration: The maximum time in milliseconds to wait for the result of
      the execution. If None or zero, will wait until the pipeline finishes.
      :return: The result of the pipeline, i.e. PipelineResult.
      """
      def read_messages() -> None:
        previous_state = -1
        for message in self._message_stream:
          if message.HasField('message_response'):
            logging.log(
                MESSAGE_LOG_LEVELS[message.message_response.importance],
                "%s",
                message.message_response.message_text)
          else:
            current_state = message.state_response.state
            if current_state != previous_state:
              _LOGGER.info(
                  "Job state changed to %s",
                  self.runner_api_state_to_pipeline_state(current_state))
              previous_state = current_state
          self._messages.append(message)
    
      message_thread = threading.Thread(
          target=read_messages, name='wait_until_finish_read')
      message_thread.daemon = True
      message_thread.start()
    
      if duration:
        state_thread = threading.Thread(
            target=functools.partial(self._observe_state, message_thread),
            name='wait_until_finish_state_observer')
        state_thread.daemon = True
        state_thread.start()
        start_time = time.time()
        duration_secs = duration / 1000
        while (time.time() - start_time < duration_secs and
               state_thread.is_alive()):
          time.sleep(1)
      else:
        self._observe_state(message_thread)
    
      if self._runtime_exception:
>       raise self._runtime_exception
E       RuntimeError: Pipeline test_sql_1723743454.8206627_5c946fc6-0105-454e-9093-3482c1823807 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=71-2 --provision_endpoint=localhost:38011'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/portable_runner.py:568: RuntimeError

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_expand_kafka_read (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 21s]
Raw output
AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
Pipeline test_expand_kafka_read_1723743815.0698233_c562093c-959f-446c-bacc-1c89c03a18f1 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=17-1 --provision_endpoint=localhost:32843'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming testMethod=test_expand_kafka_read>

    def test_expand_kafka_read(self):
      # We expect to fail here because we do not have a Kafka cluster handy.
      # Nevertheless, we check that the transform is expanded by the
      # ExpansionService and that the pipeline fails during execution.
      with self.assertRaises(Exception) as ctx:
        self.enable_commit = True
        with self.create_pipeline() as p:
          # pylint: disable=expression-not-assigned
          (
              p
              | ReadFromKafka(
                  consumer_config={
                      'bootstrap.servers': 'notvalid1:7777, notvalid2:3531',
                      'group.id': 'any_group'
                  },
                  topics=['topic1', 'topic2'],
                  key_deserializer='org.apache.kafka.'
                  'common.serialization.'
                  'ByteArrayDeserializer',
                  value_deserializer='org.apache.kafka.'
                  'common.serialization.'
                  'LongDeserializer',
                  commit_offset_in_finalize=True,
                  timestamp_policy=ReadFromKafka.create_time_policy,
                  redistribute=False,
                  redistribute_num_keys=0,
                  allow_duplicates=False,
                  expansion_service=self.get_expansion_service()))
>     self.assertTrue(
          'No resolvable bootstrap urls given in bootstrap.servers' in str(
              ctx.exception),
          'Expected to fail due to invalid bootstrap.servers, but '
          'failed due to:\n%s' % str(ctx.exception))
E     AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
E     Pipeline test_expand_kafka_read_1723743815.0698233_c562093c-959f-446c-bacc-1c89c03a18f1 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=17-1 --provision_endpoint=localhost:32843'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/flink_runner_test.py:259: AssertionError

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_external_transform (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 7s]
Raw output
RuntimeError: Pipeline test_external_transform_1723743839.2302938_a243f553-9218-4488-9a22-ae45664fc641 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=18-1 --provision_endpoint=localhost:42611'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming testMethod=test_external_transform>

    def test_external_transform(self):
>     with self.create_pipeline() as p:

apache_beam/runners/portability/flink_runner_test.py:223: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/pipeline.py:614: in __exit__
    self.result.wait_until_finish()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.portability.portable_runner.PipelineResult object at 0x7d63b0701a60>
duration = None

    def wait_until_finish(self, duration=None):
      """
      :param duration: The maximum time in milliseconds to wait for the result of
      the execution. If None or zero, will wait until the pipeline finishes.
      :return: The result of the pipeline, i.e. PipelineResult.
      """
      def read_messages() -> None:
        previous_state = -1
        for message in self._message_stream:
          if message.HasField('message_response'):
            logging.log(
                MESSAGE_LOG_LEVELS[message.message_response.importance],
                "%s",
                message.message_response.message_text)
          else:
            current_state = message.state_response.state
            if current_state != previous_state:
              _LOGGER.info(
                  "Job state changed to %s",
                  self.runner_api_state_to_pipeline_state(current_state))
              previous_state = current_state
          self._messages.append(message)
    
      message_thread = threading.Thread(
          target=read_messages, name='wait_until_finish_read')
      message_thread.daemon = True
      message_thread.start()
    
      if duration:
        state_thread = threading.Thread(
            target=functools.partial(self._observe_state, message_thread),
            name='wait_until_finish_state_observer')
        state_thread.daemon = True
        state_thread.start()
        start_time = time.time()
        duration_secs = duration / 1000
        while (time.time() - start_time < duration_secs and
               state_thread.is_alive()):
          time.sleep(1)
      else:
        self._observe_state(message_thread)
    
      if self._runtime_exception:
>       raise self._runtime_exception
E       RuntimeError: Pipeline test_external_transform_1723743839.2302938_a243f553-9218-4488-9a22-ae45664fc641 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=18-1 --provision_endpoint=localhost:42611'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/portable_runner.py:568: RuntimeError

Check warning on line 0 in apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming

See this annotation in the file changed.

@github-actions github-actions / Test Results

test_sql (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming) failed

sdks/python/test-suites/portable/py312/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 9s]
Raw output
RuntimeError: Pipeline test_sql_1723743954.6003191_cc029fbe-36aa-4681-8155-c0b8dd7087c9 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=54-10 --provision_endpoint=localhost:35113'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming testMethod=test_sql>

    def test_sql(self):
>     with self.create_pipeline() as p:

apache_beam/runners/portability/flink_runner_test.py:286: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/pipeline.py:614: in __exit__
    self.result.wait_until_finish()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.runners.portability.portable_runner.PipelineResult object at 0x7d63b06bba40>
duration = None

    def wait_until_finish(self, duration=None):
      """
      :param duration: The maximum time in milliseconds to wait for the result of
      the execution. If None or zero, will wait until the pipeline finishes.
      :return: The result of the pipeline, i.e. PipelineResult.
      """
      def read_messages() -> None:
        previous_state = -1
        for message in self._message_stream:
          if message.HasField('message_response'):
            logging.log(
                MESSAGE_LOG_LEVELS[message.message_response.importance],
                "%s",
                message.message_response.message_text)
          else:
            current_state = message.state_response.state
            if current_state != previous_state:
              _LOGGER.info(
                  "Job state changed to %s",
                  self.runner_api_state_to_pipeline_state(current_state))
              previous_state = current_state
          self._messages.append(message)
    
      message_thread = threading.Thread(
          target=read_messages, name='wait_until_finish_read')
      message_thread.daemon = True
      message_thread.start()
    
      if duration:
        state_thread = threading.Thread(
            target=functools.partial(self._observe_state, message_thread),
            name='wait_until_finish_state_observer')
        state_thread.daemon = True
        state_thread.start()
        start_time = time.time()
        duration_secs = duration / 1000
        while (time.time() - start_time < duration_secs and
               state_thread.is_alive()):
          time.sleep(1)
      else:
        self._observe_state(message_thread)
    
      if self._runtime_exception:
>       raise self._runtime_exception
E       RuntimeError: Pipeline test_sql_1723743954.6003191_cc029fbe-36aa-4681-8155-c0b8dd7087c9 failed in state FAILED: java.io.IOException: Received exit code 125 for command 'docker run -d --network=host --env=DOCKER_MAC_CONTAINER=null apache/beam_java11_sdk:2.59.0.dev --id=54-10 --provision_endpoint=localhost:35113'. stderr: Unable to find image 'apache/beam_java11_sdk:2.59.0.dev' locallydocker: Error response from daemon: manifest for apache/beam_java11_sdk:2.59.0.dev not found: manifest unknown: manifest unknown.See 'docker run --help'.

apache_beam/runners/portability/portable_runner.py:568: RuntimeError

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

49 skipped tests found

There are 49 skipped tests, see "Raw output" for the full list of skipped tests.
Raw output
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_teststream_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_expand_kafka_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_expand_kafka_write
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_external_transform
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sql
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_teststream_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_teststream_pardo_timers

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

213 tests found

There are 213 tests, see "Raw output" for the full list of tests.
Raw output
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_assert_that
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_dofn_params
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_fusion_break
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_overlapping_windows
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_override_type_inference
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_pardo_window_param
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_rebatch_pardos
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_batch_to_element_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_combine_per_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_create
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_create_value_provider_pipeline_option
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_element_to_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_error_message_includes_stage
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_error_traceback_includes_user_code
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_expand_kafka_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_expand_kafka_write
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_external_transform
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_flatmap_numpy_array
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_flatten
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_flatten_same_pcollections
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_flattened_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_gbk_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_group_by_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_group_by_key_with_empty_pcoll_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_metrics
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_multimap_multiside_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_multimap_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_multimap_side_input_type_coercion
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pack_combiners
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_dynamic_timer
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_and_main_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_input_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_side_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_state_only
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_state_timers_non_standard_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_state_with_custom_key_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_timers_clear
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_unfusable_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_unfusable_side_inputs_with_separation
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_windowed_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_reshuffle
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_synthetic_source
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_check_done_failed
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_dofn_as_restriction_provider
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_dofn_as_watermark_estimator
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_sql
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_teststream_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_windowed_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_windowing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_assert_that
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_dofn_params
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_fusion_break
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_overlapping_windows
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_override_type_inference
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_pardo_window_param
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_rebatch_pardos
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_batch_to_element_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_combine_per_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_create
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_create_value_provider_pipeline_option
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_element_to_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_error_message_includes_stage
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_error_traceback_includes_user_code
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_expand_kafka_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_expand_kafka_write
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_external_transform
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_flatmap_numpy_array
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_flatten
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_flatten_same_pcollections
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_flattened_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_gbk_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_group_by_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_group_by_key_with_empty_pcoll_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_metrics
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_multimap_multiside_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_multimap_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_multimap_side_input_type_coercion
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pack_combiners
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_dynamic_timer
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_and_main_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_input_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_side_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_state_only
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_state_timers_non_standard_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_state_with_custom_key_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_timers_clear
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_unfusable_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_unfusable_side_inputs_with_separation
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_windowed_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_reshuffle
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_synthetic_source
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_check_done_failed
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_dofn_as_restriction_provider
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_dofn_as_watermark_estimator
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_sql
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_teststream_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_windowed_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_windowing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_assert_that
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_dofn_params
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_fusion_break
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_overlapping_windows
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_override_type_inference
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_trigger_flush
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_pardo_window_param
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_rebatch_pardos
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_batch_to_element_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_callbacks_with_exception
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_combine_per_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_create
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_create_value_provider_pipeline_option
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_custom_merging_window
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_custom_window_type
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_draining_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_element_to_batch_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_error_message_includes_stage
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_error_traceback_includes_user_code
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_expand_kafka_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_expand_kafka_write
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_external_transform
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_flatmap_numpy_array
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_flatten
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_flatten_same_pcollections
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_flattened_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_gbk_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_group_by_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_group_by_key_with_empty_pcoll_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_large_elements
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_metrics
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_multimap_multiside_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_multimap_side_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_multimap_side_input_type_coercion
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_no_subtransform_composite
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pack_combiners
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_dynamic_timer
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_large_input
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_and_main_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_input_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_input_sparse_dependencies
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_side_outputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_state_only
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_state_timers_non_standard_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_state_with_custom_key_coder
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_timers_clear
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_unfusable_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_unfusable_side_inputs_with_separation
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_windowed_side_inputs
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_read
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_register_finalizations
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_reshuffle
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_default_truncate_when_bounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_default_truncate_when_unbounded
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_synthetic_source
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_check_done_failed
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_dofn_as_restriction_provider
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_dofn_as_watermark_estimator
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_sdf_initiated_checkpointing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_truncate
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sdf_with_watermark_tracking
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_sql
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_teststream_pardo_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_windowed_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_windowing