This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 044f8e1 [FLINK-21115][python] Add AggregatingState and corresponding
StateDescriptor for Python DataStream API
add 3148b82 [FLINK-21475][decl-scheduler] Support
StateWithExecutionGraph.suspend when EG has reached globally terminal state
No new revisions were added by this update.
Summary of changes:
.../adaptive/StateWithExecutionGraph.java | 2 +-
.../adaptive/StateWithExecutionGraphTest.java | 148 +++++++++++++++++++++
2 files changed, 149 insertions(+), 1 deletion(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraphTest.java
