Aitozi [Sat, 21 May 2022 15:33:38 +0000 (23:33 +0800)]
[FLINK-27666] Cover manual savepoint triggering in E2E tests
Gyula Fora [Fri, 20 May 2022 18:39:55 +0000 (20:39 +0200)]
[build] Add doc build for new release branch
Co-authored-by: Marton Balassi <marton@apple.com>
Matyas Orhidi [Thu, 19 May 2022 10:44:06 +0000 (12:44 +0200)]
[FLINK-27647] Improve Metrics documentation to include newly added metrics
Gyula Fora [Thu, 19 May 2022 13:31:35 +0000 (15:31 +0200)]
[FLINK-27686] Only patch status on change
wangyang0918 [Fri, 20 May 2022 04:10:02 +0000 (12:10 +0800)]
[hotfix] Change version of documentation in update_branch_version.sh
Matyas Orhidi [Wed, 18 May 2022 12:22:02 +0000 (14:22 +0200)]
[FLINK-27675] Improve manual savepoint tracking
Matyas Orhidi [Tue, 17 May 2022 14:32:55 +0000 (16:32 +0200)]
[FLINK-27645] Update overview / supported features page for 1.0.0
Gyula Fora [Thu, 19 May 2022 04:43:22 +0000 (06:43 +0200)]
[hotfix][FLINK-27572] Harden HA meta checking logic
Yang Wang [Wed, 18 May 2022 20:18:53 +0000 (04:18 +0800)]
[FLINK-26914] Various improvements for notice and license files
Nicholas Jiang [Wed, 18 May 2022 13:17:00 +0000 (21:17 +0800)]
[FLINK-27008] Document the configurable parameters of the helm chart and their default values
This closes #222.
Gyula Fora [Mon, 16 May 2022 19:01:26 +0000 (21:01 +0200)]
[FLINK-27643] Add new features to lifecycle management docs
Matyas Orhidi [Tue, 17 May 2022 10:16:12 +0000 (12:16 +0200)]
[FLINK-27665] Optimize event triggering on DeploymentFailedExceptions
Gyula Fora [Tue, 17 May 2022 14:36:19 +0000 (16:36 +0200)]
[release] Update version to 1.1-SNAPSHOT
Gyula Fora [Tue, 17 May 2022 10:06:17 +0000 (12:06 +0200)]
[hotfix] Do not use nulls in status for savepoint trigger and cluster info
Matyas Orhidi [Fri, 13 May 2022 12:38:27 +0000 (14:38 +0200)]
[FLINK-27609] Tracking flink-version and flink-revision in FlinkDeploymentStatus
Hao Xin [Tue, 17 May 2022 07:08:26 +0000 (15:08 +0800)]
[FLINK-27600] Add logs for deleting jar files
Aitozi [Tue, 17 May 2022 07:05:30 +0000 (15:05 +0800)]
[FLINK-27612] Generate warning events when deleting the session cluster with running jobs
Gyula Fora [Tue, 17 May 2022 06:10:47 +0000 (08:10 +0200)]
[hotfix] Add some missing savepoint history tests
Closes #216
Thomas Weise [Mon, 16 May 2022 17:02:22 +0000 (10:02 -0700)]
[FLINK-27435] Savepoint History
Gyula Fora [Thu, 12 May 2022 15:13:39 +0000 (17:13 +0200)]
[FLINK-27572][FLINK-27594] Ensure HA metadata is present before restoring job with last state
Aitozi [Sat, 14 May 2022 08:35:40 +0000 (16:35 +0800)]
[FLINK-27614] Use informer in webhook to avoid query apiserver at each update
FuyaoLi2017 [Sun, 15 May 2022 18:48:46 +0000 (11:48 -0700)]
[FLINK-27483] Make http artifact fetcher headers configurable
Aitozi [Wed, 11 May 2022 15:45:15 +0000 (23:45 +0800)]
[FLINK-27270] Add document of session job operations
Aitozi [Wed, 11 May 2022 04:31:29 +0000 (12:31 +0800)]
[FLINK-27337] Prevent session cluster to be deleted when there are running jobs
Gyula Fora [Sun, 8 May 2022 19:26:00 +0000 (21:26 +0200)]
[FLINK-27495] Observe last savepoint status directly from cluster
Hao Xin [Fri, 13 May 2022 01:45:08 +0000 (09:45 +0800)]
[FLINK-27595] Make security context configurable in helm
This closes #210.
Matyas Orhidi [Wed, 11 May 2022 16:55:36 +0000 (18:55 +0200)]
[FLINK-27573] Configuring a new random job result store directory
Marton Balassi [Thu, 12 May 2022 09:58:24 +0000 (11:58 +0200)]
[FLINK-26639][hotfix] Snapshot publishing typo
Marton Balassi [Thu, 12 May 2022 08:55:35 +0000 (10:55 +0200)]
[FLINK-26639] Snapshot publishing fixes
SteNicholas [Tue, 10 May 2022 14:11:16 +0000 (22:11 +0800)]
[FLINK-27499] Bump base Flink version to 1.15.0
Márton Balassi [Thu, 12 May 2022 07:53:52 +0000 (09:53 +0200)]
[FLINK-26639] Publish snapshot artifacts nightly
Marton Balassi [Wed, 11 May 2022 14:47:05 +0000 (16:47 +0200)]
[FLINK-27036] Exclude final release tags from docker build
These should be tagged manually from the latest rc instead.
Biao Geng [Wed, 11 May 2022 13:34:52 +0000 (21:34 +0800)]
[FLINK-27329] Add default value of replica of JM pod and not declare it in example yamls
Gyula Fora [Wed, 11 May 2022 12:36:48 +0000 (14:36 +0200)]
[FLINK-27551] Update status manually instead of relying on updatecontrol
Nicholas Jiang [Wed, 11 May 2022 09:14:40 +0000 (17:14 +0800)]
[FLINK-27261] Disable 'web.cancel.enable' for session cluster
This closes #198.
SteNicholas [Sat, 7 May 2022 10:02:06 +0000 (18:02 +0800)]
[FLINK-27412] Allow flinkVersion v1_13 in flink-kubernetes-operator and improve e2e tests to cover all supported Flink versions
This closes #197.
SteNicholas [Tue, 10 May 2022 04:06:26 +0000 (12:06 +0800)]
[hotfix] Specify container in kubectl command
Gyula Fora [Thu, 5 May 2022 13:09:52 +0000 (15:09 +0200)]
[FLINK-27500] Validation errors should not block reconciliation
Gyula Fora [Sat, 7 May 2022 09:15:25 +0000 (11:15 +0200)]
[FLINK-27468] Recover missing deployments and other cancel/upgrade improvements for 1.15
SteNicholas [Wed, 4 May 2022 06:07:28 +0000 (14:07 +0800)]
[FLINK-27097] Document custom validator implementations
This closes #192.
Aitozi [Wed, 27 Apr 2022 06:58:03 +0000 (14:58 +0800)]
[FLINK-27262] Enrich validator for FlinkSessionJob
Matyas Orhidi [Tue, 3 May 2022 10:59:46 +0000 (12:59 +0200)]
[FLINK-26953] Introduce Operator Specific Metrics
Aitozi [Thu, 5 May 2022 13:18:25 +0000 (21:18 +0800)]
[FLINK-27458] Expose allowNonRestoredState flag in JobSpec
Gyula Fora [Tue, 3 May 2022 12:13:06 +0000 (14:13 +0200)]
[FLINK-27303] Improve config cache settings + add cleanup
Aitozi [Wed, 27 Apr 2022 11:21:11 +0000 (19:21 +0800)]
[FLINK-27362] Support restartNonce semantics in session job
Aitozi [Tue, 3 May 2022 07:26:48 +0000 (15:26 +0800)]
[FLINK-27451] Enable the validator plugin in webhook
Nicholas Jiang [Tue, 3 May 2022 07:04:29 +0000 (15:04 +0800)]
[FLINK-27422] Do not create temporary pod template files for JobManager and TaskManager if not configured explicitly
ted chang [Mon, 2 May 2022 10:29:18 +0000 (03:29 -0700)]
[FLINK-27129][docs] Hardcoded namespace in FlinkDeployment manifests may fail to deploy
Signed-off-by: ted chang <htchang@us.ibm.com>
Gyula Fora [Tue, 26 Apr 2022 11:16:52 +0000 (13:16 +0200)]
[FLINK-27303][FLINK-27309] Introduce FlinkConfigManager for efficient config management
Aitozi [Mon, 25 Apr 2022 15:18:12 +0000 (23:18 +0800)]
[FLINK-27397] Improve the CrdReferenceDoclet to handle the abstract class
Aitozi [Sun, 24 Apr 2022 06:08:06 +0000 (14:08 +0800)]
[FLINK-27160] Add e2e tests for session job
This closes #179.
Aitozi [Sun, 24 Apr 2022 06:07:46 +0000 (14:07 +0800)]
[hotfix] Harden the ArtifactManagerTest
Aitozi [Sun, 24 Apr 2022 01:45:07 +0000 (09:45 +0800)]
[hotfix] fix typo
SteNicholas [Mon, 25 Apr 2022 01:43:50 +0000 (09:43 +0800)]
[FLINK-27334] Support auto generate the doc for the KubernetesOperatorConfigOptions
wangyang0918 [Sun, 24 Apr 2022 06:51:21 +0000 (14:51 +0800)]
[FLINK-27358] Fix NPE and avoid unnecessary configmap update
Nicholas Jiang [Sun, 24 Apr 2022 11:32:00 +0000 (19:32 +0800)]
[FLINK-26926] Allow users to force upgrade even if savepoint is in progress
Aitozi [Sun, 24 Apr 2022 06:36:52 +0000 (14:36 +0800)]
[FLINK-27360] Rename clusterId field of FlinkSessionJobSpec to deploymentName
Aitozi [Sun, 24 Apr 2022 05:51:38 +0000 (13:51 +0800)]
[FLINK-27279] Extract common status interfaces
Aitozi [Sat, 16 Apr 2022 10:59:37 +0000 (18:59 +0800)]
[FLINK-27161] Support to fetch user jar from different sources for session job
This closes #168.
Gyula Fora [Tue, 19 Apr 2022 10:47:21 +0000 (12:47 +0200)]
[FLINK-27023] Unify flink and operator configuration
bgeng777 [Tue, 19 Apr 2022 14:16:07 +0000 (22:16 +0800)]
[FLINK-27310] Improve github CI for integration tests
bgeng777 [Tue, 19 Apr 2022 13:14:12 +0000 (21:14 +0800)]
[FLINK-27310] Fix FlinkOperatorITCase
lz [Mon, 18 Apr 2022 10:11:30 +0000 (18:11 +0800)]
[FLINK-27289] Avoid calling waitForClusterShutdown twice when stopping session cluster with deleting HA data
This closes #171.
Nicholas Jiang [Wed, 20 Apr 2022 05:41:34 +0000 (13:41 +0800)]
[FLINK-27029] DeploymentValidator should take default flink config into account during validation
Aitozi [Sat, 16 Apr 2022 14:00:43 +0000 (22:00 +0800)]
[FLINK-27269] Clean up the jar file after submitting the job
This closes #169.
Gyula Fora [Mon, 18 Apr 2022 07:04:03 +0000 (09:04 +0200)]
[FLINK-26140] Support rollback strategies
SteNicholas [Thu, 7 Apr 2022 15:02:13 +0000 (23:02 +0800)]
[FLINK-27124] Flink Kubernetes operator prints starting logs with corrent version
This closes #160.
ted chang [Wed, 13 Apr 2022 09:12:34 +0000 (02:12 -0700)]
[FLINK-26811][docs] Document CRD upgrade process
Signed-off-by: ted chang <htchang@us.ibm.com>
Aitozi [Wed, 6 Apr 2022 12:03:35 +0000 (20:03 +0800)]
[FLINK-26871] Handle session job spec change
jbusche [Wed, 13 Apr 2022 14:23:28 +0000 (07:23 -0700)]
[FLINK-27211] Adds deployments/finalizers for OpenShift Deployment
Nicholas Jiang [Tue, 12 Apr 2022 15:13:45 +0000 (23:13 +0800)]
[FLINK-27154] Disable web.cancel.enable for application clusters
Nicholas Jiang [Tue, 12 Apr 2022 09:22:04 +0000 (17:22 +0800)]
[FLINK-27141] Improve FlinkService#waitForClusterShutdown logic
Jaganathan Asokan [Fri, 1 Apr 2022 13:37:54 +0000 (09:37 -0400)]
[FLINK-26905] Re-add FlinkDeploymentList and FlinkSessionJobList classes
Closes #129
Gyula Fora [Wed, 6 Apr 2022 11:21:04 +0000 (13:21 +0200)]
[FLINK-27065] Store last reconciled specs as string
Gyula Fora [Wed, 6 Apr 2022 09:13:06 +0000 (11:13 +0200)]
[FLINK-27005] Bump CRD version to v1beta1
Matyas Orhidi [Mon, 4 Apr 2022 15:39:06 +0000 (17:39 +0200)]
[FLINK-26663] Pod augmentation for the operator
Hao Xin [Wed, 6 Apr 2022 15:15:20 +0000 (23:15 +0800)]
[FLINK-27098] Use namespaced Kubernetes client when creating InformerEventSource in session job controller
This closes #157.
Nicholas Jiang [Wed, 6 Apr 2022 18:33:05 +0000 (02:33 +0800)]
[FLINK-26894] Support custom validator implementations
Hao Xin [Wed, 6 Apr 2022 12:18:07 +0000 (20:18 +0800)]
[chore] fix the LoggerFactory class in FlinkSessionJobReconciler
MartijnVisser [Mon, 4 Apr 2022 12:28:51 +0000 (14:28 +0200)]
[hotfix] Change email/repository notifications to match with Flink Core settings
Aitozi [Mon, 4 Apr 2022 04:57:29 +0000 (12:57 +0800)]
[FLINK-27000] Support to set JVM args for operator (#153)
wangyang0918 [Sat, 2 Apr 2022 09:19:41 +0000 (17:19 +0800)]
[FLINK-27012] Caching maven dependencies to speed up workflows in github actions
Aitozi [Sun, 3 Apr 2022 14:28:17 +0000 (22:28 +0800)]
[FLINK-26787] Initial implementation of FlinkSessionJobController and reconciler
Nicholas Jiang [Sun, 3 Apr 2022 07:06:49 +0000 (15:06 +0800)]
[FLINK-26893] Validate checkpoint config with last-state upgrade mode (#139)
Gyula Fora [Sat, 2 Apr 2022 15:49:38 +0000 (17:49 +0200)]
[FLINK-26959] Simplify quickstart after release
Biao Geng [Sat, 2 Apr 2022 10:49:21 +0000 (18:49 +0800)]
[FLINK-26611] Document operator config options
Aitozi [Sat, 2 Apr 2022 12:49:13 +0000 (20:49 +0800)]
[FLINK-26996] Break the reconcile after first create session cluster
Márton Balassi [Fri, 1 Apr 2022 19:56:32 +0000 (21:56 +0200)]
[FLINK-26991][docs] Fix GitHub action building correct doc branch
Marton Balassi [Wed, 30 Mar 2022 16:26:41 +0000 (18:26 +0200)]
[FLINK-26934] Initial meetup recording added to docs
Marton Balassi [Fri, 1 Apr 2022 12:43:07 +0000 (14:43 +0200)]
[FLINK-26991][docs] Limits docs build to main repo
and to only relevant branches.
Biao Geng [Fri, 1 Apr 2022 17:35:33 +0000 (01:35 +0800)]
[FLINK-26892] Observe current status before validating CR changes
Márton Balassi [Wed, 30 Mar 2022 13:31:37 +0000 (15:31 +0200)]
[FLINK-26924] Rename docker image and helm chart to flink-kubernetes-operator
wangyang0918 [Wed, 30 Mar 2022 08:56:30 +0000 (16:56 +0800)]
[FLINK-26917] Enforce Kubernetes HA during validation for last-state mode
Gyula Fora [Wed, 30 Mar 2022 10:48:24 +0000 (12:48 +0200)]
[hotfix] Add missing flinkVersion to doc examples
Gyula Fora [Wed, 30 Mar 2022 10:19:41 +0000 (12:19 +0200)]
[release] Release script improvements + add header to generated CRD
Marton Balassi [Mon, 28 Mar 2022 13:54:25 +0000 (15:54 +0200)]
[FLINK-26214] Add support for ARM64 docker image
Marton Balassi [Tue, 29 Mar 2022 14:37:01 +0000 (16:37 +0200)]
[FLINK-26214] Only run Maven tests in Docker during CI
wangyang0918 [Wed, 30 Mar 2022 07:36:50 +0000 (15:36 +0800)]
[FLINK-26916] Remove job graph from K8s HA ConfigMaps when submitting a Flink application cluster
Gyula Fora [Wed, 30 Mar 2022 07:18:50 +0000 (09:18 +0200)]
[release] Add license header to helm repo index file
Gyula Fora [Tue, 29 Mar 2022 08:18:44 +0000 (10:18 +0200)]
Add helm packaging to create_source_release.sh script