[jira] [Updated] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak

2023-04-24 Thread datariver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] datariver updated FLINK-31914: -- Attachment: (was: image-2023-04-24-16-11-22-251.png) > Failing to close

[jira] [Updated] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak

2023-04-24 Thread datariver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] datariver updated FLINK-31914: -- Description: Hi [~arvid] , If Exactly-Once writing is enabled, Kafka's transactional writing will be

[jira] [Updated] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak

2023-04-24 Thread datariver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] datariver updated FLINK-31914: -- Attachment: image-2023-04-25-13-47-25-703.png > Failing to close FlinkKafkaInternalProducer created

[GitHub] [flink] reswqa commented on pull request #22447: [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-04-24 Thread via GitHub
reswqa commented on PR #22447: URL: https://github.com/apache/flink/pull/22447#issuecomment-1521183716 Thanks @1996fanrui for the quick review, I have updated this in a fix-up commit, please take a look~ -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] reswqa commented on a diff in pull request #22447: [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-04-24 Thread via GitHub
reswqa commented on code in PR #22447: URL: https://github.com/apache/flink/pull/22447#discussion_r1176029546 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java: ## @@ -878,6 +874,18 @@ private void

[GitHub] [flink] reswqa commented on a diff in pull request #22445: [FLINK-31876][QS] Migrate flink-queryable-state-client tests to JUnit5

2023-04-24 Thread via GitHub
reswqa commented on code in PR #22445: URL: https://github.com/apache/flink/pull/22445#discussion_r1176019508 ## flink-queryable-state/flink-queryable-state-client-java/src/test/java/org/apache/flink/queryablestate/client/state/ImmutableAggregatingStateTest.java: ## @@ -53,20

[jira] [Updated] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31748: --- Affects Version/s: pulsar-4.0.0 > Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

[jira] [Updated] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-31748: --- Component/s: Connectors / Pulsar > Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

[jira] [Closed] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31748. -- Fix Version/s: pulsar-4.0.1 Resolution: Fixed > Adapt SplitFetcherManager#removeSplit for

[jira] [Commented] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716082#comment-17716082 ] Weijie Guo commented on FLINK-31748: Temporarily fixed in main via

[jira] [Comment Edited] (FLINK-24785) Relocate RocksDB's log under flink log directory by default

2023-04-24 Thread jinghaihang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707083#comment-17707083 ] jinghaihang edited comment on FLINK-24785 at 4/25/23 4:44 AM: --

[jira] [Assigned] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31748: -- Assignee: Zili Chen (was: Yufan Sheng) > Adapt SplitFetcherManager#removeSplit for

[jira] [Commented] (FLINK-31918) Pulsar Source does not failing build against Flink 1.18 on nightly CI

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716077#comment-17716077 ] Weijie Guo commented on FLINK-31918: This compile problem should already be fixed in

[jira] [Assigned] (FLINK-31560) Savepoint failing to complete with ExternallyInducedSources

2023-04-24 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-31560: -- Assignee: Yanfei Lei > Savepoint failing to complete with ExternallyInducedSources >

[jira] [Commented] (FLINK-31560) Savepoint failing to complete with ExternallyInducedSources

2023-04-24 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716075#comment-17716075 ] Yanfei Lei commented on FLINK-31560: [~fyang86] After reading the

[jira] [Commented] (FLINK-31929) HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in k8s with IPv6 stack

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716074#comment-17716074 ] Weijie Guo commented on FLINK-31929: Thanks [~caiyi], would you mind submitting a pull request and

[jira] [Assigned] (FLINK-31931) Exception history page should not link to a non-existent TM log page.

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31931: -- Assignee: Junrui Li > Exception history page should not link to a non-existent TM log page.

[jira] [Created] (FLINK-31931) Exception history page should not link to a non-existent TM log page.

2023-04-24 Thread Junrui Li (Jira)
Junrui Li created FLINK-31931: - Summary: Exception history page should not link to a non-existent TM log page. Key: FLINK-31931 URL: https://issues.apache.org/jira/browse/FLINK-31931 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #22481: [FLINK-27805] bump orc version to 1.7.8

2023-04-24 Thread via GitHub
flinkbot commented on PR #22481: URL: https://github.com/apache/flink/pull/22481#issuecomment-1521126055 ## CI report: * 8a31508bb40da5f27e122d679175d8d545e6b38e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-31887) Upgrade Flink version of Flink ML to 1.16.1

2023-04-24 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-31887: Assignee: Jiang Xin > Upgrade Flink version of Flink ML to 1.16.1 >

[GitHub] [flink-ml] lindong28 commented on pull request #234: [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1

2023-04-24 Thread via GitHub
lindong28 commented on PR #234: URL: https://github.com/apache/flink-ml/pull/234#issuecomment-1521123703 Thanks for the update. LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-27805) Bump ORC version to 1.7.8

2023-04-24 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-27805: --- Summary: Bump ORC version to 1.7.8 (was: Bump ORC version to 1.7.5) > Bump

[GitHub] [flink] pgaref opened a new pull request, #22481: [FLINK-27805] bump orc version to 1.7.8

2023-04-24 Thread via GitHub
pgaref opened a new pull request, #22481: URL: https://github.com/apache/flink/pull/22481 Bump to orc 1.7.8 -- [Release Notes](https://orc.apache.org/news/releases/) ORC now supports writers with FSDataOutputStream (instead of just paths previously) so cleaning NoHivePhysicalWriterImpl

[GitHub] [flink] 1996fanrui commented on a diff in pull request #22447: [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool

2023-04-24 Thread via GitHub
1996fanrui commented on code in PR #22447: URL: https://github.com/apache/flink/pull/22447#discussion_r1175969922 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java: ## @@ -878,6 +874,18 @@ private void

[GitHub] [flink-ml] jiangxin369 commented on pull request #234: [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1

2023-04-24 Thread via GitHub
jiangxin369 commented on PR #234: URL: https://github.com/apache/flink-ml/pull/234#issuecomment-1521110530 @lindong28 Could you have another 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 to

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #234: [FLINK-31887] Upgrade Flink version of Flink ML to 1.16.1

2023-04-24 Thread via GitHub
jiangxin369 commented on code in PR #234: URL: https://github.com/apache/flink-ml/pull/234#discussion_r1175973954 ## flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java: ## @@ -136,31 +135,20 @@ public static StreamConfig

[GitHub] [flink] flinkbot commented on pull request #22480: [FLINK-31897][Backport 1.16] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-24 Thread via GitHub
flinkbot commented on PR #22480: URL: https://github.com/apache/flink/pull/22480#issuecomment-1521102621 ## CI report: * 64c595bd2cab5baaed949d7702500f800e2c9f1d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22479: [FLINK-31897][Backport 1.17] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-24 Thread via GitHub
flinkbot commented on PR #22479: URL: https://github.com/apache/flink/pull/22479#issuecomment-1521100027 ## CI report: * bb255f2fe9e9341ded3851bdc51816ea54ca8783 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22480: [FLINK-31897][Backport 1.16] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-24 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22480: URL: https://github.com/apache/flink/pull/22480 ## What is the purpose of the change Bach port to 1.16, the PR has been reviewed at https://github.com/apache/flink/pull/22471. Fix the unstable test

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22479: [FLINK-31897][Backport 1.17] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-24 Thread via GitHub
TanYuxin-tyx opened a new pull request, #22479: URL: https://github.com/apache/flink/pull/22479 ## What is the purpose of the change Bach port to 1.17, the PR has been reviewed at https://github.com/apache/flink/pull/22471. Fix the unstable test

[jira] [Closed] (FLINK-31907) Remove unused fields inside of ExecutionSlotSharingGroupBuilder

2023-04-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31907. --- Fix Version/s: 1.18.0 Resolution: Fixed > Remove unused fields inside of

[jira] [Commented] (FLINK-31907) Remove unused fields inside of ExecutionSlotSharingGroupBuilder

2023-04-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716069#comment-17716069 ] Rui Fan commented on FLINK-31907: - Thanks [~wanglijie] for the review. master(1.18) via

[GitHub] [flink] 1996fanrui merged pull request #22472: [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder

2023-04-24 Thread via GitHub
1996fanrui merged PR #22472: URL: https://github.com/apache/flink/pull/22472 -- 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] 1996fanrui commented on pull request #22472: [FLINK-31907][coordination] Remove the unused field inside ExecutionSlotSharingGroupBuilder

2023-04-24 Thread via GitHub
1996fanrui commented on PR #22472: URL: https://github.com/apache/flink/pull/22472#issuecomment-1521094800 Hi @wanglijie95 , thanks for your review! 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

[jira] [Commented] (FLINK-31908) cast expr to type with not null should not change nullable of expr

2023-04-24 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716062#comment-17716062 ] jackylau commented on FLINK-31908: -- hi [~jark] i will fix in calcite first here

[jira] [Commented] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-24 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716063#comment-17716063 ] Feifan Wang commented on FLINK-31900: - Thanks [~Weijie Guo] for review and merge the PR ! > Fix

[jira] [Closed] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-31900. -- Fix Version/s: 1.18.0 Resolution: Fixed master(1.18) via

[jira] [Assigned] (FLINK-31900) Fix some typo in java doc, comments and assertion message

2023-04-24 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-31900: -- Assignee: Feifan Wang > Fix some typo in java doc, comments and assertion message >

[GitHub] [flink] reswqa merged pull request #22470: [FLINK-31900] Fix some typo in java doc, comments and assertion message

2023-04-24 Thread via GitHub
reswqa merged PR #22470: URL: https://github.com/apache/flink/pull/22470 -- 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] FangYongs commented on a diff in pull request #22362: [FLINK-31544][jdbc-driver] Introduce database metadata for jdbc driver

2023-04-24 Thread via GitHub
FangYongs commented on code in PR #22362: URL: https://github.com/apache/flink/pull/22362#discussion_r1175955153 ## flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkDatabaseMetaData.java: ## @@ -0,0 +1,402 @@ +/* + * Licensed to the Apache

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175948882 ## flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java: ## @@ -0,0 +1,1073 @@ +/* + * Licensed to

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175946496 ## flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java: ## @@ -0,0 +1,1359 @@ +/* + * Licensed

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175948882 ## flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java: ## @@ -0,0 +1,1073 @@ +/* + * Licensed to

[jira] [Closed] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

2023-04-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan closed FLINK-31588. --- Fix Version/s: 1.16.2 1.17.1 Resolution: Fixed > The unaligned checkpoint type is

[jira] [Comment Edited] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

2023-04-24 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715340#comment-17715340 ] Rui Fan edited comment on FLINK-31588 at 4/25/23 2:23 AM: -- Thanks [~pnowojski]

[GitHub] [flink] 1996fanrui merged pull request #22453: [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment

2023-04-24 Thread via GitHub
1996fanrui merged PR #22453: URL: https://github.com/apache/flink/pull/22453 -- 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] 1996fanrui merged pull request #22454: [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment

2023-04-24 Thread via GitHub
1996fanrui merged PR #22454: URL: https://github.com/apache/flink/pull/22454 -- 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] 1996fanrui commented on pull request #22454: [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment

2023-04-24 Thread via GitHub
1996fanrui commented on PR #22454: URL: https://github.com/apache/flink/pull/22454#issuecomment-1521063518 Thanks for the review, 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

[GitHub] [flink] 1996fanrui commented on pull request #22453: [FLINK-31588][checkpoint] Correct the unaligned checkpoint type based on the bytesPersistedDuringAlignment

2023-04-24 Thread via GitHub
1996fanrui commented on PR #22453: URL: https://github.com/apache/flink/pull/22453#issuecomment-1521062875 Thanks for the review, 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

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175947290 ## flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java: ## @@ -144,6 +145,194 @@ public enum

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175946496 ## flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java: ## @@ -0,0 +1,1359 @@ +/* + * Licensed

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175945787 ## flink-catalog-aws/flink-catalog-aws-glue/src/test/java/org/apache/flink/table/catalog/glue/GlueCatalogTest.java: ## @@ -0,0 +1,351 @@ +/* + * Licensed to

[GitHub] [flink] zoltar9264 commented on pull request #22470: [FLINK-31900] Fix some typo in java doc, comments and assertion message

2023-04-24 Thread via GitHub
zoltar9264 commented on PR #22470: URL: https://github.com/apache/flink/pull/22470#issuecomment-1521057618 Thanks @reswqa and @TanYuxin-tyx for help review the pr ! Since the ci is passed , can you help me merge it ? -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] Aitozi commented on pull request #22455: [FLINK-31828][planner] Use the inner serializer for RawType when doin…

2023-04-24 Thread via GitHub
Aitozi commented on PR #22455: URL: https://github.com/apache/flink/pull/22455#issuecomment-1521057087 @wuchong, @twalthr could you help review this fix ? -- 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

[jira] [Commented] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak

2023-04-24 Thread chouc (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716059#comment-17716059 ] chouc commented on FLINK-31914: --- {color:#00}The FlinkKafkaInternalProducer is registered in Closer and

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in k8s with IPv6 stack

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31928: -- Summary: flink-kubernetes works not properly in k8s with IPv6 stack (was: flink-kubernetes works not

[jira] [Updated] (FLINK-31930) MetricQueryService works not properly in k8s with IPv6 stack

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31930: -- Component/s: Runtime / RPC > MetricQueryService works not properly in k8s with IPv6 stack >

[jira] [Updated] (FLINK-31929) HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in k8s with IPv6 stack

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31929: -- Summary: HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in k8s with IPv6 stack (was:

[jira] [Updated] (FLINK-31930) MetricQueryService works not properly in k8s with IPv6 stack

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31930: -- Attachment: 1.jpg > MetricQueryService works not properly in k8s with IPv6 stack >

[jira] [Created] (FLINK-31930) MetricQueryService works not properly in k8s with IPv6 stack

2023-04-24 Thread caiyi (Jira)
caiyi created FLINK-31930: - Summary: MetricQueryService works not properly in k8s with IPv6 stack Key: FLINK-31930 URL: https://issues.apache.org/jira/browse/FLINK-31930 Project: Flink Issue Type:

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in IPv6 environment in k8s

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31928: -- Description: As [https://github.com/square/okhttp/issues/7368|https://github.com/square/okhttp/issues/7368,]

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in IPv6 environment in k8s

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31928: -- Priority: Blocker (was: Critical) > flink-kubernetes works not properly in IPv6 environment in k8s >

[jira] [Updated] (FLINK-31929) HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in IPv6 stack of k8s

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31929: -- Priority: Blocker (was: Critical) > HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in

[jira] [Updated] (FLINK-31914) Failing to close FlinkKafkaInternalProducer created in KafkaWriter with exactly-once semantic results in memory leak

2023-04-24 Thread datariver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] datariver updated FLINK-31914: -- Affects Version/s: 1.16.0 > Failing to close FlinkKafkaInternalProducer created in KafkaWriter with

[jira] [Created] (FLINK-31929) HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in IPv6 stack of k8s

2023-04-24 Thread caiyi (Jira)
caiyi created FLINK-31929: - Summary: HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in IPv6 stack of k8s Key: FLINK-31929 URL: https://issues.apache.org/jira/browse/FLINK-31929

[jira] [Updated] (FLINK-31928) flink-kubernetes works not properly in IPv6 environment in k8s

2023-04-24 Thread caiyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] caiyi updated FLINK-31928: -- Description: As [https://github.com/square/okhttp/issues/7368|https://github.com/square/okhttp/issues/7368,]

[jira] [Created] (FLINK-31928) flink-kubernetes works not properly in IPv6 environment in k8s

2023-04-24 Thread caiyi (Jira)
caiyi created FLINK-31928: - Summary: flink-kubernetes works not properly in IPv6 environment in k8s Key: FLINK-31928 URL: https://issues.apache.org/jira/browse/FLINK-31928 Project: Flink Issue

[jira] [Assigned] (FLINK-31884) Upgrade ExecNode to new version causes the old serialized plan failed to pass Json SerDe round trip

2023-04-24 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-31884: --- Assignee: Jane Chan > Upgrade ExecNode to new version causes the old serialized plan

[GitHub] [flink] zzzzzzzs commented on a diff in pull request #22452: [FLINK-31881][docs] Fix the confusion in the Chinese documentation page of Flink official CEP, and add the Scala code of timesOrMo

2023-04-24 Thread via GitHub
zzzs commented on code in PR #22452: URL: https://github.com/apache/flink/pull/22452#discussion_r1175917651 ## docs/content.zh/docs/libs/cep.md: ## @@ -477,6 +477,11 @@ pattern.oneOrMore() pattern.timesOrMore(2); ``` {{< /tab >}} +{{< tab "Scala" >}} +```scala

[jira] [Comment Edited] (FLINK-31898) Flink k8s autoscaler does not work as expected

2023-04-24 Thread Kyungmin Kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715632#comment-17715632 ] Kyungmin Kim edited comment on FLINK-31898 at 4/25/23 12:50 AM: Hi I

[GitHub] [flink] noomanee commented on pull request #22400: [FLINK-31689][flink-connector-files] Check expired file state before …

2023-04-24 Thread via GitHub
noomanee commented on PR #22400: URL: https://github.com/apache/flink/pull/22400#issuecomment-1521005073 @MartijnVisser Gentle Reminder -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink-connector-pulsar] tisonkun merged pull request #43: [FLINK-31748] Dummy implementation to fix compilation failure

2023-04-24 Thread via GitHub
tisonkun merged PR #43: URL: https://github.com/apache/flink-connector-pulsar/pull/43 -- 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-connector-pulsar] tisonkun commented on pull request #43: [FLINK-31748] Dummy implementation to fix compilation failure

2023-04-24 Thread via GitHub
tisonkun commented on PR #43: URL: https://github.com/apache/flink-connector-pulsar/pull/43#issuecomment-1520993271 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 specific

[GitHub] [flink-connector-aws] vahmed-hamdy commented on a diff in pull request #70: [FLINK-31772] Adjusting Kinesis Ratelimiting strategy to fix performance regression

2023-04-24 Thread via GitHub
vahmed-hamdy commented on code in PR #70: URL: https://github.com/apache/flink-connector-aws/pull/70#discussion_r1175722682 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java: ## @@ -144,6 +150,8 @@

[GitHub] [flink-kubernetes-operator] mxm merged pull request #574: [FLINK-31827] Discard old format scaling history

2023-04-24 Thread via GitHub
mxm merged PR #574: URL: https://github.com/apache/flink-kubernetes-operator/pull/574 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #574: [FLINK-31827] Discard old format scaling history

2023-04-24 Thread via GitHub
mxm commented on code in PR #574: URL: https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175710518 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java: ## @@ -95,7 +95,7 @@ public

[jira] [Assigned] (FLINK-31927) Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster

2023-04-24 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot reassigned FLINK-31927: Assignee: Etienne Chauchot > Cassandra source raises an exception on Flink

[jira] [Created] (FLINK-31927) Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster

2023-04-24 Thread Etienne Chauchot (Jira)
Etienne Chauchot created FLINK-31927: Summary: Cassandra source raises an exception on Flink 1.16.0 on a real Cassandra cluster Key: FLINK-31927 URL: https://issues.apache.org/jira/browse/FLINK-31927

[GitHub] [flink] chachae commented on pull request #22446: [FLINK-28060][BP 1.15][Connector/Kafka] Updated Kafka Clients to 3.2.1

2023-04-24 Thread via GitHub
chachae commented on PR #22446: URL: https://github.com/apache/flink/pull/22446#issuecomment-1520556636 > @chachae Flink 1.15 is no longer community supported; therefore closing the PR. Okay,but we use Flink 1.15 on a large scale, and it's hard to carry out large scale version

[GitHub] [flink] chachae commented on pull request #22446: [FLINK-28060][BP 1.15][Connector/Kafka] Updated Kafka Clients to 3.2.1

2023-04-24 Thread via GitHub
chachae commented on PR #22446: URL: https://github.com/apache/flink/pull/22446#issuecomment-1520556021 > @chachae Flink 1.15 is no longer community supported; therefore closing the PR. > @chachae Flink 1.15 is no longer community supported; therefore closing the PR.

[GitHub] [flink] chachae commented on pull request #22446: [FLINK-28060][BP 1.15][Connector/Kafka] Updated Kafka Clients to 3.2.1

2023-04-24 Thread via GitHub
chachae commented on PR #22446: URL: https://github.com/apache/flink/pull/22446#issuecomment-1520554286 > Okay,but we use Flink 1.15 on a large scale, and it's hard to carry out large scale version upgrade for flink jobs with strong dependence on state -- This is an automated

[GitHub] [flink] pgaref commented on pull request #22467: FLINK-31888: Introduce interfaces and utils for loading and executing enrichers

2023-04-24 Thread via GitHub
pgaref commented on PR #22467: URL: https://github.com/apache/flink/pull/22467#issuecomment-1520551610 @dmvk / @akalash can you please take 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-31922) Port over Kinesis Client configurations for retry and backoff

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31922: -- Component/s: Connectors / AWS > Port over Kinesis Client configurations for retry and backoff

[jira] [Updated] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31922: -- Fix Version/s: aws-connector-4.2.0 > Port over Kinesis Client configurations for retry and

[jira] [Assigned] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-31922: - Assignee: Daren Wong > Port over Kinesis Client configurations for retry and backoff >

[GitHub] [flink-connector-aws] Samrat002 commented on a diff in pull request #47: [FLINK-30481][FLIP-277] GlueCatalog Implementation

2023-04-24 Thread via GitHub
Samrat002 commented on code in PR #47: URL: https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175579217 ## flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java: ## @@ -0,0 +1,1359 @@ +/* + * Licensed

[jira] [Created] (FLINK-31926) Implement rename Table in GlueCatalog

2023-04-24 Thread Samrat Deb (Jira)
Samrat Deb created FLINK-31926: -- Summary: Implement rename Table in GlueCatalog Key: FLINK-31926 URL: https://issues.apache.org/jira/browse/FLINK-31926 Project: Flink Issue Type: Sub-task

[GitHub] [flink-kubernetes-operator] mxm commented on a diff in pull request #574: [FLINK-31827] Discard old format scaling history

2023-04-24 Thread via GitHub
mxm commented on code in PR #574: URL: https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175535065 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java: ## @@ -95,7 +95,7 @@ public

[jira] [Closed] (FLINK-25003) RestClientTest#testConnectionTimeout fails on Java 17

2023-04-24 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25003. Resolution: Cannot Reproduce > RestClientTest#testConnectionTimeout fails on Java 17 >

[GitHub] [flink] XComp commented on pull request #22422: [FLINK-31838][runtime] Moves thread handling for leader event listener calls from DefaultMultipleComponentLeaderElectionService into DefaultLea

2023-04-24 Thread via GitHub
XComp commented on PR #22422: URL: https://github.com/apache/flink/pull/22422#issuecomment-1520425379 Thanks for the reviews. I squashed the commits in https://github.com/apache/flink/commit/e1997df38d2bd380804a1a1814d14b75db2493ed and rebased the branch in

[GitHub] [flink] flinkbot commented on pull request #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

2023-04-24 Thread via GitHub
flinkbot commented on PR #22478: URL: https://github.com/apache/flink/pull/22478#issuecomment-1520406754 ## CI report: * cdeeb1d2fe4be4be301727d378010f7c4750d87c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31917) Loss of Idempotence in JsonSerDe Round Trip for AggregateCall and RexNode

2023-04-24 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31917: --- Labels: pull-request-available (was: ) > Loss of Idempotence in JsonSerDe Round Trip for

[GitHub] [flink] LadyForest opened a new pull request, #22478: [FLINK-31917][table-planner] Fix the idempotence lost in JsonSerDe round trip for AggregateCall and RexNode

2023-04-24 Thread via GitHub
LadyForest opened a new pull request, #22478: URL: https://github.com/apache/flink/pull/22478 ## What is the purpose of the change This PR aims to fix the FLINK-31917. The details can be found in the ticket's description. ## Brief change log - Fix the issue that

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #574: [FLINK-31827] Discard old format scaling history

2023-04-24 Thread via GitHub
gyfora commented on code in PR #574: URL: https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175451671 ## flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java: ## @@ -95,7 +95,7 @@ public

[GitHub] [flink-kubernetes-operator] mxm opened a new pull request, #574: [FLINK-31827] Discard old format scaling history

2023-04-24 Thread via GitHub
mxm opened a new pull request, #574: URL: https://github.com/apache/flink-kubernetes-operator/pull/574 We recently change the format for the metric history but this also affects the scaling history because it contains new / old scaling metrics. -- This is an automated message from

[GitHub] [flink] TanYuxin-tyx commented on pull request #22471: [FLINK-31897] Fix the unstable test ClientTest#testRequestUnavailableHost

2023-04-24 Thread via GitHub
TanYuxin-tyx commented on PR #22471: URL: https://github.com/apache/flink/pull/22471#issuecomment-1520356264 @zentol Thanks for the quick replies and ideas. Since no real servers are created based on the server address, I think the given fixed port is enough. And the hostname has

[jira] [Updated] (FLINK-22828) Allow using a custom AWS credentials provider for AWS Connectors

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-22828: -- Summary: Allow using a custom AWS credentials provider for AWS Connectors (was: Allow using

[jira] [Resolved] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-22828. --- Resolution: Done > Allow using a custom AWS credentials provider for the Kinesis Connector

[jira] [Commented] (FLINK-22828) Allow using a custom AWS credentials provider for the Kinesis Connector

2023-04-24 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715857#comment-17715857 ] Danny Cranmer commented on FLINK-22828: --- Merged commit

[GitHub] [flink-connector-aws] dannycranmer merged pull request #69: [FLINK-22828][Connectors/AWS] Configure custom AWS creds provider

2023-04-24 Thread via GitHub
dannycranmer merged PR #69: URL: https://github.com/apache/flink-connector-aws/pull/69 -- 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:

  1   2   3   4   >