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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * b0dea28c30a7819c9c8ab58acba80df8f2ae8710 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki edited comment on FLINK-26537 at 3/9/22, 5:32 PM: ---

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

afedulov commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822908446 ## File path: tools/ci/shade.sh ## @@ -173,3 +173,62 @@ check_shaded_artifacts_connector_elasticsearch() { return 0 } + +check_one_per_package

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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * b0dea28c30a7819c9c8ab58acba80df8f2ae8710 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki edited comment on FLINK-26537 at 3/9/22, 5:30 PM: ---

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

[ https://issues.apache.org/jira/browse/FLINK-26537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503753#comment-17503753 ] Fil Karnicki commented on FLINK-26537: -- hi [~igal], I think that depending on which

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

RyanSkraba commented on a change in pull request #19024: URL: https://github.com/apache/flink/pull/19024#discussion_r822902236 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormatTest.java ## @@ -309,9 +328,16 @@

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * c3e816391654a6c4230414be93683ba0d7932f73 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

afedulov commented on a change in pull request #18905: URL: https://github.com/apache/flink/pull/18905#discussion_r822901231 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -288,6 +288,33 @@ under the License. -Xms256m

[jira] [Resolved] (FLINK-26485) [Changelog] State not discarded after multiple retries

[ https://issues.apache.org/jira/browse/FLINK-26485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-26485. --- Resolution: Fixed Merged into master as a3080eec4d74eda12b563e7088f7d5bef417d38a..3

[GitHub] [flink] rkhachatryan merged pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

rkhachatryan merged pull request #18976: URL: https://github.com/apache/flink/pull/18976 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-un

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Commented] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503740#comment-17503740 ] Jing Ge commented on FLINK-25416: - Hi Kevin,  thanks for your interest. The upcoming 1.

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

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503628#comment-17503628 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 5:11 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503628#comment-17503628 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 5:10 PM: -

[jira] [Created] (FLINK-26556) Refactoring MiniCluster and TestingMiniCluster

Niklas Semmler created FLINK-26556: -- Summary: Refactoring MiniCluster and TestingMiniCluster Key: FLINK-26556 URL: https://issues.apache.org/jira/browse/FLINK-26556 Project: Flink Issue Type

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

flinkbot edited a comment on pull request #19020: URL: https://github.com/apache/flink/pull/19020#issuecomment-1062833750 ## CI report: * e16c14406fad0e2693e9e86f21ba3376e3ba743e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #19021: URL: https://github.com/apache/flink/pull/19021#issuecomment-1062847721 ## CI report: * 8a14a4d32b8a2f69426d0faa7fb1e7d18e809475 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-25416: Description: *Background information* Current AvroParquet implementation AvroParquetRecordFormat uses the

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

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503628#comment-17503628 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 5:00 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

flinkbot edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 1425c2712c72bff10ba5b60b8fccf5cbc871d22a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * c3e816391654a6c4230414be93683ba0d7932f73 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503628#comment-17503628 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 4:57 PM: -

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

[ https://issues.apache.org/jira/browse/FLINK-25235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503628#comment-17503628 ] Niklas Semmler edited comment on FLINK-25235 at 3/9/22, 4:56 PM: -

[GitHub] [flink] snuyanzin commented on pull request #18874: [FLINK-26295][table] Operation strategies should allow having spaces …

snuyanzin commented on pull request #18874: URL: https://github.com/apache/flink/pull/18874#issuecomment-1063139866 @godfreyhe sorry for the poke... could you please have a look since it is already approved and it is related to https://github.com/apache/flink/pull/18363 -- This is an

[GitHub] [flink] einarjohnson commented on pull request #8568: [FLINK-7697][connectors] Add metrics for ElasticSearchSink

einarjohnson commented on pull request #8568: URL: https://github.com/apache/flink/pull/8568#issuecomment-1063140104 are there any metrics available for the elasticsearch sink? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

flinkbot edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 1425c2712c72bff10ba5b60b8fccf5cbc871d22a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 1aadc0dbc7f297ab864e6dee57b1df74a1359b1e Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

flinkbot edited a comment on pull request #18905: URL: https://github.com/apache/flink/pull/18905#issuecomment-1049717092 ## CI report: * 4fa3790a48a8f3e67e854d8579d830f5f5c3f6a2 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] slinkydeveloper edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

slinkydeveloper edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063131040 There is one pitfall to this PR. If you do `mvn checkstyle:apply` in a subdirectory project (e.g. `cd flink-scala && mvn spotless:apply`), it will fail cause it

[GitHub] [flink] slinkydeveloper commented on pull request #19025: [FLINK-26553][build] Configure scalafmt

slinkydeveloper commented on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063131040 There is one pitfall to this PR. If you do `mvn checkstyle:apply` in a subdirectory project (e.g. `cd flink-scala && mvn spotless:apply`), it will fail cause it can't f

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

flinkbot edited a comment on pull request #19001: URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402 ## CI report: * 6ef2e345162e0e64ad1bddfe38e0c3022ab378fa Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 2175ee842d81b35cff07f0524c154c240fd4ec0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18980: URL: https://github.com/apache/flink/pull/18980#issuecomment-1059275933 ## CI report: * 679718e76727607cb4a95ade98717b3f8769b054 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

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

flinkbot edited a comment on pull request #18996: URL: https://github.com/apache/flink/pull/18996#issuecomment-1060587342 ## CI report: * c6f6997bf5e337e02855e4f0f4750c5c6e542339 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19025: [FLINK-26553][build] Configure scalafmt

slinkydeveloper commented on a change in pull request #19025: URL: https://github.com/apache/flink/pull/19025#discussion_r822852678 ## File path: pom.xml ## @@ -1959,6 +1959,34 @@ under the License.

[GitHub] [flink] flinkbot edited a comment on pull request #19015: [BP-1.14][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

flinkbot edited a comment on pull request #19015: URL: https://github.com/apache/flink/pull/19015#issuecomment-1062684744 ## CI report: * 1d494b08f78e7dd6e2d7a057a1575915d0f01536 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #19001: URL: https://github.com/apache/flink/pull/19001#issuecomment-1060869402 ## CI report: * 6ef2e345162e0e64ad1bddfe38e0c3022ab378fa Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 2175ee842d81b35cff07f0524c154c240fd4ec0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-1536) Graph partitioning operators for Gelly

[ https://issues.apache.org/jira/browse/FLINK-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503714#comment-17503714 ] Amit Srivastava commented on FLINK-1536: Just wanted to know what is the current

[jira] [Commented] (FLINK-25416) Build unified Parquet BulkFormat for both Table API and DataStream API

[ https://issues.apache.org/jira/browse/FLINK-25416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503710#comment-17503710 ] Kevin Lam commented on FLINK-25416: --- Hi, has there been any updates to this issue? I'm

[GitHub] [flink] slinkydeveloper commented on a change in pull request #19025: [FLINK-26553][build] Configure scalafmt

slinkydeveloper commented on a change in pull request #19025: URL: https://github.com/apache/flink/pull/19025#discussion_r822847216 ## File path: pom.xml ## @@ -1959,6 +1959,34 @@ under the License.

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot edited a comment on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18987: URL: https://github.com/apache/flink/pull/18987#issuecomment-1059995435 ## CI report: * 2175ee842d81b35cff07f0524c154c240fd4ec0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 4:24 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-26498: -- Description: the sql of job : {code:java} CREATE TABLE tableSource( name string, age int not n

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

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan edited comment on FLINK-26498 at 3/9/22, 4:23 PM:

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

[ https://issues.apache.org/jira/browse/FLINK-26498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503699#comment-17503699 ] hehuiyuan commented on FLINK-26498: ---  The `00:59:20.100` record are late  but  the tim

[GitHub] [flink] flinkbot commented on pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

flinkbot commented on pull request #19028: URL: https://github.com/apache/flink/pull/19028#issuecomment-1063104634 ## CI report: * 1b4b5e91e821a8c048f1e2f4b485eb26fbd65180 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #19026: [FLINK-15550][runtime] Debug logging for TaskTest

flinkbot edited a comment on pull request #19026: URL: https://github.com/apache/flink/pull/19026#issuecomment-1063097126 ## CI report: * 2cf1e3caca524420e205575fd43f1c78968e03b5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19027: [FLINK-15550][runtime] Debug logging for TaskTest

flinkbot edited a comment on pull request #19027: URL: https://github.com/apache/flink/pull/19027#issuecomment-1063097287 ## CI report: * 720a3e375ff3202093a62a945b00a63231af0264 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

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

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

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

[GitHub] [flink] zentol commented on pull request #18498: [FLINK-25801][ metrics]add cpu processor metric of taskmanager

zentol commented on pull request #18498: URL: https://github.com/apache/flink/pull/18498#issuecomment-1063099525 This to me sounds more like something that should be logged; we generally avoid exposing inherently constant values as metrics. -- This is an automated message from the Apache

[jira] [Updated] (FLINK-26555) Missing close in FileSystemJobResultStore

[ https://issues.apache.org/jira/browse/FLINK-26555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26555: --- Labels: pull-request-available (was: ) > Missing close in FileSystemJobResultStore > --

[GitHub] [flink] XComp opened a new pull request #19028: [FLINK-26555][runtime] Adds closing and flushing to OutputStream

XComp opened a new pull request #19028: URL: https://github.com/apache/flink/pull/19028 ## What is the purpose of the change The {{FileSystemJobResultStore}} does not close the {{OutputStream}} when writing the JobResult into the file. This PR fixes the issue. ## Brief change

[GitHub] [flink] flinkbot commented on pull request #19027: [FLINK-15550][runtime] Debug logging for TaskTest

flinkbot commented on pull request #19027: URL: https://github.com/apache/flink/pull/19027#issuecomment-1063097287 ## CI report: * 720a3e375ff3202093a62a945b00a63231af0264 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #19026: [FLINK-15550][runtime] Debug logging for TaskTest

flinkbot commented on pull request #19026: URL: https://github.com/apache/flink/pull/19026#issuecomment-1063097126 ## CI report: * 2cf1e3caca524420e205575fd43f1c78968e03b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

[ https://issues.apache.org/jira/browse/FLINK-16956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16956. Resolution: Won't Fix This will happen from time to time because it inherently relies on e

[GitHub] [flink] akalash opened a new pull request #19027: [FLINK-15550][runtime] Debug logging for TaskTest

akalash opened a new pull request #19027: URL: https://github.com/apache/flink/pull/19027 (cherry picked from commit 16e9b7325881b45741f3591f73a7b7bcfd39322b) ## What is the purpose of the change Backport of https://github.com/apache/flink/pull/18981 ## Does this

[GitHub] [flink] zentol commented on a change in pull request #19025: [FLINK-26553][build] Configure scalafmt

zentol commented on a change in pull request #19025: URL: https://github.com/apache/flink/pull/19025#discussion_r822822807 ## File path: pom.xml ## @@ -1959,6 +1959,34 @@ under the License.

[GitHub] [flink] zentol commented on a change in pull request #19025: [FLINK-26553][build] Configure scalafmt

zentol commented on a change in pull request #19025: URL: https://github.com/apache/flink/pull/19025#discussion_r822823407 ## File path: pom.xml ## @@ -1959,6 +1959,34 @@ under the License.

[jira] [Assigned] (FLINK-26555) Missing close in FileSystemJobResultStore

[ https://issues.apache.org/jira/browse/FLINK-26555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-26555: - Assignee: Matthias Pohl > Missing close in FileSystemJobResultStore > -

[jira] [Updated] (FLINK-26555) Missing close in FileSystemJobResultStore

[ https://issues.apache.org/jira/browse/FLINK-26555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-26555: -- Fix Version/s: 1.15.0 > Missing close in FileSystemJobResultStore > --

[jira] [Created] (FLINK-26555) Missing close in FileSystemJobResultStore

Matthias Pohl created FLINK-26555: - Summary: Missing close in FileSystemJobResultStore Key: FLINK-26555 URL: https://issues.apache.org/jira/browse/FLINK-26555 Project: Flink Issue Type: Bug

[GitHub] [flink] akalash opened a new pull request #19026: [FLINK-15550][runtime] Debug logging for TaskTest

akalash opened a new pull request #19026: URL: https://github.com/apache/flink/pull/19026 (cherry picked from commit 16e9b7325881b45741f3591f73a7b7bcfd39322b) ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob

[GitHub] [flink] flinkbot edited a comment on pull request #18976: [FLINK-26485][state/changelog] Discard unnecessarily uploaded state

flinkbot edited a comment on pull request #18976: URL: https://github.com/apache/flink/pull/18976#issuecomment-1058916391 ## CI report: * a9a9a1ed1eb7791c15d4129c579aa098f2ef7d83 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * b1cd905439ca2922134e7884aa8adf12261eae7b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-26554) Clean termination of FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated FLINK-26554: - Parent: FLINK-25963 Issue Type: Sub-task (was: Bug) > Clean termination of FlinkDeploym

[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

flinkbot edited a comment on pull request #19017: URL: https://github.com/apache/flink/pull/19017#issuecomment-1062742669 ## CI report: * 7d4fa8b9bc0e3c8fce18c6e5c267ef3d644f454e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26554) Clean termination of FlinkDeployment

[ https://issues.apache.org/jira/browse/FLINK-26554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503689#comment-17503689 ] Thomas Weise commented on FLINK-26554: -- {code:java} java.util.concurrent.TimeoutExc

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

flinkbot edited a comment on pull request #18949: URL: https://github.com/apache/flink/pull/18949#issuecomment-1055620167 ## CI report: * b1cd905439ca2922134e7884aa8adf12261eae7b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26554) Clean termination of FlinkDeployment

Thomas Weise created FLINK-26554: Summary: Clean termination of FlinkDeployment Key: FLINK-26554 URL: https://issues.apache.org/jira/browse/FLINK-26554 Project: Flink Issue Type: Bug

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

flinkbot edited a comment on pull request #19023: URL: https://github.com/apache/flink/pull/19023#issuecomment-1062931101 ## CI report: * a7bad35a1f8622c488accc9b0ecda1e56b2d9c64 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19025: [FLINK-26553][build] Configure scalafmt

flinkbot edited a comment on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 1425c2712c72bff10ba5b60b8fccf5cbc871d22a Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

XComp commented on a change in pull request #18987: URL: https://github.com/apache/flink/pull/18987#discussion_r822805051 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleaner.java ## @@ -146,14 +146,15 @@ private Builder(

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

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

[GitHub] [flink] flinkbot commented on pull request #19025: [FLINK-26553][build] Configure scalafmt

flinkbot commented on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065558 ## CI report: * 1425c2712c72bff10ba5b60b8fccf5cbc871d22a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] sjwiesman commented on pull request #19025: [FLINK-26553][build] Configure scalafmt

sjwiesman commented on pull request #19025: URL: https://github.com/apache/flink/pull/19025#issuecomment-1063065033 🔥 Please add the formatting commit to [.git-blame-ignore-revs](https://github.com/apache/flink/blob/master/.git-blame-ignore-revs) -- This is an automated message f

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

[ https://issues.apache.org/jira/browse/FLINK-26553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26553: --- Labels: pull-request-available (was: ) > Enable scalafmt for scala codebase > -

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

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503675#comment-17503675 ] Thomas Weise commented on FLINK-26473: -- Correct, there are various error scenarios

[GitHub] [flink] flinkbot edited a comment on pull request #19015: [BP-1.14][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

flinkbot edited a comment on pull request #19015: URL: https://github.com/apache/flink/pull/19015#issuecomment-1062684744 ## CI report: * 1d494b08f78e7dd6e2d7a057a1575915d0f01536 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] slinkydeveloper opened a new pull request #19025: [FLINK-26553][build] Configure scalafmt

slinkydeveloper opened a new pull request #19025: URL: https://github.com/apache/flink/pull/19025 This PR enables scalafmt in spotless, in order to unify the scala formatting across the codebase. For more details, check the discussion: https://lists.apache.org/thread/97398pc9cb8y922

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 1b1d3595f0828f045964e58687d4a481c21ea843 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

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

[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-26528: - Assignee: Aitozi > Trigger the updateControl when the FlinkDeployment have changed > --

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

[ https://issues.apache.org/jira/browse/FLINK-26473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-26473: Assignee: Thomas Weise > Observer should support JobManager deployment crashed or deleted

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

[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503673#comment-17503673 ] Yang Wang commented on FLINK-26528: --- Thanks for your explanation. I get your point. Th

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #19015: [BP-1.14][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

flinkbot edited a comment on pull request #19015: URL: https://github.com/apache/flink/pull/19015#issuecomment-1062684744 ## CI report: * 1d494b08f78e7dd6e2d7a057a1575915d0f01536 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18838: [FLINK-26177][Connector/pulsar] Use testcontainer pulsar runtime instead o…

flinkbot edited a comment on pull request #18838: URL: https://github.com/apache/flink/pull/18838#issuecomment-1044141081 ## CI report: * bdcc449452fae9bfc0892918d51a6f3b0397 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-26352) Missing license header in WebUI source files

[ https://issues.apache.org/jira/browse/FLINK-26352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17503667#comment-17503667 ] Matthias Pohl commented on FLINK-26352: --- {{master}}: {{932934aabb55a048da390ee804f

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

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

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

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

[GitHub] [flink] XComp commented on pull request #19015: [BP-1.14][FLINK-26352][runtime-web] Add missing license headers to WebUI source files

XComp commented on pull request #19015: URL: https://github.com/apache/flink/pull/19015#issuecomment-1063049974 @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 specific c

<    1   2   3   4   5   6   7   8   >