[GitHub] [flink] liuyongvs commented on a diff in pull request #20746: [FLINK-28893][table] Add built-in conv function.

2022-11-15 Thread GitBox
liuyongvs commented on code in PR #20746: URL: https://github.com/apache/flink/pull/20746#discussion_r1023437269 ## docs/data/sql_functions.yml: ## @@ -228,6 +228,13 @@ arithmetic: - sql: UUID() table: uuid() description: Returns an UUID (Universally Unique Identifi

[GitHub] [flink] Aitozi commented on pull request #21316: [FLINK-30019] Remove the unused HiveTableFileInputFormat in hive conn…

2022-11-15 Thread GitBox
Aitozi commented on PR #21316: URL: https://github.com/apache/flink/pull/21316#issuecomment-1316205722 > Thanks for contribution. LGTM. Btw, could you please update the pr title to `[FLINK-30019][hive] Remove the unused HiveTableFileInputFormat in hive connector` Sure, done! -- Th

[GitHub] [flink] HuangXingBo closed pull request #21280: [FLINK-29966][python][doc] Replace and redesign the Python api documentation base

2022-11-15 Thread GitBox
HuangXingBo closed pull request #21280: [FLINK-29966][python][doc] Replace and redesign the Python api documentation base URL: https://github.com/apache/flink/pull/21280 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #382: [FLINK-30027] Fields min and max in BinaryTableStats support lazy deserialization

2022-11-15 Thread GitBox
JingsongLi commented on code in PR #382: URL: https://github.com/apache/flink-table-store/pull/382#discussion_r1023442925 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/BinaryTableStats.java: ## @@ -73,27 +74,40 @@ public FieldStats[] fields(Fiel

[jira] [Created] (FLINK-30033) Add primary key data type validation

2022-11-15 Thread Shammon (Jira)
Shammon created FLINK-30033: --- Summary: Add primary key data type validation Key: FLINK-30033 URL: https://issues.apache.org/jira/browse/FLINK-30033 Project: Flink Issue Type: Improvement

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #53: Bump jackson-databind from 2.12.2 to 2.12.7.1 in /java/shopping-cart

2022-11-15 Thread GitBox
dependabot[bot] opened a new pull request, #53: URL: https://github.com/apache/flink-statefun-playground/pull/53 Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2 to 2.12.7.1. Commits See full diff in https://github.com/FasterXML/jackson/commits";>compa

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #51: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/shopping-cart

2022-11-15 Thread GitBox
dependabot[bot] commented on PR #51: URL: https://github.com/apache/flink-statefun-playground/pull/51#issuecomment-1316221369 Superseded by #53. -- 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 t

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #51: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/shopping-cart

2022-11-15 Thread GitBox
dependabot[bot] closed pull request #51: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/shopping-cart URL: https://github.com/apache/flink-statefun-playground/pull/51 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #54: Bump jackson-databind from 2.12.2 to 2.12.7.1 in /java/greeter

2022-11-15 Thread GitBox
dependabot[bot] opened a new pull request, #54: URL: https://github.com/apache/flink-statefun-playground/pull/54 Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2 to 2.12.7.1. Commits See full diff in https://github.com/FasterXML/jackson/commits";>compa

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #50: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/greeter

2022-11-15 Thread GitBox
dependabot[bot] commented on PR #50: URL: https://github.com/apache/flink-statefun-playground/pull/50#issuecomment-1316221516 Superseded by #54. -- 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 t

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #50: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/greeter

2022-11-15 Thread GitBox
dependabot[bot] closed pull request #50: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/greeter URL: https://github.com/apache/flink-statefun-playground/pull/50 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-28867) Parquet reader support nested type in array/map type

2022-11-15 Thread Michael (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634609#comment-17634609 ] Michael commented on FLINK-28867: - I’m using Flink 1.16.0, and I would like to read Parq

[jira] [Comment Edited] (FLINK-28867) Parquet reader support nested type in array/map type

2022-11-15 Thread Michael (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634609#comment-17634609 ] Michael edited comment on FLINK-28867 at 11/16/22 2:49 AM: --- I’

[jira] [Updated] (FLINK-28867) Parquet reader support nested type in array/map type

2022-11-15 Thread Michael (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael updated FLINK-28867: Attachment: part-00121.parquet ReadParquetArray1.java > Parquet reader support nested type

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #55: Bump jackson-databind from 2.12.2 to 2.12.7.1 in /java/connected-components

2022-11-15 Thread GitBox
dependabot[bot] opened a new pull request, #55: URL: https://github.com/apache/flink-statefun-playground/pull/55 Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2 to 2.12.7.1. Commits See full diff in https://github.com/FasterXML/jackson/commits";>compa

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #52: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/connected-components

2022-11-15 Thread GitBox
dependabot[bot] commented on PR #52: URL: https://github.com/apache/flink-statefun-playground/pull/52#issuecomment-1316224590 Superseded by #55. -- 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 t

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #52: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/connected-components

2022-11-15 Thread GitBox
dependabot[bot] closed pull request #52: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/connected-components URL: https://github.com/apache/flink-statefun-playground/pull/52 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-statefun-playground] dependabot[bot] opened a new pull request, #56: Bump jackson-databind from 2.12.2 to 2.12.7.1 in /java/showcase

2022-11-15 Thread GitBox
dependabot[bot] opened a new pull request, #56: URL: https://github.com/apache/flink-statefun-playground/pull/56 Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.2 to 2.12.7.1. Commits See full diff in https://github.com/FasterXML/jackson/commits";>compa

[GitHub] [flink-statefun-playground] dependabot[bot] commented on pull request #49: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/showcase

2022-11-15 Thread GitBox
dependabot[bot] commented on PR #49: URL: https://github.com/apache/flink-statefun-playground/pull/49#issuecomment-1316224770 Superseded by #56. -- 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 t

[GitHub] [flink-statefun-playground] dependabot[bot] closed pull request #49: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/showcase

2022-11-15 Thread GitBox
dependabot[bot] closed pull request #49: Bump jackson-databind from 2.12.2 to 2.13.4.1 in /java/showcase URL: https://github.com/apache/flink-statefun-playground/pull/49 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-28867) Parquet reader support nested type in array/map type

2022-11-15 Thread Michael (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634609#comment-17634609 ] Michael edited comment on FLINK-28867 at 11/16/22 2:52 AM: --- I’

[jira] [Created] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

2022-11-15 Thread luoyuxia (Jira)
luoyuxia created FLINK-30034: Summary: class not found exception when using Hive 3.1.3 connector Key: FLINK-30034 URL: https://issues.apache.org/jira/browse/FLINK-30034 Project: Flink Issue Type:

[GitHub] [flink-ml] dependabot[bot] commented on pull request #165: Bump jackson-databind from 2.12.6.1 to 2.13.4.1

2022-11-15 Thread GitBox
dependabot[bot] commented on PR #165: URL: https://github.com/apache/flink-ml/pull/165#issuecomment-1316234185 Superseded by #176. -- 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 com

[GitHub] [flink-ml] dependabot[bot] opened a new pull request, #176: Bump jackson-databind from 2.12.6.1 to 2.12.7.1

2022-11-15 Thread GitBox
dependabot[bot] opened a new pull request, #176: URL: https://github.com/apache/flink-ml/pull/176 Bumps [jackson-databind](https://github.com/FasterXML/jackson) from 2.12.6.1 to 2.12.7.1. Commits See full diff in https://github.com/FasterXML/jackson/commits";>compare view

[GitHub] [flink-ml] dependabot[bot] closed pull request #165: Bump jackson-databind from 2.12.6.1 to 2.13.4.1

2022-11-15 Thread GitBox
dependabot[bot] closed pull request #165: Bump jackson-databind from 2.12.6.1 to 2.13.4.1 URL: https://github.com/apache/flink-ml/pull/165 -- 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 specifi

[jira] [Updated] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

2022-11-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30034: - Description: When using  > class not found exception when using Hive 3.1.3 connector > -

[jira] [Updated] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

2022-11-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30034: - Description: When using Hive 3.1.3 connector, I still found the class not found exceptioin. We need to

[jira] [Commented] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

2022-11-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634623#comment-17634623 ] luoyuxia commented on FLINK-30034: -- [~samrat007]  Could you please help fix again? Apo

[GitHub] [flink-kubernetes-operator] yangjf2019 opened a new pull request, #442: [hotfix][doc][test] correct the incorrect flink release version

2022-11-15 Thread GitBox
yangjf2019 opened a new pull request, #442: URL: https://github.com/apache/flink-kubernetes-operator/pull/442 ## What is the purpose of the change * I have corrected some wrong flink version numbers in the project. The current flink release is 1.15.2. ## Brief chang

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[jira] [Created] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread Steven Zhen Wu (Jira)
Steven Zhen Wu created FLINK-30035: -- Summary: ./bin/sql-client.sh won't import external jar into the session Key: FLINK-30035 URL: https://issues.apache.org/jira/browse/FLINK-30035 Project: Flink

[jira] [Updated] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-30035: --- Description: I used to be able to run the sql-client with iceberg-flink-runtime jar using t

[GitHub] [flink] HuangXingBo opened a new pull request, #21328: [BP-1.15][FLINK-29966][python][doc] Replace and Redesign PyFlink API doc

2022-11-15 Thread GitBox
HuangXingBo opened a new pull request, #21328: URL: https://github.com/apache/flink/pull/21328 ## What is the purpose of the change *This pull request will replace and redesign the Python api documentation base* *I made a demo site to make it easier to review: https://pyflink-

[GitHub] [flink-table-store] zjureel opened a new pull request, #383: [FLINK-30033] Add primary key type validation

2022-11-15 Thread GitBox
zjureel opened a new pull request, #383: URL: https://github.com/apache/flink-table-store/pull/383 At present, the table store does not verify the primary key type. Users can create primary keys on any data type. Some primary key types such as array, map, etc. are meaningless. This

[jira] [Updated] (FLINK-30033) Add primary key data type validation

2022-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30033: --- Labels: pull-request-available (was: ) > Add primary key data type validation > ---

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #383: [FLINK-30033] Add primary key type validation

2022-11-15 Thread GitBox
JingsongLi commented on code in PR #383: URL: https://github.com/apache/flink-table-store/pull/383#discussion_r1023479832 ## docs/content/docs/development/create-table.md: ## @@ -296,6 +296,24 @@ Use approach one if you have a large number of filtered queries with only `user_i

[GitHub] [flink] flinkbot commented on pull request #21328: [BP-1.15][FLINK-29966][python][doc] Replace and Redesign PyFlink API doc

2022-11-15 Thread GitBox
flinkbot commented on PR #21328: URL: https://github.com/apache/flink/pull/21328#issuecomment-1316293316 ## CI report: * 5b25a193c54abac1c2d25f0920ff022adf7f8df5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-30035) ./bin/sql-client.sh won't import external jar into the session

2022-11-15 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634635#comment-17634635 ] luoyuxia commented on FLINK-30035: -- Thanks for reporting. The regression should be repr

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

2022-11-15 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634637#comment-17634637 ] Weihua Hu commented on FLINK-27341: --- [~gaoyunhaii] I tested it in Kubernetes/Docker/St

[jira] [Created] (FLINK-30036) Force delete pod when k8s node is not ready

2022-11-15 Thread Peng Yuan (Jira)
Peng Yuan created FLINK-30036: - Summary: Force delete pod when k8s node is not ready Key: FLINK-30036 URL: https://issues.apache.org/jira/browse/FLINK-30036 Project: Flink Issue Type: Improvemen

[jira] [Updated] (FLINK-30036) Force delete pod when k8s node is not ready

2022-11-15 Thread Peng Yuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peng Yuan updated FLINK-30036: -- Description: When the K8s node is in the NotReady state, the taskmanager pod scheduled on it is alway

[GitHub] [flink] Grypse opened a new pull request, #21329: [FLINK-30036] force delete pod when the k8s node is under NotReady st…

2022-11-15 Thread GitBox
Grypse opened a new pull request, #21329: URL: https://github.com/apache/flink/pull/21329 ## What is the purpose of the change This pull request check whether the node where the pod resides is in the NotReady state. If yes, delete the pod forcibly. ## Brief change log

[jira] [Updated] (FLINK-30036) Force delete pod when k8s node is not ready

2022-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30036: --- Labels: pull-request-available (was: ) > Force delete pod when k8s node is not ready > ---

[GitHub] [flink] flinkbot commented on pull request #21329: [FLINK-30036][kubernetes] force delete pod when the k8s node is under NotReady state

2022-11-15 Thread GitBox
flinkbot commented on PR #21329: URL: https://github.com/apache/flink/pull/21329#issuecomment-1316327872 ## CI report: * 2a2cb5e1333282e2dd1b5a3be9bfe58cbc2ca015 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] rgsriram commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

2022-11-15 Thread GitBox
rgsriram commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1023511476 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,21 @@ public voi

[GitHub] [flink-kubernetes-operator] rgsriram commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

2022-11-15 Thread GitBox
rgsriram commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1023511476 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,21 @@ public voi

[GitHub] [flink-table-store] zjureel commented on pull request #382: [FLINK-30027] Fields min and max in BinaryTableStats support lazy deserialization

2022-11-15 Thread GitBox
zjureel commented on PR #382: URL: https://github.com/apache/flink-table-store/pull/382#issuecomment-1316394064 @JingsongLi Done -- 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-table-store] zjureel commented on a diff in pull request #382: [FLINK-30027] Fields min and max in BinaryTableStats support lazy deserialization

2022-11-15 Thread GitBox
zjureel commented on code in PR #382: URL: https://github.com/apache/flink-table-store/pull/382#discussion_r1023526130 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/BinaryTableStats.java: ## @@ -73,27 +74,40 @@ public FieldStats[] fields(FieldSt

[GitHub] [flink-table-store] zjureel commented on a diff in pull request #383: [FLINK-30033] Add primary key type validation

2022-11-15 Thread GitBox
zjureel commented on code in PR #383: URL: https://github.com/apache/flink-table-store/pull/383#discussion_r1023527209 ## docs/content/docs/development/create-table.md: ## @@ -296,6 +296,24 @@ Use approach one if you have a large number of filtered queries with only `user_id`,

[GitHub] [flink-kubernetes-operator] rgsriram commented on a diff in pull request #438: [FLINK-29974] Not allowing the cancelling the which are already in the completed state.

2022-11-15 Thread GitBox
rgsriram commented on code in PR #438: URL: https://github.com/apache/flink-kubernetes-operator/pull/438#discussion_r1023511476 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -362,11 +362,21 @@ public voi

[jira] [Commented] (FLINK-27341) TaskManager running together with JobManager are bind to 127.0.0.1

2022-11-15 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634670#comment-17634670 ] Yun Gao commented on FLINK-27341: - Very thanks [~huwh] for the checking! I'll have a loo

[GitHub] [flink] HuangXingBo closed pull request #21328: [BP-1.15][FLINK-29966][python][doc] Replace and Redesign PyFlink API doc

2022-11-15 Thread GitBox
HuangXingBo closed pull request #21328: [BP-1.15][FLINK-29966][python][doc] Replace and Redesign PyFlink API doc URL: https://github.com/apache/flink/pull/21328 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Closed] (FLINK-29966) Replace and redesign the Python api documentation base

2022-11-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-29966. Fix Version/s: 1.16.1 1.15.4 Resolution: Fixed Merged into master via b8

[GitHub] [flink] link3280 commented on pull request #21292: [FLINK-28617][SQL Gateway] Support stop job statement in SqlGatewayService

2022-11-15 Thread GitBox
link3280 commented on PR #21292: URL: https://github.com/apache/flink/pull/21292#issuecomment-1316434664 @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-30037) Improve the efficiency of Flink ML Python CI

2022-11-15 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30037: Summary: Improve the efficiency of Flink ML Python CI Key: FLINK-30037 URL: https://issues.apache.org/jira/browse/FLINK-30037 Project: Flink Issue Type: Impr

[GitHub] [flink-table-store] zjureel opened a new pull request, #384: [FLINK-28671] Update Spark3 to create/drop table in Compatibility Matrix

2022-11-15 Thread GitBox
zjureel opened a new pull request, #384: URL: https://github.com/apache/flink-table-store/pull/384 Update Spark3 to create/drop table in Compatibility Matrix, features have been verified in spark 3.3.1/3.2.2/3.1.3/3.0.3 versions -- This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-28671) Update Spark3 to create/drop table in Compatibility Matrix

2022-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28671: --- Labels: pull-request-available (was: ) > Update Spark3 to create/drop table in Compatibilit

[jira] [Created] (FLINK-30038) HiveE2E test is not stable

2022-11-15 Thread Shammon (Jira)
Shammon created FLINK-30038: --- Summary: HiveE2E test is not stable Key: FLINK-30038 URL: https://issues.apache.org/jira/browse/FLINK-30038 Project: Flink Issue Type: Bug Components: Table

[jira] [Commented] (FLINK-30023) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed

2022-11-15 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634693#comment-17634693 ] Feifan Wang commented on FLINK-30023: - Hi [~Weijie Guo] , you can rerun the test, an

[GitHub] [flink] zoltar9264 opened a new pull request, #21330: [FLINK-30023][changelog] increase timeout in ChangelogStorageMetricsT…

2022-11-15 Thread GitBox
zoltar9264 opened a new pull request, #21330: URL: https://github.com/apache/flink/pull/21330 …est#testTotalAttemptsPerUpload for improving stability ## What is the purpose of the change As the title said, increase timeout in ChangelogStorageMetricsTest#testTotalAttemptsPerUplo

[jira] [Updated] (FLINK-30023) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed

2022-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30023: --- Labels: pull-request-available test-stability (was: test-stability) > ChangelogStorageMetri

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #174: [FLINK-29604] Add Estimator and Transformer for CountVectorizer

2022-11-15 Thread GitBox
jiangxin369 commented on code in PR #174: URL: https://github.com/apache/flink-ml/pull/174#discussion_r1023594899 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizer.java: ## @@ -0,0 +1,219 @@ +/* + * Licensed to the Apache Software Foundati

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #174: [FLINK-29604] Add Estimator and Transformer for CountVectorizer

2022-11-15 Thread GitBox
jiangxin369 commented on code in PR #174: URL: https://github.com/apache/flink-ml/pull/174#discussion_r1023596267 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizerModel.java: ## @@ -0,0 +1,185 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] flinkbot commented on pull request #21330: [FLINK-30023][changelog] increase timeout in ChangelogStorageMetricsT…

2022-11-15 Thread GitBox
flinkbot commented on PR #21330: URL: https://github.com/apache/flink/pull/21330#issuecomment-1316514747 ## CI report: * 2c4730efedaf062e7bcf62ea42358ae7158f0cfc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Grypse commented on pull request #21329: [FLINK-30036][kubernetes] force delete pod when the k8s node is under NotReady state

2022-11-15 Thread GitBox
Grypse commented on PR #21329: URL: https://github.com/apache/flink/pull/21329#issuecomment-1316516206 @wangyang0918 Please help me review this. -- 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

[jira] [Commented] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634702#comment-17634702 ] Xintong Song commented on FLINK-29639: -- There's no response from the assignee for ~

[jira] [Assigned] (FLINK-29639) Add ResourceId in TransportException for debugging

2022-11-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-29639: Assignee: Weijie Guo (was: Liu) > Add ResourceId in TransportException for debugging >

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #174: [FLINK-29604] Add Estimator and Transformer for CountVectorizer

2022-11-15 Thread GitBox
jiangxin369 commented on code in PR #174: URL: https://github.com/apache/flink-ml/pull/174#discussion_r1023601072 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/countvectorizer/CountVectorizerParams.java: ## @@ -0,0 +1,86 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [flink] leonardBang merged pull request #21309: [FLINK-29992][hive] fix lookup join fail with Hive table as lookup table source

2022-11-15 Thread GitBox
leonardBang merged PR #21309: URL: https://github.com/apache/flink/pull/21309 -- 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.a

[GitHub] [flink-kubernetes-operator] gaborgsomogyi commented on a diff in pull request #437: [FLINK-29609] Shut down JM for terminated applications after configured duration

2022-11-15 Thread GitBox
gaborgsomogyi commented on code in PR #437: URL: https://github.com/apache/flink-kubernetes-operator/pull/437#discussion_r1023637452 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java: ## @@ -318,6 +3

[jira] [Updated] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

2022-11-15 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-29315: --- Priority: Critical (was: Blocker) > HDFSTest#testBlobServerRecovery fails on CI > -

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

2022-11-15 Thread GitBox
gaoyunhaii commented on PR #21174: URL: https://github.com/apache/flink/pull/21174#issuecomment-1314950635 @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-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

2022-11-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634229#comment-17634229 ] Piotr Nowojski commented on FLINK-16419: Hi [~YordanPavlov], as explained in thi

[GitHub] [flink] pnowojski merged pull request #21321: [FLINK-29387][tests] fix unstable late test for interval join

2022-11-15 Thread GitBox
pnowojski merged PR #21321: URL: https://github.com/apache/flink/pull/21321 -- 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.apa

[jira] [Commented] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-11-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634232#comment-17634232 ] Piotr Nowojski commented on FLINK-29387: Thanks for fixing the issue [~stupid_pi

[jira] [Closed] (FLINK-29387) IntervalJoinITCase.testIntervalJoinSideOutputRightLateData failed with AssertionError

2022-11-15 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29387. -- Fix Version/s: 1.17.0 Resolution: Fixed merged commit 7e51db9 into apache:master > Int

[GitHub] [flink] snuyanzin commented on a diff in pull request #21203: [FLINK-21239][Table SQL/API] Upgrade Calcite to 1.28.0

2022-11-15 Thread GitBox
snuyanzin commented on code in PR #21203: URL: https://github.com/apache/flink/pull/21203#discussion_r1022488387 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/casting/AbstractCodeGeneratorCastRule.java: ## @@ -204,9 +204,10 @@ public S

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #439: [FLINK-29959] Use optimistic locking when updating the status

2022-11-15 Thread GitBox
gyfora commented on PR #439: URL: https://github.com/apache/flink-kubernetes-operator/pull/439#issuecomment-1314970498 > Makes sense, note that this just needed in case a persistent state is managed in status. If that state would be in a separate ConfigMap/Secret might feel less "unnatural

[jira] [Created] (FLINK-30028) A little fix with document about period in log.changelog-mode description.

2022-11-15 Thread Hang HOU (Jira)
Hang HOU created FLINK-30028: Summary: A little fix with document about period in log.changelog-mode description. Key: FLINK-30028 URL: https://issues.apache.org/jira/browse/FLINK-30028 Project: Flink

[GitHub] [flink-table-store] houhang1005 opened a new pull request, #381: [FLINK-30028]A little fix with document about periods in log.changelog-mode description.

2022-11-15 Thread GitBox
houhang1005 opened a new pull request, #381: URL: https://github.com/apache/flink-table-store/pull/381 Another little fix with documents, this time I found that sentence get one more period. Signed-off-by: houhang -- This is an automated message from the Apache Git Service. To resp

[jira] [Updated] (FLINK-30028) A little fix with document about period in log.changelog-mode description.

2022-11-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30028: --- Labels: pull-request-available (was: ) > A little fix with document about period in log.cha

[GitHub] [flink] Jassj opened a new pull request, #21323: Update overview.md

2022-11-15 Thread GitBox
Jassj opened a new pull request, #21323: URL: https://github.com/apache/flink/pull/21323 fix:修改错别字 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-trans

[GitHub] [flink] yuzelin commented on a diff in pull request #21187: [FLINK-27837][sql-gateway] Support statement set in the SQL Gateway

2022-11-15 Thread GitBox
yuzelin commented on code in PR #21187: URL: https://github.com/apache/flink/pull/21187#discussion_r1022505487 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/context/SessionContextTest.java: ## @@ -133,6 +138,79 @@ public void testSetAndRes

[GitHub] [flink] Jassj closed pull request #21323: Update overview.md

2022-11-15 Thread GitBox
Jassj closed pull request #21323: Update overview.md URL: https://github.com/apache/flink/pull/21323 -- 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: iss

[GitHub] [flink] houhang1005 commented on pull request #21268: [FLINK-29952][table-api]Append the detail of the exception when drop tamporary table.

2022-11-15 Thread GitBox
houhang1005 commented on PR #21268: URL: https://github.com/apache/flink/pull/21268#issuecomment-1314986854 @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] zentol commented on pull request #20070: [FLINK-28202][ci] Generalize utils around shade plugin

2022-11-15 Thread GitBox
zentol commented on PR #20070: URL: https://github.com/apache/flink/pull/20070#issuecomment-1314988369 Still a gremlin in there somewhere in the parsing... -- 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] godfreyhe commented on pull request #20745: [FLINK-28988] Don't push above filters down into the right table for temporal join

2022-11-15 Thread GitBox
godfreyhe commented on PR #20745: URL: https://github.com/apache/flink/pull/20745#issuecomment-1314988767 > > Hi @lincoln-lil, I have updated the PR accordingly, please have a look. BTW, is there a principle that filters can not be pushed down into a temporal table? > > There's no sp

[GitHub] [flink] zentol merged pull request #21012: [FLINK-29543] Jar Run Rest Handler Support Flink Configuration

2022-11-15 Thread GitBox
zentol merged PR #21012: URL: https://github.com/apache/flink/pull/21012 -- 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] MartijnVisser commented on pull request #21209: [FLINK-29818] Fix the unstable test HsResultPartitionTest.testAvailability

2022-11-15 Thread GitBox
MartijnVisser commented on PR #21209: URL: https://github.com/apache/flink/pull/21209#issuecomment-1314990609 @reswqa @xintongsong What's the status of this PR, given that it's linked a Blocker Jira? -- This is an automated message from the Apache Git Service. To respond to the message, p

[jira] [Closed] (FLINK-29543) Jar Run Rest Handler Support Flink Configuration

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29543. Resolution: Fixed master: 962a3474e55f23bca0877957130cac83b38941dd > Jar Run Rest Handler

[jira] [Closed] (FLINK-29544) Update Flink doc

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29544. Fix Version/s: (was: 1.17.0) Resolution: Duplicate > Update Flink doc > ---

[jira] [Closed] (FLINK-27060) [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27060. Fix Version/s: 1.17.0 Resolution: Fixed > [FLIP-256] Support Job Dynamic Parameter

[jira] [Updated] (FLINK-27060) [FLIP-256] Support Job Dynamic Parameter With Flink Rest Api

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-27060: - Issue Type: New Feature (was: Improvement) > [FLIP-256] Support Job Dynamic Parameter W

[GitHub] [flink] MartijnVisser merged pull request #21255: [hotfix][docs] Update the missing parts of this fault_tolerance Chinese documentation.

2022-11-15 Thread GitBox
MartijnVisser merged PR #21255: URL: https://github.com/apache/flink/pull/21255 -- 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] zentol merged pull request #21304: [FLINK-30003][rpc] Wait the scheduler future is done before check

2022-11-15 Thread GitBox
zentol merged PR #21304: URL: https://github.com/apache/flink/pull/21304 -- 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

[jira] [Updated] (FLINK-30003) The ConcurrentModificationException occurred at ContextClassLoadingSettingTest

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-30003: - Issue Type: Technical Debt (was: Bug) > The ConcurrentModificationException occurred at

[jira] [Closed] (FLINK-30003) The ConcurrentModificationException occurred at ContextClassLoadingSettingTest

2022-11-15 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-30003. Resolution: Fixed master: 4fb7eee670011609b926a9eb46823ab78e06aab1 > The ConcurrentModifi

[GitHub] [flink] luoyuxia opened a new pull request, #21324: Update api

2022-11-15 Thread GitBox
luoyuxia opened a new pull request, #21324: URL: https://github.com/apache/flink/pull/21324 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them o

[GitHub] [flink] dianfu commented on a diff in pull request #21280: [FLINK-29966][python][doc] Replace and redesign the Python api documentation base

2022-11-15 Thread GitBox
dianfu commented on code in PR #21280: URL: https://github.com/apache/flink/pull/21280#discussion_r1018617362 ## flink-python/docs/reference/pyflink.table/expressions.rst: ## @@ -0,0 +1,77 @@ +.. +

  1   2   3   >