Commits

Commits on Sep 29, 2022

[FLINK-29436][build] Upgrade spotless to 2.27.1
tisonkun
committedSep 29, 2022

Commits on Aug 15, 2021

[FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections

tisonkun
authored and
tillrohrmann
committedAug 15, 2021

Commits on Nov 14, 2020

[FLINK-20139][dispatcher] Enrich logs when MiniDispatcher shutting down
tisonkun
committedNov 14, 2020

Commits on Aug 19, 2020

[FLINK-15299][test] Move ClientUtils#submitJob & ClientUtils#submitJobAndWaitForResult to test scope
tisonkun
committedAug 19, 2020

Commits on Mar 26, 2020

[hotfix][connector] Correct exception message (apache#11523 )
tisonkun
committedMar 26, 2020

Commits on Mar 12, 2020

[FLINK-15090][api] Reverse the dependency from flink-streaming-java to flink-clients

tisonkun
authored and
aljoscha
committedMar 12, 2020
[FLINK-15090][compiler] Extract JobGraphGenerator#addUserArtifactEntries to a flink-runtime utils

tisonkun
authored and
aljoscha
committedMar 12, 2020
[FLINK-15090][tests] Move streaming env tests to flink-tests

tisonkun
authored and
aljoscha
committedMar 12, 2020
[FLINK-15090][tests] Explicitly depend on flink-clients

tisonkun
authored and
aljoscha
committedMar 12, 2020

Commits on Mar 11, 2020

[FLINK-14041][tests] Refactor LeaderRetrievalServiceHostnameResolutionTest
tisonkun
committedMar 11, 2020

Commits on Mar 9, 2020

[FLINK-16427][api] Don't throw ProgramInvocationException in RemoteStreamEnvironment

tisonkun
authored and
aljoscha
committedMar 9, 2020
[FLINK-16199][table] Support IS JSON predication for SQL in blink planner

tisonkun
authored and
wuchong
committedMar 9, 2020

Commits on Mar 5, 2020

[FLINK-16194][k8s] Make FlinkPod a value class
tisonkun
committedMar 5, 2020

Commits on Feb 21, 2020

Commits on Feb 20, 2020

[hotfix] Refactor YARNFileReplicationITCase to avoid inheritance
tisonkun
committedFeb 20, 2020

Commits on Feb 10, 2020

Revert "[hotfix] Remove deadcode in ExecutionGraph#restart"
tisonkun
committedFeb 10, 2020
[hotfix] Remove deadcode in ExecutionGraph#restart
tisonkun
committedFeb 10, 2020

Commits on Jan 15, 2020

[FLINK-14091][tests] Refactor ZooKeeperCheckpointIDCounter for a more testable codebase

tisonkun
authored and
tillrohrmann
committedJan 15, 2020
[FLINK-14091][tests] Tests ZooKeeperCheckpointIDCounter can be recoverd from connection loss

tisonkun
authored and
tillrohrmann
committedJan 15, 2020
[FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tisonkun
authored and
tillrohrmann
committedJan 15, 2020

Commits on Jan 9, 2020

[FLINK-15536][configuration] Revert removal of ConfigConstants.YARN_MAX_FAILED_CONTAINERS (apache#10808 )

tisonkun
authored and
zentol
committedJan 9, 2020

Commits on Jan 8, 2020

[hotfix] Refactor OperatorID compartion in StreamGraph JSONGenerator

tisonkun
authored and
aljoscha
committedJan 8, 2020
[FLINK-15510] Pretty Print StreamGraph JSON Plan

tisonkun
authored and
aljoscha
committedJan 8, 2020

Commits on Jan 3, 2020

Commits on Dec 19, 2019

[FLINK-15312][tests] Remove PlanExposingEnvironment

tisonkun
authored and
kl0u
committedDec 19, 2019

Commits on Dec 17, 2019

[FLINK-15072][client] Hijack executeAsync instead of execute for create pipeline

tisonkun
authored and
aljoscha
committedDec 17, 2019
[FLINK-15201][client] Remove verifications in ContextEnv for detached execution

tisonkun
authored and
aljoscha
committedDec 17, 2019
[FLINK-15072][client] Remove JobExecutionResult container from ClientUtils#executeProgram

tisonkun
authored and
aljoscha
committedDec 17, 2019
[FLINK-15072][client] Move printing stringified JobExecutionResult to ContextEnv

tisonkun
authored and
aljoscha
committedDec 17, 2019

Commits on Dec 10, 2019

[FLINK-14992][client] Add job listener to execution environments

tisonkun
authored and
aljoscha
committedDec 10, 2019