This is an automated email from the ASF dual-hosted git repository.
yuanmei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a26887e [FLINK-23434][table-planner] Fix the inconsistent type in
IncrementalAggregateRule when the query has one distinct agg function and count
star agg function
add 6709573 [FLINK-23204] Provide StateBackends access to MailboxExecutor
(#16531)
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/execution/Environment.java | 18 ++++++++++++
.../flink/runtime/mailbox}/MailboxExecutor.java | 10 +++----
.../runtime/taskmanager/RuntimeEnvironment.java | 31 ++++++++++++++++++++
.../runtime/mailbox}/SyncMailboxExecutor.java | 2 +-
.../operators/testutils/MockEnvironment.java | 34 ++++++++++++++++++++++
.../changelog/ChangelogKeyedStateBackend.java | 12 +++++++-
.../state/changelog/ChangelogStateBackend.java | 4 ++-
.../source/ContinuousFileReaderOperator.java | 2 +-
.../ContinuousFileReaderOperatorFactory.java | 2 +-
.../api/operators/StreamOperatorFactoryUtil.java | 1 +
.../api/operators/YieldingOperatorFactory.java | 1 +
.../api/operators/async/AsyncWaitOperator.java | 2 +-
.../operators/async/AsyncWaitOperatorFactory.java | 2 +-
.../io/checkpointing/CheckpointedInputGate.java | 2 +-
.../io/checkpointing/InputProcessorUtil.java | 2 +-
.../tasks/ProcessingTimeServiceFactory.java | 2 +-
.../runtime/tasks/StreamOperatorWrapper.java | 2 +-
.../flink/streaming/runtime/tasks/StreamTask.java | 5 +++-
.../tasks/mailbox/MailboxExecutorFactory.java | 2 +-
.../runtime/tasks/mailbox/MailboxExecutorImpl.java | 2 +-
.../runtime/tasks/mailbox/MailboxProcessor.java | 2 +-
.../runtime/tasks/mailbox/TaskMailbox.java | 2 +-
.../api/graph/StreamingJobGraphGeneratorTest.java | 2 +-
.../runtime/io/StreamTaskNetworkInputTest.java | 2 +-
.../AlignedCheckpointsMassiveRandomTest.java | 2 +-
.../io/checkpointing/AlignedCheckpointsTest.java | 2 +-
.../checkpointing/AlternatingCheckpointsTest.java | 2 +-
.../CheckpointBarrierTrackerTest.java | 2 +-
.../io/checkpointing/InputProcessorUtilTest.java | 2 +-
.../io/checkpointing/UnalignedCheckpointsTest.java | 2 +-
.../runtime/operators/MailboxOperatorTest.java | 2 +-
.../operators/StreamTaskOperatorTimerTest.java | 2 +-
.../runtime/tasks/StreamOperatorWrapperTest.java | 2 +-
.../tasks/StreamTaskMailboxTestHarness.java | 2 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 2 +-
.../runtime/tasks/StreamTaskTestHarness.java | 2 +-
.../tasks/mailbox/MailboxExecutorImplTest.java | 2 +-
.../tasks/mailbox/TaskMailboxProcessorTest.java | 2 +-
.../util/TestCheckpointedInputGateBuilder.java | 4 +--
39 files changed, 138 insertions(+), 40 deletions(-)
rename
{flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators =>
flink-runtime/src/main/java/org/apache/flink/runtime/mailbox}/MailboxExecutor.java
(97%)
rename
{flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators =>
flink-runtime/src/test/java/org/apache/flink/runtime/mailbox}/SyncMailboxExecutor.java
(97%)
