This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c33e1ad [FLINK-19992][hive] Integrate new orc to Hive source
add c151abc [FLINK-19741] Let timer service skip reading raw keyed state
if it isn't the writer
add c775358 [FLINK-19748] Skip key groups that don't have a defined
stream offset
add 3367c23 [FLINK-19748] [test] Adjust raw keyed state test to only
write some key groups
No new revisions were added by this update.
Summary of changes:
docs/ops/state/state_backends.md | 2 +
.../state/api/input/KeyedStateInputFormat.java | 3 +-
.../api/operators/AbstractStreamOperator.java | 30 ++++-
.../api/operators/AbstractStreamOperatorV2.java | 30 ++++-
.../api/operators/InternalTimeServiceManager.java | 18 ++-
.../operators/InternalTimeServiceManagerImpl.java | 51 ++++---
.../api/operators/StreamOperatorStateHandler.java | 18 ++-
.../api/operators/StreamTaskStateInitializer.java | 5 +-
.../operators/StreamTaskStateInitializerImpl.java | 30 ++++-
.../BatchExecutionInternalTimeServiceManager.java | 11 +-
.../api/operators/AbstractStreamOperatorTest.java | 146 +++++++++++++++++++++
.../StateInitializationContextImplTest.java | 3 +-
.../operators/StreamOperatorStateHandlerTest.java | 6 +-
.../StreamTaskStateInitializerImplTest.java | 6 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 13 +-
15 files changed, 316 insertions(+), 56 deletions(-)
