flink-issues mailing list archives: March 2018

Site index · List index
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Shuyi Chen (JIRA) [jira] [Assigned] (FLINK-8866) Create unified interfaces to configure and instatiate TableSinks Mon, 26 Mar, 21:56
Shuyi Chen (JIRA) [jira] [Commented] (FLINK-9049) Create unified interfaces to configure and instatiate TableSink Mon, 26 Mar, 21:57
Shuyi Chen (JIRA) [jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security Tue, 27 Mar, 07:27
Shuyi Chen (JIRA) [jira] [Commented] (FLINK-8981) End-to-end test: Kerberos security Wed, 28 Mar, 19:39
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 02:30
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8753) Introduce savepoint that go though the incremental checkpoint path Thu, 01 Mar, 03:56
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 06:31
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-8817) Decrement numPendingContainerRequests only when request container successfully Thu, 01 Mar, 09:28
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-8816) Remove the oldWorker only after starting newWorker successfully in registerTaskExecutorInternal() Thu, 01 Mar, 09:43
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8845) Introducing `parallel recovery` mode for fully checkpoint (savepoint) Sat, 03 Mar, 13:47
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8846) ntroducing `parallel recovery` mode for incremental checkpoint Sat, 03 Mar, 13:50
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8846) Introduce `parallel recovery` mode for incremental checkpoint Sat, 03 Mar, 14:41
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8845) Introduce `parallel recovery` mode for fully checkpoint (savepoint) Sat, 03 Mar, 14:42
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint) Mon, 05 Mar, 08:03
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring Mon, 05 Mar, 12:30
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Tue, 06 Mar, 05:58
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Tue, 06 Mar, 14:00
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint) Wed, 07 Mar, 06:43
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8845) Introduce `parallel recovery` mode for full checkpoint (savepoint) Wed, 07 Mar, 07:28
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8845) Use WriteBatch to improve performance for recovery in RocksDB backend Wed, 07 Mar, 08:41
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8845) Use WriteBatch to improve performance for recovery in RocksDB backend Wed, 07 Mar, 08:44
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-8846) Introduce `parallel recovery` mode for incremental checkpoint Wed, 07 Mar, 08:50
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8790) Improve performance for recovery from incremental checkpoint Thu, 08 Mar, 03:00
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-4811) Checkpoint Overview should list failed checkpoints Thu, 08 Mar, 03:46
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8918) Introduce Runtime Filter Join Mon, 12 Mar, 05:00
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8918) Introduce Runtime Filter Join Mon, 12 Mar, 05:04
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Mon, 12 Mar, 10:36
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Mon, 12 Mar, 12:01
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Mon, 12 Mar, 13:02
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Mon, 12 Mar, 13:10
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8927) Eagerly release the checkpoint object created from RocksDB Mon, 12 Mar, 14:21
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Tue, 13 Mar, 11:19
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Thu, 15 Mar, 15:51
Sihua Zhou (JIRA) [jira] [Created] (FLINK-8968) Fix native resource leak caused by ReadOptions Thu, 15 Mar, 16:11
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8969) Move TimerService into state backend Fri, 16 Mar, 05:56
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Fri, 16 Mar, 07:11
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Fri, 16 Mar, 13:48
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Fri, 16 Mar, 14:03
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8976) End-to-end test: Resume with different parallelism Fri, 16 Mar, 15:11
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Sun, 18 Mar, 07:21
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Mon, 19 Mar, 10:04
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs Mon, 19 Mar, 10:08
Sihua Zhou (JIRA) [jira] [Created] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` Mon, 19 Mar, 11:43
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-9022) fix resource close in `StreamTaskStateInitializerImpl.streamOperatorStateContext()` Mon, 19 Mar, 11:56
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9019) Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs Mon, 19 Mar, 16:08
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it Mon, 19 Mar, 17:06
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Tue, 20 Mar, 04:13
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Tue, 20 Mar, 04:13
Sihua Zhou (JIRA) [jira] [Created] (FLINK-9028) flip6 should check config before starting cluster Tue, 20 Mar, 08:05
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it Tue, 20 Mar, 09:26
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9026) Unregister finished tasks from TaskManagerMetricGroup and close it Wed, 21 Mar, 03:28
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9040) JobVertex#setMaxParallelism does not valid argument Wed, 21 Mar, 10:46
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9041) Refactor StreamTaskTest to not use scala and akka Wed, 21 Mar, 11:05
Sihua Zhou (JIRA) [jira] [Reopened] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint Wed, 21 Mar, 12:27
Sihua Zhou (JIRA) [jira] [Resolved] (FLINK-9018) Unclosed snapshotCloseableRegistry in RocksDBKeyedStateBackend#FullSnapshotStrategy#performSnapshot Wed, 21 Mar, 12:30
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument Wed, 21 Mar, 13:42
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9047) SlotPool can fail to release slots Wed, 21 Mar, 17:08
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9055) WebUI shows job as Running although not enough resources are available Thu, 22 Mar, 15:45
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception Fri, 23 Mar, 01:04
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception Fri, 23 Mar, 01:29
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9058) Relax ListState.addAll() and ListState.update() to take Iterable Fri, 23 Mar, 05:30
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9060) Deleting state using KeyedStateBackend.getKeys() throws Exception Fri, 23 Mar, 11:14
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear() Mon, 26 Mar, 06:32
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint Tue, 27 Mar, 01:04
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9087) Return value of broadcastEvent should be closed in StreamTask#performCheckpoint Tue, 27 Mar, 11:35
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-8968) Fix native resource leak caused by ReadOptions Tue, 27 Mar, 15:20
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9082) Submission with higher parallelism than task slots fails with TimeoutException Tue, 27 Mar, 17:08
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument Wed, 28 Mar, 10:13
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9055) WebUI shows job as Running although not enough resources are available Wed, 28 Mar, 12:09
Sihua Zhou (JIRA) [jira] [Created] (FLINK-9102) Make the JobGraph disable queued scheduling for Flip6LocalStreamEnvironment Wed, 28 Mar, 12:19
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs Wed, 28 Mar, 12:37
Sihua Zhou (JIRA) [jira] [Updated] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs Wed, 28 Mar, 12:37
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs Wed, 28 Mar, 14:31
Sihua Zhou (JIRA) [jira] [Reopened] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs Wed, 28 Mar, 14:31
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-9102) Make the JobGraph disable queued scheduling for cluster with fixed TMs Wed, 28 Mar, 14:32
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9070) Improve performance of RocksDBMapState.clear() Wed, 28 Mar, 15:51
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable Wed, 28 Mar, 16:36
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-9081) ResourceManagerTaskExecutorTest is unstable Wed, 28 Mar, 16:47
Sihua Zhou (JIRA) [jira] [Closed] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location Thu, 29 Mar, 05:58
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-7219) Current allocate strategy cann‘t achieve the optimal effect with input's location Thu, 29 Mar, 15:25
Sihua Zhou (JIRA) [jira] [Commented] (FLINK-8205) Multi key get Fri, 30 Mar, 02:16
Sihua Zhou (JIRA) [jira] [Created] (FLINK-9116) Introduce getAll and removeAll for MapState Fri, 30 Mar, 07:40
Sihua Zhou (JIRA) [jira] [Assigned] (FLINK-9116) Introduce getAll and removeAll for MapState Fri, 30 Mar, 07:45
Stavros Kontopoulos (JIRA) [jira] [Commented] (FLINK-6594) Implement Flink Dispatcher for Kubernetes Wed, 14 Mar, 11:36
Stavros Kontopoulos (JIRA) [jira] [Comment Edited] (FLINK-6594) Implement Flink Dispatcher for Kubernetes Wed, 14 Mar, 11:39
Stavros Kontopoulos (JIRA) [jira] [Commented] (FLINK-6594) Implement Flink Dispatcher for Kubernetes Mon, 19 Mar, 11:10
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8751) Canceling a job results in a InterruptedException in the TM Fri, 02 Mar, 10:13
Stefan Richter (JIRA) [jira] [Comment Edited] (FLINK-8837) Move DataStreamUtils to package 'experimental'. Fri, 02 Mar, 11:48
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'. Fri, 02 Mar, 11:48
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8837) Move DataStreamUtils to package 'experimental'. Fri, 02 Mar, 11:52
Stefan Richter (JIRA) [jira] [Closed] (FLINK-8859) RocksDB backend should pass WriteOption to Rocks.put() when restoring Mon, 05 Mar, 12:52
Stefan Richter (JIRA) [jira] [Created] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Mon, 05 Mar, 17:03
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Tue, 06 Mar, 13:40
Stefan Richter (JIRA) [jira] [Comment Edited] (FLINK-8871) Checkpoint cancellation is not propagated to stop checkpointing threads on the task manager Tue, 06 Mar, 13:41
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8867) Rocksdb checkpointing failing with fs.default-scheme: hdfs:// config Tue, 06 Mar, 16:05
Stefan Richter (JIRA) [jira] [Assigned] (FLINK-8882) flink-tests fails with core dump Thu, 08 Mar, 10:52
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8882) flink-tests fails with core dump Thu, 08 Mar, 14:27
Stefan Richter (JIRA) [jira] [Commented] (FLINK-8882) flink-tests fails with core dump Thu, 08 Mar, 14:38
Stefan Richter (JIRA) [jira] [Created] (FLINK-8910) Introduce automated end-to-end test for local recovery (including sticky scheduling) Fri, 09 Mar, 12:51
Stefan Richter (JIRA) [jira] [Created] (FLINK-8922) Revert FLINK-8859 because it causes segfaults in testing Mon, 12 Mar, 10:23
Message list« Previous · 1 · 2 · 3 · 4 · 5 · 6 · 7 · 8 · 9 · 10 · 11 · 12 · 13 · 14 · 15 · 16 · 17 · 18 · 19 · 20 · 21 · 22 · 23 · 24 · 25 · 26 · 27 · 28 · 29 · 30 · 31 · 32 · 33 · 34 · 35 · 36 · 37 · 38 · 39 · 40 · 41 · 42 · 43 · 44 · 45 · 46 · 47 · 48 · 49 · Next »Thread · Author · Date
Box list
Jun 20196932
May 20197326
Apr 20195671
Mar 20194764
Feb 20195750
Jan 20194225
Dec 20183613
Nov 20186764
Oct 20186946
Sep 20184634
Aug 20185670
Jul 20187170
Jun 20184380
May 20185152
Apr 20183465
Mar 20184883
Feb 20185764
Jan 20184880
Dec 20172682
Nov 20174639
Oct 20174859
Sep 20173958
Aug 20174518
Jul 20175392
Jun 20174893
May 20176475
Apr 20174390
Mar 20177839
Feb 20175379
Jan 20175351
Dec 20163688
Nov 20164834
Oct 20164002
Sep 20163620
Aug 20165065
Jul 20163523
Jun 20164191
May 20163116
Apr 20163318
Mar 20163053
Feb 20164198
Jan 20162281
Dec 20151770
Nov 20153847
Oct 20153578
Sep 20153866
Aug 20154488
Jul 20152905
Jun 20153211
May 20152758
Apr 20152329
Mar 20152558
Feb 20151980
Jan 20151685
Dec 2014836
Nov 20141506
Oct 2014575
Sep 2014744
Aug 2014435
Jul 20141002
Jun 2014300