Commits

Commits on Feb 28, 2019

[hotfix][docs] Add that LIMIT requires ORDER BY.

fhueske
authored and
sunjincheng121
committedFeb 28, 2019
Fix typo in StreamExecutionEnvironment (apache#7854 )

libenchao
authored and
KurtYoung
committedFeb 28, 2019
Fix typo in TypeInformation
libenchao
committedFeb 28, 2019
[FLINK-11091][table] Clear the use of deprecated process(ProcessFunction) of KeyedStream in table operators.
sunjincheng121
committedFeb 28, 2019

Commits on Feb 27, 2019

[FLINK-10569][runtime] Port CoLocationConstraintTest

tisonkun
authored and
zentol
committedFeb 27, 2019
[hotfix][runtime] Remove try-catch blocks

tisonkun
authored and
zentol
committedFeb 27, 2019
[FLINK-11752] [dist] Move flink-python to opt (apache#7843 )
uce
committedFeb 27, 2019
[hotfix] Fix checkstyle violations in CheckpointCoordinator
tillrohrmann
committedFeb 27, 2019
[FLINK-11718] Make RpcEndpoint#start method final to prevent changing its behaviour
tillrohrmann
committedFeb 27, 2019
[FLINK-11718] Add onStart method to TaskExecutor
tillrohrmann
committedFeb 27, 2019
[FLINK-11718] Add onStart method to ResourceManager
tillrohrmann
committedFeb 27, 2019
[FLINK-11718] Remove start override from JobMaster
tillrohrmann
committedFeb 27, 2019
[FLINK-11718] Add onStart to Dispatcher
tillrohrmann
committedFeb 27, 2019
[hotfix] Factor logic out of AkkaRpcActor#handleRpcInvocation to reduce size of method
tillrohrmann
committedFeb 27, 2019
[FLINK-11718][rpc] Add onStart method to RpcEndpoint
tillrohrmann
committedFeb 27, 2019
[hotfix] Allow leader assignment to TestingLeaderElectionService if it has not been started
tillrohrmann
committedFeb 27, 2019
[FLINK-10912][rocksdb] Configurable RocksDBStateBackend options

Myasuka
authored and
StefanRRichter
committedFeb 27, 2019
[hotfix] Introduce common interface to all IncrementalKeyedStateHandles
StefanRRichter
committedFeb 27, 2019
[FLINK-11743] Fix problem with restoring incremental checkpoints from local state
StefanRRichter
committedFeb 27, 2019
[hotfix] Minor code cleanups in RocksDBKeyedStateBackendBuilder and RocksDBIncrementalRestoreOperation
StefanRRichter
committedFeb 27, 2019
[FLINK-11728] [table] Deprecate CalciteConfig temporarily

twalthr
authored and
sunjincheng121
committedFeb 27, 2019

Commits on Feb 26, 2019

[FLINK-11185] Fix StreamSourceOperatorWatermarksTest instability.
kl0u
committedFeb 26, 2019
[hotfix] Revert overriding toString-method in AllocationID
StefanRRichter
committedFeb 26, 2019
[FLINK-11744][core]Provide stable/final toHexString-method in AbstractID
StefanRRichter
committedFeb 26, 2019
[hotfix] fix typos in description

robbinli
authored and
dawidwys
committedFeb 26, 2019
[FLINK-11745][State TTL][E2E] Restore from the savepoint after the job cancellation.

azagrebin
authored and
kl0u
committedFeb 26, 2019
[FLINK-11343][tests] Force order that TaskExecutor shutdown after Task exit in TaskExecutorTest

tisonkun
authored and
dawidwys
committedFeb 26, 2019

Commits on Feb 25, 2019

[FLINK-7243][connector] Add ParquetInputFormats for Row, Map, and POJO.

HuangZhenQiu
authored and
fhueske
committedFeb 25, 2019
[hotfix] Repair ineffective LocalRecoveryITCase
StefanRRichter
committedFeb 25, 2019
[FLINK-11679][table] Create Blink SQL planner and runtime modules
twalthr
committedFeb 25, 2019
[hotfix][table] Remove unused geometry dependency
twalthr
committedFeb 25, 2019
Update version to 1.9-SNAPSHOT
aljoscha
committedFeb 25, 2019
[hotfix] Fix update_branch_version.sh to allow version suffixes
aljoscha
committedFeb 25, 2019

Commits on Feb 22, 2019

[FLINK-11618][state] Refactor operator state repartition mechanism

Myasuka
authored and
StefanRRichter
committedFeb 22, 2019
[FLINK-10043] [State Backends] Refactor RocksDBKeyedStateBackend object construction/initialization/restore code

carp84
authored and
StefanRRichter
committedFeb 22, 2019