[jira] [Updated] (FLINK-31640) Introduce segment index tracker

[ https://issues.apache.org/jira/browse/FLINK-31640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31640: --- Labels: pull-request-available (was: ) > Introduce segment index tracker >

[GitHub] [flink] xintongsong commented on a diff in pull request #22652: [FLINK-31640][network] Introduce the segment id tracker for the tiered storage

xintongsong commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1208289916 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SubpartitionSegmentIdTracker.java: ## @@ -0,0 +1,50 @@ +/* + * Li

[GitHub] [flink] flinkbot commented on pull request #22669: [FLINK-29913] fix shared state be discarded by mistake when maxConcurrentCheckpoint>1

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

[jira] [Updated] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29913: --- Labels: pull-request-available (was: ) > Shared state would be discarded by mistake when ma

[GitHub] [flink] zoltar9264 opened a new pull request, #22669: [FLINK-29913] fix shared state be discarded by mistake when maxConcurrentCheckpoint>1

zoltar9264 opened a new pull request, #22669: URL: https://github.com/apache/flink/pull/22669 ## What is the purpose of the change Fix shared state be discarded by mistake when maxConcurrentCheckpoint>1, discussed in [FLINK-29913](https://issues.apache.org/jira/browse/FLINK-29913).

[GitHub] [flink] xintongsong commented on a diff in pull request #22501: [FLINK-31637][network] Implement the BufferAccumulator for the tiered storage

xintongsong commented on code in PR #22501: URL: https://github.com/apache/flink/pull/22501#discussion_r1208271941 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/SubpartitionHashBufferAccumulator.java: ## @@ -0,0 +1,169 @@ +/*

[GitHub] [flink-web] dannycranmer merged pull request #642: Add Cassandra v3.1.0 for Flink 1.16.x and Flink 1.17.x

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

[GitHub] [flink-web] dannycranmer closed pull request #635: Add Cassandra v3.0.1 for Flink 1.16.x and Flink 1.17.x

dannycranmer closed pull request #635: Add Cassandra v3.0.1 for Flink 1.16.x and Flink 1.17.x URL: https://github.com/apache/flink-web/pull/635 -- 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 sp

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726834#comment-17726834 ] padavan commented on FLINK-31967: - [~fsk119] already in master ?  How can I check what

[jira] [Created] (FLINK-32210) Error import Pyflink.table.descriptors due to python3.10 version mismatch

Alireza Omidvar created FLINK-32210: --- Summary: Error import Pyflink.table.descriptors due to python3.10 version mismatch Key: FLINK-32210 URL: https://issues.apache.org/jira/browse/FLINK-32210 Proje

[GitHub] [flink-connector-pulsar] cbornet commented on pull request #27: [FLINK-24302][Connector/Pulsar] Drop the use of direct buffer memory for supporting Java 11.

cbornet commented on PR #27: URL: https://github.com/apache/flink-connector-pulsar/pull/27#issuecomment-1565455544 Is this still needed now that Pulsar 2.11 client is used ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] LadyForest commented on a diff in pull request #22539: [FLINK-31956][table] Extend the CompiledPlan to read from/write to Fl…

LadyForest commented on code in PR #22539: URL: https://github.com/apache/flink/pull/22539#discussion_r1207961398 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ## @@ -731,11 +732,22 @@ public TableResultInternal

[jira] [Updated] (FLINK-32119) Revise source partition skew logic

[ https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32119: --- Description: After choosing the target parallelism for a vertex, we choose a higher

[jira] [Updated] (FLINK-32119) Add option to control source partition skew

[ https://issues.apache.org/jira/browse/FLINK-32119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-32119: --- Summary: Add option to control source partition skew (was: Disable key group alignm

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1207855023 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java: ## @@ -191,8 +191,8 @@ private Collection getDirtyJobR

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1207850160 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/JobDispatcherLeaderProcessFactoryFactory.java: ## @@ -103,8 +103,8 @@ public static JobDisp

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1207840908 ## flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java: ## @@ -1257,10 +1259,10 @@ private CompletableFuture removeJob(JobID jobId, Clea

[GitHub] [flink] WencongLiu commented on a diff in pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1207795244 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractThreadsafeJobResultStore.java: ## @@ -44,64 +45,84 @@ public abstract class Abstract

[jira] [Updated] (FLINK-32207) Error import Pyflink.table.descriptors due to python3.10 version mismatch

[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32207: Summary: Error import Pyflink.table.descriptors due to python3.10 version mismatch (was:

[jira] [Updated] (FLINK-32207) Error import Pyflink.table.descriptors sue to python3.10 version mismatch

[ https://issues.apache.org/jira/browse/FLINK-32207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32207: Fix Version/s: 1.17.1 Summary: Error import Pyflink.table.descriptors sue to pyth

[GitHub] [flink-kubernetes-operator] mxm commented on pull request #584: [FLINK-31867] Enforce a minimum number of observations within a metric window

mxm commented on PR #584: URL: https://github.com/apache/flink-kubernetes-operator/pull/584#issuecomment-1565256801 Closing for now, this needs additional work. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink-kubernetes-operator] mxm closed pull request #584: [FLINK-31867] Enforce a minimum number of observations within a metric window

mxm closed pull request #584: [FLINK-31867] Enforce a minimum number of observations within a metric window URL: https://github.com/apache/flink-kubernetes-operator/pull/584 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-28853) FLIP-217 Support watermark alignment of source splits

[ https://issues.apache.org/jira/browse/FLINK-28853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726781#comment-17726781 ] Maximilian Michels commented on FLINK-28853: Documentation is now fixed. See

[GitHub] [flink] mxm merged pull request #22668: [BP-1.17][FLINK-28853] Document the split level watermark alignment feature an…

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