[jira] [Commented] (FLINK-29288) Can't start a job with a jar in the system classpath

2023-11-11 Thread Trystan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785217#comment-17785217 ] Trystan commented on FLINK-29288: - [~sap1ens] are you running native k8s mode or standalone mode? If the

Re: [PR] [FLINK-33522] Use created savepoint even if job cancellation fails [flink-kubernetes-operator]

2023-11-11 Thread via GitHub
gyfora commented on code in PR #706: URL: https://github.com/apache/flink-kubernetes-operator/pull/706#discussion_r1390245416 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkServiceTest.java: ## @@ -673,9 +693,11 @@ public

[jira] [Commented] (FLINK-32723) FLIP-334 : Decoupling autoscaler and kubernetes and support the Standalone Autoscaler

2023-11-11 Thread Maximilian Michels (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785183#comment-17785183 ] Maximilian Michels commented on FLINK-32723: Thanks for following through with this

[jira] [Updated] (FLINK-33361) Add Java 17 compatibility to Flink Kafka connector

2023-11-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33361: --- Labels: pull-request-available (was: ) > Add Java 17 compatibility to Flink Kafka

Re: [PR] [FLINK-33361] Add Java 17 compatibility to Flink Kafka connector [flink-connector-kafka]

2023-11-11 Thread via GitHub
boring-cyborg[bot] commented on PR #68: URL: https://github.com/apache/flink-connector-kafka/pull/68#issuecomment-1806840882 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[PR] [FLINK-33361] Add Java 17 compatibility to Flink Kafka connector [flink-connector-kafka]

2023-11-11 Thread via GitHub
snuyanzin opened a new pull request, #68: URL: https://github.com/apache/flink-connector-kafka/pull/68 The PR adds compatibility with java 17 Also it adds `ci.yml` which allows to run tests with java 17 Once this will be enabled in shared ci

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-11 Thread via GitHub
RocMarshal commented on PR #23635: URL: https://github.com/apache/flink/pull/23635#issuecomment-1806832620 Thank you @KarmaGYZ @1996fanrui very much for your comments. and I updated the PR based on your comments. Have a great weekend~ :) -- This is an automated message from the

[jira] [Updated] (FLINK-33523) DataType ARRAY fails to cast into Object[]

2023-11-11 Thread Prabhu Joseph (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Prabhu Joseph updated FLINK-33523: -- Component/s: Table SQL / API > DataType ARRAY fails to cast into Object[] >

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-11 Thread via GitHub
1996fanrui commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r139022 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java: ## @@ -95,7 +96,7 @@ public

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-11-11 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1390231615 ## flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DefaultResourceAllocationStrategy.java: ## @@ -95,7 +96,7 @@ public

[jira] [Updated] (FLINK-31854) FLIP-307:[Phase 1] [Sink Support] Flink Connector Redshift

2023-11-11 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-31854: --- Labels: pull-request-available (was: ) > FLIP-307:[Phase 1] [Sink Support] Flink Connector

[jira] [Created] (FLINK-33525) Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

2023-11-11 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-33525: - Summary: Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API Key: FLINK-33525 URL: https://issues.apache.org/jira/browse/FLINK-33525

[jira] [Assigned] (FLINK-33525) Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

2023-11-11 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-33525: - Assignee: (was: Alexander Fedulov) > Migrate LoadSimulationPipeline in

[jira] [Assigned] (FLINK-33525) Migrate LoadSimulationPipeline in Flink K8S Operator to the new Source API

2023-11-11 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov reassigned FLINK-33525: - Assignee: Alexander Fedulov > Migrate LoadSimulationPipeline in Flink K8S

[jira] [Commented] (FLINK-33251) SQL Client query execution aborts after a few seconds: ConnectTimeoutException

2023-11-11 Thread Jorick Caberio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785160#comment-17785160 ] Jorick Caberio commented on FLINK-33251: FWIW I tried replicating this in 1.16 and 1.18. 1.16