Commits

Commits on Sep 4, 2020

[hotfix][runtime] Remove never thrown IOException for ContinuousFileMonitoringFunction#listEligibleFiles

zhengcanbin
authored and
rmetzger
committedSep 4, 2020

Commits on Jun 23, 2020

[hotfix][yarn] Remove the useless static variable of flink.yarn.Utils#DEFAULT_KEYTAB_FILE

zhengcanbin
authored and
tillrohrmann
committedJun 23, 2020
[hotfix][runtime] Fix code-style in ZooKeeperJobGraphStore

zhengcanbin
authored and
tillrohrmann
committedJun 23, 2020
[hotfix][runtime] Fix code style in RunningJobsRegistry

zhengcanbin
authored and
tillrohrmann
committedJun 23, 2020

Commits on May 27, 2020

[hotfix][runtime] Fix typo.

zhengcanbin
authored and
rmetzger
committedMay 27, 2020

Commits on May 25, 2020

Commits on May 16, 2020

[hotfix][runtime] Remove useless local variable in CompletedCheckpointStoreTest3testAddCheckpointMoreThanMaxRetained

zhengcanbin
authored and
StephanEwen
committedMay 16, 2020
[FLINK-16624][k8s] Support user-specified annotations for the rest Service

zhengcanbin
authored and
tisonkun
committedMay 16, 2020

Commits on May 14, 2020

[hotfix][runtime] Remove useless class ZooKeeperCompletedCheckpointStoreITCase

zhengcanbin
authored and
StephanEwen
committedMay 14, 2020

Commits on May 6, 2020

[FLINK-17332][k8s] Fix restart policy not equals to Never for native task manager pods

zhengcanbin
authored and
tisonkun
committedMay 6, 2020

Commits on Apr 30, 2020

[hotfix][javadocs] Fix typo
zhengcanbin
committedApr 30, 2020

Commits on Apr 20, 2020

[FLINK-15816][k8s] Limit the value of kubernetes.cluster-id to have no more than 45 characters

zhengcanbin
authored and
tillrohrmann
committedApr 20, 2020

Commits on Apr 18, 2020

[FLINK-16600][k8s] Respect the rest.bind-port config option for the Kubernetes setup

zhengcanbin
authored and
tisonkun
committedApr 18, 2020

Commits on Apr 16, 2020

[hotfix][javadocs] Fix typo
zhengcanbin
committedApr 16, 2020
[hotfix][doc] Fix typo of TaskManagerSlot#jobId javadoc

zhengcanbin
authored and
tisonkun
committedApr 16, 2020
[FLINK-16598][k8s] Respect the rest port exposed by Service in Fabric8FlinkKubeClient#getRestEndpoint

zhengcanbin
authored and
tisonkun
committedApr 16, 2020

Commits on Apr 9, 2020

[FLINK-15817][k8s] Clean up residual resources when failed to deploy a new Cluster

zhengcanbin
authored and
tillrohrmann
committedApr 9, 2020

Commits on Apr 8, 2020

[FLINK-16602][k8s] Rework the internal & external Service
zhengcanbin
committedApr 8, 2020

Commits on Apr 2, 2020

[FLINK-16737][k8s] Remove KubernetesUtils#getContentFromFile
zhengcanbin
committedApr 2, 2020

Commits on Mar 25, 2020

[FLINK-16625][utils] Extract BootstrapTools#getEnvironmentVariables to ConfigurationUtils#getPrefixedKeyValuePairs
zhengcanbin
committedMar 25, 2020

Commits on Mar 24, 2020

[FLINK-15647][k8s] Return an empty Map instead of null when annotations is not set

zhengcanbin
authored and
tillrohrmann
committedMar 24, 2020
[FLINK-15647][k8s] Support user-specified annotations for the JM/TM pods

zhengcanbin
authored and
tillrohrmann
committedMar 24, 2020

Commits on Mar 23, 2020

[FLINK-16547][yarn] Respect the config option of FileJobGraphRetriever#JOB_GRAPH_FILE_PATH

zhengcanbin
authored and
kl0u
committedMar 23, 2020
[FLINK-15667][k8s] Support to mount custom Hadoop Configurations

zhengcanbin
authored and
tisonkun
committedMar 23, 2020

Commits on Mar 17, 2020

[FLINK-16494][k8s] Switch to enum type for config option KubernetesConfigOptions.CONTAINER_IMAGE_PULL_POLICY
zhengcanbin
committedMar 17, 2020

Commits on Mar 16, 2020

[FLINK-16508][k8s] Name the ports exposed by the main Container in Pod
zhengcanbin
committedMar 16, 2020

Commits on Mar 12, 2020

[FLINK-16493][k8s] Use enum type instead of string type for KubernetesConfigOptions.REST_SERVICE_EXPOSED_TYPE
zhengcanbin
committedMar 12, 2020

Commits on Mar 11, 2020

[FLINK-16546][yarn] Fix logging bug in YarnClusterDescriptor#startAppMaster

zhengcanbin
authored and
rmetzger
committedMar 11, 2020

Commits on Mar 5, 2020

[FLINK-16194][k8s] Rework FlinkKubeClient to use the new decorator pattern

zhengcanbin
authored and
tisonkun
committedMar 5, 2020
[FLINK-16194][k8s] Introduce Factories that chain the decorators together to construct all the client/cluster-side Kubernetes resources

zhengcanbin
authored and
tisonkun
committedMar 5, 2020
[FLINK-16194][k8s] Introduce decorator for mounting configuration files such as flink-conf.yaml, log4j.properties, and logback.xml

zhengcanbin
authored and
tisonkun
committedMar 5, 2020
[FLINK-16194][k8s] Introduce the internal and the external Service decorator

zhengcanbin
authored and
tisonkun
committedMar 5, 2020
[FLINK-16194][k8s] Introduce Java command decorator for the main Container of the JobManager and the TaskManger Pod

zhengcanbin
authored and
tisonkun
committedMar 5, 2020
[FLINK-16194][k8s] Introduce the monadic step decorator design and the InitJobManagerDecorator and the TaskManagerDecorator

zhengcanbin
authored and
tisonkun
committedMar 5, 2020