[GitHub] [flink] flinkbot edited a comment on pull request #14684: [FLINK-20460][Connector-HBase] Support async lookup for HBase connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

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

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[jira] [Commented] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301066#comment-17301066 ] Kezhu Wang commented on FLINK-21467: Hi [~pnowojski], I guess it depends on various

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

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

[GitHub] [flink] SteNicholas commented on a change in pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

SteNicholas commented on a change in pull request #15185: URL: https://github.com/apache/flink/pull/15185#discussion_r593852102 ## File path: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java ## @@ -1124,20 +1124,21 @@ public static void main(final Strin

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

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

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301048#comment-17301048 ] Shengkai Fang commented on FLINK-21466: --- I think you are right. Make "embedded" as

[jira] [Updated] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang updated FLINK-21466: -- Description: Users can use command {code:java} >./sql-client.sh {code} to start the sql clien

[jira] [Comment Edited] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301045#comment-17301045 ] Wei Hao edited comment on FLINK-21743 at 3/14/21, 5:26 AM: --- Th

[GitHub] [flink] LadyForest commented on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

LadyForest commented on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-798834936 > We can also remove createModuleReplaceVars and assertShowResult methods in LocalExecutorITCase. My bad:( I forgot to remove them...

[GitHub] [flink] flinkbot edited a comment on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

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

[jira] [Commented] (FLINK-21743) JdbcXaSinkFunction throws XAER_RMFAIL when calling snapshotState and beginTx

[ https://issues.apache.org/jira/browse/FLINK-21743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301045#comment-17301045 ] Wei Hao commented on FLINK-21743: - The config 'max_prepared_transactions' seems to be sp

[GitHub] [flink] flinkbot commented on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

flinkbot commented on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798833303 ## CI report: * 4841aec2ecec361d616c7b35aacdf9bb5835 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Updated] (FLINK-20740) Use managed memory to avoid direct memory OOM error for sort-merge shuffle (introduce a separated buffer pool)

[ https://issues.apache.org/jira/browse/FLINK-20740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-20740: Summary: Use managed memory to avoid direct memory OOM error for sort-merge shuffle (introduce a s

[GitHub] [flink] flinkbot commented on pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

flinkbot commented on pull request #15193: URL: https://github.com/apache/flink/pull/15193#issuecomment-798831053 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 pro

[jira] [Updated] (FLINK-21778) Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

[ https://issues.apache.org/jira/browse/FLINK-21778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21778: --- Labels: pull-request-available (was: ) > Use heap memory instead of direct memory as index

[GitHub] [flink] wsry opened a new pull request #15193: [FLINK-21778][network] Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

wsry opened a new pull request #15193: URL: https://github.com/apache/flink/pull/15193 ## What is the purpose of the change Currently, the sort-merge shuffle implementation uses a piece of direct memory as index entry cache for acceleration. This patch switches to heap memory instea

[GitHub] [flink] flinkbot edited a comment on pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

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

[jira] [Created] (FLINK-21778) Use heap memory instead of direct memory as index entry cache for sort-merge shuffle

Yingjie Cao created FLINK-21778: --- Summary: Use heap memory instead of direct memory as index entry cache for sort-merge shuffle Key: FLINK-21778 URL: https://issues.apache.org/jira/browse/FLINK-21778 Pr

[GitHub] [flink] flinkbot commented on pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

flinkbot commented on pull request #15192: URL: https://github.com/apache/flink/pull/15192#issuecomment-798828549 ## CI report: * b33ebbeb181bb30510dcd28361fb9fff39a140a2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

flinkbot commented on pull request #15192: URL: https://github.com/apache/flink/pull/15192#issuecomment-798827237 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 pro

[jira] [Updated] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call

[ https://issues.apache.org/jira/browse/FLINK-21777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21777: --- Labels: pull-request-available (was: ) > Replace the 4M data writing cache of sort-merge sh

[GitHub] [flink] wsry opened a new pull request #15192: [FLINK-21777][network] Replace the 4M data writing cache of sort-merge shuffle with writev system call

wsry opened a new pull request #15192: URL: https://github.com/apache/flink/pull/15192 ## What is the purpose of the change Currently, the sort-merge shuffle implementation uses 4M unmanaged direct memory as cache for data writing. This patch replaces the cache with writev system ca

[GitHub] [flink] flinkbot edited a comment on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][statsd] Remove flink-runtime dependency

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

[jira] [Commented] (FLINK-20388) Supports users setting operators' metrics name

[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301040#comment-17301040 ] tim yu commented on FLINK-20388: Hi [~jark] [~chesnay], What is the conclusion through a

[jira] [Updated] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call

[ https://issues.apache.org/jira/browse/FLINK-21777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21777: Description: Currently, the sort-merge shuffle implementation uses 4M unmanaged direct memory as c

[GitHub] [flink] flinkbot edited a comment on pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

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

[GitHub] [flink] rionmonster commented on a change in pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

rionmonster commented on a change in pull request #15175: URL: https://github.com/apache/flink/pull/15175#discussion_r593831333 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporter.java ## @@ -51,7

[GitHub] [flink] rionmonster commented on a change in pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

rionmonster commented on a change in pull request #15175: URL: https://github.com/apache/flink/pull/15175#discussion_r593831319 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java ## @@ -50,30 +49,11 @@

[GitHub] [flink] rionmonster commented on a change in pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

rionmonster commented on a change in pull request #15175: URL: https://github.com/apache/flink/pull/15175#discussion_r593831274 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporterFactory.java ## @@ -17,18 +1

[GitHub] [flink] rionmonster commented on a change in pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

rionmonster commented on a change in pull request #15175: URL: https://github.com/apache/flink/pull/15175#discussion_r593831263 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusPushGatewayReporterFactory.java ## @

[GitHub] [flink] flinkbot edited a comment on pull request #15182: [FLINK-21761][metrics][influxdb] Remove flink-runtime dependency

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

[jira] [Created] (FLINK-21777) Replace the 4M data writing cache of sort-merge shuffle with writev system call

Yingjie Cao created FLINK-21777: --- Summary: Replace the 4M data writing cache of sort-merge shuffle with writev system call Key: FLINK-21777 URL: https://issues.apache.org/jira/browse/FLINK-21777 Project

[GitHub] [flink] Wosin commented on pull request #15156: [FLINK-21393] [formats] Implement ParquetAvroInputFormat

Wosin commented on pull request #15156: URL: https://github.com/apache/flink/pull/15156#issuecomment-798814244 Hey :) Thanks for CC. Looks good! One thing to consider, is if there is anything stopping us from going even futher and adding possibility to deserialize `SpecificRecord` insta

[GitHub] [flink] zentol commented on a change in pull request #15175: [FLINK-16829] Refactored Prometheus Metric Reporters to use construct…

zentol commented on a change in pull request #15175: URL: https://github.com/apache/flink/pull/15175#discussion_r593813599 ## File path: flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/PrometheusReporter.java ## @@ -50,30 +49,11 @@ int

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15182: [FLINK-21761][metrics][influxdb] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][statsd] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][statsd] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15182: [FLINK-21761][metrics][influxdb] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15180: [FLINK-21762][metrics][prometheus] Remove flink-runtime dependency

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

[GitHub] [flink] LeonBein commented on a change in pull request #15109: [FLINK-20955][connectors/hbase] HBase connector using new connector API

LeonBein commented on a change in pull request #15109: URL: https://github.com/apache/flink/pull/15109#discussion_r593793297 ## File path: flink-connectors/flink-connector-hbase/pom.xml ## @@ -0,0 +1,163 @@ + + +http://maven.apache.org/POM/4.0.0"; +xmlns:xsi="ht

[GitHub] [flink] LeonBein commented on a change in pull request #15109: [FLINK-20955][connectors/hbase] HBase connector using new connector API

LeonBein commented on a change in pull request #15109: URL: https://github.com/apache/flink/pull/15109#discussion_r593793004 ## File path: flink-connectors/flink-connector-hbase/src/test/java/org/apache/flink/connector/hbase/testutil/HBaseTestClusterUtil.java ## @@ -0,0 +1,322

[GitHub] [flink] LeonBein commented on a change in pull request #15109: [FLINK-20955][connectors/hbase] HBase connector using new connector API

LeonBein commented on a change in pull request #15109: URL: https://github.com/apache/flink/pull/15109#discussion_r593792660 ## File path: flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/source/enumerator/HBaseSplitEnumerator.java ## @@ -0

[GitHub] [flink] LeonBein commented on a change in pull request #15109: [FLINK-20955][connectors/hbase] HBase connector using new connector API

LeonBein commented on a change in pull request #15109: URL: https://github.com/apache/flink/pull/15109#discussion_r593792517 ## File path: flink-connectors/flink-connector-hbase/src/test/java/org/apache/flink/connector/hbase/source/HBaseSourceITCase.java ## @@ -0,0 +1,313 @@ +

[GitHub] [flink] flinkbot edited a comment on pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #15190: [FLINK-21775][metrics] Migrate JobManagerMG instatiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][slf4j] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15186: [FLINK-21770][metrics] JobManagerMG#addJob accepts job ID and name

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

[GitHub] [flink] flinkbot edited a comment on pull request #15187: [FLINK-21771][metrics][tests] Replace StreamTaskTestHarness#TestTaskMetricGroup

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

[GitHub] [flink] flinkbot edited a comment on pull request #15179: [FLINK-21757][metrics] Add LogicalScopeProvider interface

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

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354][statebackend] Introduce ChangelogStateBackend to delegate state access

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN * 8e3149727880b6f2d8ce7f2b851f51be5b34

[GitHub] [flink] flinkbot edited a comment on pull request #15183: [FLINK-21764][metrics][dropwizard] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15184: [FLINK-21766][metrics] Remove OperatorMetricGroup#parent()

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

[jira] [Commented] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

[ https://issues.apache.org/jira/browse/FLINK-21466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300919#comment-17300919 ] zck commented on FLINK-21466: - [~jark]  plz check my thoughts. just set mode parameter as t

[GitHub] [flink] flinkbot edited a comment on pull request #15181: [FLINK-21760][metrics][jmx] Remove flink-runtime dependency

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

[GitHub] [flink] flinkbot edited a comment on pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #15190: [FLINK-21775][metrics] Migrate JobManagerMG instatiations to factory method

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

[GitHub] [flink] flinkbot edited a comment on pull request #15178: [FLINK-21756][jmx] Move JMXServer to flink-core

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

[GitHub] [flink] flinkbot commented on pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

flinkbot commented on pull request #15191: URL: https://github.com/apache/flink/pull/15191#issuecomment-798521197 ## CI report: * 4759dbafe9cf13ab47617dba7bac08703418422e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15190: [FLINK-21775][metrics] Migrate JobManagerMG instatiations to factory method

flinkbot commented on pull request #15190: URL: https://github.com/apache/flink/pull/15190#issuecomment-798496630 ## CI report: * 694f77c5efd6d4bd53279451152fe9e311463e6e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15177: [FLINK-21759][metrics][tests] Add TestMetricGroup

flinkbot edited a comment on pull request #15177: URL: https://github.com/apache/flink/pull/15177#issuecomment-798218232 ## CI report: * b099399b0f17a96f7ab6116c056577762f81771d UNKNOWN * e3c6775999035e893e0e0360eaa7862e5d967f5d Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15176: [FLINK-21758][metrics] Add default implementations for int methods

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

[jira] [Updated] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang updated FLINK-21626: --- Fix Version/s: 1.13.0 > Consider shaping newly introduced RuntimeContext.getJobId to return JobID >

[jira] [Commented] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300887#comment-17300887 ] Kezhu Wang commented on FLINK-21578: [~gaoyunhaii] Not exactly. The problem is inter

[GitHub] [flink] flinkbot commented on pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

flinkbot commented on pull request #15191: URL: https://github.com/apache/flink/pull/15191#issuecomment-798481211 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #15189: [FLINK-21773][metrics][slf4j] Remove flink-runtime dependency

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

[GitHub] [flink] zentol opened a new pull request #15191: [FLINK-21776][metrics] Migrate JobManagerJobMG instatiations to factory method

zentol opened a new pull request #15191: URL: https://github.com/apache/flink/pull/15191 Based on #15190. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[GitHub] [flink] flinkbot commented on pull request #15190: [FLINK-21775][metrics] Migrate JobManagerMG instatiations to factory method

flinkbot commented on pull request #15190: URL: https://github.com/apache/flink/pull/15190#issuecomment-798478026 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

flinkbot edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-772182984 ## CI report: * 60e427103cca73ac1fc29fb18893e3996edb1c7a UNKNOWN * 83aa947d7ab9528a7c8b3418316066b19f0e6916 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-21776) Migrate all JobManagerJobMG instantiations to factory method

Chesnay Schepler created FLINK-21776: Summary: Migrate all JobManagerJobMG instantiations to factory method Key: FLINK-21776 URL: https://issues.apache.org/jira/browse/FLINK-21776 Project: Flink

[jira] [Updated] (FLINK-21776) Migrate all JobManagerJobMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-21776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-21776: - Description: Modify all existing usages of the JobManageJobrMG constructor to use runtim

[jira] [Updated] (FLINK-21775) Migrate all JobManagerMG instantiations to factory method

[ https://issues.apache.org/jira/browse/FLINK-21775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21775: --- Labels: pull-request-available (was: ) > Migrate all JobManagerMG instantiations to factory

[GitHub] [flink] zentol opened a new pull request #15190: [FLINK-21775][metrics] Migrate JobManagerMG instatiations to factory method

zentol opened a new pull request #15190: URL: https://github.com/apache/flink/pull/15190 Based on #15186. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use th

[jira] [Created] (FLINK-21775) Migrate all JobManagerMG instantiations to factory method

Chesnay Schepler created FLINK-21775: Summary: Migrate all JobManagerMG instantiations to factory method Key: FLINK-21775 URL: https://issues.apache.org/jira/browse/FLINK-21775 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #15189: [FLINK-21773][metrics][slf4j] Remove flink-runtime dependency

flinkbot commented on pull request #15189: URL: https://github.com/apache/flink/pull/15189#issuecomment-798459150 ## CI report: * 77bf284b8395d960b0c53425bc6a663cd3103b2a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

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

[jira] [Created] (FLINK-21774) Do not display column names when retrun set is emtpy in SQL Client

Jark Wu created FLINK-21774: --- Summary: Do not display column names when retrun set is emtpy in SQL Client Key: FLINK-21774 URL: https://issues.apache.org/jira/browse/FLINK-21774 Project: Flink Iss

[GitHub] [flink] wuchong commented on pull request #15174: [FLINK-21651][sql-client] Migrate module related tests in LocalExecutorITCase to the new integration test framework

wuchong commented on pull request #15174: URL: https://github.com/apache/flink/pull/15174#issuecomment-798430818 @fsk119 I think the branch alread based on the lastest master. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot commented on pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

flinkbot commented on pull request #15188: URL: https://github.com/apache/flink/pull/15188#issuecomment-798424651 ## CI report: * 6b3c0efce0ab7cd55e1023d08ef4e4077c7bfd27 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15186: [FLINK-21770][metrics] JobManagerMG#addJob accepts job ID and name

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

[GitHub] [flink] flinkbot edited a comment on pull request #15187: [FLINK-21771][metrics][tests] Replace StreamTaskTestHarness#TestTaskMetricGroup

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

[GitHub] [flink] flinkbot commented on pull request #15189: [FLINK-21773][metrics][slf4j] Remove flink-runtime dependency

flinkbot commented on pull request #15189: URL: https://github.com/apache/flink/pull/15189#issuecomment-798422527 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 pro

[jira] [Updated] (FLINK-21773) Remove dependency from flink-metrics-statsd

[ https://issues.apache.org/jira/browse/FLINK-21773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21773: --- Labels: pull-request-available (was: ) > Remove dependency from flink-metrics-statsd >

[GitHub] [flink] zentol opened a new pull request #15189: [FLINK-21773][metrics][slf4j] Remove flink-runtime dependency

zentol opened a new pull request #15189: URL: https://github.com/apache/flink/pull/15189 Based on #15177. - reworks the tests to work directly against the reporter This is an automated message from the Apache Git Servi

[GitHub] [flink] flinkbot commented on pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

flinkbot commented on pull request #15188: URL: https://github.com/apache/flink/pull/15188#issuecomment-798417786 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 pro

[jira] [Created] (FLINK-21773) Remove dependency from flink-metrics-statsd

Chesnay Schepler created FLINK-21773: Summary: Remove dependency from flink-metrics-statsd Key: FLINK-21773 URL: https://issues.apache.org/jira/browse/FLINK-21773 Project: Flink Issue Typ

[jira] [Updated] (FLINK-21772) Remove dependency from flink-metrics-slf4j

[ https://issues.apache.org/jira/browse/FLINK-21772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21772: --- Labels: pull-request-available (was: ) > Remove dependency from flink-metrics-slf4j > -

[GitHub] [flink] zentol opened a new pull request #15188: [FLINK-21772][metrics][slf4j] Remove flink-runtime dependency

zentol opened a new pull request #15188: URL: https://github.com/apache/flink/pull/15188 Based on #15177. - reworks the tests to work directly against the reporter This is an automated message from the Apache Git Servi

[jira] [Commented] (FLINK-21578) Closeable Sink Committer/GlobalCommitter were created to function in onestep during job graph composition

[ https://issues.apache.org/jira/browse/FLINK-21578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300863#comment-17300863 ] Yun Gao commented on FLINK-21578: - Hi [~kezhuw], sorry I might not fully got the issue,

[GitHub] [flink] flinkbot commented on pull request #15187: [FLINK-21771][metrics][tests] Replace StreamTaskTestHarness#TestTaskMetricGroup

flinkbot commented on pull request #15187: URL: https://github.com/apache/flink/pull/15187#issuecomment-798412370 ## CI report: * b3112ce7fa1b1955362ef7b3a0b2de15bb1a197f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15186: [FLINK-21770][metrics] JobManagerMG#addJob accepts job ID and name

flinkbot commented on pull request #15186: URL: https://github.com/apache/flink/pull/15186#issuecomment-798412260 ## CI report: * f0997a4fb9540f80536f86175e7b37095d375231 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Created] (FLINK-21772) Remove dependency from flink-metrics-slf4j

Chesnay Schepler created FLINK-21772: Summary: Remove dependency from flink-metrics-slf4j Key: FLINK-21772 URL: https://issues.apache.org/jira/browse/FLINK-21772 Project: Flink Issue Type

[GitHub] [flink] flinkbot commented on pull request #15187: [FLINK-21771][metrics][tests] Replace StreamTaskTestHarness#TestTaskMetricGroup

flinkbot commented on pull request #15187: URL: https://github.com/apache/flink/pull/15187#issuecomment-798403944 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 pro

[jira] [Updated] (FLINK-21771) Replace StreamTaskTestHarness#TestTaskMetricGroup

[ https://issues.apache.org/jira/browse/FLINK-21771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21771: --- Labels: pull-request-available (was: ) > Replace StreamTaskTestHarness#TestTaskMetricGroup

  1   2   3   >