[GitHub] [flink] lincoln-lil commented on pull request #21551: [FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

2022-12-28 Thread GitBox
lincoln-lil commented on PR #21551: URL: https://github.com/apache/flink/pull/21551#issuecomment-1366537118 @leonardBang I've created one: https://github.com/apache/flink/pull/21568 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] X-czh commented on a diff in pull request #21569: [FLINK-30517][log]Decrease log output interval while waiting for YARN…

2022-12-28 Thread GitBox
X-czh commented on code in PR #21569: URL: https://github.com/apache/flink/pull/21569#discussion_r1058296234 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java: ## @@ -1264,9 +1265,11 @@ private ApplicationReport startAppMaster( if

[GitHub] [flink] flinkbot commented on pull request #21570: [FLINK-29666][runtime] Let adaptive batch scheduler divide subpartition range according to amount of data

2022-12-28 Thread GitBox
flinkbot commented on PR #21570: URL: https://github.com/apache/flink/pull/21570#issuecomment-1366606492 ## CI report: * 3a54472c7b56c01c593948d72a5527985dc842c7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] huwh commented on a diff in pull request #21569: [FLINK-30517][log]Decrease log output interval while waiting for YARN…

2022-12-28 Thread GitBox
huwh commented on code in PR #21569: URL: https://github.com/apache/flink/pull/21569#discussion_r1058341817 ## flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java: ## @@ -1264,9 +1265,11 @@ private ApplicationReport startAppMaster( if

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652503#comment-17652503 ] Gyula Fora commented on FLINK-30518: You are right [~tbnguyen1407] , those issues are not related,

[jira] [Updated] (FLINK-30519) Add e2e tests for operator dynamic config

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30519: --- Priority: Critical (was: Blocker) > Add e2e tests for operator dynamic config >

[jira] [Updated] (FLINK-30519) Add e2e tests for operator dynamic config

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30519: --- Issue Type: Technical Debt (was: New Feature) > Add e2e tests for operator dynamic config >

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652512#comment-17652512 ] Gyula Fora commented on FLINK-30518: [~bgeng777] I think this is not related to any operator version

[jira] [Created] (FLINK-30529) Use simple cancel for savepoint upgrades on failing jobs

2022-12-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30529: -- Summary: Use simple cancel for savepoint upgrades on failing jobs Key: FLINK-30529 URL: https://issues.apache.org/jira/browse/FLINK-30529 Project: Flink Issue

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652526#comment-17652526 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 3:50 PM:

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652526#comment-17652526 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 3:50 PM:

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652530#comment-17652530 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~gyfora] I think my assumption is wrong about the

[jira] [Closed] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30406. -- Fix Version/s: kubernetes-operator-1.3.1 Resolution: Fixed merged to main

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652533#comment-17652533 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:20 PM:

[GitHub] [flink] lincoln-lil opened a new pull request, #21568: [bp-1.16][FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

2022-12-28 Thread GitBox
lincoln-lil opened a new pull request, #21568: URL: https://github.com/apache/flink/pull/21568 this is a back port pr to 1.16 branch for fixing FLINK-27691 -- 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] huwh opened a new pull request, #21569: [FLINK-30517][log]Decrease log output interval while waiting for YARN…

2022-12-28 Thread GitBox
huwh opened a new pull request, #21569: URL: https://github.com/apache/flink/pull/21569 … JobManager be allocated. ## What is the purpose of the change Flink Client will retrieve the application status every 250ms after submitting to YARN. If JobManager does not start in 60

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058328980 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchFileWriter.java: ## @@ -0,0 +1,115 @@ +/* + *

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #489: [FLINK-30406] Detect when jobmanager never started

2022-12-28 Thread GitBox
gyfora commented on code in PR #489: URL: https://github.com/apache/flink-kubernetes-operator/pull/489#discussion_r1058387166 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -112,18 +116,23

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: (was: kubernetes-operator-1.3.0) > Arguments contains with '#' will error

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: API / Core (was: Kubernetes Operator) > Arguments contains with

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: 1.15.3 1.16.0 > Arguments contains with '#' will error

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652533#comment-17652533 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:12 PM:

[jira] [Commented] (FLINK-30513) HA storage dir leaks on cluster termination

2022-12-28 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652438#comment-17652438 ] Zhanghao Chen commented on FLINK-30513: --- Hi [~wangyang0918], looking forward to your opinions on

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-30520: Description: When i submit a flink jar job in Kubernetes Application mode which main args

[jira] [Updated] (FLINK-30517) Decrease log output interval while waiting for YARN JobManager be allocated

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30517: --- Labels: pull-request-available (was: ) > Decrease log output interval while waiting for

[jira] [Created] (FLINK-30525) Cannot open jobmanager configuration web page

2022-12-28 Thread Weihua Hu (Jira)
Weihua Hu created FLINK-30525: - Summary: Cannot open jobmanager configuration web page Key: FLINK-30525 URL: https://issues.apache.org/jira/browse/FLINK-30525 Project: Flink Issue Type: Bug

[GitHub] [flink] fsk119 commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-12-28 Thread GitBox
fsk119 commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r1058325472 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -2670,7 +2776,7 @@ private void

[GitHub] [flink] flinkbot commented on pull request #21572: [FLINK-30525][web] Do not show environment info in web ui.

2022-12-28 Thread GitBox
flinkbot commented on PR #21572: URL: https://github.com/apache/flink/pull/21572#issuecomment-1366646064 ## CI report: * 9e2996d48c3cf28425d1ac4c7531077e4e5fe24d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30526) Handle failures in OpenSearch with ActionRequestFailureHandler being deprecated

2022-12-28 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652525#comment-17652525 ] Andriy Redko commented on FLINK-30526: -- The deprecations are related to

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652532#comment-17652532 ] Gyula Fora commented on FLINK-30518: But can you clarify what doesn't work with multiple replicas?

[GitHub] [flink] flinkbot commented on pull request #21568: [bp-1.16][FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

2022-12-28 Thread GitBox
flinkbot commented on PR #21568: URL: https://github.com/apache/flink/pull/21568#issuecomment-1366543592 ## CI report: * cc7d362cc0424e05994cabb70c125173a5f0e045 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] LadyForest commented on a diff in pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-12-28 Thread GitBox
LadyForest commented on code in PR #19329: URL: https://github.com/apache/flink/pull/19329#discussion_r1058243819 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTest.java: ## @@ -1258,6 +1259,94 @@ public void

[jira] [Updated] (FLINK-30522) `SHOW TBLPROPERTIES` can't read properties of table in Spark3

2022-12-28 Thread yuzelin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-30522: Attachment: 1.png > `SHOW TBLPROPERTIES` can't read properties of table in Spark3 >

[jira] [Created] (FLINK-30523) Refine benchmark of vectorAssembler

2022-12-28 Thread weibo zhao (Jira)
weibo zhao created FLINK-30523: -- Summary: Refine benchmark of vectorAssembler Key: FLINK-30523 URL: https://issues.apache.org/jira/browse/FLINK-30523 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-30525) Cannot open jobmanager configuration web page

2022-12-28 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652489#comment-17652489 ] Weihua Hu commented on FLINK-30525: --- [~chesnay] looking forward to your opinions on it. > Cannot

[GitHub] [flink] huwh opened a new pull request, #21572: [FLINK-30525][web] Do not show environment info in web ui.

2022-12-28 Thread GitBox
huwh opened a new pull request, #21572: URL: https://github.com/apache/flink/pull/21572 ## What is the purpose of the change fix that ui of jobmanager.configuration could not open. ## Brief change log - *delete environment related logic* ## Verifying this change

[jira] [Updated] (FLINK-30525) Cannot open jobmanager configuration web page

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30525: --- Labels: pull-request-available (was: ) > Cannot open jobmanager configuration web page >

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #487: [FLINK-30411] Validate empty JmSpec and TmSpec

2022-12-28 Thread GitBox
gyfora commented on code in PR #487: URL: https://github.com/apache/flink-kubernetes-operator/pull/487#discussion_r1058430979 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java: ## @@ -241,15 +245,35 @@ private

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Description: Since flink-conf.yaml is mounted as read-only configmap, the

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652530#comment-17652530 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:03 PM:

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652530#comment-17652530 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:03 PM:

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652533#comment-17652533 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~gyfora] I did not test with jobs yet. First

[GitHub] [flink-connector-jdbc] eskabetxe commented on pull request #8: [FLINK-14102] Introduce DB2Dialect.

2022-12-28 Thread GitBox
eskabetxe commented on PR #8: URL: https://github.com/apache/flink-connector-jdbc/pull/8#issuecomment-1366582244 @MartijnVisser, @wanglijie95 LGTM -- 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

[jira] [Updated] (FLINK-22137) Execute unaligned checkpoint test on a cluster

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22137: --- Labels: pull-request-available (was: ) > Execute unaligned checkpoint test on a cluster >

[GitHub] [flink] LadyForest opened a new pull request, #21571: [FLINK-22137][sql-parser] Support ALTER TABLE DROP syntax

2022-12-28 Thread GitBox
LadyForest opened a new pull request, #21571: URL: https://github.com/apache/flink/pull/21571 ## What is the purpose of the change This pull request aims to support `ALTER TABLE table_identifier DROP` statement. ## Brief change log This PR contains two commits -

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058329666 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-30526) Handle failures in OpenSearch with ActionRequestFailureHandler being deprecated

2022-12-28 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30526: -- Summary: Handle failures in OpenSearch with ActionRequestFailureHandler being deprecated Key: FLINK-30526 URL: https://issues.apache.org/jira/browse/FLINK-30526

[jira] [Created] (FLINK-30528) Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing

2022-12-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30528: -- Summary: Job may be stuck in upgrade loop when last-state fallback is disabled and deployment is missing Key: FLINK-30528 URL: https://issues.apache.org/jira/browse/FLINK-30528

[GitHub] [flink] gyfora commented on pull request #21515: [FLINK-30429][client] Fix IllegalArgumentException when no argument in flink executable

2022-12-28 Thread GitBox
gyfora commented on PR #21515: URL: https://github.com/apache/flink/pull/21515#issuecomment-1366773913 @flinkbot run azure -- 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.

[jira] [Commented] (FLINK-30343) Migrate KubernetesLeaderElectionAndRetrievalITCase

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652461#comment-17652461 ] Wencong Liu commented on FLINK-30343: - Hi [~mapohl] , could you please illustrate this issue in

[GitHub] [flink] flinkbot commented on pull request #21569: [FLINK-30517][log]Decrease log output interval while waiting for YARN…

2022-12-28 Thread GitBox
flinkbot commented on PR #21569: URL: https://github.com/apache/flink/pull/21569#issuecomment-1366560907 ## CI report: * 2604f197ea7d721c0eecfe7e9c2fbafc810009ae UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29666) Let adaptive batch scheduler divide subpartition range according to amount of data

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29666: --- Labels: pull-request-available (was: ) > Let adaptive batch scheduler divide subpartition

[GitHub] [flink] wanglijie95 opened a new pull request, #21570: [FLINK-29666][runtime] Let adaptive batch scheduler divide subpartition range according to amount of data

2022-12-28 Thread GitBox
wanglijie95 opened a new pull request, #21570: URL: https://github.com/apache/flink/pull/21570 ## What is the purpose of the change Let adaptive batch scheduler divide subpartition range according to amount of data ## Verifying this change Test

[GitHub] [flink] luoyuxia commented on pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on PR #21257: URL: https://github.com/apache/flink/pull/21257#issuecomment-1366633565 > @beyond1920 Thanks for reviewing. I prefer to append a commit with tests to mock the speculative execution to validate these operators. Actaully, I don't think we need to add

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652511#comment-17652511 ] Biao Geng commented on FLINK-30518: --- I think [~gyfora] is right that this is not a problem before. I

[jira] [Created] (FLINK-30527) Last-state suspend followed by flinkVersion change may lead to state loss

2022-12-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30527: -- Summary: Last-state suspend followed by flinkVersion change may lead to state loss Key: FLINK-30527 URL: https://issues.apache.org/jira/browse/FLINK-30527 Project: Flink

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652520#comment-17652520 ] Biao Geng commented on FLINK-30518: --- [~gyfora] I see. Thanks for the information. I misunderstood the

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652526#comment-17652526 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~bgeng777] Thank you. I found the problem when

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652529#comment-17652529 ] Gyula Fora commented on FLINK-30518: Strange, the standalone and native integration mode should work

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: kubernetes-operator-1.3.0 (was: 1.16.0)

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: Kubernetes Operator (was: API / Core) > Arguments contains with

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Description: -Since flink-conf.yaml is mounted as read-only configmap, the

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652535#comment-17652535 ] Gyula Fora commented on FLINK-30518: Please test this with replicas 1 and 2 and see what happens

[jira] [Created] (FLINK-30522) `SHOW TBLPROPERTIES` can't read properties of table in Spark3

2022-12-28 Thread yuzelin (Jira)
yuzelin created FLINK-30522: --- Summary: `SHOW TBLPROPERTIES` can't read properties of table in Spark3 Key: FLINK-30522 URL: https://issues.apache.org/jira/browse/FLINK-30522 Project: Flink Issue

[jira] [Created] (FLINK-30524) Unify the style of the logs page

2022-12-28 Thread Yongming Zhang (Jira)
Yongming Zhang created FLINK-30524: -- Summary: Unify the style of the logs page Key: FLINK-30524 URL: https://issues.apache.org/jira/browse/FLINK-30524 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] weibozhao opened a new pull request, #194: [FLINK-30523] Refine benchmark of vectorAssembler

2022-12-28 Thread GitBox
weibozhao opened a new pull request, #194: URL: https://github.com/apache/flink-ml/pull/194 ## Refine benchmark of vectorAssembler ## Brief change log - *Refine benchmark of vectorAssembler ## Does this pull request potentially affect one of the following parts:

[jira] [Updated] (FLINK-30523) Refine benchmark of vectorAssembler

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30523: --- Labels: pull-request-available (was: ) > Refine benchmark of vectorAssembler >

[jira] [Commented] (FLINK-17372) SlotManager should expose total required resources

2022-12-28 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652480#comment-17652480 ] Weihua Hu commented on FLINK-17372: --- Hi. This issue is solved by

[GitHub] [flink] flinkbot commented on pull request #21571: [FLINK-22137][table] Support DROP column/constraint/watermark for ALTER TABLE statement

2022-12-28 Thread GitBox
flinkbot commented on PR #21571: URL: https://github.com/apache/flink/pull/21571#issuecomment-1366612880 ## CI report: * 5a0d9f427a625ca112af4f0f5c62d9914553396b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-30518: -- Attachment: screenshot-1.png > [flink-operator] Kubernetes HA not working due to wrong

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #489: [FLINK-30406] Detect when jobmanager never started

2022-12-28 Thread GitBox
gyfora merged PR #489: URL: https://github.com/apache/flink-kubernetes-operator/pull/489 -- 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:

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652526#comment-17652526 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 3:51 PM:

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Summary: [flink-operator] Kubernetes HA Service not working with standalone mode (was:

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #495: [backport][FLINK-30406] Detect when jobmanager never started

2022-12-28 Thread GitBox
gyfora merged PR #495: URL: https://github.com/apache/flink-kubernetes-operator/pull/495 -- 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:

[GitHub] [flink-table-store] zjureel commented on pull request #441: [FLINK-30423] Introduce generated codes for CastExecutor

2022-12-28 Thread GitBox
zjureel commented on PR #441: URL: https://github.com/apache/flink-table-store/pull/441#issuecomment-1366473424 Hi @JingsongLi , please help to review it again, THX :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Description: Since flink-conf.yaml is mounted as read-only configmap, the

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Environment: (was: ~ flinkdeployment.yaml ~ ``` spec:   flinkConfiguration:    

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Description: Since flink-conf.yaml is mounted as read-only configmap, the

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Binh-Nguyen Tran updated FLINK-30518: - Description: Since flink-conf.yaml is mounted as read-only configmap, the

[jira] [Created] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
Binh-Nguyen Tran created FLINK-30518: Summary: [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address Key: FLINK-30518 URL: https://issues.apache.org/jira/browse/FLINK-30518

[GitHub] [flink] flinkbot commented on pull request #21566: [FLINK-30495][table-api] Introduce TableChange to represent ADD change

2022-12-28 Thread GitBox
flinkbot commented on PR #21566: URL: https://github.com/apache/flink/pull/21566#issuecomment-1366518933 ## CI report: * b4949b180e36f118b1d2e07300afe51cce5ffdc4 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-30520: Attachment: image-2022-12-28-18-03-40-806.png > Arguments contains with '#' will error split in

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #193: [FLINK-30515] Add benchmark for CountVectorizer, Imputer, RobustScale…

2022-12-28 Thread GitBox
yunfengzhou-hub commented on code in PR #193: URL: https://github.com/apache/flink-ml/pull/193#discussion_r1058228046 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/param/HasNumDistinctValues.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652434#comment-17652434 ] Gyula Fora commented on FLINK-30518: This may be related to:

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30520: --- Labels: pull-request-available (was: ) > Arguments contains with '#' will error split in

[GitHub] [flink] leonardBang merged pull request #21551: [FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

2022-12-28 Thread GitBox
leonardBang merged PR #21551: URL: https://github.com/apache/flink/pull/21551 -- 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:

[GitHub] [flink] leonardBang commented on pull request #21551: [FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

2022-12-28 Thread GitBox
leonardBang commented on PR #21551: URL: https://github.com/apache/flink/pull/21551#issuecomment-1366514847 @lincoln-lil Could you also open a PR for release-1.16 branch? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-30512) Flink SQL state TTL has no effect when using Interval Join

2022-12-28 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30512: - Component/s: Table SQL / Runtime > Flink SQL state TTL has no effect when using Interval Join >

[GitHub] [flink] yunfengzhou-hub commented on pull request #21558: [FLINK-29217][Runtime/Checkpointing] Handle concurrent checkpoints before buffered events

2022-12-28 Thread GitBox
yunfengzhou-hub commented on PR #21558: URL: https://github.com/apache/flink/pull/21558#issuecomment-1366484650 @flinkbot run azure -- 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

[GitHub] [flink] huwh commented on pull request #21565: [FLINK-18229][ResourceManager] Support cancel pending workers if no longer needed.

2022-12-28 Thread GitBox
huwh commented on PR #21565: URL: https://github.com/apache/flink/pull/21565#issuecomment-1366510447 @xintongsong Could you please help review this PR in your free time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #193: [FLINK-30515] Add benchmark for CountVectorizer, Imputer, RobustScale…

2022-12-28 Thread GitBox
yunfengzhou-hub commented on code in PR #193: URL: https://github.com/apache/flink-ml/pull/193#discussion_r1058227606 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/param/HasNumDistinctValues.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #21567: [FLINK-30520] fix check comments in load yaml resource

2022-12-28 Thread GitBox
flinkbot commented on PR #21567: URL: https://github.com/apache/flink/pull/21567#issuecomment-1366523276 ## CI report: * 7d9e4cb0ad6ca23538cd3ea947c9f5184fea5ada UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] fsk119 closed pull request #21504: [FLINK-22316][table] Support MODIFY column/constraint/watermark for ALTER TABLE statement

2022-12-28 Thread GitBox
fsk119 closed pull request #21504: [FLINK-22316][table] Support MODIFY column/constraint/watermark for ALTER TABLE statement URL: https://github.com/apache/flink/pull/21504 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink-table-store] zjureel commented on pull request #441: [FLINK-30423] Introduce generated codes for CastExecutor

2022-12-28 Thread GitBox
zjureel commented on PR #441: URL: https://github.com/apache/flink-table-store/pull/441#issuecomment-1366461811 > Hi @zjureel , thanks for the update. > > * I still think we can introduce a `CastExecutors` class, each cast is a separate internal class or anonymous internal class

[jira] [Created] (FLINK-30519) Add e2e tests for operator dynamic config

2022-12-28 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30519: -- Summary: Add e2e tests for operator dynamic config Key: FLINK-30519 URL: https://issues.apache.org/jira/browse/FLINK-30519 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-30520: Description: When i submit a flink jar job in Kubernetes Application mode which main args

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-30520: Attachment: image-2022-12-28-17-13-25-351.png > Arguments contains with '#' will error split in

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread tanjialiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tanjialiang updated FLINK-30520: Attachment: image-2022-12-28-17-13-38-337.png > Arguments contains with '#' will error split in

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652447#comment-17652447 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 9:39 AM:

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652447#comment-17652447 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~gyfora] I checked. Both are not related. I think

  1   2   >