Commits

Commits on May 19, 2020

[FLINK-17594][filesystem] Support Hadoop path-based part-file writer
gaoyunhaii
committedMay 19, 2020
[FLINK-15813][runtime] Set default value of config “jobmanager.execution.failover-strategy” to “region”
zhuzhurk
committedMay 19, 2020

Commits on May 18, 2020

[FLINK-16998][core] Add a changeflag to Row
twalthr
committedMay 18, 2020
[FLINK-17506][state-processor-api] Use proper RocksDB configurations in KeyedStateInputFormat
sjwiesman
committedMay 18, 2020
[FLINK-17799][network] Fix performance regression in the benchmarks
pnowojski
committedMay 18, 2020
[FLINK-17781][coordination] Use Scheduler and MainThreadExecutor in OperatorCoordinator.Context.
StephanEwen
committedMay 18, 2020
[FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property
sjwiesman
committedMay 18, 2020
[hotfix][state-processor-api] Remove BoundedStreamConfig
sjwiesman
committedMay 18, 2020
[FLINK-17687][tests] Simplify collection of Mesos logs
GJL
committedMay 18, 2020
[FLINK-17687][tests] Collect log files before tearing down Mesos
GJL
committedMay 18, 2020
[FLINK-17687][tests] Enable listing files recursively by pattern
GJL
committedMay 18, 2020
[FLINK-17796] Respect user specified classpath for application mode

wangyang0918
authored and
kl0u
committedMay 18, 2020
[hotfix][client] Make ConfigUtils.decodeListFromConfig return new array list and throw exception

wangyang0918
authored and
kl0u
committedMay 18, 2020
[FLINK-17777][tests] Set HADOOP_CLASSPATH for Mesos TaskManagers
GJL
committedMay 18, 2020
[FLINK-17593] Update BucketStateSerializerTest for v2
aljoscha
committedMay 18, 2020
[FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

guoweiM
authored and
aljoscha
committedMay 18, 2020
[FLINK-17593][Connectors/FileSystem] Turn BucketStateSerializerTest into an upgrade test

guoweiM
authored and
aljoscha
committedMay 18, 2020
[minor] Allow relative paths in LocalFileSystem
aljoscha
committedMay 18, 2020
[FLINK-17792][tests] Catch and log exception if jstack fails
GJL
committedMay 18, 2020
[FLINK-17730][CI] Increase 'no output timeout' to 15 minutes
rmetzger
committedMay 18, 2020
[hotfix][Azure] Use 'ubuntu-16.04' for all AZP builds
rmetzger
committedMay 18, 2020
[FLINK-17543][Azure] Add timestamp to log name to allow multiple uploads per module
rmetzger
committedMay 18, 2020
[FLINK-15670] Kafka Shuffle Test Case + add log4j2 file

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][connector] Kafka Shuffle API Part

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][connector] Adds the consumer for KafkaShuffle.

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][connector] Adds the producer for KafkaShuffle.

curcur
authored and
pnowojski
committedMay 18, 2020
[FLINK-15670][core] Provide a utility function to flatten a recursive Properties to a first level property HashTable

curcur
authored and
pnowojski
committedMay 18, 2020
Update version to 1.12-SNAPSHOT
pnowojski
committedMay 18, 2020
[FLINK-17357][table-planner-blink] add DROP catalog DDL
SteNicholas
committedMay 18, 2020
[FLINK-17759][runtime] Remove unused RestartIndividualStrategy
zhuzhurk
committedMay 18, 2020
[FLINK-17758][runtime] Remove unused AdaptedRestartPipelinedRegionStrategyNG
zhuzhurk
committedMay 18, 2020
[FLINK-17617] Fix SQL Client autocomplete
Gyula Fora
committedMay 18, 2020
[FLINK-17681] Correct type when converting Row, Map, Array to RexNodes
dawidwys
committedMay 18, 2020
[FLINK-17602][docs] Corrected method name in dev/stream/broadcast_state document

mans2singh
authored and
aljoscha
committedMay 18, 2020
[FLINK-17618][dist] Update comment on how to change log level for Flink
wangyang0918
committedMay 18, 2020