This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e2b6588ef39 [hotfix] Reduce code duplication and add logging in
RocksDBIncrementalCheckpointUtils#deleteRangeData.
add 563ce3797dd [hotfix] Remove unused method getAllOperatorFactory()
add ddc84cc2593 [hotfix] add @Nullable annotation to operatorFactory in
StreamNode
add ea5f90ad866 [FLINK-34371][runtime] Introduce OperatorAttributes with
isOutputOnlyAfterEndOfStream
add 40eb2c2b245 [FLINK-34371][runtime] Expose OperatorAttributes to
Operator and StreamNodes
add 5fe0930fa20 [FLINK-34371][runtime] Set partitionType to Blocking on
operators with outputOnlyAfterEndOfStream
add 8d45cd9ed7d [FLINK-34371][runtime] Start checkpoint only after tasks
with blocking edge finished
add d4e0084649c [FLINK-34371][runtime] Fail savepoints until tasks with
blocking edge finished
add 89b8c5c9b79 [FLINK-34371][runtime] Apply batch settings on EOF
operators
add 5916aa4aeb7 [FLINK-34371][runtime] Support EndOfStreamTrigger in
GlobalWindows
add 94b5f031a78 [FLINK-34371][runtime] Set OutputOnlyAfterEndOfStream on
WindowOperator and StreamSortOperator
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointCoordinator.java | 14 +-
.../CheckpointCoordinatorDeActivator.java | 9 +-
.../checkpoint/CheckpointFailureManager.java | 1 +
.../checkpoint/CheckpointFailureReason.java | 2 +
.../executiongraph/DefaultExecutionGraph.java | 17 ++-
.../ExecutionGraphUtils.java} | 20 ++-
.../apache/flink/runtime/jobgraph/JobVertex.java | 7 +
.../flink/runtime/scheduler/SchedulerBase.java | 14 ++
.../scheduler/adaptive/AdaptiveScheduler.java | 25 +++-
.../runtime/scheduler/DefaultSchedulerTest.java | 60 +++++++++
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 55 ++++++++
.../flink/streaming/api/graph/StreamGraph.java | 10 +-
.../flink/streaming/api/graph/StreamNode.java | 20 ++-
.../api/graph/StreamingJobGraphGenerator.java | 39 +++++-
.../api/operators/OperatorAttributes.java | 52 ++++++++
...Factory.java => OperatorAttributesBuilder.java} | 24 +++-
.../api/operators/SimpleOperatorFactory.java | 5 +
.../streaming/api/operators/StreamOperator.java | 12 ++
.../api/operators/StreamOperatorFactory.java | 12 ++
.../AbstractMultipleInputTransformation.java | 4 +
.../transformations/OneInputTransformation.java | 4 +
.../transformations/TwoInputTransformation.java | 4 +
.../api/windowing/assigners/GlobalWindows.java | 57 ++++++--
.../operators/windowing/WindowOperator.java | 13 ++
.../runtime/translators/BatchExecutionUtils.java | 7 +-
.../MultiInputTransformationTranslator.java | 51 ++++---
.../OneInputTransformationTranslator.java | 40 ++++--
.../TwoInputTransformationTranslator.java | 42 +++---
.../api/graph/StreamingJobGraphGeneratorTest.java | 148 +++++++++++++++++++++
.../AbstractUdfStreamOperatorLifecycleTest.java | 1 +
.../api/operators/OperatorAttributesTest.java | 26 ++--
.../operators/windowing/GlobalWindowsTest.java | 3 +
.../operators/windowing/WindowOperatorTest.java | 67 ++++++++++
.../runtime/operators/sort/StreamSortOperator.java | 7 +
34 files changed, 743 insertions(+), 129 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{scheduler/ExecutionSlotAllocatorFactory.java
=> executiongraph/ExecutionGraphUtils.java} (63%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorAttributes.java
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/{YieldingOperatorFactory.java
=> OperatorAttributesBuilder.java} (58%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/YarnCancelJobTerminationHeadersTest.java
=>
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/OperatorAttributesTest.java
(58%)
