[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-13 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r850118629 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderParams.java: ## @@ -27,6 +27,9 @@ /** * Params of OneHotEncoderModel. * + * The

[jira] [Updated] (FLINK-27168) Introduce ContinuousProcessingTimeTrigger and ContinuousEventTimeTrigger

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-27168: Fix Version/s: 1.16.0 > Introduce ContinuousProcessingTimeTrigger and ContinuousEventTimeTrigger > ---

[jira] [Updated] (FLINK-27168) Introduce ContinuousProcessingTimeTrigger and ContinuousEventTimeTrigger

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-27168: Summary: Introduce ContinuousProcessingTimeTrigger and ContinuousEventTimeTrigger (was: Add continuouspro

[jira] [Closed] (FLINK-27168) Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27168. --- Resolution: Fixed Merged to master via eed14ef1913155330a53ab170d71f59df8422033 > Add continuousprocessingt

[GitHub] [flink] flinkbot commented on pull request #19468: [FLINK-18286][table] Port type inference for collection types

2022-04-13 Thread GitBox
flinkbot commented on PR #19468: URL: https://github.com/apache/flink/pull/19468#issuecomment-1098771419 ## CI report: * 4c337efbf48efc4f1b3bf36615198d921d2f6e05 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #165: [FLINK-26140] Support rollback strategies

2022-04-13 Thread GitBox
gyfora commented on PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#issuecomment-1098770799 I have rebased to the latest changes @Aitozi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array,for example Array Array ...

2022-04-13 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: !image-2022-04-14-10-27-50-340.png|width=381,height=260!   If argTypes[0] is Array ,it

[jira] [Commented] (FLINK-26782) Remove PlannerExpression and related

2022-04-13 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522095#comment-17522095 ] Francesco Guardiani commented on FLINK-26782: - I wasn't able to complete thi

[GitHub] [flink] dianfu closed pull request #19421: [FLINK-27168][API/Python]Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers

2022-04-13 Thread GitBox
dianfu closed pull request #19421: [FLINK-27168][API/Python]Add continuousprocessingtimetrigger and continuouseventtimetrigger triggers URL: https://github.com/apache/flink/pull/19421 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Assigned] (FLINK-26782) Remove PlannerExpression and related

2022-04-13 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-26782: --- Assignee: (was: Francesco Guardiani) > Remove PlannerExpression and rel

[GitHub] [flink] slinkydeveloper closed pull request #19460: [FLINK-26782][table] Remove PlannerExpression

2022-04-13 Thread GitBox
slinkydeveloper closed pull request #19460: [FLINK-26782][table] Remove PlannerExpression URL: https://github.com/apache/flink/pull/19460 -- 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] slinkydeveloper commented on pull request #19460: [FLINK-26782][table] Remove PlannerExpression

2022-04-13 Thread GitBox
slinkydeveloper commented on PR #19460: URL: https://github.com/apache/flink/pull/19460#issuecomment-1098762718 This PR is not complete and takes a while to finish it, will open a new PR only for the first commit -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Closed] (FLINK-27123) Introduce filter predicate for 'LIKE'

2022-04-13 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-27123. Resolution: Fixed master: 8d1b6256a2eb78a261967c602c0b019fdb6ee7ca > Introduce filter predicate f

[GitHub] [flink-table-store] JingsongLi merged pull request #87: [FLINK-27123] Introduce filter predicate for 'LIKE'

2022-04-13 Thread GitBox
JingsongLi merged PR #87: URL: https://github.com/apache/flink-table-store/pull/87 -- 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...@fl

[GitHub] [flink-ml] zhipeng93 commented on a diff in pull request #82: [FLINK-27072] Add Transformer of Bucketizer

2022-04-13 Thread GitBox
zhipeng93 commented on code in PR #82: URL: https://github.com/apache/flink-ml/pull/82#discussion_r850118629 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderParams.java: ## @@ -27,6 +27,9 @@ /** * Params of OneHotEncoderModel. * + * The

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-13 Thread GitBox
gyfora commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r850109308 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -159,16 +185,1

[jira] [Commented] (FLINK-27229) Cassandra overrides netty version in tests

2022-04-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522071#comment-17522071 ] Chesnay Schepler commented on FLINK-27229: -- Why is that a problem? > Cassandra

[jira] [Created] (FLINK-27244) Support subdirectories with Hive tables

2022-04-13 Thread luoyuxia (Jira)
luoyuxia created FLINK-27244: Summary: Support subdirectories with Hive tables Key: FLINK-27244 URL: https://issues.apache.org/jira/browse/FLINK-27244 Project: Flink Issue Type: Sub-task

[GitHub] [flink] luoyuxia commented on a diff in pull request #19423: [FLINK-27175][hive] Support to call Hive UDAF when the UDAF accepts one parameter with array type

2022-04-13 Thread GitBox
luoyuxia commented on code in PR #19423: URL: https://github.com/apache/flink/pull/19423#discussion_r850075408 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveGenericUDAF.java: ## @@ -105,6 +108,8 @@ private void init() throws Hiv

[GitHub] [flink] flinkbot commented on pull request #19467: [FLINK-25548][flink-sql-parser] Migrate tests to JUnit5

2022-04-13 Thread GitBox
flinkbot commented on PR #19467: URL: https://github.com/apache/flink/pull/19467#issuecomment-1098700583 ## CI report: * b4ef337281b169e720595fded2c78dee0f425341 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-25548) [JUnit5 Migration] Module: flink-sql-parser

2022-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25548: --- Labels: pull-request-available (was: ) > [JUnit5 Migration] Module: flink-sql-parser >

[GitHub] [flink] snuyanzin opened a new pull request, #19467: [FLINK-25548][flink-sql-parser] Migrate tests to JUnit5

2022-04-13 Thread GitBox
snuyanzin opened a new pull request, #19467: URL: https://github.com/apache/flink/pull/19467 ## What is the purpose of the change Update the flink-table/flink-sql-parser and flink-table/flink-sql-parser-hive modules to AssertJ and JUnit 5 following the [JUnit 5 Migration Guide](http

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522051#comment-17522051 ] luoyuxia edited comment on FLINK-27191 at 4/14/22 4:24 AM: --- [~

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522051#comment-17522051 ] luoyuxia commented on FLINK-27191: -- [~straw] Yes, you are right. I didn't notice that.

[jira] [Updated] (FLINK-27223) State access doesn't work as expected when cache size is set to 0

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-27223: Affects Version/s: 1.14.0 (was: 1.15.0) > State access doesn't work as expected

[jira] [Closed] (FLINK-27223) State access doesn't work as expected when cache size is set to 0

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27223. --- Fix Version/s: 1.14.5 Resolution: Fixed Fixed in: - master via eee8804bb8db97864ecff6b27853570e75b158

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-13 Thread GitBox
bgeng777 commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r850061884 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -159,16 +185

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-13 Thread GitBox
bgeng777 commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r850061884 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -159,16 +185

[GitHub] [flink] dianfu closed pull request #19457: [FLINK-27223][python] Fix the state access problem when python.state.cache-size is set to 0

2022-04-13 Thread GitBox
dianfu closed pull request #19457: [FLINK-27223][python] Fix the state access problem when python.state.cache-size is set to 0 URL: https://github.com/apache/flink/pull/19457 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and us

[jira] [Commented] (FLINK-25548) [JUnit5 Migration] Module: flink-sql-parser

2022-04-13 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522045#comment-17522045 ] Sergey Nuyanzin commented on FLINK-25548: - Can you assign this to me? > [JUnit

[jira] [Updated] (FLINK-27231) SQL pulsar connector lists dependencies under wrong license

2022-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27231: --- Labels: pull-request-available (was: ) > SQL pulsar connector lists dependencies under wron

[GitHub] [flink] flinkbot commented on pull request #19466: (1.15) [FLINK-27231][FLINK-27230][FLINK-27233] Fix the remaining licence issues on 1.15

2022-04-13 Thread GitBox
flinkbot commented on PR #19466: URL: https://github.com/apache/flink/pull/19466#issuecomment-1098683800 ## CI report: * acf8a13378407d05eef02e812d5dbcda9d2dd943 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-kubernetes-operator] bgeng777 commented on a diff in pull request #165: [FLINK-26140] Support rollback strategies

2022-04-13 Thread GitBox
bgeng777 commented on code in PR #165: URL: https://github.com/apache/flink-kubernetes-operator/pull/165#discussion_r850061884 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/deployment/AbstractDeploymentObserver.java: ## @@ -159,16 +185

[jira] [Updated] (FLINK-27240) Support ADD PARTITION statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27240: -- Summary: Support ADD PARTITION statement for partitioned table (was: Support ADD PARTITION statement)

[jira] [Updated] (FLINK-27240) Support ADD PARTITION statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27240: -- Component/s: Table SQL / API > Support ADD PARTITION statement for partitioned table > ---

[jira] [Updated] (FLINK-27241) Support DROP PARTITION statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27241: -- Summary: Support DROP PARTITION statement for partitioned table (was: Support DROP PARTITION statemen

[jira] [Updated] (FLINK-27241) Support DROP PARTITION statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27241: -- Component/s: Table SQL / API > Support DROP PARTITION statement for partitioned table > --

[jira] [Created] (FLINK-27243) Support SHOW PARTITIONS statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
dalongliu created FLINK-27243: - Summary: Support SHOW PARTITIONS statement for partitioned table Key: FLINK-27243 URL: https://issues.apache.org/jira/browse/FLINK-27243 Project: Flink Issue Type:

[jira] [Created] (FLINK-27242) Support RENAME PARTITION statement for partitioned table

2022-04-13 Thread dalongliu (Jira)
dalongliu created FLINK-27242: - Summary: Support RENAME PARTITION statement for partitioned table Key: FLINK-27242 URL: https://issues.apache.org/jira/browse/FLINK-27242 Project: Flink Issue Type

[jira] [Updated] (FLINK-27233) Unnecessary entries in connector-elasticsearch7 in NOTICE file

2022-04-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27233: Fix Version/s: 1.15.0 > Unnecessary entries in connector-elasticsearch7 in NOTICE file > -

[jira] [Created] (FLINK-27241) Support DROP PARTITION statement

2022-04-13 Thread dalongliu (Jira)
dalongliu created FLINK-27241: - Summary: Support DROP PARTITION statement Key: FLINK-27241 URL: https://issues.apache.org/jira/browse/FLINK-27241 Project: Flink Issue Type: Sub-task R

[jira] [Updated] (FLINK-27230) Unnecessary entries in connector-kinesis NOTICE file

2022-04-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27230: Fix Version/s: 1.15.0 > Unnecessary entries in connector-kinesis NOTICE file > ---

[jira] [Created] (FLINK-27240) Support ADD PARTITION statement

2022-04-13 Thread dalongliu (Jira)
dalongliu created FLINK-27240: - Summary: Support ADD PARTITION statement Key: FLINK-27240 URL: https://issues.apache.org/jira/browse/FLINK-27240 Project: Flink Issue Type: Sub-task Re

[GitHub] [flink] gaoyunhaii opened a new pull request, #19466: (1.15) Fix the remaining licence issues on 1.15

2022-04-13 Thread GitBox
gaoyunhaii opened a new pull request, #19466: URL: https://github.com/apache/flink/pull/19466 ## What is the purpose of the change This PR fixes the remaining licence issues in 1.15. I'll pick the PR to master after it is accepted. ## Brief change log - Fix the wrong li

[GitHub] [flink] flinkbot commented on pull request #19465: [FLINK-27239][table-planner] rewrite PreValidateReWriter from scala to java

2022-04-13 Thread GitBox
flinkbot commented on PR #19465: URL: https://github.com/apache/flink/pull/19465#issuecomment-1098680396 ## CI report: * 9b5ec21ed18cc0291b63ece21e6c3434e6ecfe5c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-27215) JDBC sink transiently deleted a record because of -u message of that record

2022-04-13 Thread tim yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tim yu updated FLINK-27215: --- Affects Version/s: 1.14.3 1.13.5 1.12.7

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partitio

[GitHub] [flink] xuyangzhong opened a new pull request, #19465: [FLINK-27239][table-planner] rewrite PreValidateReWriter from scala to java

2022-04-13 Thread GitBox
xuyangzhong opened a new pull request, #19465: URL: https://github.com/apache/flink/pull/19465 ## What is the purpose of the change This pr aims to do the processing task about FLIP-28 and rewrite PreValidateReWriter implemented from Scala to Java. ## Brief change log

[jira] [Updated] (FLINK-27239) rewrite PreValidateReWriter from scala to java

2022-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27239: --- Labels: pull-request-available (was: ) > rewrite PreValidateReWriter from scala to java > -

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partitio

[jira] [Commented] (FLINK-27239) rewrite PreValidateReWriter from scala to java

2022-04-13 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522040#comment-17522040 ] xuyang commented on FLINK-27239: I'll try to fix it. > rewrite PreValidateReWriter from

[jira] [Created] (FLINK-27239) rewrite PreValidateReWriter from scala to java

2022-04-13 Thread xuyang (Jira)
xuyang created FLINK-27239: -- Summary: rewrite PreValidateReWriter from scala to java Key: FLINK-27239 URL: https://issues.apache.org/jira/browse/FLINK-27239 Project: Flink Issue Type: Improvement

[GitHub] [flink] pltbkd commented on a diff in pull request #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

2022-04-13 Thread GitBox
pltbkd commented on code in PR #19464: URL: https://github.com/apache/flink/pull/19464#discussion_r850050705 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java: ## @@ -3688,6 +3693,92 @@ public void testTimeoutWhileCheckpointOperat

[GitHub] [flink] flinkbot commented on pull request #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

2022-04-13 Thread GitBox
flinkbot commented on PR #19464: URL: https://github.com/apache/flink/pull/19464#issuecomment-1098666230 ## CI report: * c76ce7592cea572fc27d11a8e82911efc088ec92 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-27213) Add PurgingTrigger

2022-04-13 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522036#comment-17522036 ] Dian Fu commented on FLINK-27213: - [~martijnvisser] The aim of this JIRA should be to al

[jira] [Updated] (FLINK-27148) UnalignedCheckpointITCase fails on AZP

2022-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27148: --- Labels: pull-request-available (was: ) > UnalignedCheckpointITCase fails on AZP > -

[GitHub] [flink] pltbkd opened a new pull request, #19464: [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

2022-04-13 Thread GitBox
pltbkd opened a new pull request, #19464: URL: https://github.com/apache/flink/pull/19464 ## What is the purpose of the change The PR is fixing an issue that the operator coordinator may trigger a checkpoint without canceling/completing the previous one, because the canceling

[GitHub] [flink] Myasuka commented on pull request #19461: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese

2022-04-13 Thread GitBox
Myasuka commented on PR #19461: URL: https://github.com/apache/flink/pull/19461#issuecomment-1098662430 @liuzhuang2017 First of all, why not filling up the description of this PR? You still left three parts unmodified. -- This is an automated message from the Apache Git Service. To respon

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF and HiveScalarFunction should support primitive array,for example Array Array ...

2022-04-13 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Summary: The HiveGenericUDTF and HiveScalarFunction should support primitive array,for example Array A

[jira] [Updated] (FLINK-27238) The HiveGenericUDTF should support primitive array,for example Array Array ...

2022-04-13 Thread hehuiyuan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-27238: -- Description: !image-2022-04-14-10-27-50-340.png|width=381,height=260!   If argTypes[0] is Array ,it

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522028#comment-17522028 ] Yuan Zhu commented on FLINK-27191: -- There are some static fields, such like [authentic

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread Yuan Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522028#comment-17522028 ] Yuan Zhu edited comment on FLINK-27191 at 4/14/22 2:44 AM: --- Th

[jira] [Comment Edited] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522025#comment-17522025 ] luoyuxia edited comment on FLINK-27191 at 4/14/22 2:39 AM: --- [~

[jira] [Commented] (FLINK-27191) Support multi kerberos-enabled Hive clusters

2022-04-13 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522025#comment-17522025 ] luoyuxia commented on FLINK-27191: -- [~straw] Appreciated for your detail explaination.

[jira] [Created] (FLINK-27238) The HiveGenericUDTF should support primitive array,for example Array Array ...

2022-04-13 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-27238: - Summary: The HiveGenericUDTF should support primitive array,for example Array Array ... Key: FLINK-27238 URL: https://issues.apache.org/jira/browse/FLINK-27238 Project: Fli

[jira] [Updated] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-13 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yue Ma updated FLINK-27218: --- Description: OperatorState such as *BroadcastState* or *PartitionableListState*  can only be constructed vi

[jira] [Commented] (FLINK-27235) Publish Flink k8s Operator Helm Charts via Github Actions

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522020#comment-17522020 ] Yang Wang commented on FLINK-27235: --- cc [~gyfora] Do you think it conforms to the apac

[jira] [Commented] (FLINK-17826) Add missing custom query support on new jdbc connector

2022-04-13 Thread ranqiqiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522019#comment-17522019 ] ranqiqiang commented on FLINK-17826: We have also implemented a similar function, re

[jira] [Updated] (FLINK-27218) Serializer in OperatorState has not been updated when new Serializers are NOT incompatible

2022-04-13 Thread Yue Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yue Ma updated FLINK-27218: --- Description: OperatorState such as *BroadcastState* or *PartitionableListState*  can only be constructed vi

[GitHub] [flink] gaoyunhaii commented on pull request #19454: [FLINK-27220][runtime] Remove redundant null-check for int parameter.

2022-04-13 Thread GitBox
gaoyunhaii commented on PR #19454: URL: https://github.com/apache/flink/pull/19454#issuecomment-1098645253 Thanks @dkkb for the PR! I'll have a look~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Updated] (FLINK-27231) SQL pulsar connector lists dependencies under wrong license

2022-04-13 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-27231: Fix Version/s: 1.15.0 > SQL pulsar connector lists dependencies under wrong license >

[jira] [Commented] (FLINK-27211) RBAC deployments/finalizers missing for OpenShift Deployment

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522015#comment-17522015 ] Yang Wang commented on FLINK-27211: --- [~jbusche] Thanks for the explanation. > RBAC de

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partitio

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partitio

[jira] [Updated] (FLINK-27237) Partition table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partitio

[jira] [Updated] (FLINK-27237) Partitioned table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Summary: Partitioned table statement enhancement (was: Partition table statement enhancement) > Part

[jira] [Comment Edited] (FLINK-26811) Document CRD upgrade process

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522013#comment-17522013 ] Yang Wang edited comment on FLINK-26811 at 4/14/22 2:10 AM:

[jira] [Commented] (FLINK-26811) Document CRD upgrade process

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522013#comment-17522013 ] Yang Wang commented on FLINK-26811: --- I changed the fixed version to kubernetes-operato

[jira] [Updated] (FLINK-26811) Document CRD upgrade process

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-26811: -- Fix Version/s: kubernetes-operator-1.0.0 (was: kubernetes-operator-0.1.0) > Doc

[GitHub] [flink] syhily commented on pull request #18406: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

2022-04-13 Thread GitBox
syhily commented on PR #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1098638573 @AHeise Hi Arvid, can you review this PR? -- 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-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17522010#comment-17522010 ] Yang Wang commented on FLINK-27129: --- [~tedhtchang] Thanks for working on this. Except

[jira] [Updated] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27129: -- Fix Version/s: kubernetes-operator-1.0.0 (was: 0.1.0) > Hardcoded namespace in

[jira] [Updated] (FLINK-27237) Partition table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is an umbrella issue which is used to discuss the syntax enhancement about partition

[jira] [Updated] (FLINK-27237) Partition table statement enhancement

2022-04-13 Thread dalongliu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] dalongliu updated FLINK-27237: -- Description: This is a umbrella > Partition table statement enhancement >

[jira] [Assigned] (FLINK-27129) Hardcoded namespace in FlinkDeployment manifests may fail to deploy

2022-04-13 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27129: - Assignee: Ted Chang > Hardcoded namespace in FlinkDeployment manifests may fail to deploy > ---

[jira] [Created] (FLINK-27237) Partition table statement enhancement

2022-04-13 Thread dalongliu (Jira)
dalongliu created FLINK-27237: - Summary: Partition table statement enhancement Key: FLINK-27237 URL: https://issues.apache.org/jira/browse/FLINK-27237 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-27236) No task slot allocated for job in larege-scale job

2022-04-13 Thread yanpengshi (Jira)
yanpengshi created FLINK-27236: -- Summary: No task slot allocated for job in larege-scale job Key: FLINK-27236 URL: https://issues.apache.org/jira/browse/FLINK-27236 Project: Flink Issue Type: Bu

[jira] [Updated] (FLINK-27213) Add PurgingTrigger

2022-04-13 Thread zhangjingcun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhangjingcun updated FLINK-27213: - Description: Add purgingtrigger trigger in pyflink. > Add PurgingTrigger > ---

[jira] [Commented] (FLINK-27213) Add PurgingTrigger

2022-04-13 Thread zhangjingcun (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17521990#comment-17521990 ] zhangjingcun commented on FLINK-27213: -- [~martijnvisser] Add purgingtrigger trigger

[GitHub] [flink] liuzhuang2017 commented on pull request #19461: [FLINK-27205][docs-zh] Translate "Concepts -> Glossary" page into Chinese

2022-04-13 Thread GitBox
liuzhuang2017 commented on PR #19461: URL: https://github.com/apache/flink/pull/19461#issuecomment-1098587752 @Myasuka ,Sorry to bother you, can you help me rewiew this pr if you have free time? Thank you very much. -- This is an automated message from the Apache Git Service. To respond t

[jira] [Updated] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25480: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-26796) TaskManagerProcessFailureStreamingRecoveryITCase.testTaskManagerProcessFailure failed on azure

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26796: --- Labels: auto-deprioritized-critical test-stability (was: stale-critical test-stability)

[jira] [Updated] (FLINK-25675) UnalignedCheckpointCompatibilityITCase.test hangs on AZP

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25675: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-21834) org.apache.flink.core.fs.AbstractRecoverableWriterTest.testResumeWithWrongOffset fail

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21834: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-22090) Upload logs fails

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22090: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-deprioritized-minor test

[jira] [Updated] (FLINK-26588) Translate the new CAST documentation to Chinese

2022-04-13 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26588: --- Labels: chinese-translation stale-assigned (was: chinese-translation) I am the [Flink Jira

[GitHub] [flink-statefun-playground] mans2singh opened a new pull request, #27: [shopping-cart][stockfn] Corrected logger

2022-04-13 Thread GitBox
mans2singh opened a new pull request, #27: URL: https://github.com/apache/flink-statefun-playground/pull/27 The **StockFn** creates logger LoggerFactory.getLogger(**UserShoppingCartFn.class**), updated to create logger for the class LoggerFactory.getLogger(**StockFn.class**). -- This is

[jira] [Closed] (FLINK-27224) Drop redundant flink.forkCountTestPackage property

2022-04-13 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-27224. Resolution: Fixed master: 55d9f43f0bf32cbe948ddeb271486846fa18b363 > Drop redundant flink

[GitHub] [flink] zentol merged pull request #19458: [FLINK-27224][build] Drop 'flink.forkCountTestPackage' property

2022-04-13 Thread GitBox
zentol merged PR #19458: URL: https://github.com/apache/flink/pull/19458 -- 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] [Created] (FLINK-27235) Publish Flink k8s Operator Helm Charts via Github Actions

2022-04-13 Thread Gezim Sejdiu (Jira)
Gezim Sejdiu created FLINK-27235: Summary: Publish Flink k8s Operator Helm Charts via Github Actions Key: FLINK-27235 URL: https://issues.apache.org/jira/browse/FLINK-27235 Project: Flink Iss

  1   2   3   4   >