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

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

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

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:

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

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

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

[ 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 >

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

[ https://issues.apache.org/jira/browse/FLINK-29639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634702#comment-17634702 ] Xintong Song commented on FLINK-29639: -- There's no response from the assignee for ~1month.

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

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

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

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-ml] jiangxin369 commented on a diff in pull request #174: [FLINK-29604] Add Estimator and Transformer for CountVectorizer

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

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

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

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

[ 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) >

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634693#comment-17634693 ] Feifan Wang commented on FLINK-30023: - Hi [~Weijie Guo] , you can rerun the test, and high

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

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] [Updated] (FLINK-28671) Update Spark3 to create/drop table in Compatibility Matrix

[ 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

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

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

[jira] [Created] (FLINK-30037) Improve the efficiency of Flink ML Python CI

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:

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

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] [Closed] (FLINK-29966) Replace and redesign the Python api documentation base

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634670#comment-17634670 ] Yun Gao commented on FLINK-27341: - Very thanks [~huwh] for the checking! I'll have a look. >

[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.

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

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

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

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

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[]

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

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

[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.

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

[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.

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

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

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`

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

[ 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] Grypse opened a new pull request, #21329: [FLINK-30036] force delete pod when the k8s node is under NotReady st…

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

[ 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

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-27341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634637#comment-17634637 ] Weihua Hu commented on FLINK-27341: --- [~gaoyunhaii] I tested it in Kubernetes/Docker/Standalone.

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

[ https://issues.apache.org/jira/browse/FLINK-30035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634635#comment-17634635 ] luoyuxia commented on FLINK-30035: -- Thanks for reporting. The regression should be reproduced in

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

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`

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

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

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

[ 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] zjureel opened a new pull request, #383: [FLINK-30033] Add primary key type validation

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

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

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:

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

[ 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

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

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

[ 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

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

[ 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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-30034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634623#comment-17634623 ] luoyuxia commented on FLINK-30034: -- [~samrat007]  Could you please help fix again? Apologize for

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

[ 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] [Updated] (FLINK-30034) class not found exception when using Hive 3.1.3 connector

[ 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 >

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

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

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

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634609#comment-17634609 ] Michael edited comment on FLINK-28867 at 11/16/22 2:52 AM: --- I’m using Flink

[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

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

[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

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

[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

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

[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

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] [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

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

[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

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

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634609#comment-17634609 ] Michael edited comment on FLINK-28867 at 11/16/22 2:49 AM: --- I’m using Flink

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

[ https://issues.apache.org/jira/browse/FLINK-28867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634609#comment-17634609 ] Michael commented on FLINK-28867: - I’m using Flink 1.16.0, and I would like to read Parquet file

[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

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

[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

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

[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

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

[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

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

[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

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

[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

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

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

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-table-store] JingsongLi commented on a diff in pull request #382: [FLINK-30027] Fields min and max in BinaryTableStats support lazy deserialization

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[]

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

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

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

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! --

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

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

[jira] [Updated] (FLINK-30030) Unexpected behavior for overwrite in Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-30030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30030: - Description: When overwrite a table in hive dialect, it might not overwrite but to append.   Just

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger source operator checkpoint

[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634602#comment-17634602 ] Hangxiang Yu commented on FLINK-29856: -- Hi, I may miss something. You mean that the savepoint is

[jira] [Commented] (FLINK-29952) Using DROP TABLE XXX to drop a temporary table （or view） in sql-client can get an exception with incomplete explaination.

[ https://issues.apache.org/jira/browse/FLINK-29952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634596#comment-17634596 ] Hang HOU commented on FLINK-29952: -- [~yzl] [~fsk119] Hi! After several retries, it just passed the

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

jiangxin369 commented on code in PR #175: URL: https://github.com/apache/flink-ml/pull/175#discussion_r1022554843 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/sqltransformer/SQLTransformer.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software Foundation

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #172: [FLINK-29592] Add Estimator and Transformer for RobustScaler

yunfengzhou-hub commented on code in PR #172: URL: https://github.com/apache/flink-ml/pull/172#discussion_r1023411005 ## docs/content/docs/operators/feature/robustscaler.md: ## @@ -0,0 +1,208 @@ +--- +title: "Robust Scaler" +weight: 1 +type: docs +aliases: +-

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #175: [FLINK-29602] Add Transformer for SQLTransformer

jiangxin369 commented on code in PR #175: URL: https://github.com/apache/flink-ml/pull/175#discussion_r1022554843 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/sqltransformer/SQLTransformer.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Resolved] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover configmaps

[ https://issues.apache.org/jira/browse/FLINK-30004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-30004. -- Fix Version/s: kubernetes-operator-1.3.0 Resolution: Fixed > Cannot resume deployment

[jira] [Updated] (FLINK-30004) Cannot resume deployment after suspend with savepoint due to leftover configmaps

[ https://issues.apache.org/jira/browse/FLINK-30004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-30004: - Summary: Cannot resume deployment after suspend with savepoint due to leftover configmaps

[GitHub] [flink-kubernetes-operator] tweise merged pull request #440: [FLINK-30004] Cleanup deployment after savepoint for Flink versions < 1.15

tweise merged PR #440: URL: https://github.com/apache/flink-kubernetes-operator/pull/440 -- 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-kubernetes-operator] morhidi commented on a diff in pull request #439: [FLINK-29959] Use optimistic locking when updating the status

morhidi commented on code in PR #439: URL: https://github.com/apache/flink-kubernetes-operator/pull/439#discussion_r1023386496 ## flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/SavepointInfo.java: ## @@ -63,7 +63,7 @@ public void

[GitHub] [flink-statefun] nathantalewis commented on pull request #314: Using Flink 1.15.0

nathantalewis commented on PR #314: URL: https://github.com/apache/flink-statefun/pull/314#issuecomment-1315981639 Can this be closed now that https://github.com/apache/flink-statefun/commit/b4a85ef031e539e7c2580a796246e2896d533d8f was merged? -- This is an automated message from the

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1023338175 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/SqlGatewayServiceImpl.java: ## @@ -311,8 +340,29 @@ public GatewayInfo

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1023336995 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/SqlGatewayServiceITCase.java: ## @@ -157,6 +169,80 @@ public void

[GitHub] [flink] jnh5y commented on a diff in pull request #21133: [FLINK-29732][sql-gateway] support configuring session with SQL statement.

jnh5y commented on code in PR #21133: URL: https://github.com/apache/flink/pull/21133#discussion_r1023336842 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java: ## @@ -84,6 +90,30 @@ public

[GitHub] [flink] MartijnVisser commented on a diff in pull request #21128: [FLINK-29710] Bump minimum supported Hadoop version to 2.10.2

MartijnVisser commented on code in PR #21128: URL: https://github.com/apache/flink/pull/21128#discussion_r102196 ## flink-yarn/pom.xml: ## @@ -181,6 +247,99 @@ under the License. + + + +

[GitHub] [flink] flinkbot commented on pull request #21327: Bump loader-utils from 2.0.2 to 2.0.4 in /flink-runtime-web/web-dashboard

flinkbot commented on PR #21327: URL: https://github.com/apache/flink/pull/21327#issuecomment-1315969968 ## CI report: * 6ca3803e7b204494c460ebf2babf491e5c7b4efc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dependabot[bot] opened a new pull request, #21327: Bump loader-utils from 2.0.2 to 2.0.4 in /flink-runtime-web/web-dashboard

dependabot[bot] opened a new pull request, #21327: URL: https://github.com/apache/flink/pull/21327 Bumps [loader-utils](https://github.com/webpack/loader-utils) from 2.0.2 to 2.0.4. Release notes Sourced from https://github.com/webpack/loader-utils/releases;>loader-utils's

[GitHub] [flink] dependabot[bot] closed pull request #21267: Bump loader-utils from 2.0.2 to 2.0.3 in /flink-runtime-web/web-dashboard

dependabot[bot] closed pull request #21267: Bump loader-utils from 2.0.2 to 2.0.3 in /flink-runtime-web/web-dashboard URL: https://github.com/apache/flink/pull/21267 -- 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] dependabot[bot] commented on pull request #21267: Bump loader-utils from 2.0.2 to 2.0.3 in /flink-runtime-web/web-dashboard

dependabot[bot] commented on PR #21267: URL: https://github.com/apache/flink/pull/21267#issuecomment-1315958131 Superseded by #21327. -- 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

[jira] [Comment Edited] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634540#comment-17634540 ] Jing Ge edited comment on FLINK-30025 at 11/15/22 10:10 PM: Afaik, for

[GitHub] [flink] JingGe commented on pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

JingGe commented on PR #21322: URL: https://github.com/apache/flink/pull/21322#issuecomment-1315926216 @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-kubernetes-operator] morhidi commented on pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

morhidi commented on PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#issuecomment-1315913708 @gyfora @mbalassi can you kick off the workflow on this pls? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

morhidi commented on code in PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#discussion_r1023287879 ## flink-kubernetes-webhook/pom.xml: ## @@ -96,6 +96,12 @@ under the License. ${okhttp.version} test + +

[GitHub] [flink] JingGe commented on pull request #21322: [FLINK-30025][table] the max column width should be resizable while printing the query result to the client console.

JingGe commented on PR #21322: URL: https://github.com/apache/flink/pull/21322#issuecomment-1315905260 @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] [Comment Edited] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634540#comment-17634540 ] Jing Ge edited comment on FLINK-30025 at 11/15/22 9:44 PM: --- Afaik, for

[jira] [Closed] (FLINK-29798) Rename K8s operator client code module

[ https://issues.apache.org/jira/browse/FLINK-29798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Márton Balassi closed FLINK-29798. -- Resolution: Fixed

[GitHub] [flink-kubernetes-operator] mbalassi merged pull request #441: [FLINK-29798][build] Exclude example modules from maven deploy phase

mbalassi merged PR #441: URL: https://github.com/apache/flink-kubernetes-operator/pull/441 -- 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] [Commented] (FLINK-30025) table.execute().print() can only use the default max column width

[ https://issues.apache.org/jira/browse/FLINK-30025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17634540#comment-17634540 ] Jing Ge commented on FLINK-30025: - Afaik, for streaming, there is no way for Flink to get the max width

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #441: [FLINK-29798][build] Exclude example modules from maven deploy phase

morhidi commented on PR #441: URL: https://github.com/apache/flink-kubernetes-operator/pull/441#issuecomment-1315899466 +1 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 to the specific

  1   2   3   >