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