clear query| facets| time Search criteria: .   Results from 1 to 10 from 266 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-18828] Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s - Flink - [issue]
...Currently, Flink jobmanager process terminates with a non-zero exit code if the job reaches the ApplicationStatus.FAILED. It is not ideal in K8s deployment, since non-zero exit code will cau...    Author: Yang Wang , 2020-09-27, 06:26
[FLINK-17613] Run K8s related e2e tests with multiple K8s versions - Flink - [issue]
...Follow the discussion in this PR [1].If we could run the K8s related e2e tests in multiple versions(the latest version, oldest maintained version, etc.), it will help us to find the ...    Author: Yang Wang , 2020-09-25, 05:59
[FLINK-17857] Kubernetes and docker e2e tests could not run on Mac OS after migration - Flink - [issue]
...In FLINK-17656, we migrate all the e2e tests from flink-container/docker to apache/flink-docker. After the migration, when building a docker image, we need to start a file server and then do...    Author: Yang Wang , 2020-09-24, 07:10
[expand - 1 more] - Checkpoint metadata deleted by Flink after ZK connection issues - Flink - [mail # user]
...> The job sub directory will be cleaned up when the jobfinished/canceled/failed.Since we could submit multiple jobs into a Flink session, what i mean iswhen a jobreached to the terminal s...
   Author: Yang Wang , 2020-09-09, 07:00
[expand - 1 more] - Fail to deploy Flink on minikube - Flink - [mail # user]
...Sorry i forget that the JobManager is binding its rpc address toflink-jobmanager, not the ip address.So you need to also update the jobmanager-session-deployment.yaml withfollowing changes.....
   Author: Yang Wang , 2020-09-03, 06:44
[expand - 1 more] - FileSystemHaServices and BlobStore - Flink - [mail # user]
...Hi Alexey,Thanks for the feedback. You are right. StatefulSet + PersistentVolume +FileSystemHaService could be anotherbundle of services for Flink HA support on K8s. The user jars could bebu...
   Author: Yang Wang , 2020-09-03, 03:21
[FLINK-17225] Support native k8s for scala shell - Flink - [issue]
...Currently, the Flink scala shell could create a new or retrieve an existing YARN session cluster automatically. It is very convenient for the users.Then it will be great we could also suppor...    Author: Yang Wang , 2020-09-02, 02:30
[FLINK-14986] Support to get detailed Kubernetes cluster description - Flink - [issue]
...Currently Flink supports get yarn cluster description by `YarnClusterDescriptor#getClusterDescription`. We should support the same behavior in Kubernetes cluster.Usually the cluster descript...    Author: Yang Wang , 2020-09-01, 08:59
[FLINK-14172] Implement KubeClient with official Java client library for kubernetes - Flink - [issue]
...Official Java client library for kubernetes is become more and more active. The new features(such as leader election) and some client implementations(informer, lister, cache) are better. So ...    Author: Yang Wang , 2020-08-31, 03:53
[FLINK-15470] Remove YARN magic properties file - Flink - [issue]
...Currently, when we start a session, flink client will write a yarn properties under {}/.yarn-properties-{user-name}. So the user could use a simple command ./bin/flink run ./ex...    Author: Yang Wang , 2020-08-28, 09:26