[jira] [Commented] (FLINK-16956) Git fetch failed with exit code 128

2022-03-09 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503663#comment-17503663 ] Matthias Pohl commented on FLINK-16956: ---

[GitHub] [flink] zentol commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822773571 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,139 @@ +/* + *

[GitHub] [flink] XComp merged pull request #19016: [BP-1.13][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

2022-03-09 Thread GitBox
XComp merged pull request #19016: URL: https://github.com/apache/flink/pull/19016 -- 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] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822776827 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,139 @@ +/* + *

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822776827 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,139 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822773571 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,139 @@ +/* + *

[GitHub] [flink] zentol commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822768800 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -146,14 +146,15 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822766550 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -165,8 +171,16 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18979: URL: https://github.com/apache/flink/pull/18979#issuecomment-1059179598 ## CI report: * c033b36aaec64f6e45d9413a67862d0d5f6248a3 Azure:

[jira] [Comment Edited] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503631#comment-17503631 ] Aitozi edited comment on FLINK-26528 at 3/9/22, 3:07 PM: - Yes, my meaning is to

[GitHub] [flink] flinkbot edited a comment on pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18979: URL: https://github.com/apache/flink/pull/18979#issuecomment-1059179598 ## CI report: * c033b36aaec64f6e45d9413a67862d0d5f6248a3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[jira] [Commented] (FLINK-25213) Add @Public annotations to flink-table-common

2022-03-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503638#comment-17503638 ] RocMarshal commented on FLINK-25213: Hi, [~monster#12]   Is there any progress to report from your

[GitHub] [flink] zentol commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
zentol commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822743640 ## File path: flink-connectors/flink-sql-connector-kafka/pom.xml ## @@ -40,6 +40,12 @@ under the License. org.apache.flink

[GitHub] [flink] XComp commented on pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on pull request #18979: URL: https://github.com/apache/flink/pull/18979#issuecomment-1063012051 Thanks for your review, @zentol . I addressed your comments. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * cbdee82a50ffe1a7c3fdc3b708bafd6258229afc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18940: [FLINK-26249][table-planner] Run BuiltInFunctionsTestBase and BuiltInAggregateFunctionsTestBase in parallel

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18940: URL: https://github.com/apache/flink/pull/18940#issuecomment-1055381485 ## CI report: * b963e2a9e1fc86e06f9149cbaa85e1b9d9d8614d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * cbdee82a50ffe1a7c3fdc3b708bafd6258229afc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503631#comment-17503631 ] Aitozi commented on FLINK-26528: Yes, my meaning is to eliminate the unchanged update to toward

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure:

[jira] [Created] (FLINK-26553) Enable scalafmt for scala codebase

2022-03-09 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26553: --- Summary: Enable scalafmt for scala codebase Key: FLINK-26553 URL: https://issues.apache.org/jira/browse/FLINK-26553 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25235) Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange

2022-03-09 Thread Niklas Semmler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503628#comment-17503628 ] Niklas Semmler commented on FLINK-25235: After staring at this problem for some time and playing

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * d22ead8681c8c8797eec9b8e2c561f4bb2625fa1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19024: [FLINK-26349][AvroParquet][test] add UT for reading reflect records from parquet file created with generic record schema.

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19024: URL: https://github.com/apache/flink/pull/19024#issuecomment-1062971456 ## CI report: * 48d10e719d0f3030060a0658debdf74f06382e30 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * e16d9fedfcda6856437a942d7e2cf409b3e0d820 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * d22ead8681c8c8797eec9b8e2c561f4bb2625fa1 Azure:

[GitHub] [flink] twalthr commented on a change in pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-09 Thread GitBox
twalthr commented on a change in pull request #18980: URL: https://github.com/apache/flink/pull/18980#discussion_r822701669 ## File path: flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImpl.scala

[jira] [Commented] (FLINK-26537) Allow disabling StatefulFunctionsConfigValidator validation for classloader.parent-first-patterns.additional

2022-03-09 Thread Igal Shilman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503610#comment-17503610 ] Igal Shilman commented on FLINK-26537: -- Hello [~Fil Karnicki],  How about we make a parameter that

[GitHub] [flink] flinkbot commented on pull request #19024: [FLINK-26349][AvroParquet][test] add UT for reading reflect records from parquet file created with generic record schema.

2022-03-09 Thread GitBox
flinkbot commented on pull request #19024: URL: https://github.com/apache/flink/pull/19024#issuecomment-1062971456 ## CI report: * 48d10e719d0f3030060a0658debdf74f06382e30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * 84a227bab9edfc98a6ee7318377e609d0c0ac164 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 46f5d666a22e3a489b1dfce4506a778c49485f12 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822695228 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] twalthr commented on a change in pull request #19014: [FLINK-24586][table-planner] JSON_VALUE should return STRING instead of VARCHAR(2000)

2022-03-09 Thread GitBox
twalthr commented on a change in pull request #19014: URL: https://github.com/apache/flink/pull/19014#discussion_r822692539 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlJsonValueFunctionWrapper.java ## @@ -0,0

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822694090 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822693325 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,164 @@ +/* + *

[jira] [Updated] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26349: --- Labels: pull-request-available (was: ) > AvroParquetReaders does not work with ReflectData

[GitHub] [flink] JingGe opened a new pull request #19024: [FLINK-26349][AvroParquet][test] add UT for reading reflect records from parquet file created with generic record schema.

2022-03-09 Thread GitBox
JingGe opened a new pull request #19024: URL: https://github.com/apache/flink/pull/19024 ## What is the purpose of the change There was an issue while chaning the AvroParquetFileReadITCase to read reflect data from parquet file created with generic record schema. The reason is that

[GitHub] [flink] flinkbot edited a comment on pull request #19021: [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19021: URL: https://github.com/apache/flink/pull/19021#issuecomment-1062847721 ## CI report: * 3dd50180ec315c1375a79e0017928dd9e4d37b06 Azure:

[jira] [Commented] (FLINK-26498) The window result may not have been emitted when use window emit feature and set allow-latency

2022-03-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503607#comment-17503607 ] Jark Wu commented on FLINK-26498: - Yes, the "00:59:20.100" is cleaned up before fired. > The window

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
slinkydeveloper commented on a change in pull request #19020: URL: https://github.com/apache/flink/pull/19020#discussion_r822689482 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@

[jira] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2022-03-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586 ] Timo Walther deleted comment on FLINK-24586: -- was (Author: twalthr): This is indeed a bug. [~nicholasjiang] do you have capacity to fix this missing piece? > SQL functions should return

[jira] [Commented] (FLINK-24586) SQL functions should return STRING instead of VARCHAR(2000)

2022-03-09 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503606#comment-17503606 ] Timo Walther commented on FLINK-24586: -- This is indeed a bug. [~nicholasjiang] do you have capacity

[GitHub] [flink] matriv commented on a change in pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
matriv commented on a change in pull request #19020: URL: https://github.com/apache/flink/pull/19020#discussion_r822684289 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableITCase.java ## @@ -299,29

[GitHub] [flink] flinkbot edited a comment on pull request #19021: [hotfix][docs] Clarify semantic of tolerable checkpoint failure number

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19021: URL: https://github.com/apache/flink/pull/19021#issuecomment-1062847721 ## CI report: * 3dd50180ec315c1375a79e0017928dd9e4d37b06 Azure:

[jira] [Commented] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-03-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503603#comment-17503603 ] Jing Ge commented on FLINK-26349: - The user schema in AvroParquetRecordFormatTest is defined only for

[jira] [Comment Edited] (FLINK-26349) AvroParquetReaders does not work with ReflectData

2022-03-09 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503603#comment-17503603 ] Jing Ge edited comment on FLINK-26349 at 3/9/22, 2:04 PM: -- The user schema in

[jira] [Commented] (FLINK-26322) Test FileSink compaction manually

2022-03-09 Thread Alexander Preuss (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503602#comment-17503602 ] Alexander Preuss commented on FLINK-26322: -- I tested the FileSink's compaction and here are my

[GitHub] [flink] flinkbot edited a comment on pull request #19019: [FLINK-26547][coordination] No requirement adjustments for unmatched slots

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19019: URL: https://github.com/apache/flink/pull/19019#issuecomment-1062795247 ## CI report: * 79b8bf5bb7f39b00e94a2ef7b921a046e90be9b2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19001: [FLINK-26520][table] Implement SEARCH operator in codegen

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19001: URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402 ## CI report: * 6ef2e345162e0e64ad1bddfe38e0c3022ab378fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 679718e76727607cb4a95ade98717b3f8769b054 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r822673666 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/java/org/apache/flink/fs/s3presto/FlinkS3PrestoFileSystem.java ## @@ -0,0 +1,164 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #18980: [FLINK-26421] Use only EnvironmentSettings to configure the environment

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 91046dc10a250f5547cee5478c0b13f14d3903a2 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18979: [FLINK-26484][fs] FileSystem.delete is not implemented consistently

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18979: URL: https://github.com/apache/flink/pull/18979#discussion_r82266 ## File path: flink-core/src/test/java/org/apache/flink/core/fs/FileSystemBehaviorTestSuite.java ## @@ -97,6 +99,92 @@ public void testHomeAndWorkDir() {

[GitHub] [flink] flinkbot edited a comment on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * a7bad35a1f8622c488accc9b0ecda1e56b2d9c64 Azure:

[GitHub] [flink] ChengkaiYang2022 commented on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-09 Thread GitBox
ChengkaiYang2022 commented on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062932807 Hi,@RocMarshal, can you help me to review this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Closed] (FLINK-26507) Last state upgrade mode should allow reconciliation regardless of job and deployment status

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26507. -- Resolution: Fixed merged: a738c815a12fc647d24cbbd10a2f4f0a5b9f6900 > Last state upgrade mode should

[GitHub] [flink] flinkbot commented on pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-09 Thread GitBox
flinkbot commented on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * a7bad35a1f8622c488accc9b0ecda1e56b2d9c64 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503593#comment-17503593 ] Gyula Fora commented on FLINK-26528: I think we are not trying to change the reschedule behaviour

[jira] [Updated] (FLINK-25705) Translate "Metric Reporters" page of "Deployment" in to Chinese

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25705: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Translate "Metric

[GitHub] [flink] ChengkaiYang2022 opened a new pull request #19023: [FLINK-25705][docs]Translate "Metric Reporters" page of "Deployment" …

2022-03-09 Thread GitBox
ChengkaiYang2022 opened a new pull request #19023: URL: https://github.com/apache/flink/pull/19023 …in to Chinese ## What is the purpose of the change Translate "Metric Reporters" page of "Deployment" in to Chinese. ## Brief change log *(for

[jira] [Commented] (FLINK-26473) Observer should support JobManager deployment crashed or deleted externally

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503592#comment-17503592 ] Gyula Fora commented on FLINK-26473: I would say this is not really a duplicate anymore, give that

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * 91b6e51ce99dc6f74161a657897a6f8476ad68b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18739: [FLINK-26030][yarn] Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18739: URL: https://github.com/apache/flink/pull/18739#issuecomment-1037747523 ## CI report: * 2b4ab65d7d448a28cc214e4096bb188593b7da6f Azure:

[jira] [Assigned] (FLINK-26454) Improve operator logging

2022-03-09 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26454: -- Assignee: Nicholas Jiang > Improve operator logging > > >

[jira] [Created] (FLINK-26552) Try to use @EnableKubernetesMockClient(crud = true) in controller test

2022-03-09 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-26552: -- Summary: Try to use @EnableKubernetesMockClient(crud = true) in controller test Key: FLINK-26552 URL: https://issues.apache.org/jira/browse/FLINK-26552 Project: Flink

[jira] [Updated] (FLINK-26551) Make the legacy behavior disabled by default

2022-03-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26551: --- Labels: pull-request-available (was: ) > Make the legacy behavior disabled by default >

[GitHub] [flink] flinkbot edited a comment on pull request #19020: [FLINK-26551][table] Flip legacy casting to disable by default

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * 91b6e51ce99dc6f74161a657897a6f8476ad68b0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19018: [FLINK-25819][runtime] Reordered requesting and recycling buffers in order to avoid race condition in testIsAvailableOrNotAfterReques

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19018: URL: https://github.com/apache/flink/pull/19018#issuecomment-1062745397 ## CI report: * 33be62479b9cdc58021afa8cfb68bd87355b5f26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 1ba1816cfb7266ee178e8bf815aa79daac42a026 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18949: [FLINK-25235][tests] re-enable zookeeper test

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * b1cd905439ca2922134e7884aa8adf12261eae7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 1ba1816cfb7266ee178e8bf815aa79daac42a026 Azure:

[jira] [Assigned] (FLINK-26551) Make the legacy behavior disabled by default

2022-03-09 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-26551: --- Assignee: Francesco Guardiani > Make the legacy behavior disabled by

[jira] [Created] (FLINK-26551) Make the legacy behavior disabled by default

2022-03-09 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-26551: --- Summary: Make the legacy behavior disabled by default Key: FLINK-26551 URL: https://issues.apache.org/jira/browse/FLINK-26551 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * e2a3ce71c31c2bcc1ac90697f1a08bf4fd0b3c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18996: URL: https://github.com/apache/flink/pull/18996#issuecomment-1060587342 ## CI report: * 473e98ad1d65e474a9b1841931d71ced4d11e62a Azure:

[GitHub] [flink] XComp commented on pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1062911725 Thanks for your review, @zentol . I addressed your comments. PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 46f5d666a22e3a489b1dfce4506a778c49485f12 Azure:

[jira] [Commented] (FLINK-25771) CassandraConnectorITCase.testRetrialAndDropTables timeouts on AZP

2022-03-09 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25771?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503584#comment-17503584 ] Etienne Chauchot commented on FLINK-25771: -- Thanks [~chesnay] for merging to master and also

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822635906 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -165,8 +171,16 @@ public boolean

[GitHub] [flink] echauchot commented on pull request #18973: [FLINK-25771][connectors][Cassandra][test] Raise the Cassandra driver timeouts at the Cluster level

2022-03-09 Thread GitBox
echauchot commented on pull request #18973: URL: https://github.com/apache/flink/pull/18973#issuecomment-1062910144 @zentol thanks for 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 to go to

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822634591 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java ## @@ -165,8 +171,16 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #19022: [FLINK-26550][checkpoint] Correct the information of checkpoint failure

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19022: URL: https://github.com/apache/flink/pull/19022#issuecomment-1062855606 ## CI report: * e2a3ce71c31c2bcc1ac90697f1a08bf4fd0b3c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18996: URL: https://github.com/apache/flink/pull/18996#issuecomment-1060587342 ## CI report: * 473e98ad1d65e474a9b1841931d71ced4d11e62a Azure:

[GitHub] [flink] afedulov commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
afedulov commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822634017 ## File path: flink-formats/flink-parquet/pom.xml ## @@ -308,6 +314,33 @@ under the License.

[GitHub] [flink] afedulov commented on a change in pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
afedulov commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822633815 ## File path: flink-formats/flink-orc/pom.xml ## @@ -204,6 +210,33 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #18905: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 414adf3bf2aa1467db7e089b10e18b4e9e349b56 Azure:

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822632235 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -166,21 +188,49 @@ private

[GitHub] [flink] XComp commented on a change in pull request #18987: [FLINK-26494][runtime] Cleanup does not reveal exceptions

2022-03-09 Thread GitBox
XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822632235 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -166,21 +188,49 @@ private

[GitHub] [flink] JingGe commented on a change in pull request #18996: [FLINK-26492][metric] deprecate umRecordsOutErrorsCounter

2022-03-09 Thread GitBox
JingGe commented on a change in pull request #18996: URL: https://github.com/apache/flink/pull/18996#discussion_r822631316 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/SinkMetricsITCase.java ## @@ -147,7 +147,7 @@ private void

[jira] [Commented] (FLINK-26394) CheckpointCoordinator.isTriggering can not be reset if a checkpoint expires while the checkpointCoordinator task is queuing in the SourceCoordinator executor.

2022-03-09 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503579#comment-17503579 ] Yun Tang commented on FLINK-26394: -- Though the PR still has broken tests, I think this problem really

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #19017: [FLINK-26542][hive] fix "schema of both sides of union should match" exception with Hive dialect

2022-03-09 Thread GitBox
flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 6c5a21cd9c95112a97ef3195eac68d6e4899616c Azure:

<    1   2   3   4   5   6   7   8   >