[GitHub] [flink] reswqa commented on pull request #23013: [FLINK-32620][sink] Migrate DiscardingSink to sinkv2.

reswqa commented on PR #23013: URL: https://github.com/apache/flink/pull/23013#issuecomment-1702274990 @MartijnVisser Yes, sorry for the delay. I just waiting for the 1.18 branch cut-off before as this is for 1.19. It's time to rebase and merge this. -- This is an automated message from t

[jira] [Assigned] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-20886: --- Assignee: Zakelly Lan > Add the option to get a threaddump on checkpoint timeouts > ---

[jira] [Commented] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761201#comment-17761201 ] Zakelly Lan commented on FLINK-20886: - Hi guys, I noticed this issue and also found

[jira] [Updated] (FLINK-32620) Migrate DiscardingSink to sinkv2

[ https://issues.apache.org/jira/browse/FLINK-32620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-32620: --- Affects Version/s: 1.19.0 (was: 1.18.0) > Migrate DiscardingSink to sinkv

[GitHub] [flink] hackergin opened a new pull request, #23346: [FLINK-32475][docs] Add doc for time travel (#23109)

hackergin opened a new pull request, #23346: URL: https://github.com/apache/flink/pull/23346 cherry-pick FLINK-32475 -- 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 uns

[GitHub] [flink] flinkbot commented on pull request #23346: [BP-1.18][FLINK-32475][docs] Add doc for time travel

flinkbot commented on PR #23346: URL: https://github.com/apache/flink/pull/23346#issuecomment-1702291703 ## CI report: * e005ab43fdf0c7800f0e979e6b8083e7dc93e848 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

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

[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761205#comment-17761205 ] Sergey Nuyanzin commented on FLINK-33010: - I submitted PR btw > NPE when using

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

[ https://issues.apache.org/jira/browse/FLINK-33010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33010: Labels: pull-request-available (was: ) > NPE when using GREATEST() in Flink SQL > ---

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

swuferhong commented on PR #23338: URL: https://github.com/apache/flink/pull/23338#issuecomment-1702299505 @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-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32570: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > Deprecate API t

[jira] [Updated] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32570: -- Affects Version/s: 1.19.0 > Deprecate API that uses Flink's Time implementation (related to FL

[jira] [Updated] (FLINK-32570) Deprecate API that uses Flink's Time implementation (related to FLINK-14638)

[ https://issues.apache.org/jira/browse/FLINK-32570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32570: -- Fix Version/s: (was: 1.18.0) > Deprecate API that uses Flink's Time implementation (relate

[jira] [Commented] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761215#comment-17761215 ] Matthias Pohl commented on FLINK-33014: --- Hi [~zhuyinjun] do you use a LoadBalancer

[jira] [Updated] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33014: -- Description:   The Flink cluster was deployed using the Docker image of Flink 1.17.1 java8. A

[jira] [Updated] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33014: -- Component/s: Runtime / Coordination > flink jobmanager raise java.io.IOException: Connection

[jira] [Commented] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs

[ https://issues.apache.org/jira/browse/FLINK-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761218#comment-17761218 ] Yangyang ZHANG commented on FLINK-9631: --- [~hangxiang] I would like to fix this issu

[jira] [Commented] (FLINK-31788) Add back Support emitValueWithRetract for TableAggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761219#comment-17761219 ] Jane Chan commented on FLINK-31788: --- Sorry for just noticing this issue now. This prob

[jira] [Assigned] (FLINK-32785) Release Testing: Verify FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

[ https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-32785: --- Assignee: Sergey Nuyanzin (was: Sergey Nuyanzin) > Release Testing: Verify FLIP-29

[jira] [Commented] (FLINK-32785) Release Testing: Verify FLIP-292: Enhance COMPILED PLAN to support operator-level state TTL configuration

[ https://issues.apache.org/jira/browse/FLINK-32785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761222#comment-17761222 ] Sergey Nuyanzin commented on FLINK-32785: - Please let me know if anything else i

[GitHub] [flink-statefun] gfmio opened a new pull request, #337: Max Retries

gfmio opened a new pull request, #337: URL: https://github.com/apache/flink-statefun/pull/337 This PR adds a `maxRetries` option that limits the amount of times a request will be attempted before the request is dropped. When set to the default value of -1, batches will be retried indefinite

[jira] [Commented] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761229#comment-17761229 ] zhu commented on FLINK-33014: - Hi [~mapohl]  There is no LoadBalancer configured on my k8s s

[GitHub] [flink] xiangyuf commented on a diff in pull request #23201: [FLINK-15959][flink-runtime] Add min number of slots configuration to limit total number of slots

xiangyuf commented on code in PR #23201: URL: https://github.com/apache/flink/pull/23201#discussion_r1312731126 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java: ## @@ -359,24 +425,45 @@ private void tryFu

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

RanJinh commented on PR #23000: URL: https://github.com/apache/flink/pull/23000#issuecomment-1702377438 @lindong28 could you please take 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

[GitHub] [flink] xiangyuf commented on pull request #23328: [FLINK-32755][docs] Add doc for OLAP quickstart

xiangyuf commented on PR #23328: URL: https://github.com/apache/flink/pull/23328#issuecomment-1702398434 Hi @FangYongs @KarmaGYZ this is a joint work between @zoudan and me. Pls add this into the commit message if it has passed the review. -- This is an automated message from the Apache

[jira] [Commented] (FLINK-33014) flink jobmanager raise java.io.IOException: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761243#comment-17761243 ] Matthias Pohl commented on FLINK-33014: --- [~wangyang0918] Did you experience someth

[GitHub] [flink-web] xintongsong commented on a diff in pull request #672: Update Flink Roadmap

xintongsong commented on code in PR #672: URL: https://github.com/apache/flink-web/pull/672#discussion_r1312716081 ## docs/content/roadmap.md: ## @@ -25,19 +25,14 @@ under the License. # Roadmap -**Preamble:** This roadmap means to provide user and contributors with a high

[jira] [Updated] (FLINK-32994) LeaderElectionDriver.toString() is not implemented

[ https://issues.apache.org/jira/browse/FLINK-32994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32994: -- Fix Version/s: (was: 1.19.0) > LeaderElectionDriver.toString() is not implemented > --

[GitHub] [flink] KarmaGYZ commented on pull request #23328: [FLINK-32755][docs] Add doc for OLAP quickstart

KarmaGYZ commented on PR #23328: URL: https://github.com/apache/flink/pull/23328#issuecomment-1702431802 > Hi @FangYongs @KarmaGYZ @libenchao this is a joint work between @zoudan and me. Pls add this into the commit message if it has passed the review. You can directly add him. Pls ta

[GitHub] [flink] XComp merged pull request #23271: [FLINK-32909] [dist] fix the bug of Pass arguments to jobmanager.sh failed

XComp merged PR #23271: URL: https://github.com/apache/flink/pull/23271 -- 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] XComp merged pull request #23278: [BP-1.18][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

XComp merged PR #23278: URL: https://github.com/apache/flink/pull/23278 -- 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] XComp merged pull request #23280: [BP-1.17][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

XComp merged PR #23280: URL: https://github.com/apache/flink/pull/23280 -- 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] XComp merged pull request #23279: [BP-1.16][FLINK-32909][dist]fix the bug of Pass arguments to jobmanager.sh failed

XComp merged PR #23279: URL: https://github.com/apache/flink/pull/23279 -- 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-32869) Flink Kubernetes related tests failed to run on aarch64

[ https://issues.apache.org/jira/browse/FLINK-32869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-32869: -- Fix Version/s: (was: 1.19.0) > Flink Kubernetes related tests failed to run on aarch64 > -

[jira] [Resolved] (FLINK-32909) The jobmanager.sh pass arguments failed

[ https://issues.apache.org/jira/browse/FLINK-32909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-32909. --- Fix Version/s: 1.18.0 1.16.3 1.17.2 Resolution:

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

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761246#comment-17761246 ] Jinzhong Li commented on FLINK-14032: - hi, [~yunta] , are you still working on this

[GitHub] [flink] aajisaka commented on pull request #19233: [FLINK-23632][docs] Fix the setup-pyflink-virtual-env.sh link

aajisaka commented on PR #19233: URL: https://github.com/apache/flink/pull/19233#issuecomment-1702446504 Thank you @gaborgsomogyi! -- 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 com

[jira] [Commented] (FLINK-23632) [DOCS]The link to setup-Pyflink-virtual-env.sh is broken for page dev/python/faq

[ https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761249#comment-17761249 ] Akira Ajisaka commented on FLINK-23632: --- Hi [~gaborgsomogyi] would you set the ass

[jira] [Assigned] (FLINK-23632) [DOCS]The link to setup-Pyflink-virtual-env.sh is broken for page dev/python/faq

[ https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi reassigned FLINK-23632: - Assignee: Akira Ajisaka (was: wuguihu) > [DOCS]The link to setup-Pyflink-virtual-env.s

[jira] [Commented] (FLINK-23632) [DOCS]The link to setup-Pyflink-virtual-env.sh is broken for page dev/python/faq

[ https://issues.apache.org/jira/browse/FLINK-23632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761251#comment-17761251 ] Gabor Somogyi commented on FLINK-23632: --- Done > [DOCS]The link to setup-Pyflink-v

[GitHub] [flink] lindong28 commented on a diff in pull request #23331: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails

lindong28 commented on code in PR #23331: URL: https://github.com/apache/flink/pull/23331#discussion_r1312867815 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/CheckpointAfterAllTasksFinishedITCase.java: ## @@ -129,40 +131,56 @@ public void testRestoreAfterSome

[GitHub] [flink] lindong28 merged pull request #23331: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails

lindong28 merged PR #23331: URL: https://github.com/apache/flink/pull/23331 -- 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

[jira] [Commented] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761270#comment-17761270 ] Dong Lin commented on FLINK-32996: -- Merged to apache/flink master branch 6608d873db5fd9

[GitHub] [flink] lindong28 closed pull request #23332: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails

lindong28 closed pull request #23332: [FLINK-32996][Tests] Fix the CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails URL: https://github.com/apache/flink/pull/23332 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-32996: - Fix Version/s: 1.18.0 > CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished > fai

[jira] [Closed] (FLINK-32996) CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-32996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin closed FLINK-32996. Resolution: Fixed > CheckpointAfterAllTasksFinishedITCase.testFailoverAfterSomeTasksFinished > fails on

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312873829 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/PartitionFileReader.java: ## @@ -78,4 +91,165 @@ long getPriority(

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312875141 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java: ## @@ -99,40 +115,96 @@ pub

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312876023 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java: ## @@ -99,40 +115,96 @@ pub

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312876410 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/file/ProducerMergedPartitionFileReader.java: ## @@ -204,6 +279,159 @@ pr

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312876903 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskIOScheduler.java: ## @@ -338,6 +338,8 @@ private class Sch

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #23255: [FLINK-32870][network] Tiered storage supports reading multiple small buffers by reading and slicing one large buffer

TanYuxin-tyx commented on code in PR #23255: URL: https://github.com/apache/flink/pull/23255#discussion_r1312877483 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/disk/DiskIOScheduler.java: ## @@ -399,8 +405,48 @@ private void pre

[jira] [Commented] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761284#comment-17761284 ] Sergey Nuyanzin commented on FLINK-26644: - https://dev.azure.com/apache-flink/ap

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

[ https://issues.apache.org/jira/browse/FLINK-32988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761285#comment-17761285 ] Sergey Nuyanzin commented on FLINK-32988: - https://dev.azure.com/apache-flink/ap

[jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761286#comment-17761286 ] Sergey Nuyanzin commented on FLINK-32006: - https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-26644) python StreamExecutionEnvironmentTests.test_generate_stream_graph_with_dependencies failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-26644: Affects Version/s: 1.19.0 > python > StreamExecutionEnvironmentTests.test_generate_stream

[jira] [Updated] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32006: Affects Version/s: 1.19.0 > AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrd

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

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14032: - Priority: Major (was: Minor) > Make the cache size of RocksDBPriorityQueueSetFactory configurable > ---

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

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-14032: Assignee: Jinzhong Li > Make the cache size of RocksDBPriorityQueueSetFactory configurable >

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

[ https://issues.apache.org/jira/browse/FLINK-14032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761288#comment-17761288 ] Yun Tang commented on FLINK-14032: -- [~lijinzhong] already assigned to you. > Make the

[jira] [Commented] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761292#comment-17761292 ] Yun Tang commented on FLINK-20886: -- [~Zakelly] If the task cannot receive the checkpoin

[GitHub] [flink] Myasuka commented on a diff in pull request #14611: [FLINK-13194][docs] Add explicit clarification about thread-safety of state

Myasuka commented on code in PR #14611: URL: https://github.com/apache/flink/pull/14611#discussion_r1312966645 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java: ## @@ -30,6 +30,11 @@ /** * A keyed state backend provides methods for managing

[jira] [Commented] (FLINK-26948) Add SORT_ARRAY supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761316#comment-17761316 ] Jörn Kottmann commented on FLINK-26948: --- Sorry for the delay, I will try to get th

[jira] [Commented] (FLINK-27146) [JUnit5 Migration] Module: flink-filesystems

[ https://issues.apache.org/jira/browse/FLINK-27146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761317#comment-17761317 ] Jörn Kottmann commented on FLINK-27146: --- The PR is available and is waiting for a

[jira] [Reopened] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reopened FLINK-32523: - > NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout > on AZP > -

[jira] [Updated] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32523: Fix Version/s: (was: 1.16.3) > NotifyCheckpointAbortedITCase.testNotifyCheckpointAbort

[jira] [Commented] (FLINK-32523) NotifyCheckpointAbortedITCase.testNotifyCheckpointAborted fails with timeout on AZP

[ https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761319#comment-17761319 ] Sergey Nuyanzin commented on FLINK-32523: - I reopen this since it is reproduced

[jira] [Updated] (FLINK-32571) Prebuild HBase testing docker image

[ https://issues.apache.org/jira/browse/FLINK-32571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32571: --- Fix Version/s: hbase-3.0.1 (was: hbase-3.0.0) > Prebuild HBase testin

[jira] [Assigned] (FLINK-28013) java.lang.ClassNotFoundException: org.apache.flink.hbase.shaded.io.netty.channel.EventLoopGroup

[ https://issues.apache.org/jira/browse/FLINK-28013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28013: -- Assignee: He Wang > java.lang.ClassNotFoundException: > org.apache.flink.hbase.shade

[GitHub] [flink] gaborgsomogyi commented on pull request #21788: [FLINK-30812][yarn] Fix uploading local files when using YARN with S3

gaborgsomogyi commented on PR #21788: URL: https://github.com/apache/flink/pull/21788#issuecomment-1702976674 @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 comm

[GitHub] [flink] gaborgsomogyi commented on pull request #21788: [FLINK-30812][yarn] Fix uploading local files when using YARN with S3

gaborgsomogyi commented on PR #21788: URL: https://github.com/apache/flink/pull/21788#issuecomment-1702977545 Unless there are objections + azure is passing I'm intended to merge this tomorrow. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-web] wuchong commented on pull request #672: Update Flink Roadmap

wuchong commented on PR #672: URL: https://github.com/apache/flink-web/pull/672#issuecomment-1702977949 Thank you @xintongsong , I will merge it. -- 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-web] wuchong merged pull request #672: Update Flink Roadmap

wuchong merged PR #672: URL: https://github.com/apache/flink-web/pull/672 -- 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.apach

[GitHub] [flink-kubernetes-operator] darenwkt opened a new pull request, #662: [FLINK-33008] Refactor to use KubernetesClient from JOSDK Context

darenwkt opened a new pull request, #662: URL: https://github.com/apache/flink-kubernetes-operator/pull/662 ## What is the purpose of the change Refactor code to use KubernetesClient from JOSDK Context ## Brief change log KubernetesClient is passed from josdkC

[GitHub] [flink] Zakelly opened a new pull request, #23347: [FLINK-20886] Support printing the thread dump when checkpoint timeout

Zakelly opened a new pull request, #23347: URL: https://github.com/apache/flink/pull/23347 ## What is the purpose of the change The thread dump of TM is very useful to investigate the reason why checkpoint happens to timeout. This PR make it possible for TM to print thread dump to l

[GitHub] [flink] flinkbot commented on pull request #23347: [FLINK-20886] Support printing the thread dump when checkpoint expired

flinkbot commented on PR #23347: URL: https://github.com/apache/flink/pull/23347#issuecomment-1703101331 ## CI report: * 6b832dd160c87d252c29980964adecf96cbb54ae UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-29855) UDF randomly processed input data twice

[ https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyi Yan updated FLINK-29855: -- Affects Version/s: 1.17.0 1.18.0 > UDF randomly processed input data twice > -

[jira] [Commented] (FLINK-31958) Table to DataStream allow partial fields

[ https://issues.apache.org/jira/browse/FLINK-31958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761373#comment-17761373 ] padavan commented on FLINK-31958: - up > Table to DataStream allow partial fields >

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

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

[jira] [Commented] (FLINK-30519) Add e2e tests for operator dynamic config

[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761421#comment-17761421 ] haiqingchen commented on FLINK-30519: - [~gyfora] sorry, I'm not working on this righ

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17761442#comment-17761442 ] Arseniy Tashoyan commented on FLINK-30530: -- I would say that default config is