[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18297: [FLINK-25395][state] Don't discard shared state on TM

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18297: URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142 ## CI report: * 7407da5e58ed7e7d093ddfd048e08583a5b5f49e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot commented on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933892 ## CI report: * bff97576f03c57c0f3fd436c84b4edebcd2ce78a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
flinkbot commented on pull request #18320: URL: https://github.com/apache/flink/pull/18320#issuecomment-1008933540 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] flinkbot edited a comment on pull request #18297: [FLINK-25395][state] Don't discard shared state on TM

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18297: URL: https://github.com/apache/flink/pull/18297#issuecomment-1007316142 ## CI report: * 7407da5e58ed7e7d093ddfd048e08583a5b5f49e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] akalash opened a new pull request #18320: [FLINK-25427] Decreased number of tests

2022-01-10 Thread GitBox
akalash opened a new pull request #18320: URL: https://github.com/apache/flink/pull/18320 ## What is the purpose of the change *This PR fixes the hanging in test* ## Verifying this change It is test ## Does this pull request potentially affect one of t

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 0cb7e0c49e9b417f460573885d6d7ba483f18ba1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1008922616 Thanks for the review @gaoyunhaii @alpreu I have addressed all your comments. PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781234978 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781234514 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781233508 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Committer.java ## @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [flink] flinkbot edited a comment on pull request #18314: [connectors/firehose] FLINK-24228 - Unified Async Sink for Kinesis Firehose

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18314: URL: https://github.com/apache/flink/pull/18314#issuecomment-1008761781 ## CI report: * 0cb7e0c49e9b417f460573885d6d7ba483f18ba1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781231320 ## File path: flink-core/src/main/java/org/apache/flink/api/connector/sink2/Sink.java ## @@ -0,0 +1,106 @@ +/* + * Licensed to the Apache Software Foundat

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781227987 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/ProcessingTimeService.java ## @@ -0,0 +1,56 @@ +/* + * Licensed to the Apache

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-10 Thread GitBox
XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781224232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -935,6 +942,19 @@ protected CleanupJobState jobReached

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-10 Thread GitBox
XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781224232 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -935,6 +942,19 @@ protected CleanupJobState jobReached

[jira] [Created] (FLINK-25596) Specify hash/sortmerge join in SQL hint

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25596: -- Summary: Specify hash/sortmerge join in SQL hint Key: FLINK-25596 URL: https://issues.apache.org/jira/browse/FLINK-25596 Project: Flink Issue Type: Sub-task

[GitHub] [flink] twalthr commented on a change in pull request #18215: [FLINK-25392][table-planner]Support new StatementSet syntax in planner and parser

2022-01-10 Thread GitBox
twalthr commented on a change in pull request #18215: URL: https://github.com/apache/flink/pull/18215#discussion_r781220838 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -683,12 +683,6 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18319: [FLINK-25531][connectors/kafka] Set ProducerConfig 'retries' to 3 to speed up testRetryComittableOnRetriableError

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822 ## CI report: * eb853c67af624764b4e5c0c3fce054a7fdedbf0e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18319: [FLINK-25531][connectors/kafka] Set ProducerConfig 'retries' to 3 to speed up testRetryComittableOnRetriableError

2022-01-10 Thread GitBox
flinkbot commented on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008898822 ## CI report: * eb853c67af624764b4e5c0c3fce054a7fdedbf0e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Created] (FLINK-25595) Specify hash/sort aggregate strategy in SQL hint

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25595: -- Summary: Specify hash/sort aggregate strategy in SQL hint Key: FLINK-25595 URL: https://issues.apache.org/jira/browse/FLINK-25595 Project: Flink Issue Type: Sub-

[jira] [Updated] (FLINK-25531) The test testRetryCommittableOnRetriableError takes one hour before completing succesfully

2022-01-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25531: --- Labels: pull-request-available test-stability (was: test-stability) > The test testRetryCom

[GitHub] [flink] flinkbot edited a comment on pull request #18274: [FLINK-25230][table-planner] Harden type serialization for LogicalType and DataType

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18274: URL: https://github.com/apache/flink/pull/18274#issuecomment-1005845834 ## CI report: * c445781fa99453f887f9d91978e5bb9ca9d1f91a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul commented on a change in pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on a change in pull request #18302: URL: https://github.com/apache/flink/pull/18302#discussion_r781214232 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamGraphGeneratorTest.java ## @@ -806,6 +809,54 @@ public void te

[jira] [Created] (FLINK-25594) Take parquet metadata into consideration when source is parquet files

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25594: -- Summary: Take parquet metadata into consideration when source is parquet files Key: FLINK-25594 URL: https://issues.apache.org/jira/browse/FLINK-25594 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18319: [FLINK-25531][connectors/kafka] Set ProducerConfig 'retries' to 3 to speed up testRetryComittableOnRetriableError

2022-01-10 Thread GitBox
flinkbot commented on pull request #18319: URL: https://github.com/apache/flink/pull/18319#issuecomment-1008897334 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

2022-01-10 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25592: --- Description: This is a parent JIRA to track improvements on Flink Batch SQL, including parser, opti

[GitHub] [flink] alpreu opened a new pull request #18319: [FLINK-25531][connectors/kafka] Set ProducerConfig 'retries' to 3 to speed up testRetryComittableOnRetriableError

2022-01-10 Thread GitBox
alpreu opened a new pull request #18319: URL: https://github.com/apache/flink/pull/18319 ## What is the purpose of the change testRetryComittableORetriableError is taking over an hour on CI runs. We want to speed up the test. The KafkaProducer doc states: * * To

[jira] [Created] (FLINK-25593) A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25593: -- Summary: A redundant scan could be skipped if it is an input of join and the other input is empty after partition prune Key: FLINK-25593 URL: https://issues.apache.org/jira/browse/FLI

[GitHub] [flink] flinkbot edited a comment on pull request #18318: [FLINK-25576][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18318: URL: https://github.com/apache/flink/pull/18318#issuecomment-100611 ## CI report: * e8c0089788c0c0f2ac3f9d24d9204fcfff6a0785 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] XComp commented on a change in pull request #18189: [FLINK-25430] Replace RunningJobRegistry by JobResultStore

2022-01-10 Thread GitBox
XComp commented on a change in pull request #18189: URL: https://github.com/apache/flink/pull/18189#discussion_r781204397 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -196,6 +198,8 @@ public Dispatcher( this.rec

[GitHub] [flink] flinkbot commented on pull request #18318: [FLINK-25576][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot commented on pull request #18318: URL: https://github.com/apache/flink/pull/18318#issuecomment-100611 ## CI report: * e8c0089788c0c0f2ac3f9d24d9204fcfff6a0785 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18317: [FLINK-25576][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18317: URL: https://github.com/apache/flink/pull/18317#issuecomment-1008884033 ## CI report: * b243b63a00bd7ae1870eb2ddcb1bb83f02fc2ee2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18318: [FLINK-25576][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot commented on pull request #18318: URL: https://github.com/apache/flink/pull/18318#issuecomment-1008885609 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] flinkbot commented on pull request #18317: [FLINK-25576][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot commented on pull request #18317: URL: https://github.com/apache/flink/pull/18317#issuecomment-1008884033 ## CI report: * b243b63a00bd7ae1870eb2ddcb1bb83f02fc2ee2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

2022-01-10 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25095: --- Parent: FLINK-25592 Issue Type: Sub-task (was: Bug) > Case when would be translated into di

[GitHub] [flink] flinkbot commented on pull request #18317: [FLINK-25576][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot commented on pull request #18317: URL: https://github.com/apache/flink/pull/18317#issuecomment-1008883266 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] MartijnVisser edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
MartijnVisser edited a comment on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216 @fapaul Can you merge? I'll also create a backport for 1.14 and 1.13 -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] MartijnVisser opened a new pull request #18318: [FLINK-25576][BP 1.13][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
MartijnVisser opened a new pull request #18318: URL: https://github.com/apache/flink/pull/18318 Backport of https://github.com/apache/flink/pull/18301 -- 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 g

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25095) Case when would be translated into different expression in Hive dialect and default dialect

2022-01-10 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25095: --- Summary: Case when would be translated into different expression in Hive dialect and default dialect

[jira] [Updated] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

2022-01-10 Thread Jing Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang updated FLINK-25592: --- Description: This is a parent JIRA to track improvements on Flink Batch SQL, including parser, opti

[jira] [Created] (FLINK-25592) Improvement of parser, optimizer and execution for Flink Batch SQL

2022-01-10 Thread Jing Zhang (Jira)
Jing Zhang created FLINK-25592: -- Summary: Improvement of parser, optimizer and execution for Flink Batch SQL Key: FLINK-25592 URL: https://issues.apache.org/jira/browse/FLINK-25592 Project: Flink

[GitHub] [flink] cuibo01 commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
cuibo01 commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008881143 > @cuibo01 I know, but the CI won't pass without you rebasing since this is still pointing to a CI installation that's no longer valid. Without a green CI build, the PR can't g

[GitHub] [flink] MartijnVisser edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
MartijnVisser edited a comment on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216 @fapaul Can you merge? I'll also create a backport for 1.14 -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] flinkbot edited a comment on pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18316: URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978 ## CI report: * 716ceb4e65626fde5dee8a5f0b11c6ed266e40fd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1007550439 ## CI report: * 1f32fec2896f73c2a4599a00d04a103f55bc252a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] MartijnVisser opened a new pull request #18317: [FLINK-25576][BP 1.14][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
MartijnVisser opened a new pull request #18317: URL: https://github.com/apache/flink/pull/18317 Backport of https://github.com/apache/flink/pull/18301 -- 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 g

[GitHub] [flink] fapaul commented on pull request #18302: [FLINK-25569][core] Add decomposed Sink V2 interface

2022-01-10 Thread GitBox
fapaul commented on pull request #18302: URL: https://github.com/apache/flink/pull/18302#issuecomment-1008877750 @zentol FYI 5c2fd49 adds public annotations to the metrics classes -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[GitHub] [flink] flinkbot commented on pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-10 Thread GitBox
flinkbot commented on pull request #18316: URL: https://github.com/apache/flink/pull/18316#issuecomment-1008875688 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the pr

[GitHub] [flink] MartijnVisser commented on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1008875216 @fapaul Can you merge? I'll also create a backport for 1.14 and 1.13 (to be sure) -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot commented on pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-10 Thread GitBox
flinkbot commented on pull request #18316: URL: https://github.com/apache/flink/pull/18316#issuecomment-1008874978 ## CI report: * 716ceb4e65626fde5dee8a5f0b11c6ed266e40fd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] MartijnVisser commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008874128 @cuibo01 I know, but the CI won't pass without you rebasing since this is still pointing to a CI installation that's no longer valid. Without a green CI build, the PR can

[GitHub] [flink] MartijnVisser commented on a change in pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-10 Thread GitBox
MartijnVisser commented on a change in pull request #18316: URL: https://github.com/apache/flink/pull/18316#discussion_r781188418 ## File path: docs/content.zh/docs/dev/table/config.md ## @@ -91,6 +91,39 @@ Flink SQL> SET 'table.exec.mini-batch.size' = '5000'; {{< /tab >}} {{

[GitHub] [flink] MartijnVisser opened a new pull request #18316: [hotfix][docs] Fixing multiple internal and external 404 links

2022-01-10 Thread GitBox
MartijnVisser opened a new pull request #18316: URL: https://github.com/apache/flink/pull/18316 ## What is the purpose of the change * This PR addresses multiple broken links (404s) existing throughout the English and Chinese documentation. ## Brief change log * Fixed

[GitHub] [flink] cuibo01 commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
cuibo01 commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008868247 > @cuibo01 Can you also please rebase on master and squash your commits? Sorry for the hassle. hi @MartijnVisser , github provides rebase and squash, and does not need to

[GitHub] [flink] flinkbot edited a comment on pull request #18305: [FLINK-25580][State Backends]Improve the logic of over fraction calcu…

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18305: URL: https://github.com/apache/flink/pull/18305#issuecomment-1008223896 ## CI report: * f20decd97ab0a9fded76ab714f7f7f0b33c9f9f0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] alpreu commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

2022-01-10 Thread GitBox
alpreu commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1008866360 > I believe it is the right direction to use the `KubernetesLabel` for generating and validating labels and names. I have one more concern about this PR. IIRC, only the labels,

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * a4cbe47def1a55221c40be3e16ab532662c4d336 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18313: Update match_recognize.md

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18313: URL: https://github.com/apache/flink/pull/18313#issuecomment-1008743407 ## CI report: * 9e65f5754e07a6f0f31839cf297369c439098ef4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] cuibo01 commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
cuibo01 commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008848874 > @cuibo01 Can you also please rebase on master and squash your commits? Sorry for the hassle. ok thx @MartijnVisser -- This is an automated message from the Apache G

[GitHub] [flink] twalthr commented on pull request #18221: [FLINK-24803][table-planner] Fix cast BINARY/VARBINARY to STRING

2022-01-10 Thread GitBox
twalthr commented on pull request #18221: URL: https://github.com/apache/flink/pull/18221#issuecomment-1008847150 Thanks for the investigation. I would be fine with the hex approach. It is definitely more useful than the current master implementation and allows for the "round trip" cast.

[jira] [Comment Edited] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

2022-01-10 Thread Darron Fuller (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471970#comment-17471970 ] Darron Fuller edited comment on FLINK-25579 at 1/10/22, 12:53 PM:

[jira] [Commented] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

2022-01-10 Thread Darron Fuller (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471970#comment-17471970 ] Darron Fuller commented on FLINK-25579: --- Thanks [~hxbks2ks]. That was my copy-and-

[GitHub] [flink] MartijnVisser commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845958 @cuibo01 Can you also please rebase on master and squash your commits? Sorry for the hassle. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] MartijnVisser removed a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
MartijnVisser removed a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845462 @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 t

[GitHub] [flink] MartijnVisser commented on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
MartijnVisser commented on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-1008845462 @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 sp

[jira] [Commented] (FLINK-25589) Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471969#comment-17471969 ] Alexander Preuss commented on FLINK-25589: -- Thank you [~biyuhao] , I assigned y

[jira] [Assigned] (FLINK-25589) Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Preuss reassigned FLINK-25589: Assignee: Yuhao Bi > Update Chinese version of Elasticsearch connector docs > ---

[jira] [Updated] (FLINK-25579) Py4JException: window([class org.apache.flink.table.api.SlideWithSizeAndSlide]) does not exist

2022-01-10 Thread Darron Fuller (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darron Fuller updated FLINK-25579: -- Description: CODE: {quote}in_tbl = create_ingest_table() result = in_tbl.select(col('*')).win

[GitHub] [flink] flinkbot edited a comment on pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17907: URL: https://github.com/apache/flink/pull/17907#issuecomment-979080179 ## CI report: * d38720331e663bd081f72831ed48487e4931d570 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fapaul merged pull request #18116: [hotfix][docs] Fix type name for INTERVAL in Data Type Extraction section of types.md

2022-01-10 Thread GitBox
fapaul merged pull request #18116: URL: https://github.com/apache/flink/pull/18116 -- 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] flinkbot edited a comment on pull request #18301: [FLINK-25576][Connectors][JDBC] Upgrade com.h2database:h2 to 2.0.206

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18301: URL: https://github.com/apache/flink/pull/18301#issuecomment-1007423214 ## CI report: * 6e5cb6cd44e7e91335c04d68448ab2c5ec013935 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul merged pull request #18180: [hotfix][doc] fix typo of 'note that' and 'now that'

2022-01-10 Thread GitBox
fapaul merged pull request #18180: URL: https://github.com/apache/flink/pull/18180 -- 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] fapaul merged pull request #18184: [hotfix][quickstarts] Fix misprints in DataStreamJob.java and DataStreamJob.scala

2022-01-10 Thread GitBox
fapaul merged pull request #18184: URL: https://github.com/apache/flink/pull/18184 -- 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] [Commented] (FLINK-25589) Update Chinese version of Elasticsearch connector docs

2022-01-10 Thread Yuhao Bi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471953#comment-17471953 ] Yuhao Bi commented on FLINK-25589: -- I volunteer to help with this task  > Update Chine

[jira] [Updated] (FLINK-25591) Use FileSource for StreamExecutionEnvironment.readFile

2022-01-10 Thread Fabian Paul (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-25591: Description: Evaluate whether it is possible to replace the internals of StreamExecutionEnvironme

[jira] [Created] (FLINK-25591) Use FileSource for StreamExecutionEnvironment.readFiles

2022-01-10 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-25591: --- Summary: Use FileSource for StreamExecutionEnvironment.readFiles Key: FLINK-25591 URL: https://issues.apache.org/jira/browse/FLINK-25591 Project: Flink Issue T

[GitHub] [flink] flinkbot edited a comment on pull request #18220: [FLINK-25410] Flink CLI should exit when app is accepted with detach …

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18220: URL: https://github.com/apache/flink/pull/18220#issuecomment-1001978981 ## CI report: * f80e3635619ddb32f054090170799ee6cd49313a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

2022-01-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17471920#comment-17471920 ] Aitozi commented on FLINK-23031: [~wenlong.lwl] I lose sight of the Window Operator can

[GitHub] [flink] zentol closed pull request #18315: Release 1.2

2022-01-10 Thread GitBox
zentol closed pull request #18315: URL: https://github.com/apache/flink/pull/18315 -- 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] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15861: [FLINK-22602]Upgrade parquet to 1.12.2 due to CVEs

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #15861: URL: https://github.com/apache/flink/pull/15861#issuecomment-835080848 ## CI report: * 167c27f30e6f5176e1ec7682a9ebdfe57ae46294 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18311: [FLINK-25280][connector/kafka] Disable log deletion in KafkaTestEnvironmentImpl to prevent records from being deleted during test run

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18311: URL: https://github.com/apache/flink/pull/18311#issuecomment-1008683024 ## CI report: * 6d9cda7d8a3b8e002ed7d9685d9e76322604ad7d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] Airblader commented on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

2022-01-10 Thread GitBox
Airblader commented on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-1008796327 @yangjunhan I apologize for the late response; I was on vacation over the holidays. The changes overall look fine to me, except for the open point around the linting o

[GitHub] [flink] wangyang0918 commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

2022-01-10 Thread GitBox
wangyang0918 commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1008794107 Really thanks @alpreu for working on this PR and @XComp helping with review. I believe it is the right direction to use the `KubernetesLabel` for generating and vali

[GitHub] [flink] flinkbot edited a comment on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-971446182 ## CI report: * 2a61cd825f421777b5420b90fdc54193ea76b79a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18312: Update copyright year to 2022 for NOTICE files.

2022-01-10 Thread GitBox
flinkbot edited a comment on pull request #18312: URL: https://github.com/apache/flink/pull/18312#issuecomment-1008686402 ## CI report: * 93dbd0a2c4f931c1248c2c4ae23175af1115e6ce Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

<    1   2   3   4   5   6   >