[GitHub] [flink] flinkbot commented on pull request #22702: [FLINK-32159] AbstractColumnReader throws NPE

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

[jira] [Updated] (FLINK-32159) Hudi Source throws NPE

[ https://issues.apache.org/jira/browse/FLINK-32159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32159: --- Labels: pull-request-available (was: ) > Hudi Source throws NPE > -- >

[GitHub] [flink] cuibo01 opened a new pull request, #22702: [FLINK-32159] AbstractColumnReader throws NPE

cuibo01 opened a new pull request, #22702: URL: https://github.com/apache/flink/pull/22702 ## 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

[jira] [Updated] (FLINK-32243) Bump okhttp version to 4.11.0

[ https://issues.apache.org/jira/browse/FLINK-32243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32243: --- Labels: pull-request-available (was: ) > Bump okhttp version to 4.11.0 >

[GitHub] [flink-kubernetes-operator] czy006 opened a new pull request, #610: [FLINK-32243] Bump okhttp version to 4.11.0

czy006 opened a new pull request, #610: URL: https://github.com/apache/flink-kubernetes-operator/pull/610 Bump okhttp version to 4.11.0 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink-kubernetes-operator] xccui commented on a diff in pull request #609: [FLINK-32171] Add PostStart hook to flink k8s operator helm

xccui commented on code in PR #609: URL: https://github.com/apache/flink-kubernetes-operator/pull/609#discussion_r1214659153 ## helm/flink-kubernetes-operator/values.yaml: ## @@ -183,3 +183,7 @@ operatorHealth: startupProbe: failureThreshold: 30 periodSeconds: 10

[jira] [Updated] (FLINK-32171) Add PostStart hook to flink k8s operator helm

[ https://issues.apache.org/jira/browse/FLINK-32171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32171: --- Labels: pull-request-available (was: ) > Add PostStart hook to flink k8s operator helm >

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #609: [FLINK-32171] Add PostStart hook to flink k8s operator helm

gyfora commented on code in PR #609: URL: https://github.com/apache/flink-kubernetes-operator/pull/609#discussion_r1214506467 ## helm/flink-kubernetes-operator/values.yaml: ## @@ -183,3 +183,7 @@ operatorHealth: startupProbe: failureThreshold: 30 periodSeconds: 10

[GitHub] [flink-connector-jdbc] matriv commented on pull request #29: [FLINK-31551] Add support for CrateDB

matriv commented on PR #29: URL: https://github.com/apache/flink-connector-jdbc/pull/29#issuecomment-1573891656 Thank you all involved in the PR and for all the iterations! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-connector-jdbc] snuyanzin commented on pull request #29: [FLINK-31551] Add support for CrateDB

snuyanzin commented on PR #29: URL: https://github.com/apache/flink-connector-jdbc/pull/29#issuecomment-1573890436 thanks for the contribution @matriv thanks for the review @libenchao , @eskabetxe i'm about to merge it this weekend -- This is an automated message from the

[jira] [Commented] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

[ https://issues.apache.org/jira/browse/FLINK-32245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728734#comment-17728734 ] lincoln lee commented on FLINK-32245: - fixed in master: bfe49b2973d4ffc8f7404a376cab1e419b53406a >

[jira] [Closed] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

[ https://issues.apache.org/jira/browse/FLINK-32245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-32245. --- Resolution: Fixed > NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to

[GitHub] [flink] lincoln-lil merged pull request #22701: [FLINK-32245][table-planner] Rename NonDeterministicTests to NonDeterministicTest and fix incorrect test initialization

lincoln-lil merged PR #22701: URL: https://github.com/apache/flink/pull/22701 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-kubernetes-operator] ottomata commented on pull request #604: [FLINK-32041] - Allow operator to manage leases when using watchNamespaces

ottomata commented on PR #604: URL: https://github.com/apache/flink-kubernetes-operator/pull/604#issuecomment-1573642377 Okay, thank you! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [flink] luoyuxia commented on a diff in pull request #22593: [FLINK-32053][table-planner] Introduce StateMetadata to ExecNode to support configure operator-level state TTL via CompiledPlan

luoyuxia commented on code in PR #22593: URL: https://github.com/apache/flink/pull/22593#discussion_r1214112329 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/StateMetadata.java: ## @@ -84,22 +84,23 @@ public StateMetadata(

[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728714#comment-17728714 ] Liu commented on FLINK-30629: - [~Sergey Nuyanzin] Thanks. From the log, we can see the logs in time order:

[GitHub] [flink] yuchen-ecnu commented on pull request #22659: [FLINK-32186][runtime-web] Support subtask stack auto-search when red…

yuchen-ecnu commented on PR #22659: URL: https://github.com/apache/flink/pull/22659#issuecomment-1573601846 Hi @Myasuka, can you help me to 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

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214225246 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,187 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214224183 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,187 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214223911 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/TestingTierProducerAgent.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214223698 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/TestingTierProducerAgent.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214223224 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/TestingTierProducerAgent.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-32247) Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-32247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-32247: -- Description: Considering a SQL statement below: {code:java} CREATE TABLE source1 ( `id`

[jira] [Commented] (FLINK-32247) Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-32247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728674#comment-17728674 ] Qingsheng Ren commented on FLINK-32247: --- Not sure if this is by-design or a bug in planner >

[jira] [Updated] (FLINK-32247) Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-32247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-32247: -- Description: Considering a SQL statement below: {code:java} CREATE TABLE source1 ( `id`

[jira] [Updated] (FLINK-32247) Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-32247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-32247: -- Description: Considering a SQL statement below:   {code:java} SELECT `window_start`,

[jira] [Created] (FLINK-32247) Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate

Qingsheng Ren created FLINK-32247: - Summary: Normal group by with time attributes after a window group by is interpreted as GlobalWindowAggregate Key: FLINK-32247 URL:

[jira] [Commented] (FLINK-32246) javax.management.InstanceAlreadyExistsException

[ https://issues.apache.org/jira/browse/FLINK-32246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728658#comment-17728658 ] Aitozi commented on FLINK-32246: where do you run this sql ? sql-client ? Can you provide a demo case to

[GitHub] [flink] swuferhong commented on a diff in pull request #22684: [FLINK-32220][table-runtime] Improving the adaptive local hash agg code to avoid get value from RowData repeatedly

swuferhong commented on code in PR #22684: URL: https://github.com/apache/flink/pull/22684#discussion_r1214139725 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProjectionCodeGenerator.scala: ## @@ -231,25 +230,23 @@ object

[jira] [Resolved] (FLINK-31894) ExceptionHistory and REST API failure label integration

[ https://issues.apache.org/jira/browse/FLINK-31894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek resolved FLINK-31894. --- Fix Version/s: 1.18.0 Resolution: Fixed > ExceptionHistory and REST API failure

[jira] [Assigned] (FLINK-31894) ExceptionHistory and REST API failure label integration

[ https://issues.apache.org/jira/browse/FLINK-31894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-31894: - Assignee: Panagiotis Garefalakis > ExceptionHistory and REST API failure label

[jira] [Commented] (FLINK-31894) ExceptionHistory and REST API failure label integration

[ https://issues.apache.org/jira/browse/FLINK-31894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17728640#comment-17728640 ] David Morávek commented on FLINK-31894: --- master: 28c20ad70c7100ae2358fa3f8936663f30811f78 >

[GitHub] [flink] dmvk merged pull request #22643: [FLINK-31894][runtime] ExceptionHistory and REST API failure label integration

dmvk merged PR #22643: URL: https://github.com/apache/flink/pull/22643 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

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

zoltar9264 commented on code in PR #22669: URL: https://github.com/apache/flink/pull/22669#discussion_r1214124394 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBSnapshotStrategyBase.java: ## @@ -395,18

[GitHub] [flink] flinkbot commented on pull request #22701: [FLINK-32245][table-planner] Rename NonDeterministicTests to NonDeterministicTest and fix incorrect test initialization

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

[jira] [Updated] (FLINK-32245) NonDeterministicTests #testTemporalFunctionsInBatchMode failure masked due to incorrect test initialization

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

[GitHub] [flink] LadyForest opened a new pull request, #22701: [FLINK-32245][table-planner] Rename NonDeterministicTests to NonDeterministicTest and fix incorrect test initialization

LadyForest opened a new pull request, #22701: URL: https://github.com/apache/flink/pull/22701 ## What is the purpose of the change This PR fixes the incorrect test initialization for `NonDeterministicTests` which uses `streamTableEnv` to test batch behavior, which fails of course but

[GitHub] [flink] reswqa commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

reswqa commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214057806 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/TestingTierProducerAgent.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to the

[GitHub] [flink] reswqa commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

reswqa commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214057806 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/TestingTierProducerAgent.java: ## @@ -0,0 +1,75 @@ +/* + * Licensed to the

[GitHub] [flink] TanYuxin-tyx commented on pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on PR #22652: URL: https://github.com/apache/flink/pull/22652#issuecomment-1573354370 @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

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214057512 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -80,13 +107,23 @@

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

rkhachatryan commented on code in PR #22669: URL: https://github.com/apache/flink/pull/22669#discussion_r1214051048 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBSnapshotStrategyBase.java: ## @@ -395,18

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

rkhachatryan commented on code in PR #22669: URL: https://github.com/apache/flink/pull/22669#discussion_r1214051048 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksDBSnapshotStrategyBase.java: ## @@ -395,18

[GitHub] [flink] reswqa commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

reswqa commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214045783 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -80,13 +107,23 @@ public void

[GitHub] [flink] TanYuxin-tyx commented on pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on PR #22652: URL: https://github.com/apache/flink/pull/22652#issuecomment-1573304176 @reswqa Thanks for helping review, I have addressed the comments. Could you help take a look again? Due to the significant code changes in the test code, I didn't use a fix-up

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214037314 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,352 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214036888 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,352 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214036360 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,352 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214035752 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,352 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214034785 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClientTest.java: ## @@ -0,0 +1,352 @@ +/*

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214031770 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/TierProducerAgent.java: ## @@ -35,9 +41,21 @@ public interface

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214031417 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/TierProducerAgent.java: ## @@ -35,9 +41,21 @@ public interface

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214031240 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -80,13 +107,23 @@

[GitHub] [flink] TanYuxin-tyx commented on a diff in pull request #22652: [FLINK-31640][network] Write the accumulated buffers to the right storage tier

TanYuxin-tyx commented on code in PR #22652: URL: https://github.com/apache/flink/pull/22652#discussion_r1214030893 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageProducerClient.java: ## @@ -100,26 +137,95 @@

[GitHub] [flink] wanglijie95 commented on pull request #22681: [FLINK-32199][runtime] Remove redundant metrics in TaskMetricStore after rescale down

wanglijie95 commented on PR #22681: URL: https://github.com/apache/flink/pull/22681#issuecomment-1573280214 @JunRuiLee This pr was successfully merged into master. But it had code conflicts when I cherry-pick it to release-1.17 and release-1.16, please solve the conflict and create PRs for

[GitHub] [flink] wanglijie95 closed pull request #22681: [FLINK-32199][runtime] Remove redundant metrics in TaskMetricStore after rescale down

wanglijie95 closed pull request #22681: [FLINK-32199][runtime] Remove redundant metrics in TaskMetricStore after rescale down URL: https://github.com/apache/flink/pull/22681 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] snuyanzin commented on pull request #22672: [BP-1.17][FLINK-32023][API / DataStream] Add config execution.buffer-…

snuyanzin commented on PR #22672: URL: https://github.com/apache/flink/pull/22672#issuecomment-1573240299 rebase to the latest commit in branch the reason of failure is https://issues.apache.org/jira/browse/FLINK-32231 which was merged recentlly to this branch -- This is an

[jira] [Created] (FLINK-32246) javax.management.InstanceAlreadyExistsException

jeff-zou created FLINK-32246: Summary: javax.management.InstanceAlreadyExistsException Key: FLINK-32246 URL: https://issues.apache.org/jira/browse/FLINK-32246 Project: Flink Issue Type: Bug

[GitHub] [flink] Myracle commented on pull request #22672: [BP-1.17][FLINK-32023][API / DataStream] Add config execution.buffer-…

Myracle commented on PR #22672: URL: https://github.com/apache/flink/pull/22672#issuecomment-1573230300 @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.

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #604: [FLINK-32041] - Allow operator to manage leases when using watchNamespaces

gyfora commented on PR #604: URL: https://github.com/apache/flink-kubernetes-operator/pull/604#issuecomment-1573210364 @ottomata we generally try to follow a 2 month release cycle. Details can be found here: https://cwiki.apache.org/confluence/display/FLINK/Release+Schedule+and+Planning