[GitHub] [flink] adiaixin commented on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
adiaixin commented on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-1034793957 @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

[GitHub] [flink] adiaixin removed a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
adiaixin removed a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-1034791954 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * 3556331fec7ec8ca1139085a136035a45b2d0977 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
dannycranmer commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r803555992 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriterStateSerializer.java

[GitHub] [flink] adiaixin commented on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
adiaixin commented on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-1034791954 @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

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803558181 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -225,4 +225,9 @@ function get_host_machine_address { fi } +function

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba Azure:

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803558181 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -225,4 +225,9 @@ function get_host_machine_address { fi } +function

[GitHub] [flink] pnowojski commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-10 Thread GitBox
pnowojski commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r803467988 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -267,18

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid co

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803545078 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * 33d97563bf625b702679c32c67a739f880228a42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:

[GitHub] [flink] flinkbot commented on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot commented on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034767545 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] [Updated] (FLINK-12189) Fix bugs and typos in memory management related code

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12189: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-unassigned

[GitHub] [flink] slinkydeveloper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-10 Thread GitBox
slinkydeveloper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1034766454 Thanks for the explanation! As I said before, a comment which explains this would be nice to have there, for the rest it looks good and it sounds like a nice

[GitHub] [flink] flinkbot commented on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
flinkbot commented on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * 71fd9a5a7917a6bc423a45ca3deec8b84007c9e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1033839484 ## CI report: * fbdf72f62409be6aa9d7ff9663029a90bc38585b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1029176049 ## CI report: * 861fa3fa04ca63de1ce8cfc9b057699ebc0e2002 Azure:

[jira] [Updated] (FLINK-26071) TableEnvironment#compilePlan should fail

2022-02-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26071: --- Labels: pull-request-available (was: ) > TableEnvironment#compilePlan should fail >

[GitHub] [flink] slinkydeveloper opened a new pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

2022-02-10 Thread GitBox
slinkydeveloper opened a new pull request #18701: URL: https://github.com/apache/flink/pull/18701 ## What is the purpose of the change This PR is a followup of FLINK-25841 and has a couple of quality of life improvements for the new API: * Now `Planner#compilePlan` fails if

[GitHub] [flink] matriv commented on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

2022-02-10 Thread GitBox
matriv commented on pull request #18624: URL: https://github.com/apache/flink/pull/18624#issuecomment-1034760863 I've kept only basic `consumedOptions` for the python nodes. @twalthr Can you check again? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 146d81ca276cd3189fbf26b073d513b588b571fa Azure:

[jira] [Updated] (FLINK-25813) TableITCase.testCollectWithClose failed on azure

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25813: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira

[jira] [Updated] (FLINK-24626) Flink JDBC Sink may lose data in left join

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-24626: --- Labels: correctness stale-major (was: correctness) I am the [Flink Jira

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20951: --- Labels: auto-deprioritized-critical auto-deprioritized-major auto-unassigned stale-minor

[jira] [Updated] (FLINK-8970) Add more automated end-to-end tests

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8970: -- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-8478) Add support for time-bounded joins in DataStream API

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8478: -- Labels: auto-deprioritized-major auto-unassigned stale-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-2147) Approximate calculation of frequencies in data streams

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2147: -- Labels: approximate auto-deprioritized-major auto-deprioritized-minor statistics (was:

[jira] [Updated] (FLINK-2055) Implement Streaming HBaseSink

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2055: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2151: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

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

[jira] [Updated] (FLINK-2220) Join on Pojo without hashCode() silently fails

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2220: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2186: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-2313) Change Streaming Driver Execution Model

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2313: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-2350) Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat

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

[jira] [Updated] (FLINK-2284) Confusing/inconsistent PartitioningStrategy

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2284: -- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-2396) Review the datasets of dynamic path and static path in iteration.

2022-02-10 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2396: -- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[GitHub] [flink] flinkbot edited a comment on pull request #18641: [FLINK-25761] [docs] Translate Avro format page into Chinese.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18641: URL: https://github.com/apache/flink/pull/18641#issuecomment-1031234534 ## CI report: * 995943ebd415f3b43e55d8fe2c491e3e16cdc82c Azure:

[GitHub] [flink] RyanSkraba commented on a change in pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-10 Thread GitBox
RyanSkraba commented on a change in pull request #18697: URL: https://github.com/apache/flink/pull/18697#discussion_r803517717 ## File path: mvnw ## @@ -0,0 +1,310 @@ +#!/bin/sh +# +# Licensed to the

[GitHub] [flink] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803516082 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -322,19 +335,20 @@

[GitHub] [flink] dannycranmer commented on a change in pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
dannycranmer commented on a change in pull request #18669: URL: https://github.com/apache/flink/pull/18669#discussion_r803521963 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803521572 ## File path: flink-filesystems/flink-s3-fs-presto/src/test/java/org/apache/flink/fs/s3presto/MinioTestContainer.java ## @@ -0,0 +1,146 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18651: URL: https://github.com/apache/flink/pull/18651#issuecomment-1031863806 ## CI report: * 83d261d7dfaa98ed991d32f2600ce9d9acc181e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 9720c3e92ef12305e72d1b0de4f70d8be5a3d9af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18605: [FLINK-25785][Connectors][JDBC] Upgrade com.h2database:h2 to 2.1.210

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18605: URL: https://github.com/apache/flink/pull/18605#issuecomment-1027887418 ## CI report: * 56d378844fb46ed0957fb6a96f800a949eb31f11 Azure:

[GitHub] [flink] dannycranmer commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-10 Thread GitBox
dannycranmer commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r803519894 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -267,18

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-10 Thread GitBox
tillrohrmann commented on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034741301 Thanks for opening this PR @GOODBOY008. Could you add a short description of what the script does? Is it copied from somewhere or did you develop it from scratch? If yes,

[GitHub] [flink] zentol commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803513590 ## File path: flink-filesystems/flink-s3-fs-presto/pom.xml ## @@ -46,6 +46,36 @@ under the License. provided +

[GitHub] [flink] zentol commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803513214 ## File path: flink-filesystems/flink-s3-fs-presto/pom.xml ## @@ -46,6 +46,36 @@ under the License. provided +

[GitHub] [flink] zentol commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803512948 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java ## @@ -588,8 +588,10 @@ public static URI getDefaultFsUri() { *

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803512647 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java ## @@ -684,7 +686,9 @@ public boolean exists(final Path f) throws

[GitHub] [flink] flinkbot edited a comment on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 7abbdf54df75a8e9e0041e908ab61d785d800410 Azure:

[jira] [Commented] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490071#comment-17490071 ] Roman Khachatryan commented on FLINK-25872: --- The issue also affects non-incremental

[jira] [Closed] (FLINK-25975) add doc for how to use AvroParquetRecordFormat

2022-02-10 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25975. - Resolution: Fixed Fixed via 222b72f2de43bb60b2f4741fde023493967d20f7 > add doc for how to use

[GitHub] [flink] tillrohrmann closed pull request #18660: [FLINK-25975][docs] add document about AvroParquet format use cases

2022-02-10 Thread GitBox
tillrohrmann closed pull request #18660: URL: https://github.com/apache/flink/pull/18660 -- 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] [Updated] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25872: -- Environment: (was: The issue also affects non-incremental checkpoints, updating

[jira] [Updated] (FLINK-25872) Restoring from non-changelog checkpoint with changelog state-backend enabled in CLAIM mode discards state in use

2022-02-10 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-25872: -- Description: If we restore from checkpoint with changelog state-backend enabled in

[GitHub] [flink] flinkbot edited a comment on pull request #18699: [FLINK-25937] Restore the environment parallelism before transforming in SinkExpander#expand.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18699: URL: https://github.com/apache/flink/pull/18699#issuecomment-1034581144 ## CI report: * 4a9ad6db0e1a01e9c33529b47053643721622eb7 Azure:

[jira] [Created] (FLINK-26071) TableEnvironment#compilePlan should fail

2022-02-10 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26071: --- Summary: TableEnvironment#compilePlan should fail Key: FLINK-26071 URL: https://issues.apache.org/jira/browse/FLINK-26071 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18691: Flink 25846 25848 25977 25792 compound

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18691: URL: https://github.com/apache/flink/pull/18691#issuecomment-1034110616 ## CI report: * Unknown: [CANCELED](TBD) * 84f974662b25cb8ecd1f2c644fa50a9b4625cd2d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * 33d97563bf625b702679c32c67a739f880228a42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * beeecc75734e1ffe1033d4ffbda7ee43e7d57e5f Azure:

[GitHub] [flink] autophagy commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
autophagy commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803490313 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -225,4 +225,9 @@ function get_host_machine_address { fi }

[GitHub] [flink] adiaixin commented on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
adiaixin commented on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-1034712719 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18691: Flink 25846 25848 25977 25792 compound

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18691: URL: https://github.com/apache/flink/pull/18691#issuecomment-1034110616 ## CI report: * Unknown: [CANCELED](TBD) * 84f974662b25cb8ecd1f2c644fa50a9b4625cd2d UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * 33d97563bf625b702679c32c67a739f880228a42 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18670: URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650 ## CI report: * 360c74aff2caa70284a90375a17519dc4843d4b2 Azure:

[GitHub] [flink] wanglijie95 commented on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
wanglijie95 commented on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1034709902 @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

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * beeecc75734e1ffe1033d4ffbda7ee43e7d57e5f Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #18691: Flink 25846 25848 25977 25792 compound

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18691: URL: https://github.com/apache/flink/pull/18691#issuecomment-1034708422 -- 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.

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803484034 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java ## @@ -0,0 +1,133 @@ +/* + * Licensed to

[GitHub] [flink] XComp commented on a change in pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
XComp commented on a change in pull request #18692: URL: https://github.com/apache/flink/pull/18692#discussion_r803481934 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/AbstractHaJobRunITCase.java ## @@ -0,0 +1,133 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * e88e25f069efe98417e027028d3fdf202379dd92 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18670: URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650 ## CI report: * 360c74aff2caa70284a90375a17519dc4843d4b2 Azure:

[GitHub] [flink] pltbkd commented on a change in pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-10 Thread GitBox
pltbkd commented on a change in pull request #18680: URL: https://github.com/apache/flink/pull/18680#discussion_r803478421 ## File path: flink-connectors/flink-file-sink-common/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketWriter.java ## @@

[jira] [Closed] (FLINK-25742) Remove the redundant serialization of RPC invocation at Flink side.

2022-02-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo closed FLINK-25742. -- Resolution: Done > Remove the redundant serialization of RPC invocation at Flink side. >

[jira] [Commented] (FLINK-25742) Remove the redundant serialization of RPC invocation at Flink side.

2022-02-10 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490061#comment-17490061 ] Yangze Guo commented on FLINK-25742: master: 155657e60607913b679827123cc3a0c0281d5c76 > Remove the

[GitHub] [flink] zentol commented on a change in pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18670: URL: https://github.com/apache/flink/pull/18670#discussion_r803475693 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -54,6 +54,7 @@ * (LAST), or be positioned

[jira] [Commented] (FLINK-26067) ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout

2022-02-10 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-26067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490060#comment-17490060 ] David Morávek commented on FLINK-26067: --- could be related to the Zookeeper upgrade. I won't have a

[GitHub] [flink] KarmaGYZ closed pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

2022-02-10 Thread GitBox
KarmaGYZ closed pull request #18434: URL: https://github.com/apache/flink/pull/18434 -- 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 #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527 ## CI report: * 3e380541d698a93d71dbfc0f88723b22c50bccf5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * e88e25f069efe98417e027028d3fdf202379dd92 Azure:

[GitHub] [flink] tsreaper commented on pull request #18657: [FLINK-26001][avro] Implement ProjectableDecodingFormat for avro BulkDecodingFormat

2022-02-10 Thread GitBox
tsreaper commented on pull request #18657: URL: https://github.com/apache/flink/pull/18657#issuecomment-1034694706 Hi @slinkydeveloper . Your observation is correct. Avro is a format that stores the schema in the file itself. When calling `DataFileReader.openReader` it will call

[jira] [Commented] (FLINK-26067) ZooKeeperLeaderElectionConnectionHandlingTest. testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled failed due to timeout

2022-02-10 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490058#comment-17490058 ] Yun Gao commented on FLINK-26067: - Hi [~dmvk]~ could you have a look at this issue and

[GitHub] [flink] wanglijie95 commented on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
wanglijie95 commented on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1034692239 @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

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803470735 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803468860 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803465610 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] flinkbot edited a comment on pull request #18698: [FLINK-25782] [docs] Translate datastream filesystem.md page into Chinese.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18698: URL: https://github.com/apache/flink/pull/18698#issuecomment-1034521527 ## CI report: * 3e380541d698a93d71dbfc0f88723b22c50bccf5 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #18651: [FLINK-25792][connectors] Only flushing the async sink base if it is …

2022-02-10 Thread GitBox
pnowojski commented on a change in pull request #18651: URL: https://github.com/apache/flink/pull/18651#discussion_r803467988 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer/AsyncSinkWriter.java ## @@ -267,18

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803467068 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

[GitHub] [flink] flinkbot edited a comment on pull request #18673: [FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPartitioner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18673: URL: https://github.com/apache/flink/pull/18673#issuecomment-1033295561 ## CI report: * 33d97563bf625b702679c32c67a739f880228a42 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803467068 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java ## @@ -273,6 +274,8 @@ public void setupYarnClient() { }

<    5   6   7   8   9   10   11   >