[jira] [Closed] (FLINK-31219) Add support for canary resources

2023-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-31219. -- Fix Version/s: kubernetes-operator-1.5.0 Resolution: Fixed merged to main

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #550: [FLINK-31219] Add support for canary resources

2023-03-25 Thread via GitHub
gyfora merged PR #550: URL: https://github.com/apache/flink-kubernetes-operator/pull/550 -- 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-23978) FieldAccessor has direct scala dependency

2023-03-25 Thread Alexey Novakov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704990#comment-17704990 ] Alexey Novakov commented on FLINK-23978: I am not sure either. I have tried one more time

[jira] [Assigned] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

2023-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30638: -- Assignee: Gabor Somogyi > Operator doesn't forward allowNonRestoredState flag >

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #540: [FLINK-29566] Reschedule the cleanup logic if cancel job failed

2023-03-25 Thread via GitHub
gyfora commented on code in PR #540: URL: https://github.com/apache/flink-kubernetes-operator/pull/540#discussion_r1148437562 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/sessionjob/SessionJobReconciler.java: ## @@ -100,6 +106,26

[jira] [Commented] (FLINK-31613) Some default operator config values are overwritten by values.yaml

2023-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704987#comment-17704987 ] Gyula Fora commented on FLINK-31613: I agree that this could be confusing. The rationale behind this

[GitHub] [flink-kubernetes-operator] gyfora commented on a diff in pull request #553: [FLINK-31577] Upgrade documentation to improve Operator

2023-03-25 Thread via GitHub
gyfora commented on code in PR #553: URL: https://github.com/apache/flink-kubernetes-operator/pull/553#discussion_r1148434335 ## docs/content/docs/operations/upgrade.md: ## @@ -59,6 +59,16 @@ Please note that we are using the `replace` command here which ensures that runn

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #552: Fixing the container vulnerability by updating maven dependency

2023-03-25 Thread via GitHub
gyfora commented on PR #552: URL: https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1483923191 There seem to be some failing tests, also https://github.com/apache/flink-kubernetes-operator/blob/main/flink-kubernetes-operator/src/main/resources/META-INF/NOTICE

[jira] [Updated] (FLINK-26088) Add Elasticsearch 8.0 support

2023-03-25 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26088: --- Labels: pull-request-available (was: ) > Add Elasticsearch 8.0 support >

[GitHub] [flink-connector-elasticsearch] boring-cyborg[bot] commented on pull request #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

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

[GitHub] [flink-connector-elasticsearch] mtfelisb opened a new pull request, #53: [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support

2023-03-25 Thread via GitHub
mtfelisb opened a new pull request, #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53 # Description The eighth version was released in February last year and has a lot of internal changes, such as releasing a whole new Java API Client. Therefore, we can create a

[jira] [Commented] (FLINK-31406) Do not delete jobgraph on scale only last-state upgrades

2023-03-25 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704978#comment-17704978 ] Gyula Fora commented on FLINK-31406: This should also apply to regular restarts / redeployments done

[jira] [Created] (FLINK-31614) Upgrade autoscaling example to 1.17.0 image

2023-03-25 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-31614: -- Summary: Upgrade autoscaling example to 1.17.0 image Key: FLINK-31614 URL: https://issues.apache.org/jira/browse/FLINK-31614 Project: Flink Issue Type:

[jira] [Created] (FLINK-31613) Some default operator config values are overwritten by values.yaml

2023-03-25 Thread Mate Czagany (Jira)
Mate Czagany created FLINK-31613: Summary: Some default operator config values are overwritten by values.yaml Key: FLINK-31613 URL: https://issues.apache.org/jira/browse/FLINK-31613 Project: Flink

[jira] [Commented] (FLINK-31551) Support CrateDB in JDBC Connector

2023-03-25 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704928#comment-17704928 ] Benchao Li commented on FLINK-31551: [~matriv] Will review it in the next following days. > Support

[GitHub] [flink] libenchao commented on a diff in pull request #22259: [FLINK-31522] Introduce FlinkResultSet for jdbc driver

2023-03-25 Thread via GitHub
libenchao commented on code in PR #22259: URL: https://github.com/apache/flink/pull/22259#discussion_r1148347234 ## flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkResultSet.java: ## @@ -0,0 +1,461 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] libenchao commented on a diff in pull request #22233: [FLINK-31538][jdbc-driver] Supports parse catalog/database and properties for uri

2023-03-25 Thread via GitHub
libenchao commented on code in PR #22233: URL: https://github.com/apache/flink/pull/22233#discussion_r1148345880 ## flink-table/flink-sql-jdbc-driver/src/test/java/org/apache/flink/table/jdbc/FlinkDriverTest.java: ## @@ -0,0 +1,62 @@ +/* + * Licensed to the Apache Software

[GitHub] [flink] DavidLiu001 commented on a diff in pull request #22241: [FLINK-31542][connectors] Fix FatalExceptionClassifier semantics of r…

2023-03-25 Thread via GitHub
DavidLiu001 commented on code in PR #22241: URL: https://github.com/apache/flink/pull/22241#discussion_r1148340558 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/throwable/FatalExceptionClassifier.java: ## @@ -44,6 +44,8 @@ public

[GitHub] [flink] DavidLiu001 commented on a diff in pull request #22241: [FLINK-31542][connectors] Fix FatalExceptionClassifier semantics of r…

2023-03-25 Thread via GitHub
DavidLiu001 commented on code in PR #22241: URL: https://github.com/apache/flink/pull/22241#discussion_r1148340558 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/throwable/FatalExceptionClassifier.java: ## @@ -44,6 +44,8 @@ public

[GitHub] [flink] vtkhanh commented on a diff in pull request #22241: [FLINK-31542][connectors] Fix FatalExceptionClassifier semantics of r…

2023-03-25 Thread via GitHub
vtkhanh commented on code in PR #22241: URL: https://github.com/apache/flink/pull/22241#discussion_r1148335744 ## flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/throwable/FatalExceptionClassifier.java: ## @@ -44,6 +44,8 @@ public

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Description: Hi, When I am trying to run Flink job in HA mode with GCS path as a HA

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Description: Hi, When I am trying to run Flink job in HA mode with GCS path as a HA

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Affects Version/s: 1.17.0 > ClassNotFoundException when using GCS path as HA directory >

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Component/s: Connectors / Hadoop Compatibility > ClassNotFoundException when using GCS path

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Priority: Blocker (was: Minor) > ClassNotFoundException when using GCS path as HA

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Summary: ClassNotFoundException when using GCS path as HA directory (was:

[jira] [Updated] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory.

2023-03-25 Thread Mohit Aggarwal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohit Aggarwal updated FLINK-31612: --- Description: Hi, When I am trying to run Flink job in HA mode with GCS path as a HA

[jira] [Created] (FLINK-31612) ClassNotFoundException when using GCS path as HA directory.

2023-03-25 Thread Mohit Aggarwal (Jira)
Mohit Aggarwal created FLINK-31612: -- Summary: ClassNotFoundException when using GCS path as HA directory. Key: FLINK-31612 URL: https://issues.apache.org/jira/browse/FLINK-31612 Project: Flink