[flink] 05/05: [FLINK-26297][table-planner] Rename PlannerConfiguration to PlannerConfig

This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 56da73a457a9c9150db90d58627bf2c8a08ebf7c Author: Marios Trivyzas AuthorDate: Wed Feb 23 12:47:24 2022 +0200 [FLINK-

[flink] 04/05: [FLINK-26297][table] Use `tableConfig` as name for `TableConfig` variables

This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit e2b743c98d2aabfa028c0cc79a54b62ad30507da Author: Marios Trivyzas AuthorDate: Tue Feb 22 19:47:13 2022 +0200 [FLINK-

[flink] 02/05: [hotfix][table-planner] Organize imports in scala files

This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit 2dabb2fda542c8da8c1e1f015c51f0da7c8beec6 Author: Marios Trivyzas AuthorDate: Mon Feb 14 16:18:33 2022 +0200 [hotfix

[flink] 01/05: [FLINK-26297][table-planner] Rename ShortcutUtils method to get TableConfig

This is an automated email from the ASF dual-hosted git repository. twalthr pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git commit bd46985d1ddfea02b398a744f0521094a019b487 Author: Marios Trivyzas AuthorDate: Mon Feb 21 11:47:03 2022 +0200 [FLINK-

[flink] branch master updated (f8ac2bf -> 56da73a4)

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 f8ac2bf [FLINK-26318][tests] Recover from the latest checkpoint in ChangelogCompatibilityITCase new bd46985 [

[flink-kubernetes-operator] branch main updated (aa4fa0d -> eebb796)

This is an automated email from the ASF dual-hosted git repository. wangyang0918 pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git. from aa4fa0d [FLINK-26337] Avoid to load flink conf at each reconcile loop add eebb796 [FLIN

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #18: [FLINK-26332]Move the operator env to common utils

wangyang0918 commented on pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#issuecomment-1049526186 LGTM. +1 for merging. -- 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] wangyang0918 merged pull request #18: [FLINK-26332]Move the operator env to common utils

wangyang0918 merged pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18 -- 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-m

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

wangyang0918 commented on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049524050 > Thanks for your explanation. Later, if we want to use the hot update ability of the ConfigMap do update the `flink-default-config`, Maybe we could also us

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #12: [FLINK-26138] Add stateless and stateful test for controller

gyfora commented on pull request #12: URL: https://github.com/apache/flink-kubernetes-operator/pull/12#issuecomment-1049519759 cc @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 to go to the s

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

gyfora commented on pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#issuecomment-1049518325 I wonder if caching the deployment is even necessary, it adds complexity and can lead to cases where the deployment disappears and we do not notice. The reconcile

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

gyfora commented on a change in pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#discussion_r813564416 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

tweise commented on a change in pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#discussion_r813561729 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[GitHub] [flink-kubernetes-operator] tweise commented on a change in pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

tweise commented on a change in pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#discussion_r813561088 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

gyfora commented on a change in pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#discussion_r813558909 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[GitHub] [flink-kubernetes-operator] tweise commented on pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

tweise commented on pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21#issuecomment-1049509120 @gyfora PTAL -- 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 s

[GitHub] [flink-kubernetes-operator] tweise opened a new pull request #21: [FLINK-26261] Wait for JobManager deployment ready before accessing REST API

tweise opened a new pull request #21: URL: https://github.com/apache/flink-kubernetes-operator/pull/21 First part following resource dependencies in the reconciler logic: Wait for the JM deployment to be ready before trying to access the JM. This will be built upon for improving the error

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #18: [FLINK-26332]Move the operator env to common utils

Aitozi commented on pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#issuecomment-1049500348 I have rebased the master and addressed the comments, Please take a look again, thanks cc @gyfora @wangyang0918 -- This is an automated message from the Apache

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #18: [FLINK-26332]Move the operator env to common utils

gyfora commented on pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#issuecomment-1049494900 I added a minor comment, also please rebase on top of your config changes and then it should be good to go :) -- This is an automated message from the Apache G

[GitHub] [flink-kubernetes-operator] asfgit closed pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

asfgit closed pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19 -- 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-26337] Avoid to load flink conf at each reconcile loop

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 aa4fa0d [FLINK-26337] Avoid to l

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

gyfora commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813544933 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,70 @@ +/* + *

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

wangyang0918 commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813544365 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,70 @@ +/

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

Aitozi commented on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049481523 Thanks for your explanation. Later, if we want to use the hot update ability of the ConfigMap do update the `flink-default-config`, Maybe we could also use the me

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

wangyang0918 commented on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049476677 But the ConfigMap hot update is very useful to change log level dynamically. Although we have not configured `monitorInterval` in the log4j2.properties.

[GitHub] [flink-kubernetes-operator] Aitozi commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

Aitozi commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813526890 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink-kubernetes-operator] Aitozi edited a comment on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

Aitozi edited a comment on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049468592 @wangyang0918 Thanks for your question, I have think over it a little. Now, the `flink-default-config` and `flink-operator-config` are mounted via Confi

[GitHub] [flink-kubernetes-operator] Aitozi commented on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

Aitozi commented on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049468592 @wangyang0918 Thanks for your question, I have think over it a little. Now, the `flink-default-config` and `flink-operator-config` are mounted via ConfigMap, W

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

wangyang0918 commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813523930 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,60 @@ +/

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

wangyang0918 commented on pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19#issuecomment-1049464887 Since the `flink-conf.yaml` is mounted via ConfigMap, I am afraid we will not get the latest configuration if the ConfigMap is updated. Do we have to restar

[flink] branch master updated (16be50f -> f8ac2bf)

This is an automated email from the ASF dual-hosted git repository. gaoyunhaii pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 16be50f [FLINK-25385][table-planner] Regenerate plans add f8ac2bf [FLINK-26318][tests] Recover from the lat

[GitHub] [flink-kubernetes-operator] Aitozi commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

Aitozi commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813513481 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,60 @@ +/* + *

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

This is an automated email from the ASF dual-hosted git repository. jqin pushed a change to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git. from 965774c [FLINK-25851][cassandra][tests] Inject dynamic table name into Pojos add e2a8990 [FLINK-24607] Let

[GitHub] [flink-kubernetes-operator] tweise merged pull request #20: [hotfix] Fix observer sort logic for job status merge

tweise merged pull request #20: URL: https://github.com/apache/flink-kubernetes-operator/pull/20 -- 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: [hotfix] Fix observer sort logic for job status merge

This is an automated email from the ASF dual-hosted git repository. thw 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 3e6a00f [hotfix] Fix observer sort

[flink] branch release-1.14 updated: [FLINK-26304][streaming] Do not forward failed committables

This is an automated email from the ASF dual-hosted git repository. fpaul 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 8a168e1 [FLINK-26304][streaming] Do n

[GitHub] [flink-kubernetes-operator] morhidi commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

morhidi commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813106573 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,60 @@ +/* + *

[GitHub] [flink-kubernetes-operator] morhidi commented on a change in pull request #18: [FLINK-26332]Move the operator env to common utils

morhidi commented on a change in pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18#discussion_r813103579 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/EnvUtils.java ## @@ -0,0 +1,60 @@ +/* + *

[flink] branch master updated (e432723 -> 16be50f)

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 e432723 [FLINK-26319][table-planner] Fix expected exception in CastFunctionITCase add 32700d9 [FLINK-25385][t

[GitHub] [flink-kubernetes-operator] Aitozi opened a new pull request #19: [FLINK-26337]Avoid to load flink conf at each reconcile loop

Aitozi opened a new pull request #19: URL: https://github.com/apache/flink-kubernetes-operator/pull/19 It will create FlinkConfigBuilder at every loop of reconcile, It's not necessary and may bring overhead. The default flink conf and operator conf should load at entry point. If the Confi

[flink-kubernetes-operator] branch main updated: [hotfix] Fix pod template merging if base template is null

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 27fd3e8 [hotfix] Fix pod templat

[flink] branch release-1.14 updated: [FLINK-24407][doc-zh] Fix the broken links in Chinese document of Pulsar connector

This is an automated email from the ASF dual-hosted git repository. leonard 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 fdc6d6c [FLINK-24407][doc-zh] Fix t

[GitHub] [flink-kubernetes-operator] asfgit closed pull request #17: [FLINK-26329] Adjust the order of var initialization in FlinkControll…

asfgit closed pull request #17: URL: https://github.com/apache/flink-kubernetes-operator/pull/17 -- 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-26329] Adjust the order of var initialization in FlinkControllerConfig

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 eda38b4 [FLINK-26329] Adjust the

[GitHub] [flink-kubernetes-operator] Aitozi opened a new pull request #18: [FLINK-26332]Move the operator env to common utils

Aitozi opened a new pull request #18: URL: https://github.com/apache/flink-kubernetes-operator/pull/18 Move the scattered environments variables to the `EnvUtils` and make it clear whether the variable is required -- This is an automated message from the Apache Git Service. To respond to

[flink] branch master updated: [FLINK-26319][table-planner] Fix expected exception in CastFunctionITCase

This is an automated email from the ASF dual-hosted git repository. twalthr 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 e432723 [FLINK-26319][table-planner] Fix expect

[flink] branch master updated: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

This is an automated email from the ASF dual-hosted git repository. fpaul 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 0ff6f2c [FLINK-24571][connectors/elasticsearch] S

[flink] branch master updated (26b5da3 -> d33ba96)

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 26b5da3 [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese. add d33ba96 [FLINK-2

[GitHub] [flink-kubernetes-operator] zuston opened a new pull request #17: [FLINK-26329] Adjust the order of var initialization in FlinkControll…

zuston opened a new pull request #17: URL: https://github.com/apache/flink-kubernetes-operator/pull/17 …erConfig -- 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 unsubsc

[GitHub] [flink-kubernetes-operator] asfgit closed pull request #16: [FLINK-26324] Remove duplicate condition judgment

asfgit closed pull request #16: URL: https://github.com/apache/flink-kubernetes-operator/pull/16 -- 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-26324] Remove duplicate condition judgment

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 e4cecf3 [FLINK-26324] Remove dup

[GitHub] [flink-kubernetes-operator] asfgit closed pull request #13: [FLINK-26236] Track and cap retries in ReconciliationStatus

asfgit closed pull request #13: URL: https://github.com/apache/flink-kubernetes-operator/pull/13 -- 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-26236] Track and cap retries in ReconciliationStatus

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 7198c1d [FLINK-26236] Track and

[GitHub] [flink-kubernetes-operator] gyfora commented on a change in pull request #13: [FLINK-26236] Track and cap retries in ReconciliationStatus

gyfora commented on a change in pull request #13: URL: https://github.com/apache/flink-kubernetes-operator/pull/13#discussion_r812702275 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[flink] branch master updated: [FLINK-25798][docs-zh] Translate datastream/formats/text_files.md page into Chinese.

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 26b5da3 [FLINK-25798][docs-zh] Translate da

[GitHub] [flink-kubernetes-operator] morhidi commented on a change in pull request #13: [FLINK-26236] Track and cap retries in ReconciliationStatus

morhidi commented on a change in pull request #13: URL: https://github.com/apache/flink-kubernetes-operator/pull/13#discussion_r812690378 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[GitHub] [flink-kubernetes-operator] morhidi commented on a change in pull request #13: [FLINK-26236] Track and cap retries in ReconciliationStatus

morhidi commented on a change in pull request #13: URL: https://github.com/apache/flink-kubernetes-operator/pull/13#discussion_r812689610 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java ## @@

[flink] branch master updated (9a8f068 -> 8d5a7f1)

This is an automated email from the ASF dual-hosted git repository. dannycranmer pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git. from 9a8f068 [FLINK-26226][influxdb] Migrate tests to JUnit5 add 8d5a7f1 [FLINK-26291][connectors/firehose] Ch

[GitHub] [flink-kubernetes-operator] wangyang0918 commented on a change in pull request #13: [FLINK-26236] Track and cap retries in ReconciliationStatus

wangyang0918 commented on a change in pull request #13: URL: https://github.com/apache/flink-kubernetes-operator/pull/13#discussion_r812636751 ## File path: flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentController.java

[flink] branch master updated (bfe359c -> 9a8f068)

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 bfe359c [FLINK-26228][dropwizard] Migrate tests to JUnit5 add 9a8f068 [FLINK-26226][influxdb] Migrate tests to

[flink] branch master updated (e4d2fb38 -> bfe359c)

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 e4d2fb38 [FLINK-25782][docs-zh] Translate datastream filesystem.md page into Chinese. add bfe359c [FLINK-26228