8000 Commits · wavesZh/flink · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Aug 2, 2019

[FLINK-13541][state-processor-api] State Processor Api sets the wrong key selector when writing savepoints

sjwiesman
authored and
StephanEwen
committed

Commits on Jul 29, 2019

[FLINK-12747][docs] Getting Started - Table Api Walkthrough

sjwiesman
authored and
NicoK
committed

Commits on Jul 22, 2019

[FLINK-13094][state-processor-api] Add registered*TimeTimers methods to KeyedStateReaderFunction#Context for querying the registered timers for a given key

sjwiesman
authored and
tzulitai
committed
[FLINK-13094][state-processor-api] Support iterating over registered timers in the internal timer service

sjwiesman
authored and
tzulitai
committed
[FLINK-13293] [state-processor-api] [build] Add state processor api to opt/ directory in flink-dist

sjwiesman
authored and
tzulitai
committed

Commits on Jul 10, 2019

[FLINK-13067][docs] Fix broken links to contributing docs

sjwiesman
authored and
StephanEwen
committed

Commits on Jul 4, 2019

[FLINK-12963] [docs] Document savepoint writer for bootstrapping new savepoints

sjwiesman
authored and
tzulitai
committed
[FLINK-12963] [travis] Add state processor api to travis library module

sjwiesman
authored and
tzulitai
committed
[FLINK-12963] [state-processor] Add savepoint writer for bootstrapping new savepoints

sjwiesman
authored and
tzulitai
committed

Commits on Jun 26, 2019

[hotfix][docs] Fix invalid link in migration docs

sjwiesman
authored and
zentol
committed
[FLINK-12732] [state-processing-api] Document reader for the State Processing API

sjwiesman
authored and
tzulitai
committed
[FLINK-12732] [state-processing-api] Add savepoint reader for consuming partitioned operator state

sjwiesman
authored and
tzulitai
committed
[FLINK-12732] [state-processing-api] Implement shim SavepointEnvironment on top of user RuntimeContext

sjwiesman
authored and
tzulitai
committed
[hotfix] Refactor NeverCompleteFuture into a reusable utility

sjwiesman
authored and
tzulitai
committed
[FLINK-12729] [state-processing-api] Add state reader for consuming non-partitioned operator state

sjwiesman
authored and
tzulitai
committed
[hotfix] Expose AbstractFsCheckpointStorage#resolveCheckpointPointer as public

sjwiesman
authored and
tzulitai
committed
[hotfix] Expose StateAssignmentOperation#reDistributePartitionableStates as public

sjwiesman
authored and
tzulitai
committed

Commits on Jun 19, 2019

[hotfix] Fix error message in BatchTableSourceScan & StreamTableSourceScan

sjwiesman
authored and
dawidwys
committed

Commits on Jun 5, 2019

[FLINK-12650][docs] Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

sjwiesman
authored and
rmetzger
committed

Commits on May 21, 2019

[FLINK-12560][docs] Documentation language build flags

sjwiesman
authored and
wuchong
committed

Commits on May 10, 2019

Commits on May 9, 2019

[hotfix][state] Add error message to precondition in HeapPriorityQueueSet

sjwiesman
authored and
zentol
committed

Commits on Mar 4, 2019

[FLINK-11653][DataStream] Add configuration to enforce custom UIDs on datastream

sjwiesman
authored and
dawidwys
committed

Commits on Jan 18, 2019

[hotfix][docs] Remove reference to non-existent DataStream#mapPartitionWith

sjwiesman
authored and
zentol
committed

Commits on Oct 19, 2018

[FLINK-10423][rocksdb][metrics] Expose Rocksdb native metrics

sjwiesman
authored and
zentol
committed

0