This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 4b77225 Merge pull request #9677 from xubii/time-output-timestamp
add 59f10d0 Rename FlinkClassloading to Workarounds
add 021e7b3 [BEAM-9060] Restore stdout/stderr in case Flink's
OptimizedPlanEnvironment is used
add 4f84653 Merge pull request #10517: [BEAM-9060] Restore stdout/stderr
in case Flink's OptimizedPlanEnvironment is used
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/flink/FlinkJobInvoker.java | 7 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 4 +-
.../translation/functions/FlinkDoFnFunction.java | 4 +-
.../functions/FlinkStatefulDoFnFunction.java | 4 +-
.../{FlinkClassloading.java => Workarounds.java} | 22 +++++-
.../wrappers/streaming/DoFnOperator.java | 4 +-
.../streaming/io/UnboundedSourceWrapper.java | 4 +-
.../beam/runners/flink/FlinkJobInvokerTest.java | 73 ++++++++++++++++++
.../apache/beam/runners/flink/FlinkRunnerTest.java | 89 ++++++++++++++++++++++
9 files changed, 197 insertions(+), 14 deletions(-)
rename
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/{FlinkClassloading.java
=> Workarounds.java} (52%)
create 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/FlinkRunnerTest.java
