[jira] [Commented] (FLINK-30629) ClientHeartbeatTest.testJobRunningIfClientReportHeartbeat is unstable

2023-05-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726773#comment-17726773 ] Sergey Nuyanzin commented on FLINK-30629: - https://dev.azure.com/apache-flink/ap

[jira] [Updated] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

2023-05-26 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Samrat Deb updated FLINK-32176: --- Attachment: (was: Screenshot 2023-05-27 at 9.00.53 AM.png) > [CVE-2022-1471] Mitigate CVE from s

[jira] [Comment Edited] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

2023-05-26 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726765#comment-17726765 ] Samrat Deb edited comment on FLINK-32176 at 5/27/23 3:31 AM: -

[jira] [Comment Edited] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

2023-05-26 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726765#comment-17726765 ] Samrat Deb edited comment on FLINK-32176 at 5/27/23 3:31 AM: -

[jira] [Commented] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

2023-05-26 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726765#comment-17726765 ] Samrat Deb commented on FLINK-32176: Please help triggering the workflow for the PR

[jira] [Commented] (FLINK-32137) Flame graph is hard to use with many task managers

2023-05-26 Thread Vladimir Matveev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726760#comment-17726760 ] Vladimir Matveev commented on FLINK-32137: -- Hi [~fanrui], I need to clear this

[GitHub] [flink] flinkbot commented on pull request #22668: [BP-1.17][FLINK-28853] Document the split level watermark alignment feature an…

2023-05-26 Thread via GitHub
flinkbot commented on PR #22668: URL: https://github.com/apache/flink/pull/22668#issuecomment-1564848214 ## CI report: * 60a2646b4caec19e5a3a470f5d7528009d880246 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] mas-chen opened a new pull request, #22668: [BP-1.17][FLINK-28853] Document the split level watermark alignment feature an…

2023-05-26 Thread via GitHub
mas-chen opened a new pull request, #22668: URL: https://github.com/apache/flink/pull/22668 …d fixup grammar from the configuration table ## What is the purpose of the change Update docs for watermark alignment. ## Brief change log - Update docs for watermark a

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

2023-05-26 Thread Alireza Omidvar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32206: Attachment: (was: image (1)-1.png) > ModuleNotFoundError for Pyflink.table.descriptors

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

2023-05-26 Thread Alireza Omidvar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32206: Attachment: (was: image (2)-1.png) > ModuleNotFoundError for Pyflink.table.descriptors

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

2023-05-26 Thread Alireza Omidvar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32206: Attachment: image (1)-1.png image (2)-1.png Comp

[GitHub] [flink] pgaref commented on pull request #22663: [FLINK-32198][runtime] Enforce single maxExceptions query parameter

2023-05-26 Thread via GitHub
pgaref commented on PR #22663: URL: https://github.com/apache/flink/pull/22663#issuecomment-1564774191 > This is an api-breaking change and can't be merged. Thanks for taking a look @zentol ! What the policy for making breaking changes? -- This is an automated message from th

[GitHub] [flink] kurtostfeld commented on pull request #22660: [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w…

2023-05-26 Thread via GitHub
kurtostfeld commented on PR #22660: URL: https://github.com/apache/flink/pull/22660#issuecomment-1564710396 @zentol ok, I created a Confluence login with username "kurto", however I don't seem to have permissions to create a new FLIP. I don't see a "Create" button as the docs say: >

[jira] [Comment Edited] (FLINK-3154) Update Kryo version from 2.24.0 to latest Kryo LTS version

2023-05-26 Thread Kurt Ostfeld (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726320#comment-17726320 ] Kurt Ostfeld edited comment on FLINK-3154 at 5/26/23 5:24 PM: -

[jira] [Resolved] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko resolved FLINK-32209. -- Resolution: Won't Do > Opensearch connector should remove the dependency on flink-shaded > ---

[jira] [Commented] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726691#comment-17726691 ] Andriy Redko commented on FLINK-32209: -- Already fixed by https://github.com/apache

[GitHub] [flink-connector-jdbc] ewangsdc commented on pull request #3: [FLINK-15462][connectors] Add Trino dialect

2023-05-26 Thread via GitHub
ewangsdc commented on PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3#issuecomment-1564695132 If the new Flink JDBC connector Trino dialect supports this Trino JDBC driver, i.e., https://trino.io/docs/current/client/jdbc.html & https://github.com/trinodb/docs.trino.io, Ke

[jira] [Assigned] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-32209: --- Assignee: Andriy Redko > Opensearch connector should remove the dependency on flink

[GitHub] [flink] reswqa commented on pull request #22666: Update japicmp configuration for 1.16.2

2023-05-26 Thread via GitHub
reswqa commented on PR #22666: URL: https://github.com/apache/flink/pull/22666#issuecomment-1564661314 I don't know if it was missed or just for reasons I'm not aware of, it seems that the release of `1.16.1` did not update `japicmp`. If I understand correctly, we also should update it for

[jira] [Commented] (FLINK-31944) Protobuf format throw com.google.protobuf.InvalidProtocolBufferException

2023-05-26 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726681#comment-17726681 ] Ryan Skraba commented on FLINK-31944: - This is a duplicate of FLINK-32008 – one of t

[jira] [Comment Edited] (FLINK-32008) Protobuf format cannot work with FileSystem Connector

2023-05-26 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726567#comment-17726567 ] Ryan Skraba edited comment on FLINK-32008 at 5/26/23 4:40 PM:

[jira] [Created] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Andriy Redko (Jira)
Andriy Redko created FLINK-32209: Summary: Opensearch connector should remove the dependency on flink-shaded Key: FLINK-32209 URL: https://issues.apache.org/jira/browse/FLINK-32209 Project: Flink

[jira] [Updated] (FLINK-32209) Opensearch connector should remove the dependency on flink-shaded

2023-05-26 Thread Andriy Redko (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andriy Redko updated FLINK-32209: - Description: The Opensearch connector depends on flink-shaded. With the externalization of the c

[jira] [Updated] (FLINK-32200) OrcFileSystemITCase cashed with exit code 239 (NoClassDefFoundError: scala/concurrent/duration/Deadline)

2023-05-26 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-32200: Labels: test-stability (was: ) > OrcFileSystemITCase cashed with exit code 239 (NoClassDe

[GitHub] [flink-connector-aws] snuyanzin commented on pull request #75: [FLINK-32208] Remove dependency on flink-shaded from flink-connector-aws

2023-05-26 Thread via GitHub
snuyanzin commented on PR #75: URL: https://github.com/apache/flink-connector-aws/pull/75#issuecomment-1564624709 hm... that's weird... almost same command passes locally ``` mvn clean install -DskipTests -Dflink.convergence.phase=install -Pcheck-convergence -U -B \ -Dhttp.keepA

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206929777 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/JoinITCase.scala: ## @@ -1333,7 +1335,7 @@ class JoinITCase(e

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

2023-05-26 Thread Alireza Omidvar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32206: Attachment: image (2).png image (1).png > Error ModuleNotFoundError for Py

[jira] [Updated] (FLINK-32208) Remove dependency on flink-shaded from flink-connector-aws

2023-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32208: --- Labels: pull-request-available (was: ) > Remove dependency on flink-shaded from flink-conne

[GitHub] [flink-connector-aws] boring-cyborg[bot] commented on pull request #75: [FLINK-32208] Remove dependency on flink-shaded from flink-connector-aws

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

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

2023-05-26 Thread Alireza Omidvar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alireza Omidvar updated FLINK-32206: Description: Gentlemen,       I have problem with some apache-flink modules. I am running

[jira] [Created] (FLINK-32208) Remove dependency on flink-shaded from flink-connector-aws

2023-05-26 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-32208: --- Summary: Remove dependency on flink-shaded from flink-connector-aws Key: FLINK-32208 URL: https://issues.apache.org/jira/browse/FLINK-32208 Project: Flink

[GitHub] [flink] mxm merged pull request #22531: [FLINK-28853] Document the split level watermark alignment feature an…

2023-05-26 Thread via GitHub
mxm merged PR #22531: URL: https://github.com/apache/flink/pull/22531 -- 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.apache.or

[GitHub] [flink] XComp commented on a diff in pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

2023-05-26 Thread via GitHub
XComp commented on code in PR #22010: URL: https://github.com/apache/flink/pull/22010#discussion_r1206745426 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -65,33 +71,46 @@ public void open(

[GitHub] [flink] XComp commented on a diff in pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

2023-05-26 Thread via GitHub
XComp commented on code in PR #22341: URL: https://github.com/apache/flink/pull/22341#discussion_r1206775003 ## flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/JobResultStore.java: ## @@ -43,69 +44,69 @@ public interface JobResultStore { * Registers t

[jira] [Updated] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

2023-05-26 Thread Oleksandr Nitavskyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oleksandr Nitavskyi updated FLINK-32203: Priority: Minor (was: Major) > Potential ClassLoader memory leak due to log4j con

[GitHub] [flink] echauchot commented on pull request #22667: [FLINK-31806] Fix public API rule for connectors

2023-05-26 Thread via GitHub
echauchot commented on PR #22667: URL: https://github.com/apache/flink/pull/22667#issuecomment-1564460268 Tested it on Cassandra connector and it reports these violations: 1. If I put back IOUtils use in the connector it raises `Method calls method in (CassandraEnumeratorS

[jira] [Created] (FLINK-32207) Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch

2023-05-26 Thread Alireza Omidvar (Jira)
Alireza Omidvar created FLINK-32207: --- Summary: Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch Key: FLINK-32207 URL: https://issues.apache.org/jira/browse/FLINK-32207

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

2023-05-26 Thread Alireza Omidvar (Jira)
Alireza Omidvar created FLINK-32206: --- Summary: Error ModuleNotFoundError for Pyflink.table.descriptors and wheel version mismatch Key: FLINK-32206 URL: https://issues.apache.org/jira/browse/FLINK-32206

[GitHub] [flink] RyanSkraba commented on a diff in pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

2023-05-26 Thread via GitHub
RyanSkraba commented on code in PR #22010: URL: https://github.com/apache/flink/pull/22010#discussion_r1206825892 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -65,33 +71,46 @@ public void open(

[GitHub] [flink] reswqa commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
reswqa commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206813779 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/SemiJoinITCase.scala: ## @@ -470,7 +469,7 @@ class SemiJoinITCase

[GitHub] [flink] reswqa commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
reswqa commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206804563 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/JoinITCase.scala: ## @@ -1333,7 +1335,7 @@ class JoinITCase(expec

[GitHub] [flink] flinkbot commented on pull request #22667: [FLINK-31806] Fix public API rule for connectors

2023-05-26 Thread via GitHub
flinkbot commented on PR #22667: URL: https://github.com/apache/flink/pull/22667#issuecomment-1564407238 ## CI report: * 21e34a00657502a6a502e436152d5cb01aad4872 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-31806) Prod architecture tests didn't detect non-public API usage

2023-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31806: --- Labels: pull-request-available (was: ) > Prod architecture tests didn't detect non-public A

[jira] [Commented] (FLINK-32203) Potential ClassLoader memory leak due to log4j configuration

2023-05-26 Thread Oleksandr Nitavskyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726626#comment-17726626 ] Oleksandr Nitavskyi commented on FLINK-32203: - [~chesnay] thanks for looking

[GitHub] [flink-connector-jdbc] matriv commented on pull request #29: [FLINK-31551] Add support for CrateDB

2023-05-26 Thread via GitHub
matriv commented on PR #29: URL: https://github.com/apache/flink-connector-jdbc/pull/29#issuecomment-1564380946 @MartijnVisser @snuyanzin I've rebased again, can you please run ci again? It would be great to merge it if everything passes, thx. -- This is an automated message from the A

[GitHub] [flink] XComp commented on a diff in pull request #22010: [FLINK-31192][connectors/dataGen] Fix dataGen takes too long to initi…

2023-05-26 Thread via GitHub
XComp commented on code in PR #22010: URL: https://github.com/apache/flink/pull/22010#discussion_r1206745426 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java: ## @@ -65,33 +71,46 @@ public void open(

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206741341 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/OuterJoinITCase.scala: ## @@ -398,7 +398,7 @@ class OuterJoin

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206740602 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/JoinITCase.scala: ## @@ -1333,7 +1335,7 @@ class JoinITCase(e

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206740122 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/LookupJoinITCase.scala: ## @@ -26,23 +26,31 @@ import org.ap

[GitHub] [flink] WencongLiu commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
WencongLiu commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206739358 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/SemiJoinITCase.scala: ## @@ -470,7 +469,7 @@ class SemiJoinIT

[jira] [Commented] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726616#comment-17726616 ] Matthias Pohl commented on FLINK-32204: --- FYI: I couldn't reproduce the error local

[jira] [Commented] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726613#comment-17726613 ] Matthias Pohl commented on FLINK-32204: --- The curator's {{TreeCache}} isn't thread-

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:32 PM:

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:30 PM:

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:26 PM:

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:24 PM:

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:23 PM:

[jira] [Commented] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen commented on FLINK-32188: -- Jark Wu Thank you for your reply!So should I submit

[jira] [Comment Edited] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726609#comment-17726609 ] Xin Chen edited comment on FLINK-32188 at 5/26/23 12:22 PM:

[jira] [Updated] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Xin Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Chen updated FLINK-32188: - Attachment: screenshot-8.png > Does the custom connector not support pushing down "where" query predicat

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206683144 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/PollingKinesisShardSplitReader.java: ## @@ -0,0 +1,152 @

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206671480 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206669438 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/serialization/KinesisDeserializationSchemaWrapper.java: ## @@ -

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206669002 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/UniformShardAssigner.java: ## @@ -0,0 +1,59

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r120406 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206663759 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206665143 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206664219 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206662694 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0 +1,3

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206657247 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java: ## @@ -0,0 +1,61 @@

[jira] [Commented] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726598#comment-17726598 ] Jark Wu commented on FLINK-32188: - But I'm also confused why the array constructor is no

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206656720 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSourceBuilder.java: ## @@ -0,0 +1,92 @@ +/* + * L

[jira] [Updated] (FLINK-31990) Use Flink Configuration to specify KDS Source configuration object

2023-05-26 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31990: Description: *What* Use the Flink Configuration object to standardise the method of speci

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

2023-05-26 Thread via GitHub
hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1206655247 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/KinesisStreamsSourceConfigUtil.java: ## @@ -0,0 +1,61 @@

[jira] [Commented] (FLINK-32188) Does the custom connector not support pushing down "where" query predicates to query fields of array type?

2023-05-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726597#comment-17726597 ] Jark Wu commented on FLINK-32188: - Yes, I think your fix is fine. The function name "arr

[jira] [Updated] (FLINK-32176) [CVE-2022-1471] Mitigate CVE from snakeyaml coming from pulsar-client-all

2023-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32176: --- Labels: pull-request-available (was: ) > [CVE-2022-1471] Mitigate CVE from snakeyaml coming

[GitHub] [flink-connector-pulsar] Samrat002 opened a new pull request, #51: [FLINK-32176] Exclude snakeyaml from pulsar-client-all

2023-05-26 Thread via GitHub
Samrat002 opened a new pull request, #51: URL: https://github.com/apache/flink-connector-pulsar/pull/51 ## Purpose of the change Mitigate the imapact of CVE in flink ## Brief change log Exclude snakeyaml from pulsar-client-all ## Verifying this change Pl

[jira] [Updated] (FLINK-32008) Protobuf format cannot work with FileSystem Connector

2023-05-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li updated FLINK-32008: --- Summary: Protobuf format cannot work with FileSystem Connector (was: Protobuf format throws excepti

[jira] [Commented] (FLINK-32008) Protobuf format cannot work with FileSystem Connector

2023-05-26 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726583#comment-17726583 ] Benchao Li commented on FLINK-32008: I've changed the title. > Protobuf format cann

[jira] [Commented] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726580#comment-17726580 ] Matthias Pohl commented on FLINK-32204: --- It's most likely being caused by FLINK-31

[GitHub] [flink] zentol commented on pull request #22660: [FLINK-3154][runtime] Upgrade from Kryo v2 + Chill 0.7.6 to Kryo v5 w…

2023-05-26 Thread via GitHub
zentol commented on PR #22660: URL: https://github.com/apache/flink/pull/22660#issuecomment-1564201206 I appreciate the work, but really this change has to go through a proper design process. There are open questions as to whether we really want to expose Kryo in the same way we did

[GitHub] [flink] flinkbot commented on pull request #22666: [Just For Test] Update japicmp configuration for 1.16.2

2023-05-26 Thread via GitHub
flinkbot commented on PR #22666: URL: https://github.com/apache/flink/pull/22666#issuecomment-1564193372 ## CI report: * f978740193f6053e57003801e870b91b398a3d18 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #22665: [Just For Test] Update japicmp configuration for 1.17.1

2023-05-26 Thread via GitHub
flinkbot commented on PR #22665: URL: https://github.com/apache/flink/pull/22665#issuecomment-1564188090 ## CI report: * 5ac854d04e1f587da5f70ea96326bb4d1d674497 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink-web] reswqa merged pull request #650: Add Flink 1.17.1

2023-05-26 Thread via GitHub
reswqa merged PR #650: URL: https://github.com/apache/flink-web/pull/650 -- 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.apache

[GitHub] [flink-web] reswqa merged pull request #649: Add Flink 1.16.2

2023-05-26 Thread via GitHub
reswqa merged PR #649: URL: https://github.com/apache/flink-web/pull/649 -- 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.apache

[jira] [Commented] (FLINK-32008) Protobuf format throws exception with Map datatype

2023-05-26 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726567#comment-17726567 ] Ryan Skraba commented on FLINK-32008: - It's probably worth checking in with the comm

[jira] [Commented] (FLINK-32202) useless configuration

2023-05-26 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726566#comment-17726566 ] Weihua Hu commented on FLINK-32202: --- [~zhangdong7] Could you explain more about "but t

[jira] (FLINK-32202) useless configuration

2023-05-26 Thread Weihua Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32202 ] Weihua Hu deleted comment on FLINK-32202: --- was (Author: huwh): [~zhangdong7] Could you explain more about "but the parameter query.server.ports:6125 will be generated when Flink starts"? I cou

[jira] [Updated] (FLINK-32202) useless configuration

2023-05-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-32202: --- Component/s: Runtime / Queryable State (was: API / Core) > useless conf

[jira] [Closed] (FLINK-32202) useless configuration

2023-05-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-32202. -- Resolution: Invalid Queryable State is (soft) deprecated, so this should doesn't have to be fi

[GitHub] [flink] MartijnVisser commented on pull request #22664: [FLINK-32203] Remove monitoringInterval to reduce probability of ClassLoader memory leak

2023-05-26 Thread via GitHub
MartijnVisser commented on PR #22664: URL: https://github.com/apache/flink/pull/22664#issuecomment-1564121721 @JTaky Thanks for the PR. However, would it be possible to actually address the issue of the memory leak, instead of applying the mitigating measure that this PR introduces?

[jira] [Closed] (FLINK-29750) Improve PostgresCatalog#listTables() by reusing resources

2023-05-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-29750. -- Fix Version/s: jdbc-3.2.0 Resolution: Fixed Fixed in apache/flink-connector-jdbc:main

[jira] [Reopened] (FLINK-29750) Improve PostgresCatalog#listTables() by reusing resources

2023-05-26 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-29750: Assignee: Mingliang Liu > Improve PostgresCatalog#listTables() by reusing resources > --

[jira] [Commented] (FLINK-32051) Fix broken documentation links in Flink blogs

2023-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726556#comment-17726556 ] Weijie Guo commented on FLINK-32051: merged in b64f8efce94018b87a4046c6c4d01e0aed1f5

[jira] [Resolved] (FLINK-32051) Fix broken documentation links in Flink blogs

2023-05-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-32051. Resolution: Fixed > Fix broken documentation links in Flink blogs > --

[GitHub] [flink-connector-jdbc] MartijnVisser commented on pull request #3: [FLINK-15462][connectors] Add Trino dialect

2023-05-26 Thread via GitHub
MartijnVisser commented on PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3#issuecomment-1564085808 > we’d appreciate it very much if you could please ensure that Flink JDBC connector Trino dialect support Kerberos authentication like Trino Python client, I think th

[jira] [Updated] (FLINK-32059) Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32059: --- Labels: pull-request-available (was: ) > Migrate subclasses of BatchAbstractTestBase in bat

[GitHub] [flink] reswqa commented on a diff in pull request #22579: [FLINK-32059] Migrate subclasses of BatchAbstractTestBase in batch.sql.agg and batch.sql.join to JUnit5

2023-05-26 Thread via GitHub
reswqa commented on code in PR #22579: URL: https://github.com/apache/flink/pull/22579#discussion_r1206475729 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/join/OuterJoinITCase.scala: ## @@ -398,7 +398,7 @@ class OuterJoinITCa

[jira] [Commented] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726545#comment-17726545 ] Matthias Pohl commented on FLINK-32204: --- FYI: CI failed on [a4de8945|https://githu

[jira] [Comment Edited] (FLINK-32204) ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement fails with The ExecutorService is shut down already. No Callables can be executed on AZP

2023-05-26 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726540#comment-17726540 ] Matthias Pohl edited comment on FLINK-32204 at 5/26/23 9:14 AM: --

  1   2   >