Commits

Commits on Aug 15, 2018

[FLINK-9546] Fix checking of heartbeatTimeoutIntervalMs in HeartbeatMonitor

sihuazhou
authored and
tillrohrmann
committedAug 15, 2018

Commits on Jul 13, 2018

[FLINK-9619] Eagerly close the connection with task manager when the container is completed.

sihuazhou
authored and
tillrohrmann
committedJul 13, 2018

Commits on Jul 12, 2018

[FLINK-9804][state] Fix KeyedStateBackend.getKeys() for RocksDBMapState.
sihuazhou
committedJul 12, 2018

Commits on Jul 11, 2018

[FLINK-9584][connector] Properly close output streams in Bucketing-/RollingSink

sihuazhou
authored and
zentol
committedJul 11, 2018

Commits on Jul 4, 2018

[FLINK-9633] Use Savepoint path's file system to create checkpoint output stream

sihuazhou
authored and
tillrohrmann
committedJul 4, 2018

Commits on Jul 1, 2018

[FLINK-9456] Let ResourceManager notify JobManager about failed/killed TaskManagers.

sihuazhou
authored and
tillrohrmann
committedJul 1, 2018

Commits on Jun 18, 2018

[FLINK-9601][state] Make sure that the copied array in CopyOnWriteStateTable#snapshotTableArrays() is big enough to hold all (flattened) entries

sihuazhou
authored and
StefanRRichter
committedJun 18, 2018

Commits on Jun 11, 2018

[hotfix][javadocs] Update OptionsFactory javadocs

sihuazhou
authored and
zentol
committedJun 11, 2018

Commits on Jun 5, 2018

[FLINK-8790][State] Improve performance of rescaling an incremental checkpoint

sihuazhou
authored and
StefanRRichter
committedJun 5, 2018
[hotfix][cep] Fix checkstyle violation in CEPOperatorTest

sihuazhou
authored and
zentol
committedJun 5, 2018

Commits on Jun 4, 2018

[FLINK-7866][runtime] Order preferred locations by score for scheduling.

sihuazhou
authored and
StefanRRichter
committedJun 4, 2018
[FLINK-9468] [core] Set outputLimit in LimitedConnectionsFileSystem#createStream() correctly.

sihuazhou
authored and
StephanEwen
committedJun 4, 2018

Commits on May 30, 2018

[FLINK-9215][resourcemanager] Simply print the exception message in the log in SlotPool#releaseSlot().

sihuazhou
authored and
dawidwys
committedMay 30, 2018

Commits on May 23, 2018

[FLINK-9426][test] Remove flaky asserts from RocksDBWriteBatchPerformanceTest.benchMark().

sihuazhou
authored and
StefanRRichter
committedMay 23, 2018
[FLINK-8845][state] Introduce RocksDBWriteBatchWrapper to improve batched write performance in RocksDB backend.

sihuazhou
authored and
StefanRRichter
committedMay 23, 2018

Commits on May 18, 2018

[FLINK-9070][state] Improve the performance of RocksDBMapState.clear() with WriteBatch.

sihuazhou
authored and
StefanRRichter
committedMay 18, 2018

Commits on May 17, 2018

[FLINK-9373][statebackend] Introduce RocksIteratorWrapper to wrap Seek(), Next(), SeekToFirst(), SeekToLast(), SeekForPrev(), and Prev() to check the iterator status.

sihuazhou
authored and
StefanRRichter
committedMay 17, 2018

Commits on May 16, 2018

[hotfix][docs] Update docs regarding externalized checkpoint

sihuazhou
authored and
zentol
committedMay 16, 2018
[FLINK-9174] Make type of state created in ProcessWindowFunction.process() consistent

sihuazhou
authored and
aljoscha
committedMay 16, 2018

Commits on May 14, 2018

[FLINK-9336] [state] Set the userKeyOffset in every MapEntry.

sihuazhou
authored and
kl0u
committedMay 14, 2018

Commits on May 3, 2018

[FLINK-9269][state] Fix concurrency problem when performing checkpoint in HeapKeyedStateBackend.

sihuazhou
authored and
StefanRRichter
committedMay 3, 2018

Commits on May 2, 2018

[FLINK-9263][state] Fix concurrency problem in DefaultOperatorStateBackend.

sihuazhou
authored and
StefanRRichter
committedMay 2, 2018

Commits on Apr 24, 2018

[FLINK-9100][core] Hide configured value for "password"/"secret"

sihuazhou
authored and
zentol
committedApr 24, 2018
[FLINK-8793][REST] Hide configured value for "password"/"secret"

sihuazhou
authored and
zentol
committedApr 24, 2018
[FLINK-9240][tests] Harden WebFrontendITCase#testStopYarn()

sihuazhou
authored and
zentol
committedApr 24, 2018

Commits on Apr 22, 2018

[FLINK-9158] [core] Set default FixedRestartDelayStrategy delay to 0s.

sihuazhou
authored and
StephanEwen
committedApr 22, 2018

Commits on Apr 6, 2018

[hotfix] Use try-with-resources to ensure RocksIterator is always closed in RocksDBMapState.

sihuazhou
authored and
StefanRRichter
committedApr 6, 2018
[FLINK-8699][state] Deep copy state info to avoid potential concurrency problem in full checkpoint.

sihuazhou
authored and
StefanRRichter
committedApr 6, 2018
[FLINK-8968][state] Pull the creation of readOptions out of loop to avoid native resource leak.

sihuazhou
authored and
StefanRRichter
committedApr 6, 2018

Commits on Mar 29, 2018

[FLINK-9060][state] Fix concurrent modification exception when iterating keys.

sihuazhou
authored and
kl0u
committedMar 29, 2018

Commits on Mar 28, 2018

[FLINK-9081] [tests] Harden ResourceManagerJobMasterTest and ResourceManagerTaskExecutorTest

sihuazhou
authored and
tillrohrmann
committedMar 28, 2018
[FLINK-9026] [flip6] Close the TaskManagerMetricGroup when the TaskExecutor is shut down

sihuazhou
authored and
tillrohrmann
committedMar 28, 2018

Commits on Mar 21, 2018

[FLINK-9022][state] Fix resource release in StreamTaskStateInitializerImpl.streamOperatorStateContext()

sihuazhou
authored and
tillrohrmann
committedMar 21, 2018
[FLINK-9028] [yarn] Perform parameters checking before Yarn starting cluster

sihuazhou
authored and
tillrohrmann
committedMar 21, 2018

Commits on Mar 20, 2018

[hotfix][javadocs] Minor javadoc fixes

sihuazhou
authored and
zentol
committedMar 20, 2018