[jira] [Created] (FLINK-29491) Primary key without partition field can be supported from full changelog

2022-09-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29491: Summary: Primary key without partition field can be supported from full changelog Key: FLINK-29491 URL: https://issues.apache.org/jira/browse/FLINK-29491 Project:

[jira] [Created] (FLINK-29490) Timestamp LTZ is unsupported in table store

2022-09-30 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29490: Summary: Timestamp LTZ is unsupported in table store Key: FLINK-29490 URL: https://issues.apache.org/jira/browse/FLINK-29490 Project: Flink Issue Type: Bug

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

2022-09-30 Thread GitBox
flinkbot commented on PR #20935: URL: https://github.com/apache/flink/pull/20935#issuecomment-1264115737 ## CI report: * 03bf998619ad1f5ceae2eb1c067a27837c7b0b37 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

2022-09-30 Thread GitBox
liuml07 commented on PR #20935: URL: https://github.com/apache/flink/pull/20935#issuecomment-1264113384 CC @knaufk @MartijnVisser -- 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] liuml07 opened a new pull request, #20935: [hotfix][doc] Make referencing custom image clearer for Docker

2022-09-30 Thread GitBox
liuml07 opened a new pull request, #20935: URL: https://github.com/apache/flink/pull/20935 ## What is the purpose of the change Make referencing custom image clearer for Docker ## Brief change log hotfix ## Verifying this change Please make sure both new

[GitHub] [flink] stevenzwu commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
stevenzwu commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1264009972 @leletan we shall come back to this PR after the internal class renaming is merged. Please create a jira and PR for that first. -- This is an automated message from the Apache Git

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1263952346 As per discussion https://github.com/apache/flink/pull/20852#issuecomment-1260402519, will address the internal class renaming in a follow up PR. -- This is an automated message from

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1263951145 @pnowojski Your comments and change requests should all be addressed. Please let me know if I miss anything. Thanks! -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] leletan commented on pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on PR #20852: URL: https://github.com/apache/flink/pull/20852#issuecomment-1263949515 @stevenzwu All your comments should be addressed. Please let me know if there is anything missing. Thanks! -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r984896568 ## flink-core/src/main/java/org/apache/flink/core/execution/CheckpointType.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r984896981 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java: ## @@ -511,6 +514,42 @@ public CompletableFuture

[GitHub] [flink] leletan commented on a diff in pull request #20852: [FLINK-27101][checkpointing][rest] Add restful API to trigger checkpoints

2022-09-30 Thread GitBox
leletan commented on code in PR #20852: URL: https://github.com/apache/flink/pull/20852#discussion_r984896360 ## flink-core/src/main/java/org/apache/flink/core/execution/CheckpointType.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[GitHub] [flink] flinkbot commented on pull request #20934: Bump pulsar-broker from 2.10.0 to 2.10.1 in /flink-connectors/flink-connector-pulsar

2022-09-30 Thread GitBox
flinkbot commented on PR #20934: URL: https://github.com/apache/flink/pull/20934#issuecomment-1263891667 ## CI report: * 6cbcae8c6e692a220051d1361de480c41f106ef0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dependabot[bot] opened a new pull request, #20934: Bump pulsar-broker from 2.10.0 to 2.10.1 in /flink-connectors/flink-connector-pulsar

2022-09-30 Thread GitBox
dependabot[bot] opened a new pull request, #20934: URL: https://github.com/apache/flink/pull/20934 Bumps [pulsar-broker](https://github.com/apache/pulsar) from 2.10.0 to 2.10.1. Release notes Sourced from https://github.com/apache/pulsar/releases;>pulsar-broker's releases.

[GitHub] [flink] stevenzwu commented on pull request #19537: [FLINK-23589][flink-avro] Support microsecond precision for timestamp

2022-09-30 Thread GitBox
stevenzwu commented on PR #19537: URL: https://github.com/apache/flink/pull/19537#issuecomment-1263847172 @matriv is this PR blocked by https://issues.apache.org/jira/browse/FLINK-17224 and https://issues.apache.org/jira/browse/FLINK-27331? Without them, will the converters btw Flink

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #158: [FLINK-29409] Add Transformer and Estimator for VarianceThresholdSelector

2022-09-30 Thread GitBox
lindong28 commented on code in PR #158: URL: https://github.com/apache/flink-ml/pull/158#discussion_r984668405 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/VarianceThresholdSelectorTest.java: ## @@ -0,0 +1,294 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Created] (FLINK-29489) Display issue when querying complex, deeply nested fields

2022-09-30 Thread Justin (Jira)
Justin created FLINK-29489: -- Summary: Display issue when querying complex, deeply nested fields Key: FLINK-29489 URL: https://issues.apache.org/jira/browse/FLINK-29489 Project: Flink Issue Type:

[GitHub] [flink] alpinegizmo commented on a diff in pull request #20893: [FLINK-29403][cep] Streamline SimpleCondition usage

2022-09-30 Thread GitBox
alpinegizmo commented on code in PR #20893: URL: https://github.com/apache/flink/pull/20893#discussion_r984666197 ## flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java: ## @@ -40,4 +40,13 @@ public boolean filter(T value,

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611629#comment-17611629 ] Huang Xingbo commented on FLINK-29427: --

[jira] [Commented] (FLINK-29427) LookupJoinITCase failed with classloader problem

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611628#comment-17611628 ] Huang Xingbo commented on FLINK-29427: --

[jira] [Commented] (FLINK-29419) HybridShuffle.testHybridFullExchangesRestart hangs

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611627#comment-17611627 ] Huang Xingbo commented on FLINK-29419: --

[jira] [Commented] (FLINK-29483) flink python udf arrow in thread model bug

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611617#comment-17611617 ] Huang Xingbo commented on FLINK-29483: -- [~jackylau] You means your job runs in `thread mode` will

[GitHub] [flink] zentol commented on a diff in pull request #20930: [FLINK-29455] Introduce OperatorIdentifier

2022-09-30 Thread GitBox
zentol commented on code in PR #20930: URL: https://github.com/apache/flink/pull/20930#discussion_r984616865 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/OperatorIdentifier.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to the Apache

[GitHub] [flink] alpinegizmo commented on a diff in pull request #20930: [FLINK-29455] Introduce OperatorIdentifier

2022-09-30 Thread GitBox
alpinegizmo commented on code in PR #20930: URL: https://github.com/apache/flink/pull/20930#discussion_r984612707 ## flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/OperatorIdentifier.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to the Apache

[GitHub] [flink] XComp commented on a diff in pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-09-30 Thread GitBox
XComp commented on code in PR #20805: URL: https://github.com/apache/flink/pull/20805#discussion_r982266603 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java: ## @@ -42,10 +51,10 @@ class

[GitHub] [flink] RyanSkraba commented on a diff in pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-09-30 Thread GitBox
RyanSkraba commented on code in PR #20805: URL: https://github.com/apache/flink/pull/20805#discussion_r984598630 ## flink-test-utils-parent/flink-test-utils-junit/src/test/java/org/apache/flink/testutils/junit/RetryOnExceptionExtensionTest.java: ## @@ -42,10 +51,10 @@ class

[GitHub] [flink] RyanSkraba commented on a diff in pull request #20805: [FLINK-29198][test] Fail after maximum RetryOnException

2022-09-30 Thread GitBox
RyanSkraba commented on code in PR #20805: URL: https://github.com/apache/flink/pull/20805#discussion_r984596066 ## flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/junit/extensions/retry/strategy/RetryOnExceptionStrategy.java: ## @@ -37,6

[jira] [Closed] (FLINK-29484) Support orderless check of elements in SourceTestSuiteBase and SinkTestSuiteBase

2022-09-30 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot closed FLINK-29484. Resolution: Won't Fix Closing because it is already available by overriding

[jira] [Commented] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611580#comment-17611580 ] Matthias Pohl commented on FLINK-29485: --- A similar issue exists for

[jira] [Assigned] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-29485: - Assignee: Matthias Pohl > TypeSerializerUpgradeTestBase still uses 1.15 as the current

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Affects Version/s: (was: 1.17.0) > TypeSerializerUpgradeTestBase still uses 1.15 as the

[jira] [Commented] (FLINK-29484) Support orderless check of elements in SourceTestSuiteBase and SinkTestSuiteBase

2022-09-30 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611578#comment-17611578 ] Etienne Chauchot commented on FLINK-29484: -- It seems _UnorderedCollectIteratorAssert_ already

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Priority: Blocker (was: Critical) > TypeSerializerUpgradeTestBase still uses 1.15 as the

[jira] [Updated] (FLINK-29485) TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and release-1.16

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29485: -- Summary: TypeSerializerUpgradeTestBase still uses 1.15 as the current version on master and

[jira] [Comment Edited] (FLINK-29485) TypeSerializerUpgradeTestBase doesn't use FlinkVersions.current()

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611564#comment-17611564 ] Matthias Pohl edited comment on FLINK-29485 at 9/30/22 12:45 PM: - Using

[jira] [Commented] (FLINK-29485) TypeSerializerUpgradeTestBase doesn't use FlinkVersions.current()

2022-09-30 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611564#comment-17611564 ] Matthias Pohl commented on FLINK-29485: --- Using {{FlinkVerions.current()}} doesn't resolve the

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-30 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29476: -- Fix Version/s: 1.16.1 > Kinesis Connector retry mechanism not applied to EOFException >

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-30 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29476: -- Fix Version/s: 1.17.0 > Kinesis Connector retry mechanism not applied to EOFException >

[jira] [Updated] (FLINK-29476) Kinesis Connector retry mechanism not applied to EOFException

2022-09-30 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29476: -- Fix Version/s: 1.15.3 > Kinesis Connector retry mechanism not applied to EOFException >

[GitHub] [flink] dannycranmer commented on pull request #20927: [FLINK-29476][connector][kinesis] Retry connection termination with EOFException

2022-09-30 Thread GitBox
dannycranmer commented on PR #20927: URL: https://github.com/apache/flink/pull/20927#issuecomment-1263505523 Thanks @afedulov, LGTM. Can you please also open a PR against `release-1.16` and `release-1.15`? -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] dannycranmer commented on pull request #20927: [FLINK-29476][connector][kinesis] Retry connection termination with EOFException

2022-09-30 Thread GitBox
dannycranmer commented on PR #20927: URL: https://github.com/apache/flink/pull/20927#issuecomment-1263505008 @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] XComp commented on a diff in pull request #19780: [FLINK-27727][tests] Migrate TypeSerializerUpgradeTestBase to JUnit5

2022-09-30 Thread GitBox
XComp commented on code in PR #19780: URL: https://github.com/apache/flink/pull/19780#discussion_r983718553 ## flink-core/src/test/java/org/apache/flink/api/common/typeutils/TypeSerializerUpgradeTestBase.java: ## @@ -24,50 +24,52 @@ import

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

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611543#comment-17611543 ] Chesnay Schepler commented on FLINK-29387: -- Running the test multiple times in parallel locally

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611537#comment-17611537 ] Samrat Deb commented on FLINK-29478: haha :D Thank you  > Flink sql Connector hive to support 3.1.3

[jira] [Assigned] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29478: -- Assignee: Samrat Deb > Flink sql Connector hive to support 3.1.3 >

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611525#comment-17611525 ] Martijn Visser commented on FLINK-29478: Ah lol that's even my own ticket :D I'll assign the

[jira] [Comment Edited] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611522#comment-17611522 ] Samrat Deb edited comment on FLINK-29478 at 9/30/22 11:36 AM: -- Thanks

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611522#comment-17611522 ] Samrat Deb commented on FLINK-29478: Thanks [~martijnvisser] for your input  there is an associated

[jira] [Updated] (FLINK-28291) Add kerberos delegation token renewer feature instead of logged from keytab individually

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28291: - Fix Version/s: (was: 1.13.5) > Add kerberos delegation token renewer feature

[jira] [Updated] (FLINK-29487) RpcService should implement AutoCloseableAsync

2022-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29487: --- Labels: pull-request-available (was: ) > RpcService should implement AutoCloseableAsync >

[jira] [Updated] (FLINK-29488) MetricRegistryImpl should implement AutoCloseableAsync

2022-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29488: --- Labels: pull-request-available (was: ) > MetricRegistryImpl should implement

[GitHub] [flink] flinkbot commented on pull request #20933: [FLINK-29488][metrics] MetricRegistryImpl implements AutoCloseableAsync

2022-09-30 Thread GitBox
flinkbot commented on PR #20933: URL: https://github.com/apache/flink/pull/20933#issuecomment-1263450070 ## CI report: * 2b68e500b93936eba18d6d9352b5735d8f9ec898 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #20932: [FLINK-29487][rpc] RpcService extends AutoCloseableAsync

2022-09-30 Thread GitBox
flinkbot commented on PR #20932: URL: https://github.com/apache/flink/pull/20932#issuecomment-1263449935 ## CI report: * 9255ea9840abf5ebeed5afef552f2feb9b86d59d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611520#comment-17611520 ] Chesnay Schepler commented on FLINK-29330: -- Should LeaderRetrievalService really implement it

[jira] [Comment Edited] (FLINK-29330) Provide better logs of MiniCluster shutdown procedure

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611520#comment-17611520 ] Chesnay Schepler edited comment on FLINK-29330 at 9/30/22 11:20 AM:

[jira] [Created] (FLINK-29488) MetricRegistryImpl should implement AutoCloseableAsync

2022-09-30 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29488: Summary: MetricRegistryImpl should implement AutoCloseableAsync Key: FLINK-29488 URL: https://issues.apache.org/jira/browse/FLINK-29488 Project: Flink

[jira] [Created] (FLINK-29487) RpcService should implement AutoCloseableAsync

2022-09-30 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29487: Summary: RpcService should implement AutoCloseableAsync Key: FLINK-29487 URL: https://issues.apache.org/jira/browse/FLINK-29487 Project: Flink Issue

[jira] [Updated] (FLINK-29487) RpcService should implement AutoCloseableAsync

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29487: - Component/s: Runtime / RPC (was: Runtime / Coordination) >

[jira] [Updated] (FLINK-16908) FlinkKafkaProducerITCase testScaleUpAfterScalingDown Timeout expired while initializing transactional state in 60000ms.

2022-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16908: --- Fix Version/s: (was: 1.17.0) > FlinkKafkaProducerITCase testScaleUpAfterScalingDown

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

2022-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-21307: --- Fix Version/s: (was: 1.17.0) > Revisit activation model of FlinkSecurityManager >

[jira] [Updated] (FLINK-15550) testCancelTaskExceptionAfterTaskMarkedFailed failed on azure

2022-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15550: --- Fix Version/s: (was: 1.17.0) > testCancelTaskExceptionAfterTaskMarkedFailed failed on

[jira] [Updated] (FLINK-26568) BlockingShuffleITCase.testDeletePartitionFileOfBoundedBlockingShuffle timing out on Azure

2022-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-26568: --- Fix Version/s: (was: 1.17.0) >

[jira] [Updated] (FLINK-23970) Split off the behaviour for finished StreamTask(s)

2022-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23970: --- Fix Version/s: (was: 1.17.0) > Split off the behaviour for finished StreamTask(s) >

[GitHub] [flink] snuyanzin commented on pull request #20922: [DRAFT] Apply changes for calcite 1.27

2022-09-30 Thread GitBox
snuyanzin commented on PR #20922: URL: https://github.com/apache/flink/pull/20922#issuecomment-1263431047 @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] ferenc-csaky commented on a diff in pull request #20542: [FLINK-28910][Connectors/hbase]Fix potential data deletion while updating HBase rows

2022-09-30 Thread GitBox
ferenc-csaky commented on code in PR #20542: URL: https://github.com/apache/flink/pull/20542#discussion_r984470999 ## flink-connectors/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/HBaseSinkFunction.java: ## @@ -191,8 +195,10 @@ private void

[jira] [Commented] (FLINK-28910) CDC From Mysql To Hbase Bugs

2022-09-30 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611505#comment-17611505 ] Ferenc Csaky commented on FLINK-28910: -- My HBase knowledge is a bit rusty, so bear with me if any

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611497#comment-17611497 ] Martijn Visser commented on FLINK-29478: Instead of keep adding newer versions of Hive to

[GitHub] [flink] zentol commented on a diff in pull request #20893: [FLINK-29403][cep] Streamline SimpleCondition usage

2022-09-30 Thread GitBox
zentol commented on code in PR #20893: URL: https://github.com/apache/flink/pull/20893#discussion_r984453514 ## flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/conditions/SimpleCondition.java: ## @@ -40,4 +40,13 @@ public boolean filter(T value,

[jira] [Commented] (FLINK-29437) The partition of data before and after the Kafka Shuffle are not aligned

2022-09-30 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611494#comment-17611494 ] Zakelly Lan commented on FLINK-29437: - After offline sync with [~ym] , we agree to fix this as I

[jira] [Updated] (FLINK-29480) Skip invalid messages when writing

2022-09-30 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Salva updated FLINK-29480: -- Description: As reported in [1], it seems that it's not possible to skip invalid messages when writing. More

[jira] [Updated] (FLINK-29480) Skip invalid messages when writing

2022-09-30 Thread Salva (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Salva updated FLINK-29480: -- Description: As reported in [1], it seems that it's not possible to skip invalid messages when writing. More

[GitHub] [flink] flinkbot commented on pull request #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-09-30 Thread GitBox
flinkbot commented on PR #20931: URL: https://github.com/apache/flink/pull/20931#issuecomment-1263369448 ## CI report: * 32763443345314018b4c308bc6a8d83c43491fdf UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #20930: [FLINK-29455] Introduce OperatorIdentifier

2022-09-30 Thread GitBox
flinkbot commented on PR #20930: URL: https://github.com/apache/flink/pull/20930#issuecomment-1263364132 ## CI report: * 3366ecff5109a8ba5c64a4b2b603f319d0bc3750 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] yuzelin opened a new pull request, #20931: [FLINK-29486][sql-client] Implement ClientParser for implementing remote SQL client later

2022-09-30 Thread GitBox
yuzelin opened a new pull request, #20931: URL: https://github.com/apache/flink/pull/20931 ## What is the purpose of the change The current `SqlCommandParserImpl` for SQL client use the paser of embedded `TableEnvironment`, which cannot be fetched in remote mode. So this PR

[jira] [Commented] (FLINK-29478) Flink sql Connector hive to support 3.1.3

2022-09-30 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611478#comment-17611478 ] Samrat Deb commented on FLINK-29478: Thank you [~dannycranmer] for addressing to this issue . 

[jira] [Updated] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode

2022-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29486: --- Labels: pull-request-available (was: ) > Enable SQL Client to Connect SQL Gateway in

[jira] [Updated] (FLINK-29455) Add OperatorIdentifier

2022-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29455: --- Labels: pull-request-available (was: ) > Add OperatorIdentifier > -- >

[GitHub] [flink] zentol opened a new pull request, #20930: [FLINK-29455] Introduce OperatorIdentifier

2022-09-30 Thread GitBox
zentol opened a new pull request, #20930: URL: https://github.com/apache/flink/pull/20930 This PR introduces an `OperatorIdentifier`, an abstraction over uid (hashes), and integrates it into the internal state-processing APIs. In a follow-up PR we'll adjust the user-facing APIs to

[GitHub] [flink-ml] zhipeng93 merged pull request #155: [FLINK-29318] Add Transformer for PolynomialExpansion

2022-09-30 Thread GitBox
zhipeng93 merged PR #155: URL: https://github.com/apache/flink-ml/pull/155 -- 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] zhipeng93 commented on pull request #155: [FLINK-29318] Add Transformer for PolynomialExpansion

2022-09-30 Thread GitBox
zhipeng93 commented on PR #155: URL: https://github.com/apache/flink-ml/pull/155#issuecomment-1263355508 Thanks for the update. Merging. -- 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

[jira] [Commented] (FLINK-29479) support whether using system env for pythonpath

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611469#comment-17611469 ] Huang Xingbo commented on FLINK-29479: -- [~jackylau] From my side, the users dependency will have a

[jira] [Updated] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode

2022-09-30 Thread yuzelin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-29486: Description: In [FLIP-24] and  

[jira] [Commented] (FLINK-29471) Create a flink-connector-parent pom

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17611467#comment-17611467 ] Chesnay Schepler commented on FLINK-29471: -- elasticsearch-main:

[GitHub] [flink-connector-rabbitmq] zentol commented on pull request #1: [FLINK-20628] RabbitMQ Connector using FLIP-27 Source API

2022-09-30 Thread GitBox
zentol commented on PR #1: URL: https://github.com/apache/flink-connector-rabbitmq/pull/1#issuecomment-1263341587 You can avoid a lot of boilerplate by using the preliminary flink-connector-parent pom as shown here:

[jira] [Closed] (FLINK-29372) Add a suffix to keys that violate YAML spec

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29372. Resolution: Fixed > Add a suffix to keys that violate YAML spec >

[GitHub] [flink-connector-elasticsearch] zentol merged pull request #40: [FLINK-29471] Use connector parent pom

2022-09-30 Thread GitBox
zentol merged PR #40: URL: https://github.com/apache/flink-connector-elasticsearch/pull/40 -- 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] [Updated] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode

2022-09-30 Thread yuzelin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-29486: Description: In [FLIP-24|https://cwiki.apache.org/confluence/display/FLINK/FLIP-24%3A+SQL+Client] and  

[jira] [Updated] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode

2022-09-30 Thread yuzelin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yuzelin updated FLINK-29486: Description: In [FLIP-24|http://example.com] and  [FLIP-91|], the SQL client was designed to has two

[jira] [Updated] (FLINK-29471) Create a flink-connector-parent pom

2022-09-30 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29471: - Fix Version/s: elasticsearch-3.0.0 > Create a flink-connector-parent pom >

[jira] [Created] (FLINK-29486) Enable SQL Client to Connect SQL Gateway in Remote Mode

2022-09-30 Thread yuzelin (Jira)
yuzelin created FLINK-29486: --- Summary: Enable SQL Client to Connect SQL Gateway in Remote Mode Key: FLINK-29486 URL: https://issues.apache.org/jira/browse/FLINK-29486 Project: Flink Issue Type:

[jira] [Created] (FLINK-29485) TypeSerializerUpgradeTestBase doesn't use FlinkVersions.current()

2022-09-30 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29485: - Summary: TypeSerializerUpgradeTestBase doesn't use FlinkVersions.current() Key: FLINK-29485 URL: https://issues.apache.org/jira/browse/FLINK-29485 Project: Flink

[jira] [Updated] (FLINK-29350) Add a section for moving planner jar in Hive dependencies page

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29350: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add a section for moving planner

[jira] [Updated] (FLINK-28071) Support missing built-in functions in Table API

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-28071: - Fix Version/s: 1.17.0 (was: 1.16.0) > Support missing built-in functions

[jira] [Updated] (FLINK-27467) Remove CliFrontendTestBase

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27467: - Fix Version/s: 1.17.0 (was: 1.16.0) > Remove CliFrontendTestBase >

[jira] [Updated] (FLINK-29372) Add a suffix to keys that violate YAML spec

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29372: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add a suffix to keys that violate

[jira] [Updated] (FLINK-29430) Sanity check in InternalKeyContextImpl#setCurrentKeyGroupIndex

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29430: - Fix Version/s: 1.17.0 (was: 1.16.0) > Sanity check in

[jira] [Updated] (FLINK-27432) Replace Time with Duration in TaskSlotTable

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27432: - Fix Version/s: 1.17.0 (was: 1.16.0) > Replace Time with Duration in

[jira] [Updated] (FLINK-27075) Migrate CI from Azure to Github Actions

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-27075: - Fix Version/s: 1.17.0 1.16.1 (was: 1.16.0)

[jira] [Updated] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-26360: - Fix Version/s: 1.17.0 (was: 1.16.0) > [Umbrella] Improvement for Hive

[jira] [Updated] (FLINK-29402) Add USE_DIRECT_READ configuration parameter for RocksDB

2022-09-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-29402: - Fix Version/s: 1.17.0 (was: 1.16.0) > Add USE_DIRECT_READ configuration

  1   2   3   4   >