[GitHub] [flink-web] victor9309 closed pull request #675: [hotfix] cannot jump to /zh/how-to-contribute/contribute-code/

2023-09-20 Thread via GitHub
victor9309 closed pull request #675: [hotfix] cannot jump to /zh/how-to-contribute/contribute-code/ URL: https://github.com/apache/flink-web/pull/675 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Assigned] (FLINK-33007) Integrate autoscaler config validation into the general validator flow

2023-09-20 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-33007: -- Assignee: Praneeth Ramesh > Integrate autoscaler config validation into the general validator

[GitHub] [flink] Tartarus0zm commented on pull request #23448: [FLINK-33050][table] Atomicity is not supported prompting the user to disable

2023-09-20 Thread via GitHub
Tartarus0zm commented on PR #23448: URL: https://github.com/apache/flink/pull/23448#issuecomment-1728933478 @luoyuxia CI is pass, PTAL, thanks -- 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-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767397#comment-17767397 ] Zhanghao Chen commented on FLINK-33123: --- Hi [~fanrui], thanks for sharing the issu

[GitHub] [flink] Jiabao-Sun commented on pull request #23424: [FLINK-32445][runtime] Refactor BlobStoreService's closeAndCleanupAllData to cleanupAllData

2023-09-20 Thread via GitHub
Jiabao-Sun commented on PR #23424: URL: https://github.com/apache/flink/pull/23424#issuecomment-1728913476 Hi @XComp, could you help take a look when you have time? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[jira] [Resolved] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-33126. --- Fix Version/s: 1.19.0 Resolution: Fixed master: 4f09bbb39239f5523da8ecb7c7cd5ac9fd34c0e5 > F

[GitHub] [flink] huwh merged pull request #23444: [FLINK-33126] Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread via GitHub
huwh merged PR #23444: URL: https://github.com/apache/flink/pull/23444 -- 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.o

[GitHub] [flink] flinkbot commented on pull request #23448: [FLINK-33050][table] Atomicity is not supported prompting the user to disable

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

[GitHub] [flink] Tartarus0zm opened a new pull request, #23448: [FLINK-33050][table] Atomicity is not supported prompting the user to disable

2023-09-20 Thread via GitHub
Tartarus0zm opened a new pull request, #23448: URL: https://github.com/apache/flink/pull/23448 ## What is the purpose of the change * When atomicity is enabled, an exception may occur when creating a DynamicTableSink, and we need to prompt the user to disable atomicity. * When we u

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

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-32938. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via 78d00ea9e3e278d4ce2fbb0c8a8d380abef7

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

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32938: - Assignee: Neng Lu > flink-connector-pulsar should remove all `PulsarAdmin` calls >

[jira] [Assigned] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-20 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei reassigned FLINK-33127: -- Assignee: Yangyang ZHANG > HeapKeyedStateBackend: use buffered I/O to speed up local recovery

[jira] [Created] (FLINK-33127) HeapKeyedStateBackend: use buffered I/O to speed up local recovery

2023-09-20 Thread Yangyang ZHANG (Jira)
Yangyang ZHANG created FLINK-33127: -- Summary: HeapKeyedStateBackend: use buffered I/O to speed up local recovery Key: FLINK-33127 URL: https://issues.apache.org/jira/browse/FLINK-33127 Project: Flink

[jira] [Updated] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33126: --- Labels: pull-request-available (was: ) > Fix EventTimeAllWindowCheckpointingITCase jobName

[GitHub] [flink] mayuehappy commented on pull request #23444: [FLINK-33126] Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread via GitHub
mayuehappy commented on PR #23444: URL: https://github.com/apache/flink/pull/23444#issuecomment-1728690076 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment

[jira] [Updated] (FLINK-33060) Fix the javadoc of ListState.update/addAll about not allowing null value

2023-09-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33060: --- Labels: pull-request-available (was: ) > Fix the javadoc of ListState.update/addAll about n

[GitHub] [flink] elkhand commented on a diff in pull request #23406: [FLINK-32884] [flink-clients] PyFlink remote execution should support URLs with paths and https scheme

2023-09-20 Thread via GitHub
elkhand commented on code in PR #23406: URL: https://github.com/apache/flink/pull/23406#discussion_r1332375725 ## flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java: ## @@ -255,10 +266,22 @@ private RestClusterClient( RestCl

[jira] [Commented] (FLINK-32974) RestClusterClient always leaks flink-rest-client-jobgraphs* directories

2023-09-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767357#comment-17767357 ] Lijie Wang commented on FLINK-32974: Fix via master: 6034d5ff335dc970672c29085181123

[jira] [Resolved] (FLINK-32974) RestClusterClient always leaks flink-rest-client-jobgraphs* directories

2023-09-20 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang resolved FLINK-32974. Fix Version/s: 1.18.0 1.17.2 Resolution: Fixed > RestClusterClient alway

[jira] [Commented] (FLINK-32405) Initialize catalog listener for CatalogManager

2023-09-20 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767356#comment-17767356 ] Benchao Li commented on FLINK-32405: [~zjureel] Thanks for the updating, I've also a

[jira] [Closed] (FLINK-32405) Initialize catalog listener for CatalogManager

2023-09-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32405. - Resolution: Duplicate Duplicate with FLINK-32404 > Initialize catalog listener for CatalogManager > ---

[jira] [Commented] (FLINK-32405) Initialize catalog listener for CatalogManager

2023-09-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767354#comment-17767354 ] Fang Yong commented on FLINK-32405: --- OK, it is a duplicate issue with FLINK-32404 > I

[jira] [Reopened] (FLINK-32405) Initialize catalog listener for CatalogManager

2023-09-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reopened FLINK-32405: --- > Initialize catalog listener for CatalogManager > -- > >

[jira] [Updated] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33044: --- Fix Version/s: 1.18.0 > Reduce the frequency of triggering flush for the disk tier of the tiered >

[jira] [Closed] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-33044. -- Resolution: Fixed > Reduce the frequency of triggering flush for the disk tier of the tiered > storag

[jira] [Comment Edited] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767089#comment-17767089 ] Weijie Guo edited comment on FLINK-33044 at 9/21/23 2:04 AM: -

[jira] [Updated] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33044: --- Labels: pull-request-available (was: ) > Reduce the frequency of triggering flush for the d

[GitHub] [flink] TanYuxin-tyx commented on pull request #23442: [BP][FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread via GitHub
TanYuxin-tyx commented on PR #23442: URL: https://github.com/apache/flink/pull/23442#issuecomment-1728657634 Thanks @reswqa for reviewing the change. -- 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

[GitHub] [flink] reswqa merged pull request #23442: [BP][FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread via GitHub
reswqa merged PR #23442: URL: https://github.com/apache/flink/pull/23442 -- 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

[GitHub] [flink] luoyuxia closed pull request #23389: [FLINK-33050][table] Atomicity is not supported prompting the user to disable

2023-09-20 Thread via GitHub
luoyuxia closed pull request #23389: [FLINK-33050][table] Atomicity is not supported prompting the user to disable URL: https://github.com/apache/flink/pull/23389 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

[jira] [Closed] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

2023-09-20 Thread Fang Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32848. - Resolution: Fixed Fixed by 2ced46b6ed4ebfb20f9b392cba4e789e16e4da7d...f2cb1d247283344e9194e63931a2948e0

[GitHub] [flink] becketqin commented on a diff in pull request #23313: [FLINK-20767][table planner] Support filter push down on nested fields

2023-09-20 Thread via GitHub
becketqin commented on code in PR #23313: URL: https://github.com/apache/flink/pull/23313#discussion_r1332312205 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java: ## @@ -1183,7 +1194,9 @@ private Map, Collectio

[jira] [Updated] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

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

[jira] [Updated] (FLINK-32223) Add Hive delegation token support

2023-09-20 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32223: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-32418) ClassNotFoundException when using flink-protobuf with sql-client

2023-09-20 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32418: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the [Flink

[jira] [Commented] (FLINK-30649) Shutting down MiniCluster times out

2023-09-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767290#comment-17767290 ] Matthias Pohl commented on FLINK-30649: --- Thanks for volunteering. Do you have an i

[jira] [Commented] (FLINK-15736) Support Java 17 (LTS)

2023-09-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767273#comment-17767273 ] Chesnay Schepler commented on FLINK-15736: -- Documentation added: master: 388601

[GitHub] [flink] zentol merged pull request #23445: [FLINK-15736][docs] Add Java compatibility page

2023-09-20 Thread via GitHub
zentol merged PR #23445: URL: https://github.com/apache/flink/pull/23445 -- 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

[GitHub] [flink-connector-kafka] tzulitai commented on a diff in pull request #20: [FLINK-29398][connector/kafka] Provide rack ID to Kafka Source to take advantage of Rack Awareness

2023-09-20 Thread via GitHub
tzulitai commented on code in PR #20: URL: https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1332045177 ## flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java: ## @@ -98,20 +98,24 @@ private final KafkaRecordDeseri

[jira] [Commented] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

2023-09-20 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767232#comment-17767232 ] Mason Chen commented on FLINK-33104: Do we want to ignore the violations for now? or

[jira] [Commented] (FLINK-33121) Failed precondition in JobExceptionsHandler due to concurrent global failures

2023-09-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767214#comment-17767214 ] Chesnay Schepler commented on FLINK-33121: -- Had an offline chat; our suspicion

[GitHub] [flink] flinkbot commented on pull request #23447: [FLINK-31650][metrics][rest] Cleanup terminal subtask attempt metrics to avoid confusion caused by outdated metrics

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

[jira] [Commented] (FLINK-31650) Incorrect busyMsTimePerSecond metric value for FINISHED task

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767191#comment-17767191 ] Zhanghao Chen commented on FLINK-31650: --- [~wanglijie] [~JunRuiLi] Hi, I've created

[jira] [Updated] (FLINK-31650) Incorrect busyMsTimePerSecond metric value for FINISHED task

2023-09-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31650: --- Labels: pull-request-available (was: ) > Incorrect busyMsTimePerSecond metric value for FIN

[GitHub] [flink] X-czh opened a new pull request, #23447: [FLINK-31650][metrics][rest] Cleanup terminal subtask attempt metrics to avoid confusion caused by outdated metrics

2023-09-20 Thread via GitHub
X-czh opened a new pull request, #23447: URL: https://github.com/apache/flink/pull/23447 ## What is the purpose of the change This pull request cleanups terminal subtask attempt metrics to avoid confusion caused by outdated metrics. For example, a FINISHED task may have its l

[GitHub] [flink] venkata91 commented on a diff in pull request #23313: [FLINK-20767][table planner] Support filter push down on nested fields

2023-09-20 Thread via GitHub
venkata91 commented on code in PR #23313: URL: https://github.com/apache/flink/pull/23313#discussion_r1331904794 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java: ## @@ -1183,7 +1194,9 @@ private Map, Collectio

[GitHub] [flink] venkata91 commented on a diff in pull request #23313: [FLINK-20767][table planner] Support filter push down on nested fields

2023-09-20 Thread via GitHub
venkata91 commented on code in PR #23313: URL: https://github.com/apache/flink/pull/23313#discussion_r1331904794 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java: ## @@ -1183,7 +1194,9 @@ private Map, Collectio

[jira] [Updated] (FLINK-32976) NullPointException when starting flink cluster in standalone mode

2023-09-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32976: --- Labels: pull-request-available (was: ) > NullPointException when starting flink cluster in

[jira] [Commented] (FLINK-30649) Shutting down MiniCluster times out

2023-09-20 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767154#comment-17767154 ] Flaviu Cicio commented on FLINK-30649: -- Hi, [~mapohl] Can I have this one as my fi

[GitHub] [flink] flinkbot commented on pull request #23446: [FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

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

[jira] [Commented] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

2023-09-20 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162 ] Rui Fan commented on FLINK-33123: - Hi [~Zhanghao Chen] , thanks for your report! Your a

[GitHub] [flink] hackergin opened a new pull request, #23446: [FLINK-32976][runtime] Fix NullPointException when starting flink cluster in standalone mode

2023-09-20 Thread via GitHub
hackergin opened a new pull request, #23446: URL: https://github.com/apache/flink/pull/23446 ## What is the purpose of the change *Fix NullPointException when starting flink cluster in standalone mode with hadoop configuration* ## Brief change log - Add

[jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33123: -- Description: *Background* https://issues.apache.org/jira/browse/FLINK-30213 reported that the

[jira] [Commented] (FLINK-33052) codespeed and benchmark server is down

2023-09-20 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767153#comment-17767153 ] Piotr Nowojski commented on FLINK-33052: I think there is no big difference one

[jira] [Commented] (FLINK-33121) Failed precondition in JobExceptionsHandler due to concurrent global failures

2023-09-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767029#comment-17767029 ] Chesnay Schepler commented on FLINK-33121: -- ??there are rare cases where multip

[jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33123: -- Attachment: image-2023-09-20-15-09-22-733.png > Wrong dynamic replacement of partitioner from

[jira] [Created] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33123: - Summary: Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and Key: FLINK-33123 URL: https://issues.apache.org/jira/brows

[jira] [Comment Edited] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

2023-09-20 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162 ] Rui Fan edited comment on FLINK-33123 at 9/20/23 3:30 PM: -- Hi [

[GitHub] [flink] Aoboyan closed pull request #20926: Update ch temporal_table_function.md

2023-09-20 Thread via GitHub
Aoboyan closed pull request #20926: Update ch temporal_table_function.md URL: https://github.com/apache/flink/pull/20926 -- 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 unsu

[jira] [Commented] (FLINK-33111) Flink Pulsar Connector to Pulsar Client Version Mismatch

2023-09-20 Thread Zili Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767131#comment-17767131 ] Zili Chen commented on FLINK-33111: --- We upgrade the Pulsar client version in https://

[GitHub] [flink] Aoboyan closed pull request #20923: Update temporal_table_function.md

2023-09-20 Thread via GitHub
Aoboyan closed pull request #20923: Update temporal_table_function.md URL: https://github.com/apache/flink/pull/20923 -- 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 unsubsc

[GitHub] [flink] CuiYanxiang commented on pull request #23439: [FLINK-33117][table][docs] Fix scala example in udfs page

2023-09-20 Thread via GitHub
CuiYanxiang commented on PR #23439: URL: https://github.com/apache/flink/pull/23439#issuecomment-1727100811 Hi @wuchong , would you mind helping review this pr? thanks~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[GitHub] [flink] huwh merged pull request #23243: [FLINK-32846][runtime][JUnit5 Migration] The metrics package of flink-runtime module

2023-09-20 Thread via GitHub
huwh merged PR #23243: URL: https://github.com/apache/flink/pull/23243 -- 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.o

[jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33123: -- Description: *Background* https://issues.apache.org/jira/browse/FLINK-30213 reported that the

[jira] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33123: -- Attachment: image-2023-09-20-15-14-04-679.png > Wrong dynamic replacement of partitioner from

[GitHub] [flink] zentol commented on a diff in pull request #23445: [FLINK-15736][docs] Add Java compatibility page

2023-09-20 Thread via GitHub
zentol commented on code in PR #23445: URL: https://github.com/apache/flink/pull/23445#discussion_r1331743142 ## docs/content.zh/docs/deployment/java_compatibility.md: ## @@ -0,0 +1,77 @@ +--- +title: Java Compatibility +weight: 2 +type: docs +--- + + +# Java compatibility + +Th

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-09-20 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767128#comment-17767128 ] Rui Fan commented on FLINK-33109: - Could you try this image? It's the offcial image base

[jira] [Created] (FLINK-33122) [Benchmark] Null checkpoint directory in rescaling benchmarks

2023-09-20 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-33122: --- Summary: [Benchmark] Null checkpoint directory in rescaling benchmarks Key: FLINK-33122 URL: https://issues.apache.org/jira/browse/FLINK-33122 Project: Flink

[GitHub] [flink] snuyanzin commented on a diff in pull request #23445: [FLINK-15736][docs] Add Java compatibility page

2023-09-20 Thread via GitHub
snuyanzin commented on code in PR #23445: URL: https://github.com/apache/flink/pull/23445#discussion_r1331730072 ## docs/content.zh/docs/deployment/java_compatibility.md: ## @@ -0,0 +1,77 @@ +--- +title: Java Compatibility +weight: 2 +type: docs +--- + + +# Java compatibility +

[GitHub] [flink] huwh commented on a diff in pull request #23242: [FLINK-32851][runtime][JUnit5 Migration] The rest package of flink-runtime module

2023-09-20 Thread via GitHub
huwh commented on code in PR #23242: URL: https://github.com/apache/flink/pull/23242#discussion_r1328092633 ## flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCacheTest.java: ## @@ -154,35 +149,35 @@ public void testCacheTimeoutCanBeConf

[GitHub] [flink-benchmarks] FangYongs commented on a diff in pull request #78: [FLINK-33033][olap][haservice] Add haservice micro benchmark for olap

2023-09-20 Thread via GitHub
FangYongs commented on code in PR #78: URL: https://github.com/apache/flink-benchmarks/pull/78#discussion_r1331196199 ## src/main/java/org/apache/flink/olap/benchmark/HighAvailabilityServiceBenchmark.java: ## @@ -0,0 +1,133 @@ +/* + * Licensed to the Apache Software Foundation (

[jira] [Updated] (FLINK-33124) Kafka Connector not working for table

2023-09-20 Thread Aarsh Shah (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aarsh Shah updated FLINK-33124: --- Component/s: Connectors / Kafka Table SQL / Runtime Affects Version/

[GitHub] [flink-kubernetes-operator] ashangit opened a new pull request, #680: [FLINK-33125] Bump JOSDK to 4.4.4

2023-09-20 Thread via GitHub
ashangit opened a new pull request, #680: URL: https://github.com/apache/flink-kubernetes-operator/pull/680 ## What is the purpose of the change Upgrade JOSDK to 4.4.4 which contains fix on leader election stop not called ## Brief change log - Update depende

[jira] [Updated] (FLINK-33059) Support transparent compression for file-connector for all file input formats

2023-09-20 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Etienne Chauchot updated FLINK-33059: - Description: Some FileInputFormats don't use FileInputFormat#createSplits (that would de

[jira] [Commented] (FLINK-33109) Watermark alignment not applied after recovery from checkpoint

2023-09-20 Thread Yordan Pavlov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767012#comment-17767012 ] Yordan Pavlov commented on FLINK-33109: --- Hi [~fanrui] can I ask for your help in t

[GitHub] [flink-benchmarks] FangYongs commented on pull request #78: [FLINK-33033][olap][haservice] Add haservice micro benchmark for olap

2023-09-20 Thread via GitHub
FangYongs commented on PR #78: URL: https://github.com/apache/flink-benchmarks/pull/78#issuecomment-1727208341 @KarmaGYZ I think there is another purpose to evaluate the performance of OLAP cluster with cluster ZOOKEEPER HA and NONE job HA, and whether it is consistent with the current perf

[jira] [Resolved] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

2023-09-20 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu resolved FLINK-32846. --- Fix Version/s: 1.19.0 Resolution: Fixed > [JUnit5 Migration] The metrics, minicluster and net

[GitHub] [flink] flinkbot commented on pull request #23442: [BP][FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

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

[GitHub] [flink] TanYuxin-tyx commented on pull request #23369: [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread via GitHub
TanYuxin-tyx commented on PR #23369: URL: https://github.com/apache/flink/pull/23369#issuecomment-1727044233 @xintongsong @reswqa Thanks for review the change. I update the code to rebase the fixup commit and trigger the tests again. -- This is an automated message from the Apache G

[jira] [Created] (FLINK-33125) Upgrade JOSDK to 4.4.4

2023-09-20 Thread Nicolas Fraison (Jira)
Nicolas Fraison created FLINK-33125: --- Summary: Upgrade JOSDK to 4.4.4 Key: FLINK-33125 URL: https://issues.apache.org/jira/browse/FLINK-33125 Project: Flink Issue Type: Bug Compon

[jira] [Assigned] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33126: - Assignee: Yue Ma (was: Yue Ma) > Fix EventTimeAllWindowCheckpointingITCase jobName typo >

[jira] [Commented] (FLINK-33110) Array content gets replaced with last element duplicates

2023-09-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767106#comment-17767106 ] Martijn Visser commented on FLINK-33110: [~romanlupiichuk] Can you please verify

[GitHub] [flink] flinkbot commented on pull request #23441: [FLINK-33060] Fix the javadoc of ListState interfaces about not allowing null value

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

[GitHub] [flink] flinkbot commented on pull request #23445: [FLINK-15736][docs] Add Java compatibility page

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

[jira] [Commented] (FLINK-30314) Unable to read all records from compressed delimited file input format

2023-09-20 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767099#comment-17767099 ] Etienne Chauchot commented on FLINK-30314: -- https://github.com/apache/flink/pul

[jira] [Commented] (FLINK-32846) [JUnit5 Migration] The metrics, minicluster and net packages of flink-runtime module

2023-09-20 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767056#comment-17767056 ] Weihua Hu commented on FLINK-32846: --- Metrics merged in master: 5a8321f6385f9a108773989

[jira] [Commented] (FLINK-32197) FLIP 246: Dynamic Kafka Source

2023-09-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767055#comment-17767055 ] Yun Tang commented on FLINK-32197: -- [~mason6345] Thanks for the information! I will als

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #23442: [BP][FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread via GitHub
TanYuxin-tyx opened a new pull request, #23442: URL: https://github.com/apache/flink/pull/23442 ## What is the purpose of the change *Backport the pr https://github.com/apache/flink/pull/23369 to release 1.18.* ## Brief change log - *Backport the pr http

[jira] [Assigned] (FLINK-33126) Fix EventTimeAllWindowCheckpointingITCase jobName typo

2023-09-20 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weihua Hu reassigned FLINK-33126: - Assignee: Yue Ma > Fix EventTimeAllWindowCheckpointingITCase jobName typo > ---

[GitHub] [flink] flinkbot commented on pull request #23444: [FLINK-33126] Fix EventTimeAllWindowCheckpointingITCase jobName typo

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

[GitHub] [flink] flinkbot commented on pull request #23443: [FLINK-33059] Support transparent compression for file-connector for all file input formats

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

[jira] [Comment Edited] (FLINK-32197) FLIP 246: Dynamic Kafka Source

2023-09-20 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767055#comment-17767055 ] Yun Tang edited comment on FLINK-32197 at 9/20/23 8:59 AM: --- [~

[jira] [Updated] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-33044: --- Fix Version/s: 1.19.0 > Reduce the frequency of triggering flush for the disk tier of the tiered >

[GitHub] [flink] reswqa merged pull request #23369: [FLINK-33044][network] Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread via GitHub
reswqa merged PR #23369: URL: https://github.com/apache/flink/pull/23369 -- 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] [Updated] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhanghao Chen updated FLINK-33123: -- Summary: Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and

[jira] [Commented] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767035#comment-17767035 ] Zhanghao Chen commented on FLINK-33123: --- Hi [~gyfora] [~mxm] , please help take a

[jira] [Commented] (FLINK-33044) Reduce the frequency of triggering flush for the disk tier of the tiered storage

2023-09-20 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767089#comment-17767089 ] Weijie Guo commented on FLINK-33044: master(1.19) via b076c52d8da914e81c3e004c0b0c78

[jira] [Created] (FLINK-33124) Kafka Connector not working for table

2023-09-20 Thread Aarsh Shah (Jira)
Aarsh Shah created FLINK-33124: -- Summary: Kafka Connector not working for table Key: FLINK-33124 URL: https://issues.apache.org/jira/browse/FLINK-33124 Project: Flink Issue Type: Bug

[GitHub] [flink] zentol opened a new pull request, #23445: [FLINK-15736][docs] Add Java compatibility page

2023-09-20 Thread via GitHub
zentol opened a new pull request, #23445: URL: https://github.com/apache/flink/pull/23445 (no comment) -- 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-mai

[GitHub] [flink] echauchot opened a new pull request, #23443: [Flink-33059] Support transparent compression for file-connector for all file input formats

2023-09-20 Thread via GitHub
echauchot opened a new pull request, #23443: URL: https://github.com/apache/flink/pull/23443 ## What is the purpose of the change Support transparent compression for file-connector for all file input formats. ## Brief change log - Force reading the whole file split (like

  1   2   >