boyuanzz edited a comment on pull request #11492: URL: https://github.com/apache/beam/pull/11492#issuecomment-619141429
> Test failure with batch SDF execution in https://builds.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Phrase/154/ > > ``` > * What went wrong: > Execution failed for task ':sdks:python:test-suites:portable:py2:flinkCompatibilityMatrixBatchLOOPBACK'. > > Process 'command 'sh'' finished with non-zero exit value 1 > ``` > > Looks unrelated to this change since the cron is also failing: https://builds.apache.org/job/beam_PreCommit_Python2_PVR_Flink_Cron/803/console The `test_pardo_timers` fails on unexpected result: ``` ERROR: test_pardo_timers (__main__.FlinkRunnerTestOptimized) BeamAssertException: Failed assert: [('fired', 20), ('fired', 200), ('fired', 40), ('fired', 400)] == [('fired', Timestamp(20)), ('fired', Timestamp(200))], missing elements [('fired', 40), ('fired', 400)] [while running 'assert_that/Match'] ``` If you want to repro the failure on your local machine: 1. build flink jar: ./gradlew runners:flink:1.10:job-server:shadowJar 2. python -m apache_beam.runners.portability.flink_runner_test --flink_job_server_jar=${YOUR_BEAM_DIR}/runners/flink/1.10/job-server/build/libs/beam-runners-flink-1.10-job-server-2.21.0-SNAPSHOT.jar --environment_type=LOOPBACK FlinkRunnerTest.test_pardo_timers ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
