[jira] [Resolved] (FLINK-32906) Release Testing: Verify FLIP-279 Unified the max display column width for SqlClient and Table APi in both Streaming and Batch execMode

2023-09-11 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-32906. - Resolution: Fixed > Release Testing: Verify FLIP-279 Unified the max display column width for > SqlClie

[jira] [Resolved] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

2023-09-11 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-32803. --- Resolution: Done > Release Testing: Verify FLINK-32165 - Improve observability of fine-grain

[jira] [Commented] (FLINK-32803) Release Testing: Verify FLINK-32165 - Improve observability of fine-grained resource management

2023-09-11 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764033#comment-17764033 ] Qingsheng Ren commented on FLINK-32803: --- Mark as resolved as the test result looks

[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.18.0 > NPE when using GREATEST() in Flink SQL > -

[jira] [Comment Edited] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763486#comment-17763486 ] Sergey Nuyanzin edited comment on FLINK-33010 at 9/12/23 6:45 AM:

[jira] [Updated] (FLINK-30470) Change groupId for flink-connector-parent

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30470: --- Labels: pull-request-available (was: ) > Change groupId for flink-connector-parent > --

[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.17.2 > NPE when using GREATEST() in Flink SQL > -

[jira] [Comment Edited] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763486#comment-17763486 ] Sergey Nuyanzin edited comment on FLINK-33010 at 9/12/23 6:43 AM:

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #95: [FLINK-30470][build] Change groupId for flink-connector-parent

2023-09-11 Thread via GitHub
boring-cyborg[bot] commented on PR #95: URL: https://github.com/apache/flink-connector-aws/pull/95#issuecomment-1715095098 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an

[GitHub] [flink-connector-aws] ruanhang1993 opened a new pull request, #95: [FLINK-30470][build] Change groupId for flink-connector-parent

2023-09-11 Thread via GitHub
ruanhang1993 opened a new pull request, #95: URL: https://github.com/apache/flink-connector-aws/pull/95 ## Purpose of the change Change groupId for flink-connector-parent. ## Verifying this change This change is already covered by existing tests ## Significant chan

[jira] [Updated] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Fix Version/s: 1.16.3 > NPE when using GREATEST() in Flink SQL > -

[jira] [Comment Edited] (FLINK-33010) NPE when using GREATEST() in Flink SQL

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763486#comment-17763486 ] Sergey Nuyanzin edited comment on FLINK-33010 at 9/12/23 6:42 AM:

[GitHub] [flink-connector-pulsar] ruanhang1993 opened a new pull request, #60: [hotfix] Update NOTICE files to reflect year 2023

2023-09-11 Thread via GitHub
ruanhang1993 opened a new pull request, #60: URL: https://github.com/apache/flink-connector-pulsar/pull/60 ## Purpose of the change Update NOTICE files to reflect year 2023. ## Brief change log Update NOTICE files to reflect year 2023. ## Verifying this change

[jira] [Updated] (FLINK-33064) Improve the error message when the lookup source is used as the scan source

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33064: --- Labels: pull-request-available (was: ) > Improve the error message when the lookup source i

[GitHub] [flink-connector-cassandra] boring-cyborg[bot] commented on pull request #20: [hotfix] Update NOTICE files to reflect year 2023

2023-09-11 Thread via GitHub
boring-cyborg[bot] commented on PR #20: URL: https://github.com/apache/flink-connector-cassandra/pull/20#issuecomment-1715057479 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23379: [FLINK-33065][client] Add possible root cause to the exception message when the program plan could not be fetched

2023-09-11 Thread via GitHub
1996fanrui commented on code in PR #23379: URL: https://github.com/apache/flink/pull/23379#discussion_r1322476890 ## flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java: ## @@ -183,7 +183,8 @@ public static Pipeline getPipelineFromProgram(

[GitHub] [flink-connector-hive] boring-cyborg[bot] commented on pull request #4: [hotfix] Update NOTICE files to reflect year 2023

2023-09-11 Thread via GitHub
boring-cyborg[bot] commented on PR #4: URL: https://github.com/apache/flink-connector-hive/pull/4#issuecomment-1715052124 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is an a

[GitHub] [flink] WencongLiu closed pull request #21645: [FLINK-30556][hive] Introduce the StaticHivePartitionSplitEnumerator

2023-09-11 Thread via GitHub
WencongLiu closed pull request #21645: [FLINK-30556][hive] Introduce the StaticHivePartitionSplitEnumerator URL: https://github.com/apache/flink/pull/21645 -- 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

[GitHub] [flink] WencongLiu commented on a diff in pull request #23000: [FLINK-32594][runtime] FLIP-331: Support EndOfStreamWindows and isOutputOnEOF operator attribute to optimize task deployment

2023-09-11 Thread via GitHub
WencongLiu commented on code in PR #23000: URL: https://github.com/apache/flink/pull/23000#discussion_r1321166055 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOperatorFactory.java: ## @@ -132,4 +134,12 @@ public void setInputType(TypeInfor

[jira] [Comment Edited] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

2023-09-11 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764016#comment-17764016 ] Jinzhong Li edited comment on FLINK-32953 at 9/12/23 5:39 AM:

[jira] [Comment Edited] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

2023-09-11 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764016#comment-17764016 ] Jinzhong Li edited comment on FLINK-32953 at 9/12/23 5:38 AM:

[jira] [Commented] (FLINK-32953) [State TTL]resolve data correctness problem after ttl was changed

2023-09-11 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764016#comment-17764016 ] Jinzhong Li commented on FLINK-32953: - [~masteryhx]  Currently, the stateBackend lay

[GitHub] [flink] flinkbot commented on pull request #23399: [FLINK-33061][docs] Translate failure-enricher documentation to Chinese

2023-09-11 Thread via GitHub
flinkbot commented on PR #23399: URL: https://github.com/apache/flink/pull/23399#issuecomment-1715000130 ## CI report: * f9a5b318b86856634929075d2b3c37820a858e45 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] wangzzu commented on pull request #23399: [FLINK-33061][docs] Translate failure-enricher documentation to Chinese

2023-09-11 Thread via GitHub
wangzzu commented on PR #23399: URL: https://github.com/apache/flink/pull/23399#issuecomment-1714996308 cc @pgaref @huwh -- 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

[jira] [Updated] (FLINK-33061) Translate failure-enricher documentation to Chinese

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33061: --- Labels: pull-request-available (was: ) > Translate failure-enricher documentation to Chines

[GitHub] [flink] wangzzu opened a new pull request, #23399: [FLINK-33061][docs] Translate failure-enricher documentation to Chinese

2023-09-11 Thread via GitHub
wangzzu opened a new pull request, #23399: URL: https://github.com/apache/flink/pull/23399 ## What is the purpose of the change - Translate failure-enricher documentation to Chinese ## Brief change log - Translate failure-enricher documentation to Chinese #

[GitHub] [flink] 1996fanrui commented on a diff in pull request #23391: [FLINK-33071][metrics,checkpointing] Log a json dump of checkpoint statistics when checkpoint complets or fails

2023-09-11 Thread via GitHub
1996fanrui commented on code in PR #23391: URL: https://github.com/apache/flink/pull/23391#discussion_r1322399618 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java: ## @@ -92,10 +113,18 @@ public class CheckpointStatsTracker { *

[jira] [Updated] (FLINK-32988) HiveITCase failed due to TestContainer not coming up

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-32988: -- Affects Version/s: (was: 1.16.2) (was: 1.17.1) > HiveITCase fai

[jira] [Commented] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

2023-09-11 Thread Jayadeep Jayaraman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764005#comment-17764005 ] Jayadeep Jayaraman commented on FLINK-32877: [~martijnvisser] - can you plea

[GitHub] [flink] ljz2051 commented on a diff in pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-11 Thread via GitHub
ljz2051 commented on code in PR #23376: URL: https://github.com/apache/flink/pull/23376#discussion_r1322334957 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java: ## @@ -62,6 +63,16 @@ public class RocksD

[GitHub] [flink] ljz2051 commented on a diff in pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-11 Thread via GitHub
ljz2051 commented on code in PR #23376: URL: https://github.com/apache/flink/pull/23376#discussion_r1322334666 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackendBuilder.java: ## @@ -126,6 +129,7 @@ p

[GitHub] [flink] ljz2051 commented on a diff in pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-11 Thread via GitHub
ljz2051 commented on code in PR #23376: URL: https://github.com/apache/flink/pull/23376#discussion_r1322333661 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBPriorityQueueSetFactory.java: ## @@ -52,7 +52,9 @@ pub

[jira] [Updated] (FLINK-14032) Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14032: --- Labels: auto-unassigned pull-request-available usability (was: auto-unassigned usability)

[GitHub] [flink] ljz2051 commented on pull request #23376: [FLINK-14032][state]Make the cache size of RocksDBPriorityQueueSetFactory configurable

2023-09-11 Thread via GitHub
ljz2051 commented on PR #23376: URL: https://github.com/apache/flink/pull/23376#issuecomment-1714932710 > Thanks for the pr. PTAL my comments. And you should also provide a UT Case to verify reading the correct config. @masteryhx Thanks for the comments. In the latest commit, i add

[jira] [Closed] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2023-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32978. Resolution: Done > Deprecate RichFunction#open(Configuration parameters) > ---

[jira] [Commented] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2023-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763999#comment-17763999 ] Xintong Song commented on FLINK-32978: -- master (1.19): e9353319ad625baa5b2c20fa709a

[jira] [Assigned] (FLINK-32978) Deprecate RichFunction#open(Configuration parameters)

2023-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-32978: Assignee: Wencong Liu > Deprecate RichFunction#open(Configuration parameters) > -

[GitHub] [flink] xintongsong closed pull request #23058: [FLINK-32978] Deprecate RichFunction#open(Configuration parameters)

2023-09-11 Thread via GitHub
xintongsong closed pull request #23058: [FLINK-32978] Deprecate RichFunction#open(Configuration parameters) URL: https://github.com/apache/flink/pull/23058 -- 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

[jira] [Closed] (FLINK-32870) Reading multiple small buffers by reading and slicing one large buffer for tiered storage

2023-09-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-32870. Fix Version/s: 1.18.0 Resolution: Fixed - master(1.19): ade583cf80478ac60e9b83fc0a97f36bc2b

[GitHub] [flink] xintongsong closed pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

2023-09-11 Thread via GitHub
xintongsong closed pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer URL: https://github.com/apache/flink/pull/23255 -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Assigned] (FLINK-33011) Operator deletes HA data unexpectedly

2023-09-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33011: -- Assignee: Gyula Fora > Operator deletes HA data unexpectedly > --

[jira] [Updated] (FLINK-33011) Operator deletes HA data unexpectedly

2023-09-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33011: --- Priority: Blocker (was: Critical) > Operator deletes HA data unexpectedly > ---

[jira] [Updated] (FLINK-33011) Operator deletes HA data unexpectedly

2023-09-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-33011: --- Priority: Critical (was: Major) > Operator deletes HA data unexpectedly > -

[GitHub] [flink-connector-elasticsearch] liyubin117 commented on pull request #39: [FLINK-29042][Connectors/ElasticSearch] Support lookup join for es connector

2023-09-11 Thread via GitHub
liyubin117 commented on PR #39: URL: https://github.com/apache/flink-connector-elasticsearch/pull/39#issuecomment-1714909304 @snuyanzin @MartijnVisser Thanks a lot for your patient work. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] WencongLiu closed pull request #23375: Dev 0908 1101

2023-09-11 Thread via GitHub
WencongLiu closed pull request #23375: Dev 0908 1101 URL: https://github.com/apache/flink/pull/23375 -- 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: iss

[GitHub] [flink] flinkbot commented on pull request #23398: [hotfix][network] Fix some bugs of Hybrid Shuffle

2023-09-11 Thread via GitHub
flinkbot commented on PR #23398: URL: https://github.com/apache/flink/pull/23398#issuecomment-1714902279 ## CI report: * 2c46fa10143f17ad1a2946536046858556f14771 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23397: [hotfix][network] Fix some bugs of Hybrid Shuffle

2023-09-11 Thread via GitHub
flinkbot commented on PR #23397: URL: https://github.com/apache/flink/pull/23397#issuecomment-1714902192 ## CI report: * edbcd0e920025a70f0aa770daeb8e0caa12d9c72 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] WencongLiu opened a new pull request, #23398: [hotfix][network] Fix some bugs of Hybrid Shuffle

2023-09-11 Thread via GitHub
WencongLiu opened a new pull request, #23398: URL: https://github.com/apache/flink/pull/23398 ## What is the purpose of the change [hotfix][network] Fix the memory usage threshold that triggers disk writing in Hybrid Shuffle [hotfix][network] Optimize the backlog calculation logic

[GitHub] [flink] WencongLiu opened a new pull request, #23397: [hotfix][network] Fix some bugs of Hybrid Shuffle

2023-09-11 Thread via GitHub
WencongLiu opened a new pull request, #23397: URL: https://github.com/apache/flink/pull/23397 ## What is the purpose of the change [hotfix][network] Fix the memory usage threshold that triggers disk writing in Hybrid Shuffle [hotfix][network] Optimize the backlog calculation logic

[jira] [Closed] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-33063. - Resolution: Fixed > udaf with user defined pojo object throw error while generate record equalis

[jira] [Commented] (FLINK-33063) udaf with user defined pojo object throw error while generate record equaliser

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763994#comment-17763994 ] Shengkai Fang commented on FLINK-33063: --- Merged into release-1.18: f2584a1df364a14

[jira] [Closed] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-32952. - Resolution: Fixed > Scan reuse with readable metadata and watermark push down will get wrong >

[GitHub] [flink] fsk119 merged pull request #23388: [FLINK-33063][table-runtime] Fix udaf with complex user defined pojo object throw error while generate record equaliser

2023-09-11 Thread via GitHub
fsk119 merged PR #23388: URL: https://github.com/apache/flink/pull/23388 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-32952) Scan reuse with readable metadata and watermark push down will get wrong watermark

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763993#comment-17763993 ] Shengkai Fang commented on FLINK-32952: --- Merged into release-1.18: f66679bfe5f5b34

[GitHub] [flink] fsk119 merged pull request #23338: [FLINK-32952][table-planner] Fix scan reuse with readable metadata and watermark push down get wrong watermark error

2023-09-11 Thread via GitHub
fsk119 merged PR #23338: URL: https://github.com/apache/flink/pull/23338 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Commented] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-09-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763992#comment-17763992 ] Yangze Guo commented on FLINK-32488: Thanks for the PR [~hejufang001] and [~xiangyu0

[jira] [Comment Edited] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-09-11 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763989#comment-17763989 ] xiangyu feng edited comment on FLINK-32488 at 9/12/23 2:51 AM: ---

[jira] [Assigned] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-09-11 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-32488: -- Assignee: Jufang He (was: xiangyu feng) > Introduce configuration to control ExecutionGraph

[jira] [Commented] (FLINK-32488) Introduce configuration to control ExecutionGraph cache in REST API

2023-09-11 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763989#comment-17763989 ] xiangyu feng commented on FLINK-32488: -- Hi [~guoyangze] , [~hejufang001] has create

[GitHub] [flink] flinkbot commented on pull request #23396: Cherry pick to release-1.18

2023-09-11 Thread via GitHub
flinkbot commented on PR #23396: URL: https://github.com/apache/flink/pull/23396#issuecomment-1714856384 ## CI report: * 7b43c3eacd85d79286bc47629e738f7e674a6374 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] fsk119 opened a new pull request, #23396: Cherry pick to release-1.18

2023-09-11 Thread via GitHub
fsk119 opened a new pull request, #23396: URL: https://github.com/apache/flink/pull/23396 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Commented] (FLINK-32988) HiveITCase failed due to TestContainer not coming up

2023-09-11 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763984#comment-17763984 ] Shengkai Fang commented on FLINK-32988: --- Merged into master: 649b7fe197c8b03cce959

[GitHub] [flink] fsk119 closed pull request #23370: [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3

2023-09-11 Thread via GitHub
fsk119 closed pull request #23370: [FLINK-32731][e2e] Fix NameNode uses port 9870 in hadoop3 URL: https://github.com/apache/flink/pull/23370 -- 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 speci

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r132058 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed t

[jira] [Assigned] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33073: --- Assignee: Hong Liang Teoh > Implement end-to-end tests for the Kinesis Streams Sink

[jira] [Updated] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33072: Description: *What* We want to implement end-to-end tests that target real Kinesis Data S

[jira] [Updated] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33073: --- Labels: pull-request-available (was: ) > Implement end-to-end tests for the Kinesis Streams

[GitHub] [flink-connector-aws] hlteoh37 opened a new pull request, #94: [FLINK-33073][Connectors/AWS] Implement end-to-end tests for KinesisS…

2023-09-11 Thread via GitHub
hlteoh37 opened a new pull request, #94: URL: https://github.com/apache/flink-connector-aws/pull/94 …treamsSink ## Purpose of the change Implement end-to-end tests for KinesisStreamsSink. ## Verifying this change This change added tests and can be verified as follows: -

[jira] [Created] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33073: --- Summary: Implement end-to-end tests for the Kinesis Streams Sink Key: FLINK-33073 URL: https://issues.apache.org/jira/browse/FLINK-33073 Project: Flink

[jira] [Created] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33072: --- Summary: Implement end-to-end tests for AWS Kinesis Connectors Key: FLINK-33072 URL: https://issues.apache.org/jira/browse/FLINK-33072 Project: Flink I

[GitHub] [flink] tweise commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
tweise commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1322170417 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed to

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1322163343 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed t

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1322162928 ## flink-clients/src/main/java/org/apache/flink/client/program/rest/UrlPrefixDecorator.java: ## @@ -41,7 +40,7 @@ */ public class UrlPrefixDecorator<

[GitHub] [flink-connector-elasticsearch] mtfelisb commented on a diff in pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

2023-09-11 Thread via GitHub
mtfelisb commented on code in PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#discussion_r1322154473 ## flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/INetworkConfigFactory.java: ## @@ -0,0 +1,29 @@ +/* +

[jira] [Updated] (FLINK-24241) test_table_environment_api.py fail with NPE

2023-09-11 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24241: --- Labels: stale-major test-stability (was: test-stability) I am the [Flink Jira Bot|https://g

[jira] [Updated] (FLINK-31857) Support pluginable observers mechanism

2023-09-11 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-31857: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32938: --- Labels: pull-request-available (was: ) > flink-connector-pulsar should remove all `PulsarAd

[GitHub] [flink-connector-pulsar] nlu90 commented on pull request #59: [FLINK-32938] Replace pulsar admin calls

2023-09-11 Thread via GitHub
nlu90 commented on PR #59: URL: https://github.com/apache/flink-connector-pulsar/pull/59#issuecomment-1714662290 Can someone help rerun the CI? On my local laptop, everything runs fine: ``` -> mvn clean verify ... ... ... [INFO] ---

[GitHub] [flink] flinkbot commented on pull request #23395: [FLINK-33058][formats] Add encoding option to Avro format

2023-09-11 Thread via GitHub
flinkbot commented on PR #23395: URL: https://github.com/apache/flink/pull/23395#issuecomment-1714582332 ## CI report: * 858c3eebae767ea71e1d43fc5e8f4af88f924c4a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33058) Support for JSON-encoded Avro

2023-09-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33058: --- Labels: avro flink flink-formats pull-request-available (was: avro flink flink-formats) >

[GitHub] [flink] dalelane opened a new pull request, #23395: [FLINK-33058][formats] Add encoding option to Avro format

2023-09-11 Thread via GitHub
dalelane opened a new pull request, #23395: URL: https://github.com/apache/flink/pull/23395 ## What is the purpose of the change Initially proposed in https://issues.apache.org/jira/browse/FLINK-33058 Avro supports two serialization encoding methods: binary and JSON (cf. [Avro

[jira] [Commented] (FLINK-29042) Support lookup join for es connector

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763915#comment-17763915 ] Sergey Nuyanzin commented on FLINK-29042: - Merged as [fef5c964f4a2fc8b61c482b0b

[GitHub] [flink] flinkbot commented on pull request #23394: [BP-1.16][FLINK-33010][table] GREATEST/LEAST should work with other functions as input

2023-09-11 Thread via GitHub
flinkbot commented on PR #23394: URL: https://github.com/apache/flink/pull/23394#issuecomment-1714538178 ## CI report: * fa40b4f52627a9b2fc32b48b138310311d211a6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-29042) Support lookup join for es connector

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-29042. --- Fix Version/s: elasticsearch-4.0.0 Resolution: Fixed > Support lookup join for es con

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #39: [FLINK-29042][Connectors/ElasticSearch] Support lookup join for es connector

2023-09-11 Thread via GitHub
boring-cyborg[bot] commented on PR #39: URL: https://github.com/apache/flink-connector-elasticsearch/pull/39#issuecomment-1714536181 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-connector-elasticsearch] snuyanzin merged pull request #39: [FLINK-29042][Connectors/ElasticSearch] Support lookup join for es connector

2023-09-11 Thread via GitHub
snuyanzin merged PR #39: URL: https://github.com/apache/flink-connector-elasticsearch/pull/39 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-uns

[GitHub] [flink] flinkbot commented on pull request #23393: [BP-1.18][FLINK-33010][table] GREATEST/LEAST should work with other functions as input

2023-09-11 Thread via GitHub
flinkbot commented on PR #23393: URL: https://github.com/apache/flink/pull/23393#issuecomment-1714524505 ## CI report: * e296671f364fdeda71054bc090ad35e3f77ad07b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #23392: [BP-1.17][FLINK-33010][table] GREATEST/LEAST should work with other functions as input

2023-09-11 Thread via GitHub
flinkbot commented on PR #23392: URL: https://github.com/apache/flink/pull/23392#issuecomment-1714518365 ## CI report: * d7e7c703c9a23d18f5c44a0c8b42db7d6afe46a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Resolved] (FLINK-32999) Remove HBase connector from master branch

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-32999. - Fix Version/s: 1.18.0 1.19.0 Resolution: Fixed > Remove HBase

[jira] [Commented] (FLINK-32999) Remove HBase connector from master branch

2023-09-11 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763905#comment-17763905 ] Sergey Nuyanzin commented on FLINK-32999: - Merged to 1.18 as [53981d81d378770f8

[GitHub] [flink] snuyanzin merged pull request #23343: [BP-1.18][FLINK-32999][connectors/hbase] Remove HBase connector code from main repo

2023-09-11 Thread via GitHub
snuyanzin merged PR #23343: URL: https://github.com/apache/flink/pull/23343 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apa

[GitHub] [flink] rkhachatryan commented on a diff in pull request #23391: [FLINK-33071][metrics,checkpointing] Log a json dump of checkpoint statistics when checkpoint complets or fails

2023-09-11 Thread via GitHub
rkhachatryan commented on code in PR #23391: URL: https://github.com/apache/flink/pull/23391#discussion_r1321980461 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java: ## @@ -227,11 +257,23 @@ void reportFailedCheckpoint(FailedCheckpoi

[jira] [Assigned] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

2023-09-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33066: -- Assignee: dongwoo.kim > Enable to inject environment variable from secret/configmap to operat

[jira] [Commented] (FLINK-33066) Enable to inject environment variable from secret/configmap to operatorPod

2023-09-11 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763887#comment-17763887 ] Gyula Fora commented on FLINK-33066: I think this would be a nice improvement :)  >

[GitHub] [flink] pgaref commented on a diff in pull request #23386: [FLINK-33022] Log an error when enrichers defined as part of the configuration can not be found/loaded

2023-09-11 Thread via GitHub
pgaref commented on code in PR #23386: URL: https://github.com/apache/flink/pull/23386#discussion_r1321976643 ## flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java: ## @@ -106,23 +108,34 @@ static Collection getFailureEnrichers( }

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1321874986 ## flink-clients/src/main/java/org/apache/flink/client/program/rest/UrlPrefixDecorator.java: ## @@ -41,7 +40,7 @@ */ public class UrlPrefixDecorator<

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1321869568 ## flink-clients/src/main/java/org/apache/flink/client/program/rest/MonitoringApiMessageHeaders.java: ## @@ -0,0 +1,51 @@ +/* + * Licensed to the Apache Software Founda

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1321868038 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed t

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1321865428 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed t

[GitHub] [flink] elkhand commented on a diff in pull request #23383: [FLINK-32885 ] [flink-clients] Refactoring: Moving UrlPrefixDecorator into flink-clients so it can be used by RestClusterClient for

2023-09-11 Thread via GitHub
elkhand commented on code in PR #23383: URL: https://github.com/apache/flink/pull/23383#discussion_r1321865428 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/SQLGatewayUrlPrefixDecorator.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed t

  1   2   >