[jira] [Commented] (FLINK-31966) Flink Kubernetes operator lacks TLS support

2023-10-16 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17776026#comment-17776026 ] Gyula Fora commented on FLINK-31966: [~tagarr] we could introduce a new config specific for the

Re: [PR] FLINK-32107 Kubernetes test failed because ofunable to establish ssl connection to github on AZP [flink]

2023-10-16 Thread via GitHub
flinkbot commented on PR #23528: URL: https://github.com/apache/flink/pull/23528#issuecomment-1765703486 ## CI report: * dd121ab31046b877a9a9545166939e5314d2a183 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-32107) Kubernetes test failed because ofunable to establish ssl connection to github on AZP

2023-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32107: --- Labels: pull-request-available starter test-stability (was: starter test-stability) >

[PR] FLINK-32107 Kubernetes test failed because ofunable to establish ssl connection to github on AZP [flink]

2023-10-16 Thread via GitHub
victor9309 opened a new pull request, #23528: URL: https://github.com/apache/flink/pull/23528 ## What is the purpose of the change *(We could make CI fail earlier when download fails.)* ## Brief change log - *modify common_kubernetes.sh* ## Does

Re: [PR] [FLINK-28303] Support LatestOffsetsInitializer to avoid latest-offset strategy lose data [flink-connector-kafka]

2023-10-16 Thread via GitHub
Tan-JiaLiang commented on PR #52: URL: https://github.com/apache/flink-connector-kafka/pull/52#issuecomment-1765621807 @mas-chen Hi Mason, thanks for your feedback. I think empty splits may not be the point in this problem. The point is we should not store the marker (i.e. -1) into

[jira] [Commented] (FLINK-3755) Introduce key groups for key-value state to support dynamic scaling

2023-10-16 Thread Jinzhong Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775998#comment-17775998 ] Jinzhong Li commented on FLINK-3755: [~trohrmann]  [~martijnvisser]  I want to take a look at the

Re: [PR] [FLINK-33202][runtime] Support switching from batch to stream mode to improve throughput when processing backlog data [flink]

2023-10-16 Thread via GitHub
Sxnan commented on PR #23521: URL: https://github.com/apache/flink/pull/23521#issuecomment-1765550224 @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.

Re: [PR] FLINK-31180 Fail early when installing minikube and check whether we can retry [flink]

2023-10-16 Thread via GitHub
victor9309 commented on code in PR #23497: URL: https://github.com/apache/flink/pull/23497#discussion_r1361434258 ## flink-end-to-end-tests/test-scripts/common_kubernetes.sh: ## @@ -54,6 +54,17 @@ function setup_kubernetes_for_linux { chmod +x minikube && sudo mv

[jira] [Commented] (FLINK-33184) HybridShuffleITCase fails with exception in resource cleanup of task Map on AZP

2023-10-16 Thread Xuannan Su (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775983#comment-17775983 ] Xuannan Su commented on FLINK-33184:

Re: [PR] [FLINK-28229][streaming-java] Source API alternatives for StreamExecutionEnvironment#fromCollection() methods [flink]

2023-10-16 Thread via GitHub
afedulov commented on PR #22850: URL: https://github.com/apache/flink/pull/22850#issuecomment-1765388782 @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] [Assigned] (FLINK-33286) DataGeneratorSource should support automatic return type detection

2023-10-16 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-33286: - Assignee: Alexander Fedulov > DataGeneratorSource should support automatic

[jira] [Commented] (FLINK-33286) DataGeneratorSource should support automatic return type detection

2023-10-16 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775923#comment-17775923 ] Alexander Fedulov commented on FLINK-33286: --- Connectors / DataGen component is missing. If you

[jira] [Created] (FLINK-33286) DataGeneratorSource should support automatic return type detection

2023-10-16 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-33286: - Summary: DataGeneratorSource should support automatic return type detection Key: FLINK-33286 URL: https://issues.apache.org/jira/browse/FLINK-33286

Re: [PR] [AVRO-3536] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-16 Thread via GitHub
m8719-github commented on PR #23524: URL: https://github.com/apache/flink/pull/23524#issuecomment-1765180123 I've reached out to Martin here: [FLINK-33238](https://issues.apache.org/jira/browse/FLINK-33238) to see if we can consolidate. -- This is an automated message from the Apache

Re: [PR] [FLINK-31631][FileSystems] shade guava in gs-fs filesystem [flink]

2023-10-16 Thread via GitHub
afedulov commented on PR #23489: URL: https://github.com/apache/flink/pull/23489#issuecomment-1765166054 @cnauroth flink bot does not add every run into the CI report list, so it probably did. The issue is with the licenses/NOTICE file:

Re: [PR] FLINK-31180 Fail early when installing minikube and check whether we can retry [flink]

2023-10-16 Thread via GitHub
afedulov commented on code in PR #23497: URL: https://github.com/apache/flink/pull/23497#discussion_r1361179604 ## flink-end-to-end-tests/test-scripts/common_kubernetes.sh: ## @@ -54,6 +54,17 @@ function setup_kubernetes_for_linux { chmod +x minikube && sudo mv

Re: [PR] FLINK-31180 Fail early when installing minikube and check whether we can retry [flink]

2023-10-16 Thread via GitHub
afedulov commented on code in PR #23497: URL: https://github.com/apache/flink/pull/23497#discussion_r1361179604 ## flink-end-to-end-tests/test-scripts/common_kubernetes.sh: ## @@ -54,6 +54,17 @@ function setup_kubernetes_for_linux { chmod +x minikube && sudo mv

Re: [PR] [AVRO-3536] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-16 Thread via GitHub
m8719-github commented on code in PR #23524: URL: https://github.com/apache/flink/pull/23524#discussion_r1361173226 ## flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchemaTest.java: ## @@ -85,7 +85,7 @@ void

[jira] [Assigned] (FLINK-33218) First Steps - error when run with zsh

2023-10-16 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-33218: - Assignee: Robin Moffatt > First Steps - error when run with zsh >

Re: [PR] [FLINK-33238][Formats/Avro] Upgrade used AVRO version to 1.11.3 [flink]

2023-10-16 Thread via GitHub
afedulov commented on PR #23508: URL: https://github.com/apache/flink/pull/23508#issuecomment-1765132464 @MartijnVisser head up for the test failure fix: https://github.com/apache/flink/pull/23524/files -- This is an automated message from the Apache Git Service. To respond to the

Re: [PR] [AVRO-3536] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-16 Thread via GitHub
afedulov commented on PR #23524: URL: https://github.com/apache/flink/pull/23524#issuecomment-1765131440 Actually, there is already an earlier PR with this bump to address vulnarabilities: https://github.com/apache/flink/pull/23508 -- This is an automated message from the Apache Git

Re: [PR] [AVRO-3536] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-16 Thread via GitHub
afedulov commented on code in PR #23524: URL: https://github.com/apache/flink/pull/23524#discussion_r1361168261 ## flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchemaTest.java: ## @@ -85,7 +85,7 @@ void

Re: [PR] [AVRO-3536] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-16 Thread via GitHub
afedulov commented on PR #23524: URL: https://github.com/apache/flink/pull/23524#issuecomment-1765124381 @m8719-github thanks for the contribution. All Flink PRs need to have a corresponding issue in Flink JIRA. Could you please create one with a brief description of the issue being

Re: [PR] [FLINK-33116][tests] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-16 Thread via GitHub
Jiabao-Sun commented on code in PR #23515: URL: https://github.com/apache/flink/pull/23515#discussion_r1361042492 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientTest.java: ## @@ -300,6 +303,8 @@ void testCancelExecutionInteractiveMode()

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

2023-10-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30519: --- Labels: auto-deprioritized-critical pull-request-available stale-assigned starter (was:

[PR] [FLINK-30519] add dynamic config e2e [flink-kubernetes-operator]

2023-10-16 Thread via GitHub
HuangZhenQiu opened a new pull request, #684: URL: https://github.com/apache/flink-kubernetes-operator/pull/684 ## What is the purpose of the change Add e2e for dynamic config feature of Flink Operator ## Brief change log - add test_dynamic_config.sh ## Verifying this

[jira] [Updated] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-30400: --- Fix Version/s: aws-connector-4.2.0 kafka-3.1.0 > Stop bundling

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775827#comment-17775827 ] Martijn Visser commented on FLINK-30400: Fixed in apache/flink-connector-kafka:main

Re: [PR] [FLINK-30400][build] Stop bundling flink-connector-base [flink-connector-kafka]

2023-10-16 Thread via GitHub
MartijnVisser merged PR #50: URL: https://github.com/apache/flink-connector-kafka/pull/50 -- 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-30490) Deleted topic from KafkaSource is still included in subsequent restart from savepoint

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30490. -- Resolution: Duplicate > Deleted topic from KafkaSource is still included in subsequent

[jira] [Closed] (FLINK-24045) KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24045. -- Resolution: Cannot Reproduce > KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure

[jira] [Updated] (FLINK-24045) KafkaTableITCase.testPerPartitionWatermarkKafka fails on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24045: --- Fix Version/s: (was: 1.15.5) > KafkaTableITCase.testPerPartitionWatermarkKafka fails on

[jira] [Closed] (FLINK-25498) FlinkKafkaProducerITCase. testRestoreToCheckpointAfterExceedingProducersPool failed on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25498. -- Resolution: Cannot Reproduce > FlinkKafkaProducerITCase.

Re: [PR] [FLINK-33097][autoscaler] Initialize the generic autoscaler module and interfaces [flink-kubernetes-operator]

2023-10-16 Thread via GitHub
mateczagany commented on code in PR #677: URL: https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1360856610 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java: ## @@ -441,15 +442,21 @@ protected Collection

[jira] [Commented] (FLINK-33283) core stage: WebFrontendBootstrapTest.testHandlersMustBeLoaded

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775794#comment-17775794 ] Matthias Pohl commented on FLINK-33283: --- hm, but it's also not built in the Azure CI runs (see

Re: [PR] [FLINK-33116][tests] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-16 Thread via GitHub
XComp commented on code in PR #23515: URL: https://github.com/apache/flink/pull/23515#discussion_r1360500601 ## flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/CliClientTest.java: ## @@ -311,6 +316,8 @@ void testCancelExecutionInteractiveMode()

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360731620 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceParallelismChangeRescalingControllerTest.java: ## @@ -0,0 +1,64 @@

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360730445 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/scalingpolicy/EnforceParallelismChangeRescalingControllerTest.java: ## @@ -0,0 +1,64 @@

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360728058 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -594,8 +683,12 @@ public FailureResult

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360721374 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/ExecutingTest.java: ## @@ -594,8 +683,12 @@ public FailureResult

Re: [PR] [FLINK-33181] Allow a table definition can be used to read & write data to. [flink-connector-aws]

2023-10-16 Thread via GitHub
vtkhanh commented on PR #105: URL: https://github.com/apache/flink-connector-aws/pull/105#issuecomment-1764483073 > Actions are failing due to a recent bug, will fix Merged your fix and updated the PR. Thanks for looking @dannycranmer. -- This is an automated message from the

Re: [PR] [FLINK-33181] Allow a table definition can be used to read & write data to. [flink-connector-aws]

2023-10-16 Thread via GitHub
vtkhanh commented on PR #105: URL: https://github.com/apache/flink-connector-aws/pull/105#issuecomment-1764481474 > Hi @vtkhanh, Could you please describe the use case more. It feels like an anti-pattern to use the same stream as source and sink. Kinesis Table API source and sink

[jira] [Commented] (FLINK-33217) Flink SQL: UNNEST fails with on LEFT JOIN with NOT NULL type in array

2023-10-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775748#comment-17775748 ] Sergey Nuyanzin commented on FLINK-33217: - after looking a bit deeper it looks like it is not

[jira] [Comment Edited] (FLINK-33217) Flink SQL: UNNEST fails with on LEFT JOIN with NOT NULL type in array

2023-10-16 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775748#comment-17775748 ] Sergey Nuyanzin edited comment on FLINK-33217 at 10/16/23 1:01 PM: ---

[jira] [Commented] (FLINK-33230) Support Expanding ExecutionGraph to StreamGraph in Web UI

2023-10-16 Thread Yu Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775743#comment-17775743 ] Yu Chen commented on FLINK-33230: - Hi [~JunRuiLi] , Sure, I'll illustrate the details of the

[jira] [Closed] (FLINK-25582) flink sql kafka source cannot special custom parallelism

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25582. -- Resolution: Duplicate > flink sql kafka source cannot special custom parallelism >

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

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32210. -- Resolution: Cannot Reproduce > Error import Pyflink.table.descriptors due to python3.10

[jira] [Closed] (FLINK-31740) Allow setting boundedness for upsert-kafka SQL connector

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31740. -- Resolution: Fixed > Allow setting boundedness for upsert-kafka SQL connector >

[jira] [Closed] (FLINK-32822) Add connector option to control whether to enable auto-commit of offsets when checkpoints is enabled

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32822. -- Resolution: Won't Fix I'm +1 with [~mason6345] on this, this is by design and we shouldn't

[jira] [Closed] (FLINK-32138) SQLClientSchemaRegistryITCase fails with timeout on AZP

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32138. -- Resolution: Cannot Reproduce > SQLClientSchemaRegistryITCase fails with timeout on AZP >

[jira] [Closed] (FLINK-32206) ModuleNotFoundError for Pyflink.table.descriptors wheel version mismatch

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32206. -- Resolution: Information Provided > ModuleNotFoundError for Pyflink.table.descriptors wheel

[jira] [Closed] (FLINK-31862) KafkaSinkITCase.testStartFromSavepoint is unstable

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31862. -- Resolution: Cannot Reproduce > KafkaSinkITCase.testStartFromSavepoint is unstable >

[jira] [Closed] (FLINK-31342) SQLClientSchemaRegistryITCase timed out when starting the test container

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31342. -- Resolution: Cannot Reproduce > SQLClientSchemaRegistryITCase timed out when starting the test

[jira] [Closed] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31756. -- Resolution: Cannot Reproduce > KafkaTableITCase.testStartFromGroupOffsetsNone fails due to >

Re: [PR] [FLINK-33171][table planner] Consistent implicit type coercion support for equal and non-equal comparisons for codegen [flink]

2023-10-16 Thread via GitHub
fengjiajie commented on PR #23478: URL: https://github.com/apache/flink/pull/23478#issuecomment-1764364941 1. When constructing "non-comparable types," there is no problem with `testSqlApi("NULL = f30", "NULL")`, but `testSqlApi("NULL = f30", "NULL")` throws an exception: ```Caused

Re: [PR] [FLINK-32896][Runtime/Coordination] Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity [flink]

2023-10-16 Thread via GitHub
itonyli commented on PR #23518: URL: https://github.com/apache/flink/pull/23518#issuecomment-1764353014 LGTM -- 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

[jira] [Commented] (FLINK-33282) core stage: 137 exit code

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775734#comment-17775734 ] Matthias Pohl commented on FLINK-33282: --- yes, could be. I didn't do research on whether it's

[jira] [Closed] (FLINK-31134) Out of memory error in KafkaSourceE2ECase>SourceTestSuiteBase.testScaleDown

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31134. -- Resolution: Cannot Reproduce > Out of memory error in

[jira] [Closed] (FLINK-27695) KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27695. -- Resolution: Cannot Reproduce > KafkaTransactionLogITCase failed on azure due to Could not

[jira] [Closed] (FLINK-30262) UpsertKafkaTableITCase failed when starting the container because waiting for a port timed out

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-30262. -- Resolution: Cannot Reproduce > UpsertKafkaTableITCase failed when starting the container

[jira] [Closed] (FLINK-26566) FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice failed on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26566. -- Resolution: Cannot Reproduce > FlinkKafkaProducerITCase.testFailAndRecoverSameCheckpointTwice

[jira] [Closed] (FLINK-31341) OutOfMemoryError in Kafka e2e tests

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31341. -- Resolution: Cannot Reproduce > OutOfMemoryError in Kafka e2e tests >

[jira] [Closed] (FLINK-28818) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee failed with AssertionFailedError

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-28818. -- Resolution: Cannot Reproduce >

[jira] [Closed] (FLINK-26533) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on azure due to delete topic timeout

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26533. -- Resolution: Cannot Reproduce > KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee failed on

[jira] [Closed] (FLINK-25966) KafkaSourceITCase failed on azure due to Create test topic : topic1 failed

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25966. -- Resolution: Cannot Reproduce > KafkaSourceITCase failed on azure due to Create test topic :

[jira] [Closed] (FLINK-27883) KafkaSubscriberTest failed with NPC

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27883. -- Resolution: Cannot Reproduce > KafkaSubscriberTest failed with NPC >

[jira] [Closed] (FLINK-28545) FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not present in me

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-28545. -- Resolution: Cannot Reproduce >

[jira] [Closed] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-20928. -- Resolution: Cannot Reproduce >

[jira] [Closed] (FLINK-25624) KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked on azure pipeline

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25624. -- Resolution: Cannot Reproduce > KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee blocked

[jira] [Closed] (FLINK-25449) KafkaSourceITCase.testRedundantParallelism failed on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25449. -- Resolution: Cannot Reproduce > KafkaSourceITCase.testRedundantParallelism failed on azure >

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

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775732#comment-17775732 ] Matthias Pohl commented on FLINK-33277: --- None that I know of. I haven't looked into it, yet but

[jira] [Closed] (FLINK-25451) KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed on azure

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25451. -- Resolution: Cannot Reproduce > KafkaEnumeratorTest.testDiscoverPartitionsPeriodically failed

[jira] [Closed] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25456. -- Resolution: Cannot Reproduce > FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint >

[jira] [Closed] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-22194. -- Resolution: Cannot Reproduce > KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers

[jira] [Closed] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-16634. -- Assignee: (was: Fangliang Liu) Resolution: Won't Fix Given that FlinkKafkaConsumer

[jira] [Closed] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-20777. -- Resolution: Information Provided Superseded by

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

2023-10-16 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-20777: --- Fix Version/s: (was: 1.12.8) > Default value of property

[jira] [Updated] (FLINK-33171) Consistent implicit type coercion support for equal and non-equal comparisons for codegen

2023-10-16 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33171: Summary: Consistent implicit type coercion support for equal and non-equal comparisons for

[jira] [Updated] (FLINK-33171) Consistent implicit type coercion support for equal and non-equi comparison for codegen

2023-10-16 Thread Feng Jiajie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feng Jiajie updated FLINK-33171: Summary: Consistent implicit type coercion support for equal and non-equi comparison for codegen

[jira] [Resolved] (FLINK-33236) Deprecate the unused high-availability.zookeeper.path.running-registry option

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33236. --- Resolution: Fixed master: 935188f06a8a94b3a2c991a8aa6e48b2bfaeee70 > Deprecate the unused

Re: [PR] [FLINK-33236][config] Deprecate the unused high-availability.zookeeper.path.running-registry option [flink]

2023-10-16 Thread via GitHub
XComp merged PR #23506: URL: https://github.com/apache/flink/pull/23506 -- 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] [Commented] (FLINK-33284) core stage: HistoryServerStaticFileServerHandlerTest.testRespondWithFile(Path)

2023-10-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775706#comment-17775706 ] Chesnay Schepler commented on FLINK-33284: -- Same cause as FLINK-32283. > core stage:

[jira] [Commented] (FLINK-33283) core stage: WebFrontendBootstrapTest.testHandlersMustBeLoaded

2023-10-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775705#comment-17775705 ] Chesnay Schepler commented on FLINK-33283: -- Probably caused by the WebUI never being built. >

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

2023-10-16 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775697#comment-17775697 ] Chesnay Schepler commented on FLINK-33277: -- Is there a strong benefit in using v4? Connector CI

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360489801 ## docs/content/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These release

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360486457 ## docs/content/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These release

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360488280 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360487410 ## docs/content/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These release

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360486457 ## docs/content/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These release

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360484701 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360483461 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360482517 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

[jira] [Assigned] (FLINK-33116) CliClientTest.testCancelExecutionInteractiveMode fails with NPE on AZP

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33116: - Assignee: Jiabao Sun > CliClientTest.testCancelExecutionInteractiveMode fails with NPE

[jira] [Assigned] (FLINK-33116) CliClientTest.testCancelExecutionInteractiveMode fails with NPE on AZP

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33116: - Assignee: (was: Matthias Pohl) > CliClientTest.testCancelExecutionInteractiveMode

[jira] [Assigned] (FLINK-33116) CliClientTest.testCancelExecutionInteractiveMode fails with NPE on AZP

2023-10-16 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-33116: - Assignee: Matthias Pohl > CliClientTest.testCancelExecutionInteractiveMode fails with

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360482132 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360481680 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-16 Thread via GitHub
snuyanzin commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1360481156 ## docs/content.zh/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360479261 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,23 +158,70 @@ private void

Re: [PR] [FLINK-21883][scheduler] Implement cooldown period for adaptive scheduler [flink]

2023-10-16 Thread via GitHub
echauchot commented on code in PR #22985: URL: https://github.com/apache/flink/pull/22985#discussion_r1360474345 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java: ## @@ -124,23 +158,70 @@ private void

  1   2   3   >