[jira] [Updated] (FLINK-29790) Implement Catalog#getDatabase

2022-10-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29790: --- Labels: pull-request-available (was: ) > Implement Catalog#getDatabase > --

[GitHub] [flink-table-store] LadyForest opened a new pull request, #339: [FLINK-29790] Implement Catalog#getDatabase

2022-10-27 Thread GitBox
LadyForest opened a new pull request, #339: URL: https://github.com/apache/flink-table-store/pull/339 A minor change to implement `getDatabase`. -- 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 th

[GitHub] [flink] xintongsong commented on pull request #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-27 Thread GitBox
xintongsong commented on PR #21122: URL: https://github.com/apache/flink/pull/21122#issuecomment-1294531619 @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 commen

[jira] [Updated] (FLINK-29790) Implement Catalog#getDatabase

2022-10-27 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29790: -- Description: This is a basic API and should be supported. (was: This is a basic API and should be sup

[jira] [Updated] (FLINK-29790) Implement Catalog#getDatabase

2022-10-27 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-29790: -- Summary: Implement Catalog#getDatabase (was: Table Store Catalog implement getDatabase) > Implement

[jira] [Created] (FLINK-29790) Table Store Catalog implement getDatabase

2022-10-27 Thread Jane Chan (Jira)
Jane Chan created FLINK-29790: - Summary: Table Store Catalog implement getDatabase Key: FLINK-29790 URL: https://issues.apache.org/jira/browse/FLINK-29790 Project: Flink Issue Type: Improvement

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quantiles

2022-10-27 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r1007692506 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java: ## @@ -0,0 +1,400 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quantiles

2022-10-27 Thread GitBox
zhipeng93 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r1007688263 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java: ## @@ -0,0 +1,400 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[GitHub] [flink] HuangXingBo closed pull request #20859: [release] release notes for the 1.16 release

2022-10-27 Thread GitBox
HuangXingBo closed pull request #20859: [release] release notes for the 1.16 release URL: https://github.com/apache/flink/pull/20859 -- 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 comm

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quantiles

2022-10-27 Thread GitBox
jiangxin369 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r1007679762 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java: ## @@ -0,0 +1,400 @@ +/* + * Licensed to the Apache Software Foundation (ASF) und

[jira] [Commented] (FLINK-27940) [JUnit5 Migration] Module: flink-connector-jdbc

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625452#comment-17625452 ] Lijie Wang commented on FLINK-27940: [~rskraba] good idea, I will do so :) > [JUnit

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1294506824 @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

[GitHub] [flink] xintongsong commented on pull request #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-27 Thread GitBox
xintongsong commented on PR #21122: URL: https://github.com/apache/flink/pull/21122#issuecomment-1294505532 @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 commen

[jira] [Commented] (FLINK-29787) fix ci METHOD_NEW_DEFAULT issue

2022-10-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625446#comment-17625446 ] Aitozi commented on FLINK-29787: I also encountered this issue. Does it related to this

[GitHub] [flink] Aitozi commented on pull request #21174: [FLINK-29557] Fix the SinkOperator with OutputFormatFunction is ignor…

2022-10-27 Thread GitBox
Aitozi commented on PR #21174: URL: https://github.com/apache/flink/pull/21174#issuecomment-1294497007 Maybe it's caused by this: https://issues.apache.org/jira/browse/FLINK-29787 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] Aitozi commented on pull request #21174: [FLINK-29557] Fix the SinkOperator with OutputFormatFunction is ignor…

2022-10-27 Thread GitBox
Aitozi commented on PR #21174: URL: https://github.com/apache/flink/pull/21174#issuecomment-1294495106 Hi @gaoyunhaii , can you help me understand the CI failure? > [ERROR] Failed to execute goal io.github.zentol.japicmp:japicmp-maven-plugin:0.16.0_m325:cmp (default) on project flin

[jira] [Updated] (FLINK-26390) InputStream is not closed at CliClient#executeFile

2022-10-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26390: -- Fix Version/s: 1.17.0 > InputStream is not closed at CliClient#executeFile > -

[jira] [Commented] (FLINK-29748) Expose the optimize phase in the connector context

2022-10-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625440#comment-17625440 ] Aitozi commented on FLINK-29748: As I know, the \{{getScanRuntimeProvider}} will be invo

[jira] [Resolved] (FLINK-26390) InputStream is not closed at CliClient#executeFile

2022-10-27 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-26390. --- Resolution: Fixed master: 74c0ace01b61f18cda5c13abf0b940fe81f13e8a > InputStream is not clo

[GitHub] [flink] XComp merged pull request #18927: [FLINK-26390] Use try resourses for CliClient#executeFile

2022-10-27 Thread GitBox
XComp merged PR #18927: URL: https://github.com/apache/flink/pull/18927 -- 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: issues-unsubscr...@flink.apache.

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #167: [FLINK-29786] VarianceThresholdSelector Uses FeaturesCol Incorrectly

2022-10-27 Thread GitBox
lindong28 commented on code in PR #167: URL: https://github.com/apache/flink-ml/pull/167#discussion_r1007646156 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/param/HasFeaturesCol.java: ## @@ -24,6 +24,14 @@ import org.apache.flink.ml.param.WithParams; /** Interfac

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #166: [FLINK-29598] Add Estimator and Transformer for Imputer

2022-10-27 Thread GitBox
yunfengzhou-hub commented on code in PR #166: URL: https://github.com/apache/flink-ml/pull/166#discussion_r1007561913 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/imputer/ImputerParams.java: ## @@ -0,0 +1,59 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[jira] [Comment Edited] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625437#comment-17625437 ] Lijie Wang edited comment on FLINK-29541 at 10/28/22 5:37 AM:

[jira] [Assigned] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-29541: -- Assignee: Ryan Skraba > [JUnit5 Migration] Module: flink-table-planner >

[jira] [Commented] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

2022-10-27 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625437#comment-17625437 ] Lijie Wang commented on FLINK-29541: Sure, just assigned to you :). It would be bett

[jira] [Assigned] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao reassigned FLINK-29565: --- Assignee: wangshiwei > In Flink per job mode, the logs printed by taskManager on the web UI will no

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625435#comment-17625435 ] Yun Gao commented on FLINK-29565: - Thanks [~1336399775] for helping fix the issue! I hav

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quantiles

2022-10-27 Thread GitBox
lindong28 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r1007633262 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java: ## @@ -0,0 +1,400 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Comment Edited] (FLINK-29711) Topic notification not present in metadata after 60000 ms.

2022-10-27 Thread Durgesh Mishra (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624881#comment-17624881 ] Durgesh Mishra edited comment on FLINK-29711 at 10/28/22 5:25 AM:

[GitHub] [flink] liuml07 commented on pull request #20917: [hotfix][doc] Refine code examples in data_stream_api

2022-10-27 Thread GitBox
liuml07 commented on PR #20917: URL: https://github.com/apache/flink/pull/20917#issuecomment-1294473427 Thank you @Myasuka for prompt review and commit. -- 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

[GitHub] [flink] liuml07 commented on a diff in pull request #20935: [hotfix][doc] Make referencing custom image clearer for Docker

2022-10-27 Thread GitBox
liuml07 commented on code in PR #20935: URL: https://github.com/apache/flink/pull/20935#discussion_r1007632470 ## docs/content.zh/docs/deployment/resource-providers/standalone/docker.md: ## @@ -406,15 +406,15 @@ services: You can then start creating tables and queries those.

[GitHub] [flink] liuml07 commented on a diff in pull request #20935: [hotfix][doc] Make referencing custom image clearer for Docker

2022-10-27 Thread GitBox
liuml07 commented on code in PR #20935: URL: https://github.com/apache/flink/pull/20935#discussion_r1007632470 ## docs/content.zh/docs/deployment/resource-providers/standalone/docker.md: ## @@ -406,15 +406,15 @@ services: You can then start creating tables and queries those.

[GitHub] [flink] flinkbot commented on pull request #21183: [FLINK-29789][tests] Fix flaky test in CheckpointCoordinatorTest

2022-10-27 Thread GitBox
flinkbot commented on PR #21183: URL: https://github.com/apache/flink/pull/21183#issuecomment-1294459420 ## CI report: * 6cb844d32692779b408f5f216899183ff2f849b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] sopan98 opened a new pull request, #21183: [FLINK-29789][tests] Fix flaky test in CheckpointCoordinatorTest

2022-10-27 Thread GitBox
sopan98 opened a new pull request, #21183: URL: https://github.com/apache/flink/pull/21183 This PR aims to solve the issue presented here: https://issues.apache.org/jira/browse/FLINK-29789 ## What is the purpose of the change The fix is to change the HashMap of PendingCheckpoint in

[jira] [Updated] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

2022-10-27 Thread Sopan Phaltankar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sopan Phaltankar updated FLINK-29789: - Description: The test org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest.tes

[GitHub] [flink-web] godfreyhe closed pull request #574: Announcement blogpost for the 1.16 release

2022-10-27 Thread GitBox
godfreyhe closed pull request #574: Announcement blogpost for the 1.16 release URL: https://github.com/apache/flink-web/pull/574 -- 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.

[GitHub] [flink-web] godfreyhe commented on pull request #574: Announcement blogpost for the 1.16 release

2022-10-27 Thread GitBox
godfreyhe commented on PR #574: URL: https://github.com/apache/flink-web/pull/574#issuecomment-1294451826 merge & close -- 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 u

[jira] [Updated] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

2022-10-27 Thread Sopan Phaltankar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sopan Phaltankar updated FLINK-29789: - Description: The test org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest.tes

[jira] [Created] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

2022-10-27 Thread Sopan Phaltankar (Jira)
Sopan Phaltankar created FLINK-29789: Summary: Fix flaky tests in CheckpointCoordinatorTest Key: FLINK-29789 URL: https://issues.apache.org/jira/browse/FLINK-29789 Project: Flink Issue Ty

[jira] [Comment Edited] (FLINK-29611) Fix flaky tests in CoBroadcastWithNonKeyedOperatorTest

2022-10-27 Thread Sopan Phaltankar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619810#comment-17619810 ] Sopan Phaltankar edited comment on FLINK-29611 at 10/28/22 4:35 AM: --

[jira] [Comment Edited] (FLINK-29611) Fix flaky tests in CoBroadcastWithNonKeyedOperatorTest

2022-10-27 Thread Sopan Phaltankar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619810#comment-17619810 ] Sopan Phaltankar edited comment on FLINK-29611 at 10/28/22 4:34 AM: --

[GitHub] [flink] reswqa commented on a diff in pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-10-27 Thread GitBox
reswqa commented on code in PR #21137: URL: https://github.com/apache/flink/pull/21137#discussion_r100709 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java: ## @@ -683,21 +665,66 @@ public void testJobAlreadyDone() th

[jira] [Commented] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints

2022-10-27 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625417#comment-17625417 ] Hangxiang Yu commented on FLINK-29788: -- Sure. It's known limitation that changelog

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-27 Thread wangshiwei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625409#comment-17625409 ] wangshiwei commented on FLINK-29565: yes  > In Flink per job mode, the logs printed

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1294406889 @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

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #162: [FLINK-29593] Add QuantileSummary to help calculate approximate quant…

2022-10-27 Thread GitBox
zhipeng93 commented on code in PR #162: URL: https://github.com/apache/flink-ml/pull/162#discussion_r1007572419 ## flink-ml-lib/src/main/java/org/apache/flink/ml/common/util/QuantileSummary.java: ## @@ -0,0 +1,400 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

[jira] [Updated] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints

2022-10-27 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29788: - Priority: Critical (was: Major) > StatefulJobWBroadcastStateMigrationITCase failed in native sa

[jira] [Commented] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints

2022-10-27 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625404#comment-17625404 ] Huang Xingbo commented on FLINK-29788: -- [~masteryhx] Could you help take a look? Th

[GitHub] [flink] liyubin117 commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
liyubin117 commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1294397909 @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] [Created] (FLINK-29788) StatefulJobWBroadcastStateMigrationITCase failed in native savepoints

2022-10-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-29788: Summary: StatefulJobWBroadcastStateMigrationITCase failed in native savepoints Key: FLINK-29788 URL: https://issues.apache.org/jira/browse/FLINK-29788 Project: Flink

[GitHub] [flink] xintongsong commented on pull request #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-27 Thread GitBox
xintongsong commented on PR #21122: URL: https://github.com/apache/flink/pull/21122#issuecomment-1294395156 @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 commen

[jira] [Commented] (FLINK-28863) Snapshot result of RocksDB native savepoint should have empty shared-state

2022-10-27 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625402#comment-17625402 ] Jinzhong Li commented on FLINK-28863: - In my opinion, for Rocksdb native savepoint S

[jira] [Created] (FLINK-29787) fix ci METHOD_NEW_DEFAULT issue

2022-10-27 Thread Yubin Li (Jira)
Yubin Li created FLINK-29787: Summary: fix ci METHOD_NEW_DEFAULT issue Key: FLINK-29787 URL: https://issues.apache.org/jira/browse/FLINK-29787 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] Myasuka merged pull request #20917: [hotfix][doc] Refine code examples in data_stream_api

2022-10-27 Thread GitBox
Myasuka merged PR #20917: URL: https://github.com/apache/flink/pull/20917 -- 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: issues-unsubscr...@flink.apach

[jira] [Commented] (FLINK-28973) Extending /jars/:jarid/plan API to support setting Flink configs

2022-10-27 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625399#comment-17625399 ] Zhanghao Chen commented on FLINK-28973: --- Hi [~gaoyunhaii]. The concern is totally

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-27 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625396#comment-17625396 ] Yun Gao commented on FLINK-29565: - Hi [~1336399775] then would you like to open a PR to

[GitHub] [flink] HuangXingBo commented on pull request #20859: [release] release notes for the 1.16 release

2022-10-27 Thread GitBox
HuangXingBo commented on PR #20859: URL: https://github.com/apache/flink/pull/20859#issuecomment-1294382816 @zentol Ok. I have addressed the comment at the latest commit. :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
flinkbot commented on PR #21182: URL: https://github.com/apache/flink/pull/21182#issuecomment-1294381431 ## CI report: * 0a7afa1d3cb5370c44b1bea729afa6577ae7d3c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29565) In Flink per job mode, the logs printed by taskManager on the web UI will not be highlighted, because the log contents are annotated due to special symbols, which will

2022-10-27 Thread wangshiwei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625395#comment-17625395 ] wangshiwei commented on FLINK-29565: yes, I have > In Flink per job mode, the logs

[GitHub] [flink] reswqa commented on a diff in pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-10-27 Thread GitBox
reswqa commented on code in PR #21137: URL: https://github.com/apache/flink/pull/21137#discussion_r1007555607 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java: ## @@ -683,21 +665,66 @@ public void testJobAlreadyDone() th

[GitHub] [flink] reswqa commented on a diff in pull request #21137: [FLINK-29234][runtime] JobMasterServiceLeadershipRunner handle leader event in a separate executor to avoid dead lock

2022-10-27 Thread GitBox
reswqa commented on code in PR #21137: URL: https://github.com/apache/flink/pull/21137#discussion_r1007555607 ## flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java: ## @@ -683,21 +665,66 @@ public void testJobAlreadyDone() th

[GitHub] [flink] liyubin117 closed pull request #21116: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
liyubin117 closed pull request #21116: [FLINK-29679][table] DESCRIBE statement shows column comment URL: https://github.com/apache/flink/pull/21116 -- 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 th

[GitHub] [flink] liyubin117 opened a new pull request, #21182: [FLINK-29679][table] DESCRIBE statement shows column comment

2022-10-27 Thread GitBox
liyubin117 opened a new pull request, #21182: URL: https://github.com/apache/flink/pull/21182 ## What is the purpose of the change DESCRIBE statement print column comment to make results user-friendly, such as help analysts write sql adaptive to corresponding business logics. #

[jira] [Commented] (FLINK-29765) SQL query not executing properly

2022-10-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625391#comment-17625391 ] Shengkai Fang commented on FLINK-29765: --- It's better you can share more infos, e.g

[jira] [Commented] (FLINK-29748) Expose the optimize phase in the connector context

2022-10-27 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625388#comment-17625388 ] Shengkai Fang commented on FLINK-29748: --- I think you can validate when StreamExec

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #160: [FLINK-29434] Add AlgoOperator for Splitter

2022-10-27 Thread GitBox
yunfengzhou-hub commented on code in PR #160: URL: https://github.com/apache/flink-ml/pull/160#discussion_r1007543761 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/randomsplitter/RandomSplitterParams.java: ## @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software F

[jira] [Updated] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol Incorrectly

2022-10-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29786: --- Labels: pull-request-available (was: ) > VarianceThresholdSelector Uses FeaturesCol Incorre

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #167: [FLINK-29786] VarianceThresholdSelector Uses FeaturesCol Incorrectly

2022-10-27 Thread GitBox
jiangxin369 opened a new pull request, #167: URL: https://github.com/apache/flink-ml/pull/167 ## What is the purpose of the change Replace `FeaturesCol` with `InputCol` in VarianceThresholdSelector. ## Brief change log - Add Javadoc for `HasFeaturesCol` to disti

[GitHub] [flink] xintongsong commented on pull request #21122: [FLINK-28889] Hybrid shuffle supports multiple consumer and broadcast optimization

2022-10-27 Thread GitBox
xintongsong commented on PR #21122: URL: https://github.com/apache/flink/pull/21122#issuecomment-1294359915 @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 commen

[GitHub] [flink] wangyang0918 merged pull request #21179: [BP-1.16][FLINK-29539][Deployment/Kubernetes] dnsPolicy in FlinkPod is not overridable

2022-10-27 Thread GitBox
wangyang0918 merged PR #21179: URL: https://github.com/apache/flink/pull/21179 -- 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: issues-unsubscr...@flink.

[GitHub] [flink] wangyang0918 merged pull request #20982: [FLINK-29539] [Deployment/Kubernetes] dnsPolicy in FlinkPod is not overridable

2022-10-27 Thread GitBox
wangyang0918 merged PR #20982: URL: https://github.com/apache/flink/pull/20982 -- 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: issues-unsubscr...@flink.

[jira] [Comment Edited] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625383#comment-17625383 ] Xintong Song edited comment on FLINK-29572 at 10/28/22 2:15 AM: --

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-27 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625383#comment-17625383 ] Xintong Song commented on FLINK-29572: -- You don't have to configure different ports

[GitHub] [flink] wangyang0918 commented on pull request #21178: [BP-1.15][FLINK-29539][Deployment/Kubernetes] dnsPolicy in FlinkPod is not overridable

2022-10-27 Thread GitBox
wangyang0918 commented on PR #21178: URL: https://github.com/apache/flink/pull/21178#issuecomment-1294356340 Fix the compile error and force pushed. -- 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 t

[jira] [Updated] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol Incorrectly

2022-10-27 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-29786: -- Description: Flink ML has both `FeaturesCol` and `InputCol` to be used to set input. The `FeaturesCol

[jira] [Updated] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol Incorrectly

2022-10-27 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-29786: -- Summary: VarianceThresholdSelector Uses FeaturesCol Incorrectly (was: VarianceThresholdSelector Uses

[jira] [Commented] (FLINK-29749) flink info command support dynamic properties

2022-10-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625374#comment-17625374 ] Yang Wang commented on FLINK-29749: --- Thanks [~jackylau] for your contribution. > flin

[jira] [Closed] (FLINK-29749) flink info command support dynamic properties

2022-10-27 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-29749. - Resolution: Fixed Fixed via: master: f8c6a668cd2b887f33a0cf4608de2d6b95c71f03 release-1.16: 38e90428bf

[GitHub] [flink] wangyang0918 merged pull request #21166: [FLINK-29749][client] Make 'flink info' command could support dynamic…

2022-10-27 Thread GitBox
wangyang0918 merged PR #21166: URL: https://github.com/apache/flink/pull/21166 -- 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: issues-unsubscr...@flink.

[jira] [Created] (FLINK-29786) VarianceThresholdSelector Uses FeaturesCol as Input Param

2022-10-27 Thread Jiang Xin (Jira)
Jiang Xin created FLINK-29786: - Summary: VarianceThresholdSelector Uses FeaturesCol as Input Param Key: FLINK-29786 URL: https://issues.apache.org/jira/browse/FLINK-29786 Project: Flink Issue Typ

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #156: [FLINK-29323] Refine Transformer for VectorAssembler

2022-10-27 Thread GitBox
yunfengzhou-hub commented on code in PR #156: URL: https://github.com/apache/flink-ml/pull/156#discussion_r1007512230 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/vectorassembler/VectorAssembler.java: ## @@ -47,10 +47,16 @@ /** * A Transformer which combines a

[jira] [Created] (FLINK-29785) Upgrade Flink Elasticsearch-7 connector elasticsearch.version to 7.17.0

2022-10-27 Thread Elkhan Dadashov (Jira)
Elkhan Dadashov created FLINK-29785: --- Summary: Upgrade Flink Elasticsearch-7 connector elasticsearch.version to 7.17.0 Key: FLINK-29785 URL: https://issues.apache.org/jira/browse/FLINK-29785 Project

[GitHub] [flink] ericxiao251 commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-10-27 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1294158906 @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 commen

[jira] [Comment Edited] (FLINK-29783) Flaky test: KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime

2022-10-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625337#comment-17625337 ] Martijn Visser edited comment on FLINK-29783 at 10/27/22 9:14 PM:

[jira] [Closed] (FLINK-29783) Flaky test: KafkaShuffleExactlyOnceITCase.testAssignedToPartitionFailureRecoveryEventTime

2022-10-27 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29783. -- Resolution: Duplicate Duplicate of FLINk-24119 > Flaky test: > KafkaShuffleExactlyOnceITCase

[jira] [Closed] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution

2022-10-27 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexis Sarda-Espinosa closed FLINK-29716. - Resolution: Won't Do > Separate slf4j jar in the lib folder from the distributio

[jira] [Commented] (FLINK-29716) Separate slf4j jar in the lib folder from the distribution

2022-10-27 Thread Alexis Sarda-Espinosa (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625336#comment-17625336 ] Alexis Sarda-Espinosa commented on FLINK-29716: --- I see, all right. > Sepa

[GitHub] [flink] ericxiao251 commented on pull request #21077: [FLINK-29498] Add Scala Async Retry Strategies and ResultPredicates Helper Classes

2022-10-27 Thread GitBox
ericxiao251 commented on PR #21077: URL: https://github.com/apache/flink/pull/21077#issuecomment-1294048147 @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 commen

[jira] [Commented] (FLINK-29572) Flink Task Manager skip loopback interface for resource manager registration

2022-10-27 Thread Kevin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625277#comment-17625277 ] Kevin Li commented on FLINK-29572: -- It will work if we configure different ports for ea

[GitHub] [flink] gaborgsomogyi commented on pull request #21180: [FLINK-29783][tests] Add some random to KafkaShuffleExactlyOnceITCase topic names

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21180: URL: https://github.com/apache/flink/pull/21180#issuecomment-1293940368 @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 comm

[jira] [Created] (FLINK-29784) Build fails with There is at least one incompatibility: org.apache.flink.api.connector.source.SourceReader

2022-10-27 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-29784: --- Summary: Build fails with There is at least one incompatibility: org.apache.flink.api.connector.source.SourceReader Key: FLINK-29784 URL: https://issues.apache.org/jira/brow

[GitHub] [flink] gaborgsomogyi commented on pull request #21160: [FLINK-29761][runtime][security] Simplify HadoopModule

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21160: URL: https://github.com/apache/flink/pull/21160#issuecomment-1293904151 @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 comm

[GitHub] [flink] gaborgsomogyi commented on pull request #21180: [FLINK-29783][tests] Add some random to KafkaShuffleExactlyOnceITCase topic names

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21180: URL: https://github.com/apache/flink/pull/21180#issuecomment-1293903766 @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 comm

[GitHub] [flink] gaborgsomogyi commented on pull request #21147: [FLINK-28330][runtime][security] Remove old delegation token framework code

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21147: URL: https://github.com/apache/flink/pull/21147#issuecomment-1293897838 @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 comm

[GitHub] [flink] flinkbot commented on pull request #21181: [hotfix][doc] `FlinkKafkaConsumer` will be removed with Flink 1.17 instead of 1.15

2022-10-27 Thread GitBox
flinkbot commented on PR #21181: URL: https://github.com/apache/flink/pull/21181#issuecomment-1293882353 ## CI report: * 85079793ed48230d97a1921862c7d28304f34fc7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] JingGe opened a new pull request, #21181: [hotfix][doc] `FlinkKafkaConsumer` will be removed with Flink 1.17 instead of 1.15

2022-10-27 Thread GitBox
JingGe opened a new pull request, #21181: URL: https://github.com/apache/flink/pull/21181 ## What is the purpose of the change Back port #21172 to master: Change the docs: FlinkKafkaConsumer is deprecated and will be removed with Flink 1.17 instead of 1.15 since Flink 1.16 has code

[GitHub] [flink] sap1ens commented on a diff in pull request #20475: [FLINK-28842][Connector/Kafka] Add client.id.prefix for the KafkaSink

2022-10-27 Thread GitBox
sap1ens commented on code in PR #20475: URL: https://github.com/apache/flink/pull/20475#discussion_r1007187247 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java: ## @@ -398,6 +407,11 @@ private void registerMetricSync(

[GitHub] [flink] SaravananArumugam-Opus commented on a diff in pull request #20922: [DRAFT] Apply changes for calcite 1.3x

2022-10-27 Thread GitBox
SaravananArumugam-Opus commented on code in PR #20922: URL: https://github.com/apache/flink/pull/20922#discussion_r1007141005 ## flink-table/pom.xml: ## @@ -76,10 +76,10 @@ under the License. - 1.26.0 + 1.32.0

[GitHub] [flink] flinkbot commented on pull request #21180: [FLINK-29783][Tests] Add some random to KafkaShuffleExactlyOnceITCasetopic names

2022-10-27 Thread GitBox
flinkbot commented on PR #21180: URL: https://github.com/apache/flink/pull/21180#issuecomment-1293803451 ## CI report: * ccc5e22c6617909e90705c11e4e28dfc12d9310b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gaborgsomogyi commented on pull request #21180: [FLINK-29783][Tests] Add some random to KafkaShuffleExactlyOnceITCasetopic names

2022-10-27 Thread GitBox
gaborgsomogyi commented on PR #21180: URL: https://github.com/apache/flink/pull/21180#issuecomment-1293804227 Let's see whether it helps. -- 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 speci

  1   2   3   >