This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 827ad19 Merge pull request #10947: [BEAM-9364] Refactor KafkaIO to
use DeserializerProviders
add 6fe1542 [BEAM-9345] Remove workaround to restore stdout/stderr during
JobGraph creation
add 4303ff2 [BEAM-9345] Add end-to-end Flink job submission test
add f7e7bc3 Merge pull request #10950: [BEAM-9345] Add end-to-end Flink
job submission test
No new revisions were added by this update.
Summary of changes:
.../beam/runners/flink/RemoteMiniClusterImpl.java | 67 ++++++
.../beam/runners/flink/RemoteMiniClusterImpl.java | 71 ++++++
.../apache/beam/runners/flink/FlinkJobInvoker.java | 2 -
.../org/apache/beam/runners/flink/FlinkRunner.java | 2 -
.../flink/translation/utils/Workarounds.java | 18 --
.../beam/runners/flink/FlinkJobInvokerTest.java | 73 ------
.../beam/runners/flink/FlinkSubmissionTest.java | 250 +++++++++++++++++++++
.../beam/runners/flink/RemoteMiniCluster.java} | 16 +-
8 files changed, 400 insertions(+), 99 deletions(-)
create mode 100644
runners/flink/1.7/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java
create mode 100644
runners/flink/1.8/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java
delete mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkJobInvokerTest.java
create mode 100644
runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkSubmissionTest.java
copy
runners/flink/src/{main/java/org/apache/beam/runners/flink/FlinkStateBackendFactory.java
=> test/java/org/apache/beam/runners/flink/RemoteMiniCluster.java} (65%)
