This is an automated email from the ASF dual-hosted git repository.
jkff pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 69fb5c9 Merge pull request #5576: [BEAM-4414] Create more specific
namespace for each IOIT in FileBasedIOIT
add 96006ed Add reference to ArtifactSourcePool implementation
add e38f7aa Clean up FlinkExecutableStageFunction and tests
add 8e1b3bd [BEAM-4523] Implement batch flink executable stage context
new dd14be7 Merge pull request #5588: [BEAM-4523] Implement batch flink
executable stage context
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../beam/runners/flink/ArtifactSourcePool.java | 6 ++
.../BatchFlinkExecutableStageContext.java | 107 +++++++++++++++++++++
...ext.java => FlinkBatchStateRequestHandler.java} | 37 +++----
.../functions/FlinkExecutableStageContext.java | 22 ++---
.../functions/FlinkExecutableStageFunction.java | 7 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../FlinkExecutableStageFunctionTest.java | 20 ++--
7 files changed, 146 insertions(+), 55 deletions(-)
create mode 100644
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/BatchFlinkExecutableStageContext.java
copy
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/{FlinkExecutableStageContext.java
=> FlinkBatchStateRequestHandler.java} (51%)
--
To stop receiving notification emails like this one, please contact
[email protected].
