[jira] [Closed] (FLINK-24454) Consolidate all CAST related test into the new CastFunctionITCase class

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

[jira] [Updated] (FLINK-24731) Add a blank space for TransitiveClosureNaive

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24731: --- Labels: pull-request-available (was: ) > Add a blank space for TransitiveClosureNaive >

[GitHub] [flink] AHeise commented on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-02 Thread GitBox
AHeise commented on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-957254354 > > > > @echauchot > > > > > Sure, I saw the comments about split and data types etc... But I feel unconfortable about draft PRs because they usually cannot be merged as is.

[GitHub] [flink] flinkbot edited a comment on pull request #17624: [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17624: URL: https://github.com/apache/flink/pull/17624#issuecomment-956206702 ## CI report: * e98a9f4b64d8898f8432bb625513afabbdf1b875 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #17624: [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

2021-11-02 Thread GitBox
twalthr commented on a change in pull request #17624: URL: https://github.com/apache/flink/pull/17624#discussion_r740864075 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -874,7 +876,24 @@ public

[GitHub] [flink] echauchot opened a new pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-02 Thread GitBox
echauchot opened a new pull request #17640: URL: https://github.com/apache/flink/pull/17640 This PR is the port of [this PR](https://github.com/apache/flink/pull/17523) for master without the DataSet API changes -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957264269 ## CI report: * 5e35ddcb121f8f5b2c5d0bad2739c6fc2e1a7cc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957270143 ## CI report: * 4f7eb8397a272b0cd017df2f9669535f73c775ae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17606: URL: https://github.com/apache/flink/pull/17606#issuecomment-954752065 ## CI report: * 308144b47092d73d777530ce5d0a11c85d7ab5c6 Azure:

[GitHub] [flink] slinkydeveloper opened a new pull request #17642: [hotfix][table-common] Add `DataType#excludeFields`

2021-11-02 Thread GitBox
slinkydeveloper opened a new pull request #17642: URL: https://github.com/apache/flink/pull/17642 ## What is the purpose of the change Add `DataType#excludeFields` to simplify connectors implementation that requires excluding fields ## Brief change log - Add

[GitHub] [flink] beyond1920 commented on a change in pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

2021-11-02 Thread GitBox
beyond1920 commented on a change in pull request #17571: URL: https://github.com/apache/flink/pull/17571#discussion_r740950808 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

2021-11-02 Thread GitBox
beyond1920 commented on a change in pull request #17571: URL: https://github.com/apache/flink/pull/17571#discussion_r740950486 ## File path:

[jira] [Commented] (FLINK-24707) Upgrade Curator framework dependecy.

2021-11-02 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-24707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437292#comment-17437292 ] David Morávek commented on FLINK-24707: --- Yes, it would, but we can not do it, because the fix

[GitHub] [flink] beyond1920 commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
beyond1920 commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r740955899 ## File path:

[GitHub] [flink] beyond1920 commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
beyond1920 commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r740955153 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalWindowDeduplicate.scala

[jira] [Commented] (FLINK-24730) Support prompt in SqlCli

2021-11-02 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437294#comment-17437294 ] Timo Walther commented on FLINK-24730: -- [~liyubin117] we are currently discussing a couple of

[jira] [Assigned] (FLINK-24734) testSecretOption fails due to missing required options

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-24734: Assignee: Chesnay Schepler > testSecretOption fails due to missing required

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740973594 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSink.java

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740973594 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSink.java

[jira] [Commented] (FLINK-24381) Table API exceptions may leak sensitive configuration values

2021-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437315#comment-17437315 ] Jark Wu commented on FLINK-24381: - The release-1.13 branch keeps failing on the new introduced test:

[GitHub] [flink] flinkbot edited a comment on pull request #17541: [FLINK-24189] Perform buffer debloating per single gate

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17541: URL: https://github.com/apache/flink/pull/17541#issuecomment-948765818 ## CI report: * 9b84d08ded8b9bb26c497dd0b541a4c2c01bde4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-956476981 ## CI report: * e792679a9f83c8345bece7b15335ea680e844e51 Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17626: [FLINK-24715] Update multiple Jackson dependencies to latest version

2021-11-02 Thread GitBox
MartijnVisser commented on pull request #17626: URL: https://github.com/apache/flink/pull/17626#issuecomment-957480841 HBase uses org.apache.htrace:htrace-core4 which is bundled with Jackson 2.4.0 -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r741023145 ## File path:

[GitHub] [flink] MartijnVisser commented on a change in pull request #17626: [FLINK-24715] Update multiple Jackson dependencies to latest version

2021-11-02 Thread GitBox
MartijnVisser commented on a change in pull request #17626: URL: https://github.com/apache/flink/pull/17626#discussion_r741022824 ## File path: flink-table/flink-table-planner/pom.xml ## @@ -356,6 +356,7 @@ under the License.

[GitHub] [flink] flinkbot commented on pull request #17644: [FLINK-24725] Update Cython to the latest version

2021-11-02 Thread GitBox
flinkbot commented on pull request #17644: URL: https://github.com/apache/flink/pull/17644#issuecomment-957523411 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

[jira] [Assigned] (FLINK-21510) ExecutionGraph metrics collide on restart

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-21510: Assignee: Chesnay Schepler > ExecutionGraph metrics collide on restart >

[jira] [Assigned] (FLINK-24732) Remove scala suffix from respective benchmarks dependencies

2021-11-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-24732: Assignee: Dawid Wysakowicz > Remove scala suffix from respective benchmarks

[GitHub] [flink] flinkbot commented on pull request #17639: [FLINK-24731] add a blank space

2021-11-02 Thread GitBox
flinkbot commented on pull request #17639: URL: https://github.com/apache/flink/pull/17639#issuecomment-957242723 ## CI report: * 81dbac15f868ab07bbf0d7079415915b2bd6a794 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] twalthr commented on a change in pull request #17624: [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

2021-11-02 Thread GitBox
twalthr commented on a change in pull request #17624: URL: https://github.com/apache/flink/pull/17624#discussion_r740854369 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java ## @@ -874,7 +876,24 @@ public

[GitHub] [flink] flinkbot commented on pull request #17641: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-02 Thread GitBox
flinkbot commented on pull request #17641: URL: https://github.com/apache/flink/pull/17641#issuecomment-957271907 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] fapaul commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
fapaul commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740884341 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSink.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 241278dc532532c89819e46bfad689e07057be50 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #17426: [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSend…

2021-11-02 Thread GitBox
tillrohrmann commented on a change in pull request #17426: URL: https://github.com/apache/flink/pull/17426#discussion_r740964619 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatReceiver.java ## @@ -0,0 +1,40 @@ +/* + * Licensed to the

[GitHub] [flink] zentol commented on a change in pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

2021-11-02 Thread GitBox
zentol commented on a change in pull request #17606: URL: https://github.com/apache/flink/pull/17606#discussion_r740969750 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java ## @@ -67,7 +67,7 @@ public void

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r741007504 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSinkWriter.java

[GitHub] [flink] xuyangzhong commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
xuyangzhong commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r741007648 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalWindowDeduplicate.scala

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r741026165 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSinkWriter.java

[GitHub] [flink] flinkbot edited a comment on pull request #17626: [FLINK-24715] Update multiple Jackson dependencies to latest version

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17626: URL: https://github.com/apache/flink/pull/17626#issuecomment-956209711 ## CI report: * 54f60a073480c153a132e85a54e361f1835c2657 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r741026655 ## File path: flink-connectors/flink-connector-aws/src/test/resources/profile ## @@ -0,0 +1,7 @@ +[default]

[GitHub] [flink] flinkbot edited a comment on pull request #17624: [FLINK-24714][table-api-java] Validate partition keys for ResolvedCatalogTable

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17624: URL: https://github.com/apache/flink/pull/17624#issuecomment-956206702 ## CI report: * 613c06c3925cee4c8fa1436efd5205e1a4cb6304 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17626: [FLINK-24715] Update multiple Jackson dependencies to latest version

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17626: URL: https://github.com/apache/flink/pull/17626#issuecomment-956209711 ## CI report: * 54f60a073480c153a132e85a54e361f1835c2657 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r741056377 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -236,8

[jira] [Commented] (FLINK-24737) Update outdated web dependencies in flink-runtime-web

2021-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437360#comment-17437360 ] Martijn Visser commented on FLINK-24737: [~junhany] Could you help with this?  > Update

[jira] [Created] (FLINK-24735) SQL client crashes with `Cannot add expression of different type to set`

2021-11-02 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-24735: -- Summary: SQL client crashes with `Cannot add expression of different type to set` Key: FLINK-24735 URL: https://issues.apache.org/jira/browse/FLINK-24735

[GitHub] [flink] flinkbot edited a comment on pull request #17426: [FLINK-24167][Runtime]Add default HeartbeatReceiver and HeartbeatSend…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17426: URL: https://github.com/apache/flink/pull/17426#issuecomment-938516939 ## CI report: * b3f889f3c75ca26e6e54e45694d207e529d9dd43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] MartijnVisser commented on pull request #17635: [FLINK-24724] Update Sun XML Bind dependencies to latest minor version

2021-11-02 Thread GitBox
MartijnVisser commented on pull request #17635: URL: https://github.com/apache/flink/pull/17635#issuecomment-957366431 You're both right, I'll revisit and update the PR -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437320#comment-17437320 ] Martijn Visser commented on FLINK-24733: [~syhily] What are your thoughts on this one? > Data

[GitHub] [flink] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740981731 ## File path: flink-connectors/flink-connector-aws/pom.xml ## @@ -0,0 +1,130 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink] fapaul commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
fapaul commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740903692 ## File path: flink-connectors/flink-connector-aws/src/main/java/org/apache/flink/streaming/connectors/kinesis/unified/KinesisDataStreamsSinkWriter.java

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[jira] [Updated] (FLINK-24734) testSecretOption fails due to missing required options

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24734: - Affects Version/s: (was: 1.13.3) 1.13.4 > testSecretOption

[jira] [Closed] (FLINK-24381) Table API exceptions may leak sensitive configuration values

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24381. Resolution: Fixed Reverted for 1.13. > Table API exceptions may leak sensitive

[jira] [Closed] (FLINK-24734) testSecretOption fails due to missing required options

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-24734. Fix Version/s: 1.13.4 Resolution: Fixed Reverted FLINK-24381. > testSecretOption

[jira] [Updated] (FLINK-24381) Table API exceptions may leak sensitive configuration values

2021-11-02 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24381: - Fix Version/s: (was: 1.13.4) > Table API exceptions may leak sensitive

[jira] [Created] (FLINK-24736) Non vulenerable jar files for Apache Flink 1.14.0

2021-11-02 Thread Parag Somani (Jira)
Parag Somani created FLINK-24736: Summary: Non vulenerable jar files for Apache Flink 1.14.0 Key: FLINK-24736 URL: https://issues.apache.org/jira/browse/FLINK-24736 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 78c60988637f6aa36c46e6df6af8f09724676d18 Azure:

[GitHub] [flink] godfreyhe commented on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

2021-11-02 Thread GitBox
godfreyhe commented on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-957391630 @twalthr Thanks for driving this. I will pay more attention to the code quality of test cases. Currently, `select 1 = '1'` will generate wrong result, and all Flink (SQL)

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[jira] [Updated] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24733: --- Labels: pull-request-available (was: ) > Data loss in pulsar source when using shared mode

[GitHub] [flink] flinkbot edited a comment on pull request #17637: [FLINK-24708][planner] Fix wrong results of the IN operator

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17637: URL: https://github.com/apache/flink/pull/17637#issuecomment-957122792 ## CI report: * 78c60988637f6aa36c46e6df6af8f09724676d18 Azure:

[GitHub] [flink] wsz94 opened a new pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared modefix bug of pulsar source lost data

2021-11-02 Thread GitBox
wsz94 opened a new pull request #17643: URL: https://github.com/apache/flink/pull/17643 ## What is the purpose of the change This pull request fix data loss when using flink pulsar source. ## Brief change log - Add invalid **CompletableFuture** cancel when poll

[GitHub] [flink] flinkbot commented on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
flinkbot commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957412578 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] CrynetLogistics commented on a change in pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
CrynetLogistics commented on a change in pull request #17345: URL: https://github.com/apache/flink/pull/17345#discussion_r740995225 ## File path:

[jira] [Commented] (FLINK-24733) Data loss in pulsar source when using shared mode

2021-11-02 Thread wang shengzhi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437324#comment-17437324 ] wang shengzhi commented on FLINK-24733: --- [~syhily] [~MartijnVisser] I have fixed this bug, please

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] flinkbot commented on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
flinkbot commented on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596 ## CI report: * cf441ef1184f44a76f08dcc304de6f1da8f0fd55 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17643: [FLINK-24733][connector/pulsar] Data loss in pulsar source when using shared mode

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17643: URL: https://github.com/apache/flink/pull/17643#issuecomment-957416596 ## CI report: * cf441ef1184f44a76f08dcc304de6f1da8f0fd55 Azure:

[GitHub] [flink] zentol commented on a change in pull request #17580: [FLINK-11470][runtime] Pass configurations to filesystems when executing in LocalStreamEnvironment

2021-11-02 Thread GitBox
zentol commented on a change in pull request #17580: URL: https://github.com/apache/flink/pull/17580#discussion_r741005171 ## File path: flink-clients/src/test/resources/META-INF/services/org.apache.flink.core.fs.FileSystemFactory ## @@ -0,0 +1,16 @@ +# Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 23e2117992f607a68b076470bc69977aef6504da Azure:

[GitHub] [flink] tsreaper opened a new pull request #17638: [FLINK-24728][table-runtime] Close output stream in batch SQL file sink

2021-11-02 Thread GitBox
tsreaper opened a new pull request #17638: URL: https://github.com/apache/flink/pull/17638 ## What is the purpose of the change Currently the output format created in `FileSystemTableSink#createBulkWriterOutputFormat` only finishes the `BulkWriter` and does not close the output

[jira] [Commented] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans

2021-11-02 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437201#comment-17437201 ] Timo Walther commented on FLINK-24716: -- Thanks for the explanation. It seems there is more magic

[jira] [Created] (FLINK-24730) Support prompt in SqlCli

2021-11-02 Thread Yubin Li (Jira)
Yubin Li created FLINK-24730: Summary: Support prompt in SqlCli Key: FLINK-24730 URL: https://issues.apache.org/jira/browse/FLINK-24730 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-24722) Only set keyContext for the normal records

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24722: --- Labels: pull-request-available (was: ) > Only set keyContext for the normal records >

[jira] [Commented] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-11-02 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437208#comment-17437208 ] Biao Geng commented on FLINK-24494: --- Hi [~mahen], I have met this problem as well. I have implemented

[GitHub] [flink] flinkbot edited a comment on pull request #17639: [FLINK-24731] add a blank space

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17639: URL: https://github.com/apache/flink/pull/17639#issuecomment-957242723 ## CI report: * 81dbac15f868ab07bbf0d7079415915b2bd6a794 Azure:

[jira] [Closed] (FLINK-24732) Remove scala suffix from respective benchmarks dependencies

2021-11-02 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24732. Resolution: Duplicate > Remove scala suffix from respective benchmarks dependencies >

[jira] [Updated] (FLINK-24732) Remove scala suffix from respective benchmarks dependencies

2021-11-02 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24732: --- Labels: pull-request-available (was: ) > Remove scala suffix from respective benchmarks

[GitHub] [flink] echauchot commented on pull request #17640: [FLINK-21407][doc][formats] Add formats to DataStream connectors doc

2021-11-02 Thread GitBox
echauchot commented on pull request #17640: URL: https://github.com/apache/flink/pull/17640#issuecomment-957262094 R: @AHeise as discussed :slightly_smiling_face: -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

2021-11-02 Thread Biao Geng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437208#comment-17437208 ] Biao Geng edited comment on FLINK-24494 at 11/2/21, 9:56 AM: - Hi [~mahen], I

[GitHub] [flink] curcur merged pull request #17620: [FLINK-24671][runtime] Return 0 buffers in use until subpartition vie…

2021-11-02 Thread GitBox
curcur merged pull request #17620: URL: https://github.com/apache/flink/pull/17620 -- 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 #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 0cd3dcf68c5e470489388cacad95ec40fde6f74d Azure:

[GitHub] [flink] zentol commented on a change in pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

2021-11-02 Thread GitBox
zentol commented on a change in pull request #17606: URL: https://github.com/apache/flink/pull/17606#discussion_r740932666 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java ## @@ -67,7 +67,7 @@ public void

[jira] [Assigned] (FLINK-24657) Add metric of the total real size of input/output buffers queue

2021-11-02 Thread Anton Kalashnikov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-24657: - Assignee: Anton Kalashnikov > Add metric of the total real size of

[jira] [Updated] (FLINK-19390) mysql jdbc join error java.lang.ClassCastException: java.math.BigInteger cannot be cast to java.lang.Long

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19390: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19371) Support table transforming functions in SQL

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19371: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19335) Automatically get udf's resource files from hdfs when running a job that uses hive-udf

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19335: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19249: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-19383) Per Partition State

2021-11-02 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19383: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[GitHub] [flink] tillrohrmann commented on a change in pull request #17606: [FLINK-24706][rpc] Forward deserialization errors to returned future

2021-11-02 Thread GitBox
tillrohrmann commented on a change in pull request #17606: URL: https://github.com/apache/flink/pull/17606#discussion_r740942116 ## File path: flink-tests/src/test/java/org/apache/flink/test/recovery/TaskManagerProcessFailureBatchRecoveryITCase.java ## @@ -67,7 +67,7 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17509: [FLINK-24501][table-runtime] Stores window progress into state in order to check whether an input element is late or not for window-t

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17509: URL: https://github.com/apache/flink/pull/17509#issuecomment-945571594 ## CI report: * 4f49c906baed3dc3b56c8462b20324e943e1 Azure:

[jira] [Commented] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

2021-11-02 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437297#comment-17437297 ] Till Rohrmann commented on FLINK-21289: --- I agree with [~wangyang0918]. I think your change is

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 241278dc532532c89819e46bfad689e07057be50 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17607: [FLINK-24543][runtime] Avoid possible inconsistencies of ZookeeperSta…

2021-11-02 Thread GitBox
flinkbot edited a comment on pull request #17607: URL: https://github.com/apache/flink/pull/17607#issuecomment-954762085 ## CI report: * 7ccc4b0240e733447c42bbfa48911f768afac57d Azure:

  1   2   3   4   5   6   7   8   >