[GitHub] [flink-kubernetes-operator] asfgit closed pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

asfgit closed pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: c

[flink-kubernetes-operator] branch main updated: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

This is an automated email from the ASF dual-hosted git repository. gyfora pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git The following commit(s) were added to refs/heads/main by this push: new cdfc7a2 [FLINK-26290] Introduce

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

gyfora commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047503489 I think what Thomas did makes a lot of sense. The service account config is pretty confusing and easy to get wrong. This way we can set the relevant settings depe

[flink] 01/02: [FLINK-25851][build][tests] Bump bytebuddy to 1.8.22

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit d725ba879226db96377a0b07ae9e56e24481dba6 Author: Etienne Chauchot AuthorDate: Thu Feb 17 10:16:49 2022 +0100

[flink] 02/02: [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 1ff23ac8483045a4e5b653c05b5afb0354882286 Author: Etienne Chauchot AuthorDate: Fri Jan 28 13:05:26 2022 +0100

[flink] branch release-1.14 updated (cfc54ca -> 1ff23ac)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from cfc54ca [FLINK-25856][python][BP-1.14] Fix use of UserDefinedType in from_elements new d725ba8 [FLINK-2

[flink] 02/02: [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 965774ca1c4923d1c5c78bbc5f1a7b26262e6682 Author: Etienne Chauchot AuthorDate: Fri Jan 28 13:05:26 2022 +0100

[flink] 01/02: [FLINK-25851][build][tests] Bump bytebuddy to 1.8.22

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git commit 42db40c33eae39518e16640ebdf093594590c1da Author: Etienne Chauchot AuthorDate: Thu Feb 17 10:16:49 2022 +0100

[flink] branch release-1.13 updated (b0d0a00 -> 965774c)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from b0d0a00 [FLINK-25227][table] Boxed numeric type should be considered when generating code for equality checki

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #11: [FLINK-26260] Support watching specific namespaces only

gyfora commented on pull request #11: URL: https://github.com/apache/flink-kubernetes-operator/pull/11#issuecomment-1047490260 cc @wangyang0918 @morhidi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request #11: [FLINK-26260] Support watching specific namespaces only

gyfora opened a new pull request #11: URL: https://github.com/apache/flink-kubernetes-operator/pull/11 This PR introduces a new config option for watching a list of specific namespaces for FlinkDeployment resources. The config can be set in the Helm chart as a list and is passed as an en

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

Aitozi commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047483487 @wangyang0918 I have not seen the standalone mode `Reconciler` in the code repo. But IMO, standalone mode will generate the JobManager deployment, TaskManager dep

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

wangyang0918 commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047473369 @Aitozi I am afraid the service account related config options(e.g. `KubernetesConfigOptions#KUBERNETES_SERVICE_ACCOUNT`) could not take effect for standalo

[GitHub] [flink-kubernetes-operator] asfgit closed pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

asfgit closed pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: com

[flink-kubernetes-operator] branch main updated: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

This is an automated email from the ASF dual-hosted git repository. gyfora pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git The following commit(s) were added to refs/heads/main by this push: new 29ef2f5 [FLINK-26163] Refactor F

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

wangyang0918 commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811595777 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -72,6 +72,12 @

[flink] branch master updated: [FLINK-26152] [docs] Translate the page of SQL/queries/WITH clause (#18828)

This is an automated email from the ASF dual-hosted git repository. jark pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 84530f4 [FLINK-26152] [docs] Translate the page of

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

Aitozi commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047438031 Hi @tweise I left one concern for this PR I think we should avoid to introduce option as first class field when there is already config in Flink have the sa

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

tweise commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811565535 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -72,6 +72,12 @@ publ

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a change in pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 commented on a change in pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#discussion_r811551466 ## File path: flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/utils/FlinkConfigBuilderTest.java ## @@ -0,0 +1,

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

wangyang0918 commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047383868 > CR should abstract how we interact with k8s and also work for standalone mode. This is a good point and explains why we need to make `serviceAccount

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

wangyang0918 commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811544151 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -72,6 +72,12 @

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

tweise commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047378623 > @tweise Thanks for creating this PR. Regarding the `serviceAccount` and `taskSlots`, could you please share the guideline which fields should or should not be f

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

tweise commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811538809 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -72,6 +72,12 @@ publ

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

wangyang0918 commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811529382 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -72,6 +72,12 @

[flink] branch release-1.14 updated: [FLINK-25856][python][BP-1.14] Fix use of UserDefinedType in from_elements

This is an automated email from the ASF dual-hosted git repository. hxb pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.14 by this push: new cfc54ca [FLINK-25856][python][BP-1.14]

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

tweise commented on a change in pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#discussion_r811464631 ## File path: examples/basic-checkpoint-ha.yaml ## @@ -25,6 +25,7 @@ spec: image: flink:1.14.3 flinkVersion: 1.14.3 flinkConfigurat

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

tweise commented on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1047253336 Also see #10 for related field changes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #10: [FLINK-26290] Introduce serviceAccount as direct field, remove taskSlots

tweise commented on pull request #10: URL: https://github.com/apache/flink-kubernetes-operator/pull/10#issuecomment-1047252973 @gyfora -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[flink] 02/02: [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 8488368b86a99a064446ca74e775b670b94a Author: Etienne Chauchot AuthorDate: Fri Jan 28 13:05:26 2022 +0100 [FLINK

[flink] branch master updated (4191094 -> 8488368)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 4191094 [FLINK-26221][prometheus] Migrate tests to JUnit5 new bbd5682 [FLINK-25851][build][tests] Bump bytebud

[flink] 01/02: [FLINK-25851][build][tests] Bump bytebuddy to 1.8.22

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bbd568207494499b0123c280b300caae9fb9c8fd Author: Etienne Chauchot AuthorDate: Thu Feb 17 10:16:49 2022 +0100 [FLINK

[flink] branch master updated (b28aa17 -> 4191094)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from b28aa17 [hotfix][table-planner] Improve error reporting when serializing CatalogTable into the plan add 419109

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

gyfora commented on a change in pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#discussion_r811273546 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java ## @@ -55,109 +43,19 @@

[flink] branch master updated (3eca2ba -> b28aa17)

This is an automated email from the ASF dual-hosted git repository. twalthr pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 3eca2ba [FLINK-26064][connector/firehose][connector/kinesis] Using separate event loop groups for firehose and kine

[flink] branch master updated: [FLINK-26064][connector/firehose][connector/kinesis] Using separate event loop groups for firehose and kinesis IT tests.

This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3eca2ba [FLINK-26064][connector/firehose][

[GitHub] [flink-kubernetes-operator] bgeng777 edited a comment on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 edited a comment on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1046823084 Thanks a lot for the detailed review! 1. Sure. It seems that the fix of JM replicas is just a piece of codes so I did it here. I will move it out and lea

[GitHub] [flink-kubernetes-operator] bgeng777 edited a comment on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 edited a comment on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1046823084 1. Sure. It seems that the fix of JM replicas is just some lines of codes so I did it here. I will move it out and leave the work to the separate [jira](ht

[GitHub] [flink-kubernetes-operator] bgeng777 commented on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 commented on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1046823084 1. Sure. It seems that the fix of JM replicas is just some lines of codes so I did it here. I will move it out and leave the work to the separate [jira](https://i

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

wangyang0918 commented on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1046798237 > 1. Refactor `FlinkUtils#getEffectiveConfig` into smaller pieces. > 2. Fix the problem that the field of `replicas` in `JobManagerSpec` will not take effec

[GitHub] [flink-kubernetes-operator] wangyang0918 merged pull request #8: [FLINK-26157] Containers Should Not Run As Root

wangyang0918 merged pull request #8: URL: https://github.com/apache/flink-kubernetes-operator/pull/8 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mai

[flink-kubernetes-operator] branch main updated: [FLINK-26157] Containers Should Not Run As Root

This is an automated email from the ASF dual-hosted git repository. wangyang0918 pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git The following commit(s) were added to refs/heads/main by this push: new 2511860 [FLINK-26157] Cont

[flink] branch master updated (a7411b6 -> 6056680)

This is an automated email from the ASF dual-hosted git repository. hxb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from a7411b6 [FLINK-26120][tests] Relax CheckpointIDCounterTestBase assertions add 6056680 [FLINK-25856][python] Fix u

[flink] 01/02: [FLINK-25893][runtime] Fix that ResourceManagerServiceImpl may call ResourceManager#deregisterApplication before RM being fully started.

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit ce560c612a7d3b9b9f2e2cf810bf51c25cba9053 Author: Xintong Song AuthorDate: Sun Feb 20 17:32:25 2022 +0800 [FLIN

[flink] 02/02: [FLINK-25893][runtime] Do not report error if ResourceManagerServiceImpl#deregisterApplication is called when there's no leading RM.

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git commit 451c5aa98b516bc7dde2dedfe01a6d3ae8d9c8dd Author: Xintong Song AuthorDate: Sun Feb 20 17:52:59 2022 +0800 [FLIN

[flink] branch release-1.14 updated (2465c850 -> 451c5aa)

This is an automated email from the ASF dual-hosted git repository. xtsong pushed a change to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git. from 2465c850 [FLINK-23240][runtime] Master process supports living through multiple leader sessions. new ce560

[GitHub] [flink-kubernetes-operator] bgeng777 commented on pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 commented on pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9#issuecomment-1046699367 cc @wangyang0918 @gyfora @tweise -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-kubernetes-operator] bgeng777 opened a new pull request #9: [FLINK-26163] Refactor FlinkUtils#getEffectiveConfig into smaller pieces

bgeng777 opened a new pull request #9: URL: https://github.com/apache/flink-kubernetes-operator/pull/9 1. Refactor `FlinkUtils#getEffectiveConfig` into smaller pieces. 2. Fix the problem that the field of `replicas` in `JobManagerSpec` will not take effect. 3. Fix the problem that the

[flink] branch master updated (38b9185 -> a7411b6)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 38b9185 [FLINK-26145][docs] Fix a kubernetes image that does not exist in the document. add a7411b6 [FLINK-26

[flink] branch master updated: [FLINK-26145][docs] Fix a kubernetes image that does not exist in the document.

This is an automated email from the ASF dual-hosted git repository. wangyang0918 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 38b9185 [FLINK-26145][docs] Fix a kubernet

[flink] branch master updated (3c99b00 -> 967e43f)

This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 3c99b00 [FLINK-26235][connectors/filesystem] CompactingFileWriter and PendingFileRecoverable should not be exposed

[flink] branch master updated: [FLINK-26235][connectors/filesystem] CompactingFileWriter and PendingFileRecoverable should not be exposed to users.

This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new 3c99b00 [FLINK-26235][connectors/filesystem]

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #8: [FLINK-26157] Containers Should Not Run As Root

morhidi commented on pull request #8: URL: https://github.com/apache/flink-kubernetes-operator/pull/8#issuecomment-1046607054 CC @wangyang0918 @gyfora @tweise -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request #8: [FLINK-26157] Containers Should Not Run As Root

morhidi opened a new pull request #8: URL: https://github.com/apache/flink-kubernetes-operator/pull/8 - creating non-privileged user flink:flink - set the default user to flink -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH