This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a889332 [FLINK-19324][yarn] Match requested and allocated containers
with priority rather than resources.
add daa54cb [hotfix] Fixes in CEP operator
add 2ff3b77 [FLINK-19640] Enable sorting inputs for batch
No new revisions were added by this update.
Summary of changes:
.../flink/configuration/ExecutionOptions.java | 22 +
.../org/apache/flink/cep/operator/CepOperator.java | 19 +-
.../environment/StreamExecutionEnvironment.java | 8 +-
.../streaming/api/graph/StreamGraphGenerator.java | 54 ++-
.../flink/streaming/api/graph/StreamNode.java | 3 +-
.../api/graph/TransformationTranslator.java | 6 +
.../api/operators/InternalTimeServiceManager.java | 4 +-
.../runtime/translators/BatchExecutionUtils.java | 98 ++++
.../MultiInputTransformationTranslator.java | 7 +-
.../OneInputTransformationTranslator.java | 8 +-
.../TwoInputTransformationTranslator.java | 8 +-
.../StreamGraphGeneratorBatchExecutionTest.java | 497 +++++++++++++++++++++
12 files changed, 709 insertions(+), 25 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/translators/BatchExecutionUtils.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorBatchExecutionTest.java
