[jira] [Updated] (FLINK-33914) Workflow: Add basic CI that will run with the default configuration

[ https://issues.apache.org/jira/browse/FLINK-33914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33914: -- Affects Version/s: 1.18.0 1.19.0 > Workflow: Add basic CI that will

[jira] [Updated] (FLINK-27082) Disable tests relying on non-writable directories

[ https://issues.apache.org/jira/browse/FLINK-27082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-27082: -- Affects Version/s: 1.18.0 1.19.0 > Disable tests relying on

[jira] [Updated] (FLINK-33912) Template: Add CI template for pre-compile steps

[ https://issues.apache.org/jira/browse/FLINK-33912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33912: -- Affects Version/s: 1.18.0 > Template: Add CI template for pre-compile steps >

[jira] [Updated] (FLINK-33916) Workflow: Add nightly build for release-1.18

[ https://issues.apache.org/jira/browse/FLINK-33916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33916: -- Affects Version/s: 1.18.0 > Workflow: Add nightly build for release-1.18 >

[jira] [Updated] (FLINK-33915) Workflow: Add nightly build for the dev version (currently called "master")

[ https://issues.apache.org/jira/browse/FLINK-33915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33915: -- Affects Version/s: 1.18.0 > Workflow: Add nightly build for the dev version (currently called

[jira] [Updated] (FLINK-33907) Makes copying test jars being done earlier

[ https://issues.apache.org/jira/browse/FLINK-33907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33907: -- Affects Version/s: 1.18.0 > Makes copying test jars being done earlier >

[jira] [Updated] (FLINK-33910) Custom Action: Enable Java version in Flink's CI Docker image

[ https://issues.apache.org/jira/browse/FLINK-33910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33910: -- Affects Version/s: 1.18.0 > Custom Action: Enable Java version in Flink's CI Docker image >

[jira] [Updated] (FLINK-33906) tools/azure-pipelines/debug_files_utils.sh should support GHA output as well

[ https://issues.apache.org/jira/browse/FLINK-33906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33906: -- Affects Version/s: 1.18.0 > tools/azure-pipelines/debug_files_utils.sh should support GHA

[jira] [Updated] (FLINK-33911) Custom Action: Select workflow configuration

[ https://issues.apache.org/jira/browse/FLINK-33911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33911: -- Affects Version/s: 1.18.0 > Custom Action: Select workflow configuration >

[jira] [Updated] (FLINK-33904) Add zip as a package to GitHub Actions runners

[ https://issues.apache.org/jira/browse/FLINK-33904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33904: -- Affects Version/s: 1.18.0 > Add zip as a package to GitHub Actions runners >

[jira] [Updated] (FLINK-33908) Custom Action: Move files within the Docker image to the root folder to match the user

[ https://issues.apache.org/jira/browse/FLINK-33908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33908: -- Affects Version/s: 1.18.0 > Custom Action: Move files within the Docker image to the root

[jira] [Updated] (FLINK-33913) Template: Add CI template for running Flink's test suite

[ https://issues.apache.org/jira/browse/FLINK-33913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33913: -- Affects Version/s: 1.18.0 > Template: Add CI template for running Flink's test suite >

[jira] [Updated] (FLINK-33903) Reenable tests that edit file permissions

[ https://issues.apache.org/jira/browse/FLINK-33903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33903: -- Affects Version/s: 1.18.0 > Reenable tests that edit file permissions >

[jira] [Updated] (FLINK-33902) Switch to OpenSSL legacy algorithms

[ https://issues.apache.org/jira/browse/FLINK-33902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33902: -- Affects Version/s: 1.18.0 > Switch to OpenSSL legacy algorithms >

[jira] [Updated] (FLINK-33901) Trial Period: GitHub Actions

[ https://issues.apache.org/jira/browse/FLINK-33901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-33901: -- Affects Version/s: 1.18.0 > Trial Period: GitHub Actions > > >

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

flashJd commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433921836 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java: ## @@ -264,4 +262,21 @@ private static Map

[jira] [Comment Edited] (FLINK-33924) Register for INFRA's self-hosted runner trial

[ https://issues.apache.org/jira/browse/FLINK-33924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799365#comment-17799365 ] Matthias Pohl edited comment on FLINK-33924 at 12/21/23 10:35 AM: -- I

[jira] [Commented] (FLINK-33924) Register for INFRA's self-hosted runner trial

[ https://issues.apache.org/jira/browse/FLINK-33924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799365#comment-17799365 ] Matthias Pohl commented on FLINK-33924: --- I created INFRA-25203 in accordance with [the

Re: [PR] [FLINK-33917] fix hostname can't be null for certain edgecases [flink-kubernetes-operator]

mxm commented on code in PR #738: URL: https://github.com/apache/flink-kubernetes-operator/pull/738#discussion_r1433868387 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java: ## @@ -234,23 +235,29 @@ public JobID

[jira] [Assigned] (FLINK-33924) Register for INFRA's self-hosted runner trial

[ https://issues.apache.org/jira/browse/FLINK-33924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33924: - Assignee: Matthias Pohl > Register for INFRA's self-hosted runner trial >

[jira] [Created] (FLINK-33924) Register for INFRA's self-hosted runner trial

Matthias Pohl created FLINK-33924: - Summary: Register for INFRA's self-hosted runner trial Key: FLINK-33924 URL: https://issues.apache.org/jira/browse/FLINK-33924 Project: Flink Issue Type:

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799357#comment-17799357 ] Maciej Obuchowski commented on FLINK-31275: --- Hey [~zjureel], is there any news regarding this

[jira] [Commented] (FLINK-33917) IllegalArgumentException: hostname can't be null

[ https://issues.apache.org/jira/browse/FLINK-33917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799352#comment-17799352 ] Maximilian Michels commented on FLINK-33917: The description doesn’t describe under which

[jira] [Assigned] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33883: --- Assignee: Jiabao Sun > Bump CI flink version on flink-connector-jdbc >

[jira] [Commented] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799351#comment-17799351 ] Sergey Nuyanzin commented on FLINK-33883: - Merged to main as

[jira] [Resolved] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33883. - Resolution: Fixed > Bump CI flink version on flink-connector-jdbc >

[jira] [Closed] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33883. --- > Bump CI flink version on flink-connector-jdbc > -

[jira] [Updated] (FLINK-33883) Bump CI flink version on flink-connector-jdbc

[ https://issues.apache.org/jira/browse/FLINK-33883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-33883: Fix Version/s: jdbc-3.2.0 > Bump CI flink version on flink-connector-jdbc >

Re: [PR] [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 [flink-connector-jdbc]

snuyanzin merged PR #85: URL: https://github.com/apache/flink-connector-jdbc/pull/85 -- 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:

[jira] [Closed] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33877. --- > CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException >

[jira] [Resolved] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-33877. - Resolution: Fixed > CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to

[jira] [Commented] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

[ https://issues.apache.org/jira/browse/FLINK-33923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799346#comment-17799346 ] Matthias Pohl commented on FLINK-33923: --- See further reasoning in FLINK-33277 > Upgrade

[jira] [Commented] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799347#comment-17799347 ] Sergey Nuyanzin commented on FLINK-33877: - Merged to master as

[jira] [Assigned] (FLINK-33877) CollectSinkFunctionTest.testConfiguredPortIsUsed fails due to BindException

[ https://issues.apache.org/jira/browse/FLINK-33877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-33877: --- Assignee: Jiabao Sun > CollectSinkFunctionTest.testConfiguredPortIsUsed fails due

[jira] [Closed] (FLINK-33277) Upgrading to actions/checkout@v4 requires GLIBC 2.25, 2.27, or 2.28 to be installed, apparently

[ https://issues.apache.org/jira/browse/FLINK-33277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-33277. - Resolution: Duplicate I'm closing this one and created a duplicate issue under the FLINK-33901

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

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

[jira] [Created] (FLINK-33923) Upgrade upload-artifacts and download-artifacts to version 4

Matthias Pohl created FLINK-33923: - Summary: Upgrade upload-artifacts and download-artifacts to version 4 Key: FLINK-33923 URL: https://issues.apache.org/jira/browse/FLINK-33923 Project: Flink

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

snuyanzin commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433842115 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

Re: [PR] [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable - mixin approach [flink]

leonardBang commented on code in PR #23912: URL: https://github.com/apache/flink/pull/23912#discussion_r1433838959 ## flink-core/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java: ## @@ -40,17 +37,9 @@ * @param The type of the committables. */

[jira] [Updated] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

[ https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-33921: - Description: getMinIdleStateRetentionTime() getMaxIdleStateRetentionTime() was:

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

Jiabao-Sun commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433822304 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

Jiabao-Sun commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433817373 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

Re: [PR] [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M… [flink]

lsyldliu closed pull request #23121: [FLINK-32721] [planner] Support CharType for the MaxAggFunction and M… URL: https://github.com/apache/flink/pull/23121 -- 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

Re: [PR] Test [flink]

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

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

Jiabao-Sun commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433817373 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

[PR] Test [flink]

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

[jira] [Updated] (FLINK-33922) table-planner jar will be removed as it is created at /tmp by default

[ https://issues.apache.org/jira/browse/FLINK-33922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guojun Li updated FLINK-33922: -- Attachment: (was: image-2023-12-21-17-31-29-220.png) > table-planner jar will be removed as it is

[jira] [Created] (FLINK-33922) table-planner jar will be removed as it is created at /tmp by default

Guojun Li created FLINK-33922: - Summary: table-planner jar will be removed as it is created at /tmp by default Key: FLINK-33922 URL: https://issues.apache.org/jira/browse/FLINK-33922 Project: Flink

[jira] [Commented] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

[ https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799328#comment-17799328 ] Yubin Li commented on FLINK-33921: -- [~qingyue] Could you please assign this to me? thanks! > Cleanup

[jira] [Updated] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

[ https://issues.apache.org/jira/browse/FLINK-33921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yubin Li updated FLINK-33921: - Parent: FLINK-31596 Issue Type: Sub-task (was: Improvement) > Cleanup usage of deprecated

Re: [PR] [FLINK-33328] Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable - mixin approach [flink]

pvary commented on code in PR #23912: URL: https://github.com/apache/flink/pull/23912#discussion_r1433804590 ## flink-core/src/main/java/org/apache/flink/api/connector/sink2/TwoPhaseCommittingSink.java: ## @@ -40,17 +37,9 @@ * @param The type of the committables. */

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

snuyanzin commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433803550 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

snuyanzin commented on code in PR #23976: URL: https://github.com/apache/flink/pull/23976#discussion_r1433803072 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunctionTest.java: ## @@ -136,9 +135,8 @@ void

[jira] [Created] (FLINK-33921) Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig

Yubin Li created FLINK-33921: Summary: Cleanup usage of deprecated IdleStateRetentionTime related method in org.apache.flink.table.api.TableConfig Key: FLINK-33921 URL:

[jira] [Comment Edited] (FLINK-33414) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails due to unexpected TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-33414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799308#comment-17799308 ] Jiang Xin edited comment on FLINK-33414 at 12/21/23 9:26 AM: - [~mapohl]

Re: [PR] [FLINK-33877][streaming] Adjusting CollectSinkFunctionTest.testConfiguredPortIsUsed's assertion message to work with JDK 17 & 21 [flink]

Jiabao-Sun commented on PR #23976: URL: https://github.com/apache/flink/pull/23976#issuecomment-1865928438 @snuyanzin could you have a look please? -- 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

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433793487 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/UnionResultSubpartitionViewTest.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433794402 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/Buffer.java: ## @@ -304,7 +306,15 @@ enum DataType {

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799321#comment-17799321 ] Sergey Nuyanzin commented on FLINK-33528: - ok I see, thanks for clarification > Externalize

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799320#comment-17799320 ] Peter Vary commented on FLINK-33528: [~Sergey Nuyanzin]: FLINK-33762 is needed, so the connectors

Re: [PR] [Flink-33414] Fix the unstable test MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot [flink]

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

[jira] [Commented] (FLINK-33528) Externalize Python connector code

[ https://issues.apache.org/jira/browse/FLINK-33528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799315#comment-17799315 ] Sergey Nuyanzin commented on FLINK-33528: - [~pvary], [~dianfu] could you please clarify: once

[PR] [Flink-33414] Fix the unstable test MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot [flink]

jiangxin369 opened a new pull request, #23977: URL: https://github.com/apache/flink/pull/23977 ## What is the purpose of the change Fix the unstable test MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot. ## Brief change log - Disable the resource

[jira] [Comment Edited] (FLINK-33414) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails due to unexpected TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-33414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799308#comment-17799308 ] Jiang Xin edited comment on FLINK-33414 at 12/21/23 8:59 AM: - [~mapohl]

Re: [PR] [FLINK-33795] Add a new config to forbid autoscale execution in the configured excluded periods [flink-kubernetes-operator]

gyfora commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1433757961 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingExecutor.java: ## @@ -264,4 +262,21 @@ private static Map

[jira] [Updated] (FLINK-33905) FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

[ https://issues.apache.org/jira/browse/FLINK-33905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33905: --- Labels: pull-request-available (was: ) > FLIP-382: Unify the Provision of Diverse Metadata

Re: [PR] [FLINK-33905][core] Unify the Provision of Diverse Metadata for Context-like APIs [flink]

xintongsong commented on code in PR #23905: URL: https://github.com/apache/flink/pull/23905#discussion_r1433693565 ## flink-core/src/main/java/org/apache/flink/api/common/TaskInfoImpl.java: ## @@ -0,0 +1,123 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one

[jira] [Commented] (FLINK-33414) MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails due to unexpected TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-33414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17799308#comment-17799308 ] Jiang Xin commented on FLINK-33414: --- I also met the exception and after delving into the code, I found

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433753103 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SubpartitionSelector.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433752308 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java: ## @@ -281,15 +271,9 @@ public SingleInputGate(

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433747654 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageConsumerClient.java: ## @@ -52,33 +55,39 @@

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433743541 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/PartitionRequestClient.java: ## @@ -62,9 +62,11 @@ void requestSubpartition( *

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433740732 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java: ## @@ -1736,7 +1738,8 @@ private

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433735764 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/CancelPartitionRequestTest.java: ## @@ -100,7 +102,12 @@ void

Re: [PR] [FLINK-33743][runtime] Support consuming multiple subpartitions on a single channel [flink]

yunfengzhou-hub commented on code in PR #23927: URL: https://github.com/apache/flink/pull/23927#discussion_r1433736474 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionIndexRange.java: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the

Re: [PR] [FLINK-33914][ci] Adds basic Flink CI workflow [flink]

snuyanzin commented on code in PR #23970: URL: https://github.com/apache/flink/pull/23970#discussion_r1433730346 ## .github/actions/set_java_in_container/action.yml: ## @@ -0,0 +1,32 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license

[jira] [Created] (FLINK-33920) StandaloneKubernetesTaskManagerFactory doesn't support recent config additions

Gyula Fora created FLINK-33920: -- Summary: StandaloneKubernetesTaskManagerFactory doesn't support recent config additions Key: FLINK-33920 URL: https://issues.apache.org/jira/browse/FLINK-33920 Project:

<    1   2