Skip to content

update spotless to 7.2 and reformat #38439

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
derrickaw wants to merge 10 commits into
base: master
Choose a base branch
from

try minimizing checks

f462021
Select commit
Loading
Failed to load commit list.
Refresh
Sign in for the full log view
Draft

update spotless to 7.2 and reformat #38439

try minimizing checks
f462021
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results failed May 15, 2026 in 0s

2 fail, 52 skipped, 183 pass in 12m 21s

  1 files   - 133    1 suites   - 133   12m 21s ⏱️ - 14m 22s
237 tests  - 657  183 ✅  - 696  52 💤 +37  2 ❌ +2 
237 runs   - 663  183 ✅  - 702  52 💤 +37  2 ❌ +2 

Results for commit f462021. ± Comparison against earlier commit 4ea112a.

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/py314/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 7s]
Raw output 
AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
<_InactiveRpcError of RPC that terminated with:
	status = StatusCode.INTERNAL
	details = ""
	debug_error_string = "UNKNOWN:Error received from peer  {grpc_status:13, grpc_message:""}"
>
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest testMethod=test_expand_kafka_read>

    def test_expand_kafka_read(self):
      if self.environment_type == 'PROCESS':
        self.skipTest(
            "Skipping Kafka read test in PROCESS mode due to "
            "https://github.com/apache/beam/issues/19461 (Flink expansion "
            "service incompatibility).")
      # 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     <_InactiveRpcError of RPC that terminated with:
E     	status = StatusCode.INTERNAL
E     	details = ""
E     	debug_error_string = "UNKNOWN:Error received from peer  {grpc_status:13, grpc_message:""}"
E     >

apache_beam/runners/portability/flink_runner_test.py:300: 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_expand_kafka_read (apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming) failed 

sdks/python/test-suites/portable/py314/build/srcs/sdks/python/pytest_flink-runner-test.xml [took 7s]
Raw output 
AssertionError: False is not true : Expected to fail due to invalid bootstrap.servers, but failed due to:
<_InactiveRpcError of RPC that terminated with:
	status = StatusCode.INTERNAL
	details = ""
	debug_error_string = "UNKNOWN:Error received from peer  {grpc_status:13, grpc_message:""}"
>
self = <apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming testMethod=test_expand_kafka_read>

    def test_expand_kafka_read(self):
      if self.environment_type == 'PROCESS':
        self.skipTest(
            "Skipping Kafka read test in PROCESS mode due to "
            "https://github.com/apache/beam/issues/19461 (Flink expansion "
            "service incompatibility).")
      # 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     <_InactiveRpcError of RPC that terminated with:
E     	status = StatusCode.INTERNAL
E     	details = ""
E     	debug_error_string = "UNKNOWN:Error received from peer  {grpc_status:13, grpc_message:""}"
E     >

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

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

52 skipped tests found 

There are 52 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_flatten_and_gbk
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_flatten_and_gbk
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_flatten_and_gbk
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

237 tests found 

There are 237 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_first_pane
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_and_gbk
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_et_timer_with_no_firing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_et_timer_with_no_reset
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTest ‑ test_pardo_et_timer_with_no_reset_and_no_clear
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_reshuffle_after_custom_window
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_sliding_windows
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_combine_per_key
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_first_pane
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_and_gbk
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_et_timer_with_no_firing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_et_timer_with_no_reset
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestOptimized ‑ test_pardo_et_timer_with_no_reset_and_no_clear
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_reshuffle_after_custom_window
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_sliding_windows
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_combine_per_key
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_first_pane
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_and_gbk
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_et_timer_with_no_firing
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_et_timer_with_no_reset
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_pardo_et_timer_with_no_reset_and_no_clear
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_reshuffle_after_custom_window
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_sliding_windows
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_combine_per_key
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_windowed_pardo_state_timers
apache_beam.runners.portability.flink_runner_test.FlinkRunnerTestStreaming ‑ test_windowing
View more details on GitHub Actions