Commits

Commits on Jun 6, 2019

[FLINK-12683] Provide task manager location information for checkpoint coordinator specific log messages

yanghua
authored and
tillrohrmann
committedJun 6, 2019

Commits on Jun 5, 2019

[FLINK-12476] [State TTL] Consider setting a default background cleanup strategy in StateTtlConfig

yanghua
authored and
GJL
committedJun 5, 2019

Commits on Jun 4, 2019

[FLINK-11249][kafka] Use custom serializers for NextTransactionalIdHint in 0.11 and universal FlinkKafkaProducer

yanghua
authored and
pnowojski
committedJun 4, 2019

Commits on May 27, 2019

[FLINK-11283] Accessing the key when processing connected keyed stream

yanghua
authored and
aljoscha
committedMay 27, 2019

Commits on May 26, 2019

[FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN

yanghua
authored and
tillrohrmann
committedMay 26, 2019

Commits on May 15, 2019

[FLINK-11159] Allow configuration whether to fall back to savepoints for restore

yanghua
authored and
Gyula Fora
committedMay 15, 2019

Commits on Apr 29, 2019

[FLINK-10724] Refactor failure handling in check point coordinator

yanghua
authored and
StefanRRichter
committedApr 29, 2019

Commits on Apr 25, 2019

[FLINK-12024] Bump universal Kafka connector to Kafka dependency to 2.2.0 (apache#8055 )

yanghua
authored and
pnowojski
committedApr 25, 2019

Commits on Apr 11, 2019

[FLINK-11757][tests] Add 1.8 to MigrationVersion

yanghua
authored and
zentol
committedApr 11, 2019

Commits on Apr 9, 2019

[FLINK-12009][runtime] Fix wrong check message about heartbeat interval for HeartbeatServices

yanghua
authored and
sunjincheng121
committedApr 9, 2019

Commits on Mar 28, 2019

[FLINK-11996][scala][docs] Remove warning about max fields in case class

yanghua
authored and
zentol
committedMar 28, 2019

Commits on Feb 19, 2019

[FLINK-10964][sql-client] SQL Client throws exception when paging through finished batch query

yanghua
authored and
twalthr
committedFeb 19, 2019

Commits on Feb 15, 2019

[FLINK-11081][rest] Support server port range

yanghua
authored and
zentol
committedFeb 15, 2019

Commits on Jan 24, 2019

[FLINK-10251][rpc] Handle oversized response messages in AkkaRpcActor

yanghua
authored and
tillrohrmann
committedJan 24, 2019

Commits on Dec 18, 2018

[FLINK-10786][tests][cep] Update CEPMigrationTest for 1.7

yanghua
authored and
zentol
committedDec 18, 2018
[FLINK-10787][tests] Update AbstractNonKeyedOperatorRestoreTestBase for 1.7

yanghua
authored and
zentol
committedDec 18, 2018
[FLINK-10782][tests] Update AbstractKeyedOperatorRestoreTestBase for 1.7

yanghua
authored and
zentol
committedDec 18, 2018
[FLINK-10788][tests] Update ContinuousFileProcessingMigrationTest for 1.7

yanghua
authored and
zentol
committedDec 18, 2018
[FLINK-10784][tests] Update FlinkKafkaConsumerBaseMigrationTest for 1.7

yanghua
authored and
zentol
committedDec 18, 2018

Commits on Dec 11, 2018

[FLINK-10252][metrics] Handle oversized metric messages

yanghua
authored and
zentol
committedDec 11, 2018
[FLINK-10252][metrics] Pass akkaFrameSize to MetricQueryService

yanghua
authored and
zentol
committedDec 11, 2018
[FLINK-10359] [docs] Scala example in DataSet docs is broken

yanghua
authored and
tzulitai
committedDec 11, 2018

Commits on Dec 3, 2018

[FLINK-10798] Add the version number of Flink 1.7 to MigrationVersion

yanghua
authored and
tzulitai
committedDec 3, 2018

Commits on Nov 30, 2018

[FLINK-11015] Remove deprecated code for format-specific Kafka table connectors

yanghua
authored and
twalthr
committedNov 30, 2018

Commits on Nov 19, 2018

[FLINK-10922] Refactor the placement of the Flink Kafka connector end to end test module

yanghua
authored and
tillrohrmann
committedNov 19, 2018

Commits on Nov 16, 2018

[FLINK-10891] Upgrade Kafka client version to 2.0.1

yanghua
authored and
pnowojski
committedNov 16, 2018
[FLINK-10872] [e2e] Extend SQL Client end-to-end to for Kafka 0.11 connector

yanghua
authored and
twalthr
committedNov 16, 2018

Commits on Nov 15, 2018

[FLINK-10624] Extend SQL client end-to-end to test new KafkaTableSink

yanghua
authored and
pnowojski
committedNov 15, 2018

Commits on Nov 9, 2018

[FLINK-10771] Replace hard code of job graph file path with config option for FileJobGraphRetriever

yanghua
authored and
tillrohrmann
committedNov 9, 2018
[FLINK-10733][tests] Inline clean_log_files()

yanghua
authored and
zentol
committedNov 9, 2018

Commits on Nov 8, 2018

[FLINK-10791] Provide end-to-end test for Kafka 0.11 connector (apache#7038 )

yanghua
authored and
pnowojski
committedNov 8, 2018

Commits on Nov 7, 2018

[FLINK-10704][end-to-end] Fix sql client end to end test failure

yanghua
authored and
pnowojski
committedNov 7, 2018

Commits on Nov 6, 2018

[FLINK-10600] Provide End-to-end test cases for modern Kafka connectors

yanghua
authored and
pnowojski
committedNov 6, 2018

Commits on Oct 26, 2018

[FLINK-10599][Documentation] Provide documentation for the universal (1.0.0+) Kafka connector (apache#6889 )

yanghua
authored and
pnowojski
committedOct 26, 2018

Commits on Oct 24, 2018

[FLINK-10425][runtime] Use TaskManagerOptions#HOST

yanghua
authored and
zentol
committedOct 24, 2018