[GitHub] [flink] tillrohrmann opened a new pull request #17397: [BP-1.14][FLINK-24117][HA]Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

2021-09-30 Thread GitBox
tillrohrmann opened a new pull request #17397: URL: https://github.com/apache/flink/pull/17397 Backport of #17150 to `release-1.14`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Closed] (FLINK-21142) Flink guava Dependence problem

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21142. Resolution: Fixed > Flink guava Dependence problem > -- > >

[jira] [Reopened] (FLINK-21142) Flink guava Dependence problem

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-21142: -- > Flink guava Dependence problem > -- > > Key:

[jira] [Closed] (FLINK-21142) Flink guava Dependence problem

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-21142. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 268f980ade47dbc2e0b95f7a734298a0c5823cb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17369: URL: https://github.com/apache/flink/pull/17369#issuecomment-929030154 ## CI report: * cb02a4b37c6c11ef3b0950d4eb57a7b9bd5f972b Azure:

[jira] [Assigned] (FLINK-21142) Flink guava Dependence problem

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-21142: Assignee: Timo Walther > Flink guava Dependence problem > --

[GitHub] [flink] twalthr closed pull request #16012: [FLINK-21142][connector-hive] Hide Guava from Hadoop and security tools

2021-09-30 Thread GitBox
twalthr closed pull request #16012: URL: https://github.com/apache/flink/pull/16012 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

2021-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422826#comment-17422826 ] Piotr Nowojski commented on FLINK-24357: I've attached the logs extracted from [the

[jira] [Updated] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

2021-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24357: --- Attachment: logs-ci_build-test_ci_build_core-1632297723.zip >

[jira] [Commented] (FLINK-15816) Limit the maximum length of the value of kubernetes.cluster-id configuration option

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422825#comment-17422825 ] Till Rohrmann commented on FLINK-15816: --- I agree that implicit behaviour, such as truncating the

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-30 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r719487292 ## File path: flink-connectors/flink-connector-elasticsearch7/src/test/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriterITCase.java

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-30 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r719486443 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchWriter.java ## @@

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-30 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r719484986 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchSinkBuilder.java

[GitHub] [flink] AHeise commented on a change in pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-30 Thread GitBox
AHeise commented on a change in pull request #17363: URL: https://github.com/apache/flink/pull/17363#discussion_r719483898 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/sink/ElasticsearchProcessor.java ##

[jira] [Commented] (FLINK-24357) ZooKeeperLeaderElectionConnectionHandlingTest#testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled fails with an Unhandled error

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422821#comment-17422821 ] Till Rohrmann commented on FLINK-24357: --- [~pnowojski] do you have the logs for the test run? If

[GitHub] [flink] AHeise commented on a change in pull request #17106: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-30 Thread GitBox
AHeise commented on a change in pull request #17106: URL: https://github.com/apache/flink/pull/17106#discussion_r719478106 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java ## @@ -74,6

[GitHub] [flink] twalthr commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
twalthr commented on a change in pull request #17384: URL: https://github.com/apache/flink/pull/17384#discussion_r719477270 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecSink.java ## @@ -109,12

[jira] [Updated] (FLINK-24117) Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-24117: -- Fix Version/s: 1.14.1 > Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and >

[GitHub] [flink] AHeise commented on pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

2021-09-30 Thread GitBox
AHeise commented on pull request #14277: URL: https://github.com/apache/flink/pull/14277#issuecomment-931375249 This is superseded by #17106. -- 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

[GitHub] [flink] AHeise closed pull request #14277: [FLINK-20443][API/DataStream]fix lost data in last interval in per window

2021-09-30 Thread GitBox
AHeise closed pull request #14277: URL: https://github.com/apache/flink/pull/14277 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 7af1ce39a30a6948d47ed4211dfeecd21a1cccf8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17369: URL: https://github.com/apache/flink/pull/17369#issuecomment-929030154 ## CI report: * cb02a4b37c6c11ef3b0950d4eb57a7b9bd5f972b Azure:

[jira] [Updated] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20443: Priority: Major (was: Not a Priority) > ContinuousProcessingTimeTrigger doesn't fire at the end

[jira] [Assigned] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-30 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20443: --- Assignee: liwei li > ContinuousProcessingTimeTrigger doesn't fire at the end of the window

[GitHub] [flink] twalthr closed pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes"

2021-09-30 Thread GitBox
twalthr closed pull request #17141: URL: https://github.com/apache/flink/pull/17141 -- 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:

[GitHub] [flink] twalthr commented on pull request #17141: Revert "[FLINK-22770][docs] Update usage of SET in docs to use quotes"

2021-09-30 Thread GitBox
twalthr commented on pull request #17141: URL: https://github.com/apache/flink/pull/17141#issuecomment-931372611 Merge in c6863d184e0386ea69799a03f67dc218ae2a516c. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] matriv commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
matriv commented on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931372324 > * I see there are some failing "casts" returning null. Perhaps, given the [TRY_CAST issue](https://issues.apache.org/jira/browse/FLINK-24385), would it be better for the

[jira] [Updated] (FLINK-23946) Application mode fails fatally when being shut down

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23946: -- Fix Version/s: 1.15.0 > Application mode fails fatally when being shut down >

[jira] [Commented] (FLINK-24117) Remove unHandledErrorListener in ZooKeeperLeaderElectionDriver and ZooKeeperLeaderRetrievalDriver

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422813#comment-17422813 ] Till Rohrmann commented on FLINK-24117: --- I think this is a very good idea [~aitozi]. Do you want

[jira] [Closed] (FLINK-23668) Check Log Pollution for 1.14 release

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23668. - Resolution: Fixed > Check Log Pollution for 1.14 release >

[jira] [Updated] (FLINK-22226) Insufficient slots when submitting jobs results in massive stacktrace

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6: -- Parent Issue: FLINK-24430 (was: FLINK-23668) > Insufficient slots when submitting jobs

[jira] [Updated] (FLINK-22230) Misleading TaskExecutorResourceUtils log messages

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22230: -- Parent Issue: FLINK-24430 (was: FLINK-23668) > Misleading TaskExecutorResourceUtils log

[jira] [Updated] (FLINK-22228) Random log exception when tasks finish after a checkpoint was started

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8: -- Parent Issue: FLINK-24430 (was: FLINK-23668) > Random log exception when tasks finish after

[jira] [Updated] (FLINK-22222) Global config is logged twice by the client for batch jobs

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-2: -- Parent Issue: FLINK-24430 (was: FLINK-23668) > Global config is logged twice by the client

[jira] [Created] (FLINK-24430) Clean up log pollution

2021-09-30 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-24430: - Summary: Clean up log pollution Key: FLINK-24430 URL: https://issues.apache.org/jira/browse/FLINK-24430 Project: Flink Issue Type: Technical Debt

[GitHub] [flink] matriv commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
matriv commented on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931366735 Added this commit f25f9ba57ecf6f76d63aef4af3bca4e03b33c665 which imho improves overall readability, what do you think? -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-23668) Check Log Pollution for 1.14 release

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23668: -- Fix Version/s: (was: 1.15.0) 1.14.0 > Check Log Pollution for 1.14

[jira] [Commented] (FLINK-24332) Support to mount a dynamically-created persistent volume claim per TaskManager

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422804#comment-17422804 ] Till Rohrmann commented on FLINK-24332: --- Do you propose to add functionality similar to what a

[GitHub] [flink] sjwiesman closed pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-30 Thread GitBox
sjwiesman closed pull request #17380: URL: https://github.com/apache/flink/pull/17380 -- 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:

[GitHub] [flink] sjwiesman commented on pull request #17380: [hotfix][docs] Fix typo in sources doc

2021-09-30 Thread GitBox
sjwiesman commented on pull request #17380: URL: https://github.com/apache/flink/pull/17380#issuecomment-931353130 Thank you for opening a fix! Merging... -- 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

[GitHub] [flink] twalthr commented on a change in pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-09-30 Thread GitBox
twalthr commented on a change in pull request #17381: URL: https://github.com/apache/flink/pull/17381#discussion_r719422899 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/DataTypes.java ## @@ -96,6 +97,15 @@ @PublicEvolving public

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-09-30 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-931345116 @xintongsong Congrats on getting 1.14.0 released! Just an FYI that I haven't vanished and I plan to get the remaining changes for this PR into the next cycle. -- This is

[GitHub] [flink-web] infoverload commented on a change in pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-09-30 Thread GitBox
infoverload commented on a change in pull request #472: URL: https://github.com/apache/flink-web/pull/472#discussion_r719428381 ## File path: _posts/2021-09-29-release-1.14.0.md ## @@ -163,12 +163,11 @@ Apache Flink buffers a certain amount of data in its network stack to be

[GitHub] [flink] flinkbot edited a comment on pull request #17369: [FLINK-19792][table-planner] Fix IntervalJoin with time equality predicate

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17369: URL: https://github.com/apache/flink/pull/17369#issuecomment-929030154 ## CI report: * cb02a4b37c6c11ef3b0950d4eb57a7b9bd5f972b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 268f980ade47dbc2e0b95f7a734298a0c5823cb2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17395: URL: https://github.com/apache/flink/pull/17395#issuecomment-931075115 ## CI report: * 010dcc7cfa8eed85060d41bc2ddb0ceb8e450e8b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 999215d9f50c47cee5cbb48eacb1a550c2ff0180 Azure:

[GitHub] [flink-web] infoverload edited a comment on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-09-30 Thread GitBox
infoverload edited a comment on pull request #472: URL: https://github.com/apache/flink-web/pull/472#issuecomment-931337352 I think that everything in the content folder is generated with Hugo and so you only need to edit the Markdown file. -- This is an automated message from the

[GitHub] [flink-web] infoverload edited a comment on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-09-30 Thread GitBox
infoverload edited a comment on pull request #472: URL: https://github.com/apache/flink-web/pull/472#issuecomment-931337352 I think that anything in the content folder is generated with Hugo and so you only need to edit the Markdown file. -- This is an automated message from the Apache

[GitHub] [flink-web] infoverload commented on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-09-30 Thread GitBox
infoverload commented on pull request #472: URL: https://github.com/apache/flink-web/pull/472#issuecomment-931337352 I think that anything in the content folder is generated with Hugo and so we don't need to edit feed.xml -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-23974) Decreased throughput with enabled buffer debloat

2021-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23974: --- Summary: Decreased throughput with enabled buffer debloat (was: Lower throughput for

[jira] [Assigned] (FLINK-23974) Lower throughput for buffer debloat in case of different load profile

2021-09-30 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-23974: -- Assignee: Anton Kalashnikov > Lower throughput for buffer debloat in case of

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
slinkydeveloper commented on a change in pull request #17396: URL: https://github.com/apache/flink/pull/17396#discussion_r719387925 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -18,176

[GitHub] [flink] flinkbot commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
flinkbot commented on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 268f980ade47dbc2e0b95f7a734298a0c5823cb2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17395: URL: https://github.com/apache/flink/pull/17395#issuecomment-931075115 ## CI report: * 0d970823245673448817d305dc7748c1eee40b1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 999215d9f50c47cee5cbb48eacb1a550c2ff0180 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
Airblader commented on a change in pull request #17384: URL: https://github.com/apache/flink/pull/17384#discussion_r719393574 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSink.java ## @@ -75,7

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 999215d9f50c47cee5cbb48eacb1a550c2ff0180 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17395: URL: https://github.com/apache/flink/pull/17395#issuecomment-931075115 ## CI report: * 0d970823245673448817d305dc7748c1eee40b1b Azure:

[GitHub] [flink] flinkbot commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
flinkbot commented on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931280259 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

[GitHub] [flink] flinkbot edited a comment on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17363: URL: https://github.com/apache/flink/pull/17363#issuecomment-927758743 ## CI report: * 70e07383ac68b4c3235a89ddd05bd0925d317753 Azure:

[jira] [Updated] (FLINK-24393) Add tests for all currently supported cast combinations

2021-09-30 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24393: --- Labels: pull-request-available (was: ) > Add tests for all currently supported cast

[GitHub] [flink] matriv opened a new pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-09-30 Thread GitBox
matriv opened a new pull request #17396: URL: https://github.com/apache/flink/pull/17396 ## What is the purpose of the change Test currently supported CAST functionality ## Brief change log - Add tests for currently supported type combinations - List unsupported

[jira] [Commented] (FLINK-16205) Support JSON_OBJECTAGG

2021-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-16205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422735#comment-17422735 ] Ingo Bürk commented on FLINK-16205: --- I think FLINK-24387 will help us here, so I will work on that

[jira] [Updated] (FLINK-24387) Support a JSON_STRING

2021-09-30 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ingo Bürk updated FLINK-24387: -- Summary: Support a JSON_STRING (was: Support a JSON_STRING function) > Support a JSON_STRING >

[jira] [Commented] (FLINK-20443) ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-09-30 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422729#comment-17422729 ] Till Rohrmann commented on FLINK-20443: --- cc [~arvid] in case you missed the latest activity. >

[jira] [Created] (FLINK-24429) Port FileSystemTableSink to new Unified Sink API (FLIP-143)

2021-09-30 Thread Alexander Preuss (Jira)
Alexander Preuss created FLINK-24429: Summary: Port FileSystemTableSink to new Unified Sink API (FLIP-143) Key: FLINK-24429 URL: https://issues.apache.org/jira/browse/FLINK-24429 Project: Flink

[GitHub] [flink] zentol commented on a change in pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

2021-09-30 Thread GitBox
zentol commented on a change in pull request #17051: URL: https://github.com/apache/flink/pull/17051#discussion_r719334483 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java ## @@ -38,6 +43,12 @@ @Internal

[jira] [Comment Edited] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window

2021-09-30 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422714#comment-17422714 ] liwei li edited comment on FLINK-24247 at 9/30/21, 11:58 AM: - Is it feasible

[jira] [Comment Edited] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window

2021-09-30 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422714#comment-17422714 ] liwei li edited comment on FLINK-24247 at 9/30/21, 11:58 AM: - Is it feasible

[GitHub] [flink] zentol commented on a change in pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

2021-09-30 Thread GitBox
zentol commented on a change in pull request #17051: URL: https://github.com/apache/flink/pull/17051#discussion_r719332490 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java ## @@ -38,6 +43,12 @@ @Internal

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17395: URL: https://github.com/apache/flink/pull/17395#issuecomment-931075115 ## CI report: * 0d970823245673448817d305dc7748c1eee40b1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17381: URL: https://github.com/apache/flink/pull/17381#issuecomment-930061717 ## CI report: * dde53f8081d364a04f69c58d08460f2235ed8258 Azure:

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

2021-09-30 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422717#comment-17422717 ] liwei li commented on FLINK-23747: -- [~qingru zhang], i created an Jira 

[GitHub] [flink] Airblader commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
Airblader commented on a change in pull request #17384: URL: https://github.com/apache/flink/pull/17384#discussion_r719328578 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecSink.java ## @@ -75,7

[jira] [Issue Comment Deleted] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window

2021-09-30 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] liwei li updated FLINK-24247: - Comment: was deleted (was: hi [~jark] [~qingru zhang], may i know if you have come up with a

[jira] [Commented] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window

2021-09-30 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422714#comment-17422714 ] liwei li commented on FLINK-24247: -- Is it feasible to add limitation to these windows according to the

[jira] [Closed] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24054. Resolution: Fixed Fixed in 1.13: fa16e70774b516ddd499400d9cafa0400d314bfc > Let

[jira] [Updated] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24054: - Fix Version/s: 1.13.3 > Let SinkUpsertMaterializer emit +U instead of only +I >

[jira] [Reopened] (FLINK-24054) Let SinkUpsertMaterializer emit +U instead of only +I

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-24054: -- > Let SinkUpsertMaterializer emit +U instead of only +I >

[jira] [Reopened] (FLINK-24130) RowDataSerializerTest fails on Azure

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reopened FLINK-24130: -- > RowDataSerializerTest fails on Azure > > >

[jira] [Updated] (FLINK-24130) RowDataSerializerTest fails on Azure

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-24130: - Fix Version/s: 1.13.3 > RowDataSerializerTest fails on Azure >

[jira] [Closed] (FLINK-24130) RowDataSerializerTest fails on Azure

2021-09-30 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24130. Resolution: Fixed Fixed in 1.13: b0bf6687ac002dc87182dbd01a5fe47709ce0296 >

[GitHub] [flink] twalthr commented on pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I

2021-09-30 Thread GitBox
twalthr commented on pull request #17394: URL: https://github.com/apache/flink/pull/17394#issuecomment-931249930 Merged in release-1.13. -- 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

[GitHub] [flink] twalthr closed pull request #17394: [FLINK-24054][table-runtime] Let SinkUpsertMaterializer emit +U instead of only +I

2021-09-30 Thread GitBox
twalthr closed pull request #17394: URL: https://github.com/apache/flink/pull/17394 -- 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:

[GitHub] [flink] twalthr commented on a change in pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
twalthr commented on a change in pull request #17384: URL: https://github.com/apache/flink/pull/17384#discussion_r719319140 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/module/Module.java ## @@ -52,5 +54,47 @@ return

[GitHub] [flink] flinkbot edited a comment on pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17395: URL: https://github.com/apache/flink/pull/17395#issuecomment-931075115 ## CI report: * 0d970823245673448817d305dc7748c1eee40b1b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 999215d9f50c47cee5cbb48eacb1a550c2ff0180 Azure:

[jira] [Updated] (FLINK-24428) Fix casting between interval types

2021-09-30 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas updated FLINK-24428: Description: * Cast from any interval type to *INTERVAL(YEAR())* currently always results

[jira] [Updated] (FLINK-24426) Add support for cast from a string to an INTERVAL

2021-09-30 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas updated FLINK-24426: Description: PostgreSQL allows casts like:   {{postgres=# select '2 YEARS 5 month 3

[jira] [Created] (FLINK-24428) Fix casting between interval types

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24428: --- Summary: Fix casting between interval types Key: FLINK-24428 URL: https://issues.apache.org/jira/browse/FLINK-24428 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17384: [FLINK-24388][table] Modules can provide a table source/sink factory

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #17384: URL: https://github.com/apache/flink/pull/17384#issuecomment-930147821 ## CI report: * 999215d9f50c47cee5cbb48eacb1a550c2ff0180 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-09-30 Thread GitBox
flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * 4ddd79c8bd25ed27a74bcc2fb071e57a1ac7093a Azure:

[jira] [Created] (FLINK-24427) Hide Scala in flink-table-planner from API

2021-09-30 Thread Timo Walther (Jira)
Timo Walther created FLINK-24427: Summary: Hide Scala in flink-table-planner from API Key: FLINK-24427 URL: https://issues.apache.org/jira/browse/FLINK-24427 Project: Flink Issue Type:

[GitHub] [flink] twalthr commented on a change in pull request #17051: [FLINK-23978][scala] Move Scala-reliant FieldAccessors to flink-streaming-scala

2021-09-30 Thread GitBox
twalthr commented on a change in pull request #17051: URL: https://github.com/apache/flink/pull/17051#discussion_r719282491 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java ## @@ -38,6 +43,12 @@ @Internal

[jira] [Commented] (FLINK-23358) Refactor CoreOptions parent-first patterns to List options

2021-09-30 Thread Horace Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422689#comment-17422689 ] Horace Lee commented on FLINK-23358: [~xtsong], will you be able to help review this PR? > Refactor

[jira] [Created] (FLINK-24426) Add support for cast from a string to an INTERVAL

2021-09-30 Thread Marios Trivyzas (Jira)
Marios Trivyzas created FLINK-24426: --- Summary: Add support for cast from a string to an INTERVAL Key: FLINK-24426 URL: https://issues.apache.org/jira/browse/FLINK-24426 Project: Flink

[GitHub] [flink] zentol commented on a change in pull request #17395: [FLINK-24410] Upgrade Confluent Platform OSS version in end-to-end tests

2021-09-30 Thread GitBox
zentol commented on a change in pull request #17395: URL: https://github.com/apache/flink/pull/17395#discussion_r719275558 ## File path: flink-end-to-end-tests/test-scripts/test_sql_client.sh ## @@ -20,8 +20,8 @@ set -Eeuo pipefail KAFKA_VERSION="2.2.2"

[GitHub] [flink] dannycranmer commented on a change in pull request #17360: [FLINK-24379][Formats] Add support for Glue schema registry in Table API

2021-09-30 Thread GitBox
dannycranmer commented on a change in pull request #17360: URL: https://github.com/apache/flink/pull/17360#discussion_r718264199 ## File path: docs/content/docs/connectors/table/formats/avro-glue.md ## @@ -0,0 +1,191 @@ +--- +title: AWS Glue Avro +weight: 4 +type: docs

<    1   2   3   4   >