[jira] [Created] (FLINK-31203) Application upgrade rollbacks failed in Flink Kubernetes Operator

2023-02-23 Thread hjw (Jira)
hjw created FLINK-31203: --- Summary: Application upgrade rollbacks failed in Flink Kubernetes Operator Key: FLINK-31203 URL: https://issues.apache.org/jira/browse/FLINK-31203 Project: Flink Issue Type:

[GitHub] [flink-connector-opensearch] lilyevsky commented on a diff in pull request #11: [FLINK-30998] Add optional exception handler to flink-connector-opensearch

2023-02-23 Thread via GitHub
lilyevsky commented on code in PR #11: URL: https://github.com/apache/flink-connector-opensearch/pull/11#discussion_r1115906985 ## flink-connector-opensearch/src/main/java/org/apache/flink/connector/opensearch/sink/OpensearchSinkBuilder.java: ## @@ -148,6 +150,7 @@ public Opens

[jira] [Closed] (FLINK-31068) Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x (upcoming) clusters

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer closed FLINK-31068. - Resolution: Fixed > Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x >

[jira] [Updated] (FLINK-31068) Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x (upcoming) clusters

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31068: -- Fix Version/s: opensearch-1.1.0 > Document how to use Opensearch connector with OpenSearch 1.x

[jira] [Commented] (FLINK-31068) Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x (upcoming) clusters

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692756#comment-17692756 ] Danny Cranmer commented on FLINK-31068: --- Merged commit [{{b272fc8}}|https://githu

[jira] [Assigned] (FLINK-31068) Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x (upcoming) clusters

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-31068: - Assignee: Andriy Redko > Document how to use Opensearch connector with OpenSearch 1.x /

[GitHub] [flink-connector-opensearch] dannycranmer merged pull request #10: [FLINK-31068] Document how to use Opensearch connector with OpenSearch 1.x / 2.x / 3.x (upcoming) clusters

2023-02-23 Thread via GitHub
dannycranmer merged PR #10: URL: https://github.com/apache/flink-connector-opensearch/pull/10 -- 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: issues-uns

[GitHub] [flink] wuchong commented on pull request #21966: [FLINK-29729][parquet] Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

2023-02-23 Thread via GitHub
wuchong commented on PR #21966: URL: https://github.com/apache/flink/pull/21966#issuecomment-1442017027 Thanks for the contribution @lsyldliu , the change looks good to me. However, is it possible to add a test to verify the configuration can be passed to ParquetReader now? -- This is an

[GitHub] [flink-connector-opensearch] dannycranmer commented on pull request #5: [FLINK-30488] OpenSearch implementation of Async Sink

2023-02-23 Thread via GitHub
dannycranmer commented on PR #5: URL: https://github.com/apache/flink-connector-opensearch/pull/5#issuecomment-1442005227 @reta The PR looks good to me minus the Mockito comment. However I have questions over the approach here. We are adding a new sink alongside the existing sink, we will

[jira] [Updated] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

2023-02-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29729: Summary: Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader (was: Su

[GitHub] [flink-web] mbalassi merged pull request #608: Kubernetes Operator 1.4.0 release

2023-02-23 Thread via GitHub
mbalassi merged PR #608: URL: https://github.com/apache/flink-web/pull/608 -- 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: issues-unsubscr...@flink.apac

[GitHub] [flink] wuchong closed pull request #21130: [FLINK-29729][format] including properties from flink-conf.yaml during creating ParquetReader

2023-02-23 Thread via GitHub
wuchong closed pull request #21130: [FLINK-29729][format] including properties from flink-conf.yaml during creating ParquetReader URL: https://github.com/apache/flink/pull/21130 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] wuchong commented on pull request #21130: [FLINK-29729][format] including properties from flink-conf.yaml during creating ParquetReader

2023-02-23 Thread via GitHub
wuchong commented on PR #21130: URL: https://github.com/apache/flink/pull/21130#issuecomment-1441986636 continue in #21966 -- 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. T

[GitHub] [flink-connector-opensearch] dannycranmer commented on a diff in pull request #5: [FLINK-30488] OpenSearch implementation of Async Sink

2023-02-23 Thread via GitHub
dannycranmer commented on code in PR #5: URL: https://github.com/apache/flink-connector-opensearch/pull/5#discussion_r1115860671 ## flink-connector-opensearch/src/test/java/org/apache/flink/connector/opensearch/sink/DocSerdeRequestTest.java: ## @@ -0,0 +1,92 @@ +/* + * Licensed

[jira] [Commented] (FLINK-31066) Release Testing: Verify FLINK-29932 Upgrade Calcite to 1.29.0

2023-02-23 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692741#comment-17692741 ] Matthias Pohl commented on FLINK-31066: --- TODO: The configuration page of the JobMa

[GitHub] [flink] RocMarshal commented on pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
RocMarshal commented on PR #21999: URL: https://github.com/apache/flink/pull/21999#issuecomment-1441965644 > What do you mean by `hotfix-ticket`? For the current case, we do not need another jira ticket or another PR. In my opinion, this PR will eventually have two commits in the following

[GitHub] [flink] RocMarshal commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
RocMarshal commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115840729 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -410,6 +410,42 @@ public CloseException() { }

[GitHub] [flink] reswqa commented on pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
reswqa commented on PR #21999: URL: https://github.com/apache/flink/pull/21999#issuecomment-1441958963 What do you mean by `hotfix-ticket`? For the current case, we do not need another jira ticket or another PR. In my opinion, this PR will eventually have two commitments: 1.[hotfix] Mi

[GitHub] [flink] RocMarshal commented on pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
RocMarshal commented on PR #21999: URL: https://github.com/apache/flink/pull/21999#issuecomment-1441946575 > Thanks @RocMarshal. If you like, you'd better migrate all the tests in `StreamTaskTest` to `Junit5` and `AssertJ` in a hotfix commit. No matter what, the newly introduced test should

[jira] [Closed] (FLINK-8157) Create a "Flink Resources" page on the Apache Flink project site

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-8157. - Resolution: Done > Create a "Flink Resources" page on the Apache Flink project site > ---

[jira] [Closed] (FLINK-1044) Website: Offer a zip archive with a pre-setup user project

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-1044. - Resolution: Won't Fix > Website: Offer a zip archive with a pre-setup user project >

[jira] [Closed] (FLINK-13975) Translate "Upcoming Events" on Chinese index.html

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-13975. -- Resolution: Won't Fix > Translate "Upcoming Events" on Chinese index.html > --

[jira] [Closed] (FLINK-6986) Broken links to Photoshop images

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-6986. - Resolution: Done Completed via https://issues.apache.org/jira/browse/FLINK-22922 > Broken links

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21545: [FLINK-30396][table]make alias hint take effect in correlate

2023-02-23 Thread via GitHub
lincoln-lil commented on code in PR #21545: URL: https://github.com/apache/flink/pull/21545#discussion_r1115683129 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/stream/sql/join/LookupJoinTest.scala: ## @@ -951,6 +953,39 @@ class LookupJoin

[jira] [Updated] (FLINK-21854) WebUI show incorrect value

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-21854: --- Component/s: Runtime / Web Frontend (was: Project Website) > WebUI show

[jira] [Closed] (FLINK-3862) Restructure community website

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-3862. - Resolution: Done Completed via https://issues.apache.org/jira/browse/FLINK-22922 > Restructure c

[jira] [Closed] (FLINK-9541) Add robots.txt and sitemap.xml to Flink website

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-9541. - Resolution: Done > Add robots.txt and sitemap.xml to Flink website >

[jira] [Commented] (FLINK-18496) Anchors are not generated based on ZH characters

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692716#comment-17692716 ] Martijn Visser commented on FLINK-18496: Completed via https://issues.apache.org

[jira] [Closed] (FLINK-18496) Anchors are not generated based on ZH characters

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-18496. -- Resolution: Done > Anchors are not generated based on ZH characters >

[jira] [Closed] (FLINK-11893) Update ecosystem page and add it to the navigation bar

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-11893. -- Resolution: Done Completed via https://issues.apache.org/jira/browse/FLINK-22922 > Update eco

[GitHub] [flink-web] MartijnVisser closed pull request #187: [FLINK-11893] [Project Website] Update ecosystem to encourage sharing of the connectors

2023-02-23 Thread via GitHub
MartijnVisser closed pull request #187: [FLINK-11893] [Project Website] Update ecosystem to encourage sharing of the connectors URL: https://github.com/apache/flink-web/pull/187 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink-web] MartijnVisser commented on pull request #187: [FLINK-11893] [Project Website] Update ecosystem to encourage sharing of the connectors

2023-02-23 Thread via GitHub
MartijnVisser commented on PR #187: URL: https://github.com/apache/flink-web/pull/187#issuecomment-1441905973 Completed via https://issues.apache.org/jira/browse/FLINK-22922 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Closed] (FLINK-21720) Rework Documentation Style Guide for the new build system

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-21720. -- Resolution: Done Completed via FLINK-22922 > Rework Documentation Style Guide for the new bui

[jira] [Closed] (FLINK-10007) Security vulnerability in website build infrastructure

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-10007. -- Resolution: Done Completed via https://issues.apache.org/jira/browse/FLINK-22922 > Security v

[GitHub] [flink-web] MartijnVisser closed pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2023-02-23 Thread via GitHub
MartijnVisser closed pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system URL: https://github.com/apache/flink-web/pull/434 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink-web] MartijnVisser commented on pull request #434: [FLINK-21720] Updates documentation style guides for the new (Hugo) build system

2023-02-23 Thread via GitHub
MartijnVisser commented on PR #434: URL: https://github.com/apache/flink-web/pull/434#issuecomment-1441904545 Completed via https://issues.apache.org/jira/browse/FLINK-22922 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] reswqa commented on pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
reswqa commented on PR #21999: URL: https://github.com/apache/flink/pull/21999#issuecomment-1441903864 If you like, you'd better migrate all the tests in `StreamTaskTest` to `Junit5` and `AssertJ` in a hotfix commit. No matter what, the newly introduced test should no longer use the `hamcre

[jira] [Closed] (FLINK-13684) Translate "Code Style - Formatting Guide" page into Chinese

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-13684. -- Resolution: Done > Translate "Code Style - Formatting Guide" page into Chinese > -

[jira] [Commented] (FLINK-29533) Add proper table style to Flink website

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692712#comment-17692712 ] Martijn Visser commented on FLINK-29533: With FLINK-22922 completed I've integra

[jira] [Updated] (FLINK-28503) Fix invalid link in Python FAQ Document

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28503: --- Component/s: (was: Project Website) > Fix invalid link in Python FAQ Document >

[jira] [Closed] (FLINK-5596) Add padding to nav menu on mobile site

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-5596. - Resolution: Won't Fix > Add padding to nav menu on mobile site >

[jira] [Closed] (FLINK-5595) Add links to sub-sections in the left-hand navigation bar

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-5595. - Resolution: Won't Fix > Add links to sub-sections in the left-hand navigation bar > -

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
1996fanrui commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115773340 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -410,6 +410,42 @@ public CloseException() { }

[jira] [Updated] (FLINK-31140) Load additional dependencies in operator classpath

2023-02-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31140: --- Labels: pull-request-available (was: ) > Load additional dependencies in operator classpath

[jira] [Closed] (FLINK-27554) The asf-site does not build on Apple M1 ARM (Silicon)

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-27554. -- Resolution: Done This has been resolved now that FLINK-22922 is completed > The asf-site does

[GitHub] [flink-kubernetes-operator] tamirsagi opened a new pull request, #536: FLINK-31140 - Load additional dependencies in operator classpath from user

2023-02-23 Thread via GitHub
tamirsagi opened a new pull request, #536: URL: https://github.com/apache/flink-kubernetes-operator/pull/536 ## What is the purpose of the change Allow users to add additional dependencies onto operator classpath ## Brief change log - Create a target folder with

[GitHub] [flink] reswqa commented on pull request #21998: [Flink-clients][api] Adding a method to get ClusterClientProvider

2023-02-23 Thread via GitHub
reswqa commented on PR #21998: URL: https://github.com/apache/flink/pull/21998#issuecomment-1441893224 Thanks @jhkkhtd. Firstly, You should open a [jira ticket](https://issues.apache.org/jira/projects/FLINK/issues) and describe clearly why you need this change and how you plan to change it.

[jira] [Closed] (FLINK-22922) Migrate flink project website to Hugo

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-22922. -- Resolution: Fixed Fixed in asf-site: 1bd371b2c01dd89ee9d69302aca65b1ebfd4dc81 > Migrate flink

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
1996fanrui commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115773340 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -410,6 +410,42 @@ public CloseException() { }

[GitHub] [flink] reswqa commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
reswqa commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115766066 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -410,6 +410,42 @@ public CloseException() { } }

[GitHub] [flink] reswqa commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
reswqa commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115754252 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -410,6 +410,42 @@ public CloseException() { } }

[GitHub] [flink-web] MartijnVisser merged pull request #597: [FLINK-22922] Migrate project website from Jekyll to Hugo

2023-02-23 Thread via GitHub
MartijnVisser merged PR #597: URL: https://github.com/apache/flink-web/pull/597 -- 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: issues-unsubscr...@flink

[jira] [Updated] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31183: -- Fix Version/s: (was: 1.17.0) > Flink Kinesis EFO Consumer can fail to stop gracefully > --

[GitHub] [flink] akalash commented on a diff in pull request #21999: [FLINK-29816][streaming] Fix the bug that StreamTask doesn't handle exception during restoring

2023-02-23 Thread via GitHub
akalash commented on code in PR #21999: URL: https://github.com/apache/flink/pull/21999#discussion_r1115732271 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java: ## @@ -1018,6 +1023,11 @@ public final boolean isRunning() { re

[jira] [Updated] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31183: -- Affects Version/s: (was: aws-connector-3.0.0) > Flink Kinesis EFO Consumer can fail to sto

[jira] [Comment Edited] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692651#comment-17692651 ] Danny Cranmer edited comment on FLINK-31183 at 2/23/23 1:54 PM: --

[GitHub] [flink-connector-aws] dannycranmer merged pull request #57: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

2023-02-23 Thread via GitHub
dannycranmer merged PR #57: URL: https://github.com/apache/flink-connector-aws/pull/57 -- 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: issues-unsubscr..

[GitHub] [flink-kubernetes-operator] asardaes commented on a diff in pull request #535: [FLINK-30786] Support merge by name for podTemplate array fields

2023-02-23 Thread via GitHub
asardaes commented on code in PR #535: URL: https://github.com/apache/flink-kubernetes-operator/pull/535#discussion_r1115722661 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/utils/FlinkUtils.java: ## @@ -106,6 +99,54 @@ private static void merg

[GitHub] [flink-connector-aws] dannycranmer opened a new pull request, #57: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

2023-02-23 Thread via GitHub
dannycranmer opened a new pull request, #57: URL: https://github.com/apache/flink-connector-aws/pull/57 …to stop gracefully during stop-with-savepoint ## Purpose of the change Update Kinesis EFO consumer to exit gracefully during stop-with-savepoint. There is an edgecase where

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #535: [FLINK-30786] Support merge by name for podTemplate array fields

2023-02-23 Thread via GitHub
gyfora opened a new pull request, #535: URL: https://github.com/apache/flink-kubernetes-operator/pull/535 ## What is the purpose of the change Allow users to select the pod template merging strategy for object arrays. Currently we use a strictly position based merge strategy which c

[jira] [Updated] (FLINK-30786) Support merge by name for podTemplate array fields

2023-02-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30786: --- Labels: pull-request-available (was: ) > Support merge by name for podTemplate array fields

[GitHub] [flink] flinkbot commented on pull request #22008: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

2023-02-23 Thread via GitHub
flinkbot commented on PR #22008: URL: https://github.com/apache/flink/pull/22008#issuecomment-1441770151 ## CI report: * 6186ce2f09c80bbbccfc76829700cd6413b803fc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] dannycranmer opened a new pull request, #22008: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

2023-02-23 Thread via GitHub
dannycranmer opened a new pull request, #22008: URL: https://github.com/apache/flink/pull/22008 …to stop gracefully during stop-with-savepoint ## What is the purpose of the change Update Kinesis EFO consumer to exit gracefully during stop-with-savepoint. There is an edgecase wh

[GitHub] [flink] flinkbot commented on pull request #22007: [FLINK-31142][Table SQL/Client] Catch TokenMgrError in SqlCommandParserImpl#scan

2023-02-23 Thread via GitHub
flinkbot commented on PR #22007: URL: https://github.com/apache/flink/pull/22007#issuecomment-1441736850 ## CI report: * cf4639870e380eaacdb1980aa05ee287ba9f9533 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Comment Edited] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-23 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692658#comment-17692658 ] Sergey Nuyanzin edited comment on FLINK-31142 at 2/23/23 12:56 PM: ---

[jira] [Commented] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692660#comment-17692660 ] Rascal Wu commented on FLINK-31198: --- I also tried using 'add jar .jar' instead of

[GitHub] [flink] flinkbot commented on pull request #22006: [Flink 31170] [docs]The spelling error of the document word causes sql to fail to execute

2023-02-23 Thread via GitHub
flinkbot commented on PR #22006: URL: https://github.com/apache/flink/pull/22006#issuecomment-1441726763 ## CI report: * 2b7853f7bf56569a1f1b1d9c43db55f580b7f933 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-23 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692658#comment-17692658 ] Sergey Nuyanzin commented on FLINK-31142: - It seems that before this change all

[jira] [Updated] (FLINK-31142) Some queries lead to abrupt sql client close

2023-02-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31142: --- Labels: pull-request-available (was: ) > Some queries lead to abrupt sql client close > ---

[GitHub] [flink] snuyanzin opened a new pull request, #22007: [FLINK-31142][Table SQL/Client] Catch TokenMgrError in SqlCommandParserImpl#scan

2023-02-23 Thread via GitHub
snuyanzin opened a new pull request, #22007: URL: https://github.com/apache/flink/pull/22007 ## What is the purpose of the change After https://issues.apache.org/jira/browse/FLINK-29945 sql client started to close the session in case some invalid queries rather than just fail with error

[jira] [Commented] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692654#comment-17692654 ] Rascal Wu commented on FLINK-31198: --- Thanks [~martijnvisser] for your quick response,

[GitHub] [flink] BoYiZhang closed pull request #21990: [Flink 31170] [docs]The spelling error of the document word causes sql to fail to execute

2023-02-23 Thread via GitHub
BoYiZhang closed pull request #21990: [Flink 31170] [docs]The spelling error of the document word causes sql to fail to execute URL: https://github.com/apache/flink/pull/21990 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

[GitHub] [flink] BoYiZhang opened a new pull request, #22006: [Flink 31170] [docs]The spelling error of the document word causes sql to fail to execute

2023-02-23 Thread via GitHub
BoYiZhang opened a new pull request, #22006: URL: https://github.com/apache/flink/pull/22006 [Flink 31170] [docs]The spelling error of the document word causes sql to fail to execute -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

2023-02-23 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692651#comment-17692651 ] Danny Cranmer commented on FLINK-31183: --- Merged commit [{{a8c34db}}|https://githu

[GitHub] [flink] liuyongvs commented on pull request #21993: [FLINK-31166][table] Fix array_contains does not support null argumen…

2023-02-23 Thread via GitHub
liuyongvs commented on PR #21993: URL: https://github.com/apache/flink/pull/21993#issuecomment-1441703727 @snuyanzin has modified the PR description -- 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 t

[GitHub] [flink] dannycranmer merged pull request #22000: [FLINK-31183][Connector/Kinesis] Fix bug where EFO Consumer can fail …

2023-02-23 Thread via GitHub
dannycranmer merged PR #22000: URL: https://github.com/apache/flink/pull/22000 -- 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: issues-unsubscr...@flink.

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692648#comment-17692648 ] Martijn Visser commented on FLINK-28897: [~lsy] What is the user impact of this

[jira] [Commented] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692647#comment-17692647 ] Martijn Visser commented on FLINK-31198: [~stayrascal] There have been changes i

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: (was: image-2023-02-23-19-25-20-679.png) > Class loader problem by incorrect classload

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Description: Hi, I meet a wired problem about using Flink connector via `./bin/sql-client.sh -j conne

[jira] [Commented] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692646#comment-17692646 ] Rascal Wu commented on FLINK-31198: --- [~martijnvisser] thanks for reminder, i'm providi

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Description: Hi, I meet a wired problem about using Flink connector via ./bin/sql-client.sh -j connec

[jira] [Commented] (FLINK-31199) Add MAP_KEYS supported in SQL & Table API

2023-02-23 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692645#comment-17692645 ] jackylau commented on FLINK-31199: -- [~Sergey Nuyanzin] I just see it > Add MAP_KEYS su

[jira] [Updated] (FLINK-30069) Expected prune behavior for matches with same priority

2023-02-23 Thread Juntao Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Juntao Hu updated FLINK-30069: -- Description: When a pattern produces several matches with same priority, is it the expected behavior

[GitHub] [flink] liuyongvs commented on pull request #15797: [FLINK-22484][table] Add built-in MAP_KEYS, MAP_VALUES, MAP_FROM_ARRA…

2023-02-23 Thread via GitHub
liuyongvs commented on PR #15797: URL: https://github.com/apache/flink/pull/15797#issuecomment-1441675250 @snuyanzin do you rework it again. if you do not have time,I can do it -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: image-2023-02-23-20-21-52-113.png > Class loader problem by incorrect classloader in flink

[GitHub] [flink] Aitozi commented on pull request #21622: [FLINK-30570] Fix error inferred partition condition

2023-02-23 Thread via GitHub
Aitozi commented on PR #21622: URL: https://github.com/apache/flink/pull/21622#issuecomment-1441662850 @swuferhong could you help take a look again? -- 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 t

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: image-2023-02-23-20-14-24-895.png > Class loader problem by incorrect classloader in flink

[jira] [Closed] (FLINK-31162) Avoid setting private tokens to AM container context when kerberos delegation token fetch is disabled

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31162. -- Resolution: Fixed Fixed in release-1.16: d5c0944b8eacdb5d842c2aa443621442f6684244 > Avoid set

[jira] [Updated] (FLINK-31162) Avoid setting private tokens to AM container context when kerberos delegation token fetch is disabled

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31162: --- Fix Version/s: 1.16.2 > Avoid setting private tokens to AM container context when kerberos d

[GitHub] [flink] MartijnVisser merged pull request #21985: [FLINK-31162][yarn] Use currUsr.getCredentials.getTokens instead of currUsr.getTokens

2023-02-23 Thread via GitHub
MartijnVisser merged PR #21985: URL: https://github.com/apache/flink/pull/21985 -- 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: issues-unsubscr...@flink

[jira] [Updated] (FLINK-22484) Built-in functions for collections

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-22484: --- Description: There is a number of built-in functions to work with collections are supported

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: image-2023-02-23-20-10-27-274.png > Class loader problem by incorrect classloader in flink

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: image-2023-02-23-20-08-54-885.png > Class loader problem by incorrect classloader in flink

[jira] [Commented] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692640#comment-17692640 ] Martijn Visser commented on FLINK-31198: [~stayrascal] Please add a correct desc

[GitHub] [flink] MartijnVisser closed pull request #22005: [FLINK-31199][table] Add MAP_KEYS function.

2023-02-23 Thread via GitHub
MartijnVisser closed pull request #22005: [FLINK-31199][table] Add MAP_KEYS function. URL: https://github.com/apache/flink/pull/22005 -- 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 com

[jira] [Updated] (FLINK-31199) Add MAP_KEYS supported in SQL & Table API

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-31199: --- Parent: FLINK-6810 Issue Type: Sub-task (was: Bug) > Add MAP_KEYS supported in SQL

[GitHub] [flink] MartijnVisser commented on pull request #22005: [FLINK-31199][table] Add MAP_KEYS function.

2023-02-23 Thread via GitHub
MartijnVisser commented on PR #22005: URL: https://github.com/apache/flink/pull/22005#issuecomment-1441649940 Duplicate of FLINK-22484 -- 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

[jira] [Closed] (FLINK-31199) Add MAP_KEYS supported in SQL & Table API

2023-02-23 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-31199. -- Fix Version/s: (was: 1.18.0) Resolution: Duplicate > Add MAP_KEYS supported in SQL

[jira] [Updated] (FLINK-31198) Class loader problem by incorrect classloader in flink sql 1.16

2023-02-23 Thread Rascal Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rascal Wu updated FLINK-31198: -- Attachment: image-2023-02-23-20-04-01-936.png > Class loader problem by incorrect classloader in flink

<    1   2   3   4   >