[jira] [Assigned] (FLINK-25823) Remove Mesos from Flink Landing page

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25823: -- Assignee: Samrat Deb > Remove Mesos from Flink Landing page > ---

[jira] [Closed] (FLINK-25823) Remove Mesos from Flink Landing page

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25823. -- Resolution: Fixed Fixed in apache/flink-web:main b5e3051272b51aae40abead81c2c53b336f5946b > R

Re: [PR] [FLINK-25823] Remove Mesos from flink Architecture documentation. [flink-web]

2023-10-09 Thread via GitHub
MartijnVisser merged PR #682: URL: https://github.com/apache/flink-web/pull/682 -- 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] [Comment Edited] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

2023-10-09 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773565#comment-17773565 ] Jiang Xin edited comment on FLINK-33186 at 10/10/23 6:53 AM: -

[jira] [Commented] (FLINK-33186) CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished fails on AZP

2023-10-09 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773565#comment-17773565 ] Jiang Xin commented on FLINK-33186: --- [~Sergey Nuyanzin] I don't think the failure is r

Re: [PR] [FLINK-21949][table] Support ARRAY_AGG aggregate function [flink]

2023-10-09 Thread via GitHub
Jiabao-Sun commented on PR #23411: URL: https://github.com/apache/flink/pull/23411#issuecomment-1754523455 Hi @wuchong, could you help review this when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-33179) Improve reporting serialisation issues

2023-10-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33179. Fix Version/s: 1.19.0 Resolution: Fixed Fixed in master: 6b52a4107db7521a25f4f30889

Re: [PR] [FLINK-33179] Throw exception when serialising or deserialising ExecNode with invalid type [flink]

2023-10-09 Thread via GitHub
dawidwys merged PR #23488: URL: https://github.com/apache/flink/pull/23488 -- 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

[jira] [Comment Edited] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773558#comment-17773558 ] Dawid Wysakowicz edited comment on FLINK-33223 at 10/10/23 6:44 AM: --

[jira] [Updated] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-33223: - Fix Version/s: 1.18.1 > MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from

[jira] [Closed] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33223. Resolution: Fixed Fixed in master: 53ece12c25579497338ed59a7aebe70f2b3d9ed6 > MATCH_RECOG

Re: [PR] [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan [flink]

2023-10-09 Thread via GitHub
dawidwys merged PR #23499: URL: https://github.com/apache/flink/pull/23499 -- 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

Re: [PR] [FLINK-32650][protobuf]Added the ability to split flink-protobuf code… [flink]

2023-10-09 Thread via GitHub
ljw-hit commented on code in PR #23162: URL: https://github.com/apache/flink/pull/23162#discussion_r1351618189 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigProtoBufCodeSpiltterTest.java: ## @@ -0,0 +1,70 @@ +/* + * Licensed to the Apache Sof

Re: [PR] [FLINK-32738][formats] PROTOBUF format supports projection push down [flink]

2023-10-09 Thread via GitHub
ljw-hit commented on PR #23323: URL: https://github.com/apache/flink/pull/23323#issuecomment-1754484204 Hi, I will give my review suggestions in the next two days -- 原始邮件 -- 发件人: "Xiaogang ***@***.***>; 发送时间: 2023年10月8日(星期天) 晚上6:45 收件人:

[jira] [Commented] (FLINK-33046) [FLIP-333] Redesign Apache Flink website

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773549#comment-17773549 ] Danny Cranmer commented on FLINK-33046: --- Merged commit [{{4309cad}}|https://githu

[jira] [Commented] (FLINK-33047) Project website refresh Dark Mode

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773548#comment-17773548 ] Danny Cranmer commented on FLINK-33047: --- Merged commit [{{4309cad}}|https://githu

[jira] [Resolved] (FLINK-33047) Project website refresh Dark Mode

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33047. --- Resolution: Done > Project website refresh Dark Mode > - > >

[jira] [Resolved] (FLINK-33048) Project website refresh Light Mode

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33048. --- Resolution: Done > Project website refresh Light Mode > -- >

[jira] [Commented] (FLINK-33048) Project website refresh Light Mode

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773547#comment-17773547 ] Danny Cranmer commented on FLINK-33048: --- Merged commit [{{4309cad}}|https://githu

Re: [PR] [FLINK-33046][FLIP-333] Redesign Apache Flink website [flink-web]

2023-10-09 Thread via GitHub
dannycranmer merged PR #676: URL: https://github.com/apache/flink-web/pull/676 -- 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-33220) PyFlink support for Datagen connector

2023-10-09 Thread Liu Chong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773534#comment-17773534 ] Liu Chong commented on FLINK-33220: --- we've got the code ready for adding datagen to py

[jira] [Commented] (FLINK-33197) PyFlink support for ByteArraySchema

2023-10-09 Thread Liu Chong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773536#comment-17773536 ] Liu Chong commented on FLINK-33197: --- we've got the code ready for adding ByteArraySche

[jira] [Updated] (FLINK-33227) Flink sql cep support 'notFollowedBy' semantics

2023-10-09 Thread xiaoran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaoran updated FLINK-33227: Description: Currently, the cep mode of the Flink API can support next, notNext, followedBy, followedByAny

[jira] [Created] (FLINK-33227) Flink sql cep support 'notFollowedBy' semantics

2023-10-09 Thread xiaoran (Jira)
xiaoran created FLINK-33227: --- Summary: Flink sql cep support 'notFollowedBy' semantics Key: FLINK-33227 URL: https://issues.apache.org/jira/browse/FLINK-33227 Project: Flink Issue Type: New Feature

[jira] [Commented] (FLINK-24024) Support session Window TVF

2023-10-09 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773517#comment-17773517 ] xuyang commented on FLINK-24024: Hi, [~Sergey Nuyanzin] [~twalthr] ,I did a basic poc on

Re: [PR] [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition [flink]

2023-10-09 Thread via GitHub
swuferhong commented on code in PR #23423: URL: https://github.com/apache/flink/pull/23423#discussion_r1351218921 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushPartitionIntoTableSourceScanRule.java: ## @@ -176,6 +177,14 @@

Re: [PR] [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition [flink]

2023-10-09 Thread via GitHub
luoyuxia commented on code in PR #23423: URL: https://github.com/apache/flink/pull/23423#discussion_r1351171194 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushPartitionIntoTableSourceScanRule.java: ## @@ -176,6 +177,14 @@ p

Re: [PR] [docs] Update Vendor Solutions [flink]

2023-10-09 Thread via GitHub
JingGe merged PR #23482: URL: https://github.com/apache/flink/pull/23482 -- 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] [Created] (FLINK-33226) Forbid to drop current database

2023-10-09 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-33226: - Summary: Forbid to drop current database Key: FLINK-33226 URL: https://issues.apache.org/jira/browse/FLINK-33226 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33200: Fix Version/s: (was: 1.8.4) > ItemAt Expression validation fail in Table API due to type misma

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-33200: Affects Version/s: (was: 1.18.1) > ItemAt Expression validation fail in Table API due to type

Re: [PR] [FLINK-25593][table-planner] Skip redundant scan while partition table push down contains none-existent partition [flink]

2023-10-09 Thread via GitHub
swuferhong commented on PR #23423: URL: https://github.com/apache/flink/pull/23423#issuecomment-1754162270 > FLINK-27898 > @swuferhong Thanks for the pr. Overall, LGTM in code level. But I have one concern about it, in batch mode, it's total right to reduce the empty partition

[jira] [Updated] (FLINK-33206) Verify the existence of hbase table before read/write

2023-10-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-33206: --- Labels: pull-request-available stale-blocker (was: pull-request-available) I am the [Flink

[jira] [Updated] (FLINK-32714) JDBC: Add dialect for OceanBase database

2023-10-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32714: --- Labels: auto-deprioritized-major pull-request-available (was: pull-request-available stal

[jira] [Updated] (FLINK-32720) Add GENERATE_SERIES support in SQL & Table API

2023-10-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-32720: --- Labels: pull-request-available stale-major (was: pull-request-available) I am the [Flink Ji

[jira] [Updated] (FLINK-33207) Scan hbase table will throw error when table is empty

2023-10-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-33207: --- Labels: pull-request-available stale-blocker (was: pull-request-available) I am the [Flink

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

2023-10-09 Thread via GitHub
afedulov commented on PR #22850: URL: https://github.com/apache/flink/pull/22850#issuecomment-1753896916 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Comment Edited] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773192#comment-17773192 ] Jing Ge edited comment on FLINK-33175 at 10/9/23 9:03 PM: -- Than

[jira] [Comment Edited] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773174#comment-17773174 ] Jing Ge edited comment on FLINK-33175 at 10/9/23 9:01 PM: -- Verv

Re: [PR] [FLINK-26088][Connectors/ElasticSearch] Add Elasticsearch 8.0 support [flink-connector-elasticsearch]

2023-10-09 Thread via GitHub
mtfelisb commented on PR #53: URL: https://github.com/apache/flink-connector-elasticsearch/pull/53#issuecomment-1753824138 > hi @mtfelisb , I read the code and found that it has no implementation for `DynamicTableSink`, hence this es8 sink cannot be used in flink-sql. Would you have any pl

[jira] [Comment Edited] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773466#comment-17773466 ] Andriy Onyshchuk edited comment on FLINK-33200 at 10/9/23 7:46 PM: ---

[jira] [Comment Edited] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773466#comment-17773466 ] Andriy Onyshchuk edited comment on FLINK-33200 at 10/9/23 7:45 PM: ---

[jira] [Comment Edited] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773466#comment-17773466 ] Andriy Onyshchuk edited comment on FLINK-33200 at 10/9/23 7:43 PM: ---

[jira] [Comment Edited] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773466#comment-17773466 ] Andriy Onyshchuk edited comment on FLINK-33200 at 10/9/23 7:40 PM: ---

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Andriy Onyshchuk (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773466#comment-17773466 ] Andriy Onyshchuk commented on FLINK-33200: -- Hello, team. Here is a bit of the s

Re: [PR] [FLINK-25823] Remove Mesos from flink Architecture documentation. [flink-web]

2023-10-09 Thread via GitHub
Samrat002 commented on PR #682: URL: https://github.com/apache/flink-web/pull/682#issuecomment-1753451191 @MartijnVisser made changes for chinese doc as well . please review whenever time -- This is an automated message from the Apache Git Service. To respond to the message, please lo

[jira] [Updated] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

2023-10-09 Thread Deepyaman Datta (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepyaman Datta updated FLINK-33225: Description: In the same vein as https://issues.apache.org/jira/browse/FLINK-31915, `JVM_

[jira] [Updated] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

2023-10-09 Thread Deepyaman Datta (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepyaman Datta updated FLINK-33225: Description: In the same vein as https://issues.apache.org/jira/browse/FLINK-31915, `JVM_

[jira] [Updated] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

2023-10-09 Thread Deepyaman Datta (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepyaman Datta updated FLINK-33225: Affects Version/s: 1.17.1 1.18.0 1.18.1 > Py

[jira] [Updated] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

2023-10-09 Thread Deepyaman Datta (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepyaman Datta updated FLINK-33225: Labels: github-pullrequest (was: ) > Python API incorrectly passes `JVM_ARGS` as single a

[jira] [Created] (FLINK-33225) Python API incorrectly passes `JVM_ARGS` as single argument

2023-10-09 Thread Deepyaman Datta (Jira)
Deepyaman Datta created FLINK-33225: --- Summary: Python API incorrectly passes `JVM_ARGS` as single argument Key: FLINK-33225 URL: https://issues.apache.org/jira/browse/FLINK-33225 Project: Flink

Re: [PR] [FLINK-XXXXX][python] Parse `JVM_ARGS` as an array [flink]

2023-10-09 Thread via GitHub
deepyaman commented on PR #23500: URL: https://github.com/apache/flink/pull/23500#issuecomment-1753392855 FYI @zentol since this is very similar to your change in #22476. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] [FLINK-XXXXX][python] Parse `JVM_ARGS` as an array [flink]

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

[PR] [FLINK-XXXXX][python] Parse `JVM_ARGS` as an array [flink]

2023-10-09 Thread via GitHub
deepyaman opened a new pull request, #23500: URL: https://github.com/apache/flink/pull/23500 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[jira] [Updated] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33200: -- Affects Version/s: 1.17.1 1.18.0 1.18.1 > ItemAt

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773373#comment-17773373 ] Zhenqiu Huang commented on FLINK-33200: --- We tried both 1.17.1 and 1.18-SNAPSHOT >

[jira] [Commented] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773372#comment-17773372 ] Jing Ge commented on FLINK-33175: - [~hong] Thanks for the effort and feedback! > Nightl

Re: [PR] [FLINK-15462][connectors] Add Trino dialect [flink-connector-jdbc]

2023-10-09 Thread via GitHub
eskabetxe commented on PR #3: URL: https://github.com/apache/flink-connector-jdbc/pull/3#issuecomment-1753222806 @snuyanzin rebased and tests passing -- 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 t

[jira] [Commented] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2023-10-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773370#comment-17773370 ] Timo Walther commented on FLINK-33182: -- Great that we are on the same page. Yes I m

[jira] [Commented] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

2023-10-09 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773367#comment-17773367 ] lincoln lee commented on FLINK-33182: - [~twalthr] You're right, I checked the curren

[jira] [Commented] (FLINK-33200) ItemAt Expression validation fail in Table API due to type mismatch

2023-10-09 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773361#comment-17773361 ] lincoln lee commented on FLINK-33200: - [~ZhenqiuHuang] What flink version are you us

Re: [PR] [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan [flink]

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

[jira] [Created] (FLINK-33224) Flink Batch Job does not complete when using Kafka topics with empty partitions

2023-10-09 Thread Kanthi Vaidya (Jira)
Kanthi Vaidya created FLINK-33224: - Summary: Flink Batch Job does not complete when using Kafka topics with empty partitions Key: FLINK-33224 URL: https://issues.apache.org/jira/browse/FLINK-33224 Pr

[jira] [Updated] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33223: --- Labels: pull-request-available (was: ) > MATCH_RECOGNIZE AFTER MATCH clause can not be dese

[PR] [FLINK-33223] MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan [flink]

2023-10-09 Thread via GitHub
dawidwys opened a new pull request, #23499: URL: https://github.com/apache/flink/pull/23499 ## What is the purpose of the change Fixes deserialization issues with `AFTER MATCH` clause in `MATCH_RECOGNIZE` ## Brief change log * added `SKIP_TO_LAST` and `SKIP_TO_FIRST` to F

Re: [PR] [FLINK-33179] Throw exception when serialising or deserialising ExecNode with invalid type [flink]

2023-10-09 Thread via GitHub
dawidwys commented on code in PR #23488: URL: https://github.com/apache/flink/pull/23488#discussion_r1350384802 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java: ## @@ -167,12 +170,19 @@ public ExecNodeContext w

Re: [PR] [FLINK-33179] Throw exception when serialising or deserialising ExecNode with invalid type [flink]

2023-10-09 Thread via GitHub
dawidwys commented on code in PR #23488: URL: https://github.com/apache/flink/pull/23488#discussion_r1350384802 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java: ## @@ -167,12 +170,19 @@ public ExecNodeContext w

Re: [PR] [FLINK-33179] Throw exception when serialising or deserialising ExecNode with invalid type [flink]

2023-10-09 Thread via GitHub
dawidwys commented on code in PR #23488: URL: https://github.com/apache/flink/pull/23488#discussion_r1350383216 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/UnsupportedNodesInPlanTest.java: ## @@ -0,0 +1,45 @@ +/* + * Licensed t

Re: [PR] [FLINK-33179] Throw exception when serialising or deserialising ExecNode with invalid type [flink]

2023-10-09 Thread via GitHub
dawidwys commented on code in PR #23488: URL: https://github.com/apache/flink/pull/23488#discussion_r1350382539 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeContext.java: ## @@ -105,6 +105,9 @@ private ExecNodeContext(@N

[jira] [Created] (FLINK-33223) MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan

2023-10-09 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33223: Summary: MATCH_RECOGNIZE AFTER MATCH clause can not be deserialised from a compiled plan Key: FLINK-33223 URL: https://issues.apache.org/jira/browse/FLINK-33223

[jira] [Commented] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773329#comment-17773329 ] Danny Cranmer commented on FLINK-33068: --- [~elphastori] done, thanks > Handle DNS

[jira] [Assigned] (FLINK-33068) Handle DNS errors in AWS connectors as recoverable

2023-10-09 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33068: - Assignee: Elphas Toringepi > Handle DNS errors in AWS connectors as recoverable > -

[jira] [Created] (FLINK-33222) Operator rollback app when it should not

2023-10-09 Thread Nicolas Fraison (Jira)
Nicolas Fraison created FLINK-33222: --- Summary: Operator rollback app when it should not Key: FLINK-33222 URL: https://issues.apache.org/jira/browse/FLINK-33222 Project: Flink Issue Type: Bu

[jira] [Closed] (FLINK-33104) Nightly run for Flink Kafka connector fails due to architecture tests failing

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33104. -- Resolution: Duplicate > Nightly run for Flink Kafka connector fails due to architecture tests

[jira] [Closed] (FLINK-33219) Kafka connector has architecture test violation against Flink 1.18

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33219. -- Fix Version/s: kafka-3.1.0 Resolution: Fixed Fixed in: apache/flink-connector-kafka@ma

[jira] [Assigned] (FLINK-33219) Kafka connector has architecture test violation against Flink 1.18

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33219: -- Assignee: Qingsheng Ren > Kafka connector has architecture test violation against Fli

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

2023-10-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-33217: --- Attachment: UnnestNullErrorTest.scala > Flink SQL: UNNEST fails with on LEFT JOIN with NOT N

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

2023-10-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773311#comment-17773311 ] Robert Metzger edited comment on FLINK-33217 at 10/9/23 1:31 PM: -

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

2023-10-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-33217: --- Attachment: (was: UnnestNullErrorTest-1.scala) > Flink SQL: UNNEST fails with on LEFT JO

[jira] [Resolved] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33141. - Resolution: Implemented Resolved by https://issues.apache.org/jira/browse/FLINK-33138 >

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

2023-10-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-33217: --- Description: Steps to reproduce: Take a column of type  {code:java} business_data ARRAY {c

[jira] [Assigned] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33138: --- Assignee: Lorenzo Nicora > Prometheus Connector Sink - DataStream API implementatio

[jira] [Commented] (FLINK-33174) enabling tablesample bernoulli in flink

2023-10-09 Thread xiaogang zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773306#comment-17773306 ] xiaogang zhou commented on FLINK-33174: --- [~libenchao] [~lsy] [~martijnvisser]  Tha

[jira] [Updated] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33191: --- Labels: pull-request-available (was: ) > Kafka Connector should directly depend on 3rd-part

[PR] [FLINK-33191][Connector/Kafka] Remove dependency on Flink Shaded [flink-connector-kafka]

2023-10-09 Thread via GitHub
MartijnVisser opened a new pull request, #57: URL: https://github.com/apache/flink-connector-kafka/pull/57 (no comment) -- 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 u

[jira] [Assigned] (FLINK-33191) Kafka Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-33191: -- Assignee: Martijn Visser > Kafka Connector should directly depend on 3rd-party libs i

Re: [PR] [FLINK-33046][FLIP-333] Redesign Apache Flink website [flink-web]

2023-10-09 Thread via GitHub
dannycranmer commented on PR #676: URL: https://github.com/apache/flink-web/pull/676#issuecomment-1753004143 @MartijnVisser thanks for reporting this: > Not sure if it's intended, but when hovering over the Flink logo in top left, then "Apache Flink" becomes visible (in dark mode). I

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

2023-10-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-33217: --- Attachment: UnnestNullErrorTest-1.scala > Flink SQL: UNNEST fails with on LEFT JOIN with NOT

[jira] [Commented] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773294#comment-17773294 ] Hong Liang Teoh commented on FLINK-33175: - Verified the flink-connector-aws one

Re: [PR] [FLINK-32512] Don't register resource to user resource manager when creating temporary function [flink]

2023-10-09 Thread via GitHub
fsk119 commented on code in PR #22938: URL: https://github.com/apache/flink/pull/22938#discussion_r1350236277 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/resource/ResourceManager.java: ## @@ -65,9 +69,14 @@ public class ResourceManager implements Clo

Re: [PR] [FLINK-33219][connector/kafka] Add new archunit violation messages introduced by FLINK-31804 [flink-connector-kafka]

2023-10-09 Thread via GitHub
boring-cyborg[bot] commented on PR #56: URL: https://github.com/apache/flink-connector-kafka/pull/56#issuecomment-1752946580 Awesome work, congrats on your first merged pull request! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-33219][connector/kafka] Add new archunit violation messages introduced by FLINK-31804 [flink-connector-kafka]

2023-10-09 Thread via GitHub
MartijnVisser merged PR #56: URL: https://github.com/apache/flink-connector-kafka/pull/56 -- 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-unsubsc

[jira] [Closed] (FLINK-14102) Introduce DB2Dialect

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

[jira] [Assigned] (FLINK-14102) Introduce DB2Dialect

2023-10-09 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-14102: -- Assignee: Zhongqiang Gong > Introduce DB2Dialect > > >

Re: [PR] [FLINK-14102] Introduce DB2Dialect. [flink-connector-jdbc]

2023-10-09 Thread via GitHub
MartijnVisser merged PR #8: URL: https://github.com/apache/flink-connector-jdbc/pull/8 -- 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..

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

2023-10-09 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773263#comment-17773263 ] Sergey Nuyanzin edited comment on FLINK-33217 at 10/9/23 11:52 AM: ---

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

2023-10-09 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773263#comment-17773263 ] Sergey Nuyanzin edited comment on FLINK-33217 at 10/9/23 11:51 AM: ---

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

2023-10-09 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773263#comment-17773263 ] Sergey Nuyanzin edited comment on FLINK-33217 at 10/9/23 11:48 AM: ---

Re: [PR] [FLINK-33046][FLIP-333] Redesign Apache Flink website [flink-web]

2023-10-09 Thread via GitHub
dannycranmer commented on PR #676: URL: https://github.com/apache/flink-web/pull/676#issuecomment-1752855653 > Open any Staging link in an incognito window. Using Version 117.0.5938.149 (Official Build) (arm64) Thanks, have reproduced in incognito! (weird) -- This is an automated m

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

2023-10-09 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17773263#comment-17773263 ] Sergey Nuyanzin edited comment on FLINK-33217 at 10/9/23 11:45 AM: ---

  1   2   >