|
[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
|
| GitBox |
[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 06:04 |
| GitBox |
[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 07:35 |
| GitBox |
[GitHub] [flink] Henvealf commented on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 25 Oct, 08:06 |
|
[jira] [Assigned] (FLINK-14208) Optimize Python UDFs with parameters of constant values |
|
| Hequn Cheng (Jira) |
[jira] [Assigned] (FLINK-14208) Optimize Python UDFs with parameters of constant values |
Fri, 11 Oct, 06:10 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14208) Optimize Python UDFs with parameters of constant values |
Sat, 12 Oct, 15:25 |
| Hequn Cheng (Jira) |
[jira] [Closed] (FLINK-14208) Optimize Python UDFs with parameters of constant values |
Sat, 12 Oct, 15:27 |
| Hequn Cheng (Jira) |
[jira] [Commented] (FLINK-14208) Optimize Python UDFs with parameters of constant values |
Sat, 12 Oct, 15:27 |
|
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
|
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 06:18 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 06:42 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 07:07 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 07:50 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 08:14 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 08:50 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 15:19 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 15:40 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Wed, 16 Oct, 08:41 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Mon, 21 Oct, 02:54 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 25 Oct, 08:08 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 04:28 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 05:02 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 05:27 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 05:54 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 06:20 |
| GitBox |
[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Sat, 26 Oct, 07:12 |
|
[GitHub] [flink] TisonKun commented on issue #9861: [FLINK-14237][yarn] No need to rename shipped Flink jar |
|
| GitBox |
[GitHub] [flink] TisonKun commented on issue #9861: [FLINK-14237][yarn] No need to rename shipped Flink jar |
Fri, 11 Oct, 06:19 |
| GitBox |
[GitHub] [flink] TisonKun commented on issue #9861: [FLINK-14237][yarn] No need to rename shipped Flink jar |
Fri, 18 Oct, 03:35 |
|
[GitHub] [flink] zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure |
|
| GitBox |
[GitHub] [flink] zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure |
Fri, 11 Oct, 06:32 |
| GitBox |
[GitHub] [flink] zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure |
Fri, 11 Oct, 06:34 |
| GitBox |
[GitHub] [flink] zhijiangW commented on a change in pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure |
Fri, 11 Oct, 06:47 |
|
[GitHub] [flink] xintongsong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
|
| GitBox |
[GitHub] [flink] xintongsong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 06:56 |
| GitBox |
[GitHub] [flink] xintongsong commented on a change in pull request #9805: [FLINK-11635][docs-zh] translate dev/stream/state/checkpointing into Chinese |
Fri, 11 Oct, 06:56 |
|
[GitHub] [flink] hequn8128 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. |
|
| GitBox |
[GitHub] [flink] hequn8128 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. |
Fri, 11 Oct, 07:33 |
| GitBox |
[GitHub] [flink] hequn8128 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. |
Fri, 11 Oct, 07:33 |
| GitBox |
[GitHub] [flink] hequn8128 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. |
Fri, 11 Oct, 07:33 |
| GitBox |
[GitHub] [flink] hequn8128 commented on a change in pull request #9865: [FLINK-14212][python] Support no-argument Python UDFs. |
Fri, 11 Oct, 07:33 |
|
[jira] [Created] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 07:35 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 07:37 |
| Gary Yao (Jira) |
[jira] [Assigned] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 13:29 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 02:52 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 03:57 |
| Gary Yao (Jira) |
[jira] [Resolved] (FLINK-14365) Annotate MiniCluster tests in core modules with AlsoRunWithSchedulerNG |
Wed, 16 Oct, 11:58 |
|
[jira] [Updated] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG |
|
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 07:36 |
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 06:24 |
| Gary Yao (Jira) |
[jira] [Resolved] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 06:25 |
| Gary Yao (Jira) |
[jira] [Closed] (FLINK-14246) Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 06:25 |
|
[jira] [Created] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 07:38 |
| Gary Yao (Jira) |
[jira] [Assigned] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG |
Fri, 11 Oct, 13:29 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG |
Tue, 15 Oct, 04:03 |
| Till Rohrmann (Jira) |
[jira] [Resolved] (FLINK-14366) Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG |
Fri, 18 Oct, 15:40 |
|
[GitHub] [flink] Myasuka commented on issue #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed |
|
| GitBox |
[GitHub] [flink] Myasuka commented on issue #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed |
Fri, 11 Oct, 08:12 |
| GitBox |
[GitHub] [flink] Myasuka commented on issue #9386: [FLINK-13601][tests] Harden RegionFailoverITCase by recording info when checkpoint just completed |
Thu, 17 Oct, 14:09 |
|
[jira] [Commented] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency |
|
| Sendoh (Jira) |
[jira] [Commented] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency |
Fri, 11 Oct, 08:38 |
| Sendoh (Jira) |
[jira] [Closed] (FLINK-8225) Use JsonRowDeserializationSchema without Kafka connector dependency |
Fri, 11 Oct, 08:38 |
|
[jira] [Created] (FLINK-14367) Fully support for converting RexNode to Expression |
|
| Jark Wu (Jira) |
[jira] [Created] (FLINK-14367) Fully support for converting RexNode to Expression |
Fri, 11 Oct, 08:47 |
| Timo Walther (Jira) |
[jira] [Commented] (FLINK-14367) Fully support for converting RexNode to Expression |
Fri, 11 Oct, 09:35 |
| Jark Wu (Jira) |
[jira] [Updated] (FLINK-14367) Fully support for converting RexNode to Expression |
Sat, 12 Oct, 13:00 |
|
[jira] [Created] (FLINK-14368) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testCustomPartitioning failed on Travis |
|
| Till Rohrmann (Jira) |
[jira] [Created] (FLINK-14368) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testCustomPartitioning failed on Travis |
Fri, 11 Oct, 08:47 |
|
[jira] [Created] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis |
|
| Till Rohrmann (Jira) |
[jira] [Created] (FLINK-14369) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis |
Fri, 11 Oct, 08:48 |
|
[jira] [Created] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
|
| Till Rohrmann (Jira) |
[jira] [Created] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Fri, 11 Oct, 08:49 |
| vinoyang (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Wed, 16 Oct, 01:44 |
| ASF GitHub Bot (Jira) |
[jira] [Updated] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Wed, 16 Oct, 13:36 |
| Jiangjie Qin (Jira) |
[jira] [Assigned] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Wed, 16 Oct, 13:39 |
| Jiangjie Qin (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Wed, 16 Oct, 13:39 |
| Jark Wu (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Thu, 17 Oct, 02:00 |
| Arvid Heise (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Sat, 19 Oct, 08:30 |
| Arvid Heise (Jira) |
[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Sat, 19 Oct, 08:31 |
| Arvid Heise (Jira) |
[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Sat, 19 Oct, 08:33 |
| Jiangjie Qin (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Mon, 21 Oct, 00:45 |
| Arvid Heise (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Mon, 21 Oct, 14:11 |
| Jiangjie Qin (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 22 Oct, 03:00 |
| Arvid Heise (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 22 Oct, 07:13 |
| Piotr Nowojski (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 22 Oct, 14:39 |
| Piotr Nowojski (Jira) |
[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 22 Oct, 14:39 |
| Jiangjie Qin (Jira) |
[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Mon, 28 Oct, 09:07 |
| Jiangjie Qin (Jira) |
[jira] [Closed] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 29 Oct, 05:48 |
| Jiangjie Qin (Jira) |
[jira] [Updated] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis |
Tue, 29 Oct, 05:49 |
|
[GitHub] [flink] pnowojski commented on a change in pull request #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor |
|
| GitBox |
[GitHub] [flink] pnowojski commented on a change in pull request #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor |
Fri, 11 Oct, 09:19 |
| GitBox |
[GitHub] [flink] pnowojski commented on a change in pull request #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor |
Fri, 11 Oct, 09:19 |
|
[jira] [Created] (FLINK-14371) Enable ClassLoaderITCase to pass with scheduler NG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14371) Enable ClassLoaderITCase to pass with scheduler NG |
Fri, 11 Oct, 09:26 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase and EventTimeWindowCheckpointingITCase to pass with scheduler NG |
Fri, 18 Oct, 08:40 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase and EventTimeWindowCheckpointingITCase to pass with scheduler NG |
Fri, 18 Oct, 08:40 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase and EventTimeWindowCheckpointingITCase to pass with scheduler NG |
Fri, 18 Oct, 08:41 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase and EventTimeWindowCheckpointingITCase to pass with scheduler NG |
Fri, 18 Oct, 08:41 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase and EventTimeWindowCheckpointingITCase to pass with scheduler NG |
Tue, 29 Oct, 17:10 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14371) Enable ClassLoaderITCase to pass with scheduler NG |
Tue, 29 Oct, 17:10 |
|
[jira] [Created] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG |
Fri, 11 Oct, 09:28 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG |
Fri, 11 Oct, 09:29 |
| Gary Yao (Jira) |
[jira] [Assigned] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG |
Thu, 31 Oct, 16:30 |
|
[jira] [Created] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
Fri, 11 Oct, 09:31 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
Wed, 16 Oct, 13:47 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
Wed, 16 Oct, 13:48 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
Wed, 16 Oct, 13:48 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14373) Enable ZooKeeperHighAvailabilityITCase to pass with scheduler NG |
Tue, 29 Oct, 17:18 |
|
[jira] [Closed] (FLINK-6523) Improve lifecycle management of created BlobCaches in TaskManagerLogHandler and JobClient |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6523) Improve lifecycle management of created BlobCaches in TaskManagerLogHandler and JobClient |
Fri, 11 Oct, 09:34 |
|
[jira] [Closed] (FLINK-6524) Make server address of BlobCache configurable |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6524) Make server address of BlobCache configurable |
Fri, 11 Oct, 09:35 |
|
[jira] [Closed] (FLINK-6525) Transferred TM log/stdout files are never removed from BlobStore |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6525) Transferred TM log/stdout files are never removed from BlobStore |
Fri, 11 Oct, 09:37 |
|
[jira] [Closed] (FLINK-6526) BlobStore files might become orphans in case of recovery |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6526) BlobStore files might become orphans in case of recovery |
Fri, 11 Oct, 09:39 |
|
[jira] [Closed] (FLINK-6594) Implement Flink Dispatcher for Kubernetes |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6594) Implement Flink Dispatcher for Kubernetes |
Fri, 11 Oct, 09:41 |
|
[jira] [Closed] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6625) Flink removes HA job data when reaching JobStatus.FAILED |
Fri, 11 Oct, 09:42 |
|
[jira] [Assigned] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore |
|
| Till Rohrmann (Jira) |
[jira] [Assigned] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore |
Fri, 11 Oct, 09:43 |
|
[jira] [Closed] (FLINK-6627) Expose tmp directories via API |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6627) Expose tmp directories via API |
Fri, 11 Oct, 09:44 |
|
[jira] [Closed] (FLINK-6666) RestartStrategy should differentiate between types of recovery (global / local / resource missing) |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6666) RestartStrategy should differentiate between types of recovery (global / local / resource missing) |
Fri, 11 Oct, 09:46 |
|
[GitHub] [flink] KurtYoung commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert |
|
| GitBox |
[GitHub] [flink] KurtYoung commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert |
Fri, 11 Oct, 09:47 |
| GitBox |
[GitHub] [flink] KurtYoung commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert |
Fri, 11 Oct, 09:47 |
| GitBox |
[GitHub] [flink] KurtYoung commented on a change in pull request #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert |
Wed, 30 Oct, 07:50 |
|
[jira] [Closed] (FLINK-6668) Add flink history server to DCOS |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6668) Add flink history server to DCOS |
Fri, 11 Oct, 09:48 |
|
[jira] [Closed] (FLINK-6664) Extend Restart Strategy for Fine-grained Recovery and missing Resources |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6664) Extend Restart Strategy for Fine-grained Recovery and missing Resources |
Fri, 11 Oct, 09:48 |
|
[jira] [Closed] (FLINK-6673) Yarn single-job submission doesn't fail early when to few slows are available |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6673) Yarn single-job submission doesn't fail early when to few slows are available |
Fri, 11 Oct, 09:48 |
|
[jira] [Closed] (FLINK-6741) In yarn cluster model with high availableļ¼ the HDFS file is not deleted when cluster is shot down |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6741) In yarn cluster model with high availableļ¼ the HDFS file is not deleted when cluster is shot down |
Fri, 11 Oct, 09:50 |
|
[jira] [Created] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG |
|
| Zhu Zhu (Jira) |
[jira] [Created] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG |
Fri, 11 Oct, 09:54 |
| Zhu Zhu (Jira) |
[jira] [Updated] (FLINK-14374) Enable RegionFailoverITCase to pass with scheduler NG |
Tue, 29 Oct, 02:27 |
|
[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter |
|
| Till Rohrmann (Jira) |
[jira] [Commented] (FLINK-6900) Limit size of indiivual components in DropwizardReporter |
Fri, 11 Oct, 09:54 |
|
[jira] [Commented] (FLINK-13847) Update release scripts to also update docs/_config.yml |
|
| Gary Yao (Jira) |
[jira] [Commented] (FLINK-13847) Update release scripts to also update docs/_config.yml |
Fri, 11 Oct, 09:54 |
|
[jira] [Closed] (FLINK-6910) Metrics value for lastCheckpointExternalPath is not valid |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6910) Metrics value for lastCheckpointExternalPath is not valid |
Fri, 11 Oct, 09:55 |
|
[jira] [Closed] (FLINK-6972) Flink REPL api |
|
| Till Rohrmann (Jira) |
[jira] [Closed] (FLINK-6972) Flink REPL api |
Fri, 11 Oct, 09:56 |
|
[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter |
|
| Till Rohrmann (Jira) |
[jira] [Commented] (FLINK-7009) dogstatsd mode in statsd reporter |
Fri, 11 Oct, 09:57 |