lostluck commented on issue #21828: URL: https://github.com/apache/beam/issues/21828#issuecomment-1154396684
No one on the Go side. It looks like it's a Flink configuration issue, that is also happening with the equivalent Python Load Tests. This was originally reported in #21696 Identical Python Failures: https://ci-beam.apache.org/job/beam_LoadTests_Python_ParDo_Flink_Batch/ https://ci-beam.apache.org/job/beam_LoadTests_Python_Combine_Flink_Batch/ (the other python flink load tests are disabled, presumably for the same reason.) https://github.com/apache/beam/blob/master/.test-infra/jenkins/Flink.groovy is what's used for both. Could it be as simple as updating which flink these jobs are using? https://github.com/apache/beam/blob/master/.test-infra/jenkins/Flink.groovy#L20 Cluster script: https://github.com/apache/beam/blob/master/.test-infra/dataproc/flink_cluster.sh That's about as far as I have time to explore, but someone who knows Flink and Groovy and a little bit of DataProc would be best to solve this for both Python and Go load tests. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
