[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=17522071#comment-17522071 ] Chesnay Schepler commented on FLINK-27229: -- Why is that a problem? > Cassandra overrides netty

[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

[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

[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=17522051#comment-17522051 ] luoyuxia edited comment on FLINK-27191 at 4/14/22 4:24 AM: --- [~straw] Yes, you

[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=17522051#comment-17522051 ] luoyuxia commented on FLINK-27191: -- [~straw] Yes, you are right. I didn't notice that. But I wonder

[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

[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

[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

[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

[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

[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=17522045#comment-17522045 ] Sergey Nuyanzin commented on FLINK-25548: - Can you assign this to me? > [JUnit5 Migration]

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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=17522040#comment-17522040 ] xuyang commented on FLINK-27239: I'll try to fix it. > rewrite PreValidateReWriter from scala to java >

[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

[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=17522036#comment-17522036 ] Dian Fu commented on FLINK-27213: - [~martijnvisser] The aim of this JIRA should be to align the

[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

[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

[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=17522028#comment-17522028 ] Yuan Zhu commented on FLINK-27191: -- There are some static fields, such like

[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=17522028#comment-17522028 ] Yuan Zhu edited comment on FLINK-27191 at 4/14/22 2:44 AM: --- There are some

[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=17522025#comment-17522025 ] luoyuxia edited comment on FLINK-27191 at 4/14/22 2:39 AM: --- [~straw]

[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=17522025#comment-17522025 ] luoyuxia commented on FLINK-27191: -- [~straw] Appreciated for your detail explaination. IIUC, you mean

[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

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

[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=17522020#comment-17522020 ] Yang Wang commented on FLINK-27235: --- cc [~gyfora] Do you think it conforms to the apache way to host

[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=17522019#comment-17522019 ] ranqiqiang commented on FLINK-17826: We have also implemented a similar function, remember that the

[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

[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=17522015#comment-17522015 ] Yang Wang commented on FLINK-27211: --- [~jbusche] Thanks for the explanation. > RBAC

[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

[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

[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

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

[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=17522013#comment-17522013 ] Yang Wang edited comment on FLINK-26811 at 4/14/22 2:10 AM: I changed the

[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=17522013#comment-17522013 ] Yang Wang commented on FLINK-26811: --- I changed the fixed version to kubernetes-operator-1.0.0 since

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

[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

[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=17522010#comment-17522010 ] Yang Wang commented on FLINK-27129: --- [~tedhtchang] Thanks for working on this. Except for removing

[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

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

[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=17521990#comment-17521990 ] zhangjingcun commented on FLINK-27213: -- [~martijnvisser] Add purgingtrigger trigger in pyflink. >

[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

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

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

[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

[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

[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

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

[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

[GitHub] [flink] snuyanzin commented on pull request #19459: [FLINK-27227][table] Add PlannerTimeIntervalUnits for MILLENNIUM, CEN…

2022-04-13 Thread GitBox
snuyanzin commented on PR #19459: URL: https://github.com/apache/flink/pull/19459#issuecomment-1098447384 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink-kubernetes-operator] jbusche commented on pull request #166: Flink 27211 deployments/finalizers missing for OpenShift Deployment

2022-04-13 Thread GitBox
jbusche commented on PR #166: URL: https://github.com/apache/flink-kubernetes-operator/pull/166#issuecomment-1098430078 Thank you for reviewing, and for the tip @mbalassi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-27234) Enable fork-reuse for connector-jdbc

2022-04-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-27234: --- Labels: pull-request-available (was: ) > Enable fork-reuse for connector-jdbc >

[GitHub] [flink] flinkbot commented on pull request #19463: [FLINK-27234][jdbc] Enable fork-reuse for unit tests

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

[jira] [Created] (FLINK-27234) Enable fork-reuse for connector-jdbc

2022-04-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27234: Summary: Enable fork-reuse for connector-jdbc Key: FLINK-27234 URL: https://issues.apache.org/jira/browse/FLINK-27234 Project: Flink Issue Type:

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

2022-04-13 Thread GitBox
zentol commented on PR #19458: URL: https://github.com/apache/flink/pull/19458#issuecomment-1098375924 @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] mas-chen commented on a diff in pull request #19456: [FLINK-27041][connector/kafka] Catch IllegalStateException in KafkaPartitionSplitReader.fetch() to handle no valid partition case

2022-04-13 Thread GitBox
mas-chen commented on code in PR #19456: URL: https://github.com/apache/flink/pull/19456#discussion_r849792841 ## flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java: ## @@ -98,9 +98,16 @@ public

[jira] [Comment Edited] (FLINK-27127) Local recovery is not triggered on task manager process restart

2022-04-13 Thread Abdullah alkhawatrah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521860#comment-17521860 ] Abdullah alkhawatrah edited comment on FLINK-27127 at 4/13/22 6:15 PM:

[jira] [Commented] (FLINK-27127) Local recovery is not triggered on task manager process restart

2022-04-13 Thread Abdullah alkhawatrah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17521860#comment-17521860 ] Abdullah alkhawatrah commented on FLINK-27127: -- Thanks a lot. [~chesnay] do you think a

[GitHub] [flink] flinkbot commented on pull request #19462: [FLINK-27225][build] Remove redundant reuseForks settings

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

[jira] [Updated] (FLINK-27225) Remove redundant reuseForks settings

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

[GitHub] [flink] zentol opened a new pull request, #19462: [FLINK-27225][build] Remove redundant reuseForks settings

2022-04-13 Thread GitBox
zentol opened a new pull request, #19462: URL: https://github.com/apache/flink/pull/19462 reuseForks is true by default so some settings are redundant. flink-dist contains no unit tests that would justify disabling reuseForks. -- This is an automated message from the Apache Git Service.

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

2022-04-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26811. -- Resolution: Fixed merged to main 56af85a2a70b24917950aab7ffced90f91ee4fa0 > Document CRD upgrade

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #167: [FLINK-26811] [docs] Document CRD upgrade process

2022-04-13 Thread GitBox
gyfora merged PR #167: URL: https://github.com/apache/flink-kubernetes-operator/pull/167 -- 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] [Closed] (FLINK-26871) Handle Session job spec change

2022-04-13 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26871. -- Resolution: Fixed merged to main: ff1ca4e83385d1cfded40df7b8c0ae29cf8faec8 > Handle Session job spec

[GitHub] [flink-kubernetes-operator] tedhtchang commented on pull request #167: [FLINK-26811] [docs] Document CRD upgrade process

2022-04-13 Thread GitBox
tedhtchang commented on PR #167: URL: https://github.com/apache/flink-kubernetes-operator/pull/167#issuecomment-1098279743 @gyfora Thank you for reviewing. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

  1   2   3   4   5   6   7   8   9   >