| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. |
Thu, 14 Nov, 10:56 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it |
Thu, 14 Nov, 10:59 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10190: [hotfix][docs] fix 'optional' SQL Client function parameters stated as 'optimal' |
Thu, 14 Nov, 10:59 |
| GitBox |
[GitHub] [flink] zentol commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it |
Thu, 14 Nov, 11:00 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10135: [FLINK-14679][shuffle] Store number of partitions in PartitionDescriptor |
Thu, 14 Nov, 11:01 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile |
Thu, 14 Nov, 11:02 |
| Harold Braux (Jira) |
[jira] [Commented] (FLINK-8093) flink job fail because of kafka producer create fail of "javax.management.InstanceAlreadyExistsException" |
Thu, 14 Nov, 11:03 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10175: [FLINK-14746][web] Handle uncaught exceptions in HistoryServerArchive… |
Thu, 14 Nov, 11:05 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10189: [FLINK-14104][build] Pin jackson version to 2.10.1 |
Thu, 14 Nov, 11:07 |
| GitBox |
[GitHub] [flink] aljoscha commented on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource |
Thu, 14 Nov, 11:08 |
| Stephan Ewen (Jira) |
[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance |
Thu, 14 Nov, 11:12 |
| Dawid Wysakowicz (Jira) |
[jira] [Created] (FLINK-14782) CoreModule#getFunctionDefinition throws exception when function does not exist |
Thu, 14 Nov, 11:14 |
| Dawid Wysakowicz (Jira) |
[jira] [Commented] (FLINK-14782) CoreModule#getFunctionDefinition throws exception when function does not exist |
Thu, 14 Nov, 11:15 |
| Dawid Wysakowicz (Jira) |
[jira] [Updated] (FLINK-14782) CoreModule#getFunctionDefinition throws exception when function does not exist |
Thu, 14 Nov, 11:16 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-13528) Kafka E2E tests fail on Java 11 |
Thu, 14 Nov, 11:16 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource |
Thu, 14 Nov, 11:23 |
| GitBox |
[GitHub] [flink] wangyang0918 commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Thu, 14 Nov, 11:26 |
| GitBox |
[GitHub] [flink] wangyang0918 commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Thu, 14 Nov, 11:26 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values |
Thu, 14 Nov, 11:27 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. |
Thu, 14 Nov, 11:27 |
| lining (Jira) |
[jira] [Commented] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job |
Thu, 14 Nov, 11:28 |
| lining (Jira) |
[jira] [Comment Edited] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job |
Thu, 14 Nov, 11:29 |
| GitBox |
[GitHub] [flink] xintongsong commented on issue #10161: [FLINK-13986][runtime] Clean up legacy code for FLIP-49. |
Thu, 14 Nov, 11:29 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy |
Thu, 14 Nov, 11:30 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10135: [FLINK-14679][shuffle] Store number of partitions in PartitionDescriptor |
Thu, 14 Nov, 11:32 |
| Stephan Ewen (Jira) |
[jira] [Comment Edited] (FLINK-14735) Improve batch schedule check input consumable performance |
Thu, 14 Nov, 11:33 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile |
Thu, 14 Nov, 11:33 |
| Gary Yao (Jira) |
[jira] [Assigned] (FLINK-14767) Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR |
Thu, 14 Nov, 11:36 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10177: [FLINK-14747] Fix performance regression with latest changes to Mailbox |
Thu, 14 Nov, 11:36 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10187: [FLINK-13938][yarn] Enable configure shared libraries on YARN |
Thu, 14 Nov, 11:38 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10189: [FLINK-14104][build] Pin jackson version to 2.10.1 |
Thu, 14 Nov, 11:38 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10190: [hotfix][docs] fix 'optional' SQL Client function parameters stated as 'optimal' |
Thu, 14 Nov, 11:38 |
| Zhu Zhu (Jira) |
[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance |
Thu, 14 Nov, 11:39 |
| Zhu Zhu (Jira) |
[jira] [Comment Edited] (FLINK-14735) Improve batch schedule check input consumable performance |
Thu, 14 Nov, 11:40 |
| Gary Yao (Jira) |
[jira] [Assigned] (FLINK-14766) Remove volatile variable in ExecutionVertex |
Thu, 14 Nov, 11:40 |
| GitBox |
[GitHub] [flink] yanghua opened a new pull request #10191: [FLINK-14749] Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 11:43 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14749) Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 11:44 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-14740) Create OperatorID for OperatorMetricGroup which in batch job |
Thu, 14 Nov, 11:44 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10191: [FLINK-14749] Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 11:45 |
| GitBox |
[GitHub] [flink] wangyang0918 commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Thu, 14 Nov, 11:51 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10005: [FLINK-14533][flink-table-planner] Fix LOWER/UPPER not being pushed down to TableSource |
Thu, 14 Nov, 11:53 |
| GitBox |
[GitHub] [flink] wangyang0918 commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Thu, 14 Nov, 11:56 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10079: [FLINK-14594] Fix matching logics of ResourceSpec/ResourceProfile/Resource considering double values |
Thu, 14 Nov, 11:57 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. |
Thu, 14 Nov, 11:57 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy |
Thu, 14 Nov, 12:00 |
| GitBox |
[GitHub] [flink] zhuzhurk commented on issue #10136: [FLINK-14680][runtime, tests] Enable KafkaConsumerTestBase#runFailOnNoBrokerTest to pass with DefaultScheduler |
Thu, 14 Nov, 12:01 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile |
Thu, 14 Nov, 12:03 |
| Roman Khachatryan (Jira) |
[jira] [Created] (FLINK-14783) Implement a benchmark for `ContinuousFileReaderOperator` |
Thu, 14 Nov, 12:05 |
| Piotr Nowojski (Jira) |
[jira] [Updated] (FLINK-14783) Implement a benchmark for `ContinuousFileReaderOperator` |
Thu, 14 Nov, 12:07 |
| Piotr Nowojski (Jira) |
[jira] [Updated] (FLINK-14783) Implement a benchmark for `ContinuousFileReaderOperator` |
Thu, 14 Nov, 12:07 |
| GitBox |
[GitHub] [flink] gyfora commented on issue #9533: [FLINK-13850] [Connectors / FileSystem] Refactor part file configuration into a single method |
Thu, 14 Nov, 12:07 |
| Piotr Nowojski (Jira) |
[jira] [Assigned] (FLINK-14783) Implement a benchmark for `ContinuousFileReaderOperator` |
Thu, 14 Nov, 12:08 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10189: [FLINK-14104][build] Pin jackson version to 2.10.1 |
Thu, 14 Nov, 12:08 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10190: [hotfix][docs] fix 'optional' SQL Client function parameters stated as 'optimal' |
Thu, 14 Nov, 12:08 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10191: [FLINK-14749] Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 12:09 |
| GitBox |
[GitHub] [flink] wangyang0918 commented on issue #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread |
Thu, 14 Nov, 12:13 |
| Dinesh Balachandran (Jira) |
[jira] [Commented] (FLINK-5243) Implement an example for BipartiteGraph |
Thu, 14 Nov, 12:14 |
| GitBox |
[GitHub] [flink] GJL opened a new pull request #10192: [FLINK-14780][runtime] Register restart metrics only when start scheduling |
Thu, 14 Nov, 12:17 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14780) Avoid leaking instance of DefaultScheduler before object is constructed |
Thu, 14 Nov, 12:18 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10192: [FLINK-14780][runtime] Register restart metrics only when start scheduling |
Thu, 14 Nov, 12:20 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed |
Thu, 14 Nov, 12:22 |
| Yang Wang (Jira) |
[jira] [Updated] (FLINK-13938) Use yarn public distributed cache to speed up containers launch |
Thu, 14 Nov, 12:29 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10083: [FLINK-14472][runtime] Implement back-pressure monitor with non-blocking outputs. |
Thu, 14 Nov, 12:29 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn |
Thu, 14 Nov, 12:29 |
| Chesnay Schepler (Jira) |
[jira] [Commented] (FLINK-14748) Migrate duration and memory size related ConfigOptions to typed options |
Thu, 14 Nov, 12:30 |
| GitBox |
[GitHub] [flink] dawidwys commented on a change in pull request #10191: [FLINK-14749] Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 12:30 |
| GitBox |
[GitHub] [flink] godfreyhe commented on issue #10158: [FLINK-14694] [table-planner-blink] Most tests from package o.a.f.table.planner.functions.aggfunctions are not executed during mvn test and fix BinaryGeneric comparison failure |
Thu, 14 Nov, 12:31 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10136: [FLINK-14680][runtime, tests] Enable KafkaConsumerTestBase#runFailOnNoBrokerTest to pass with DefaultScheduler |
Thu, 14 Nov, 12:34 |
| Leonard Xu (Jira) |
[jira] [Commented] (FLINK-14674) some tpc-ds query hang in scheduled stage for long time |
Thu, 14 Nov, 12:35 |
| GitBox |
[GitHub] [flink] GJL commented on a change in pull request #10152: [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user code class loader |
Thu, 14 Nov, 12:36 |
| GitBox |
[GitHub] [flink] zentol commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it |
Thu, 14 Nov, 12:38 |
| vinoyang (Jira) |
[jira] [Commented] (FLINK-14748) Migrate duration and memory size related ConfigOptions to typed options |
Thu, 14 Nov, 12:40 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10189: [FLINK-14104][build] Pin jackson version to 2.10.1 |
Thu, 14 Nov, 12:40 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #10191: [FLINK-14749] Migrate duration and memory size ConfigOptions in JobManagerOptions |
Thu, 14 Nov, 12:40 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10192: [FLINK-14780][runtime] Register restart metrics only when start scheduling |
Thu, 14 Nov, 12:40 |
| Leonard Xu (Jira) |
[jira] [Created] (FLINK-14784) CsvTableSink miss delimiter when row start with null member |
Thu, 14 Nov, 12:42 |
| Jeff Zhang (Jira) |
[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn |
Thu, 14 Nov, 12:42 |
| Dawid Wysakowicz (Jira) |
[jira] [Updated] (FLINK-14748) Migrate duration and memory size related ConfigOptions to typed options |
Thu, 14 Nov, 12:44 |
| GitBox |
[GitHub] [flink] wangyang0918 opened a new pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary and Yarn public distributed cache to accelerate flink submission. |
Thu, 14 Nov, 12:45 |
| vinoyang (Jira) |
[jira] [Commented] (FLINK-12362) Remove legacy container number config option for Flink on yarn |
Thu, 14 Nov, 12:46 |
| Yang Wang (Jira) |
[jira] [Commented] (FLINK-13938) Use yarn public distributed cache to speed up containers launch |
Thu, 14 Nov, 12:47 |
| Jark Wu (Jira) |
[jira] [Assigned] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:47 |
| GitBox |
[GitHub] [flink] godfreyhe commented on a change in pull request #10174: [FLINK-14625][table-planner-blink] Add a rule to eliminate cross join as much as possible without statistics |
Thu, 14 Nov, 12:49 |
| Zhu Zhu (Jira) |
[jira] [Commented] (FLINK-14735) Improve batch schedule check input consumable performance |
Thu, 14 Nov, 12:49 |
| GitBox |
[GitHub] [flink] flinkbot commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary and Yarn public distributed cache to accelerate flink submission. |
Thu, 14 Nov, 12:49 |
| GitBox |
[GitHub] [flink] openinx commented on a change in pull request #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it |
Thu, 14 Nov, 12:49 |
| Yang Wang (Jira) |
[jira] [Updated] (FLINK-13938) Use yarn public distributed cache to speed up containers launch |
Thu, 14 Nov, 12:54 |