flink-issues mailing list archives: March 2017

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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6047) Master Jira for "Retraction for Flink Streaming" Tue, 14 Mar, 15:50
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase Fri, 17 Mar, 03:59
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate Fri, 17 Mar, 04:00
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate Fri, 17 Mar, 04:01
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6093) Implement and turn on retraction for table sink Fri, 17 Mar, 04:02
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6092) Implement and turn on retraction for table source Fri, 17 Mar, 04:02
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6094) Implement and turn on retraction for stream-stream inner join Fri, 17 Mar, 04:03
Shaoxuan Wang (JIRA) [jira] [Updated] (FLINK-6047) Master Jira for "Retraction for Flink Streaming" Fri, 17 Mar, 04:07
Shaoxuan Wang (JIRA) [jira] [Assigned] (FLINK-6089) Implement decoration phase for rewriting predicated logical plan after volcano optimization phase Fri, 17 Mar, 08:57
Shaoxuan Wang (JIRA) [jira] [Assigned] (FLINK-6091) Implement and turn on the retraction for grouping window aggregate Fri, 24 Mar, 07:46
Shaoxuan Wang (JIRA) [jira] [Assigned] (FLINK-6090) Implement optimizer for retraction and turn on retraction for over window aggregate Fri, 24 Mar, 07:46
Shaoxuan Wang (JIRA) [jira] [Created] (FLINK-6216) DataStream unbounded groupby aggregate with early firing Wed, 29 Mar, 19:22
Sriharsha Tikkireddy (JIRA) [jira] [Commented] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date Wed, 29 Mar, 06:17
Stavros Kontopoulos (JIRA) [jira] [Commented] (FLINK-5785) Add an Imputer for preparing data Wed, 08 Mar, 19:24
Stavros Kontopoulos (JIRA) [jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data Wed, 08 Mar, 19:25
Stavros Kontopoulos (JIRA) [jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data Wed, 08 Mar, 20:25
Stavros Kontopoulos (JIRA) [jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data Wed, 08 Mar, 20:26
Stavros Kontopoulos (JIRA) [jira] [Comment Edited] (FLINK-5785) Add an Imputer for preparing data Wed, 08 Mar, 20:27
Stavros Kontopoulos (JIRA) [jira] [Commented] (FLINK-5785) Add an Imputer for preparing data Tue, 28 Mar, 09:22
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator. Thu, 02 Mar, 09:39
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5917) Remove MapState.size() Thu, 02 Mar, 09:43
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts Fri, 03 Mar, 09:10
Stefan Richter (JIRA) [jira] [Created] (FLINK-5958) Asyncronous snapshots for heap-based keyed state backends Fri, 03 Mar, 10:53
Stefan Richter (JIRA) [jira] [Updated] (FLINK-5958) Asynchronous snapshots for heap-based keyed state backends Fri, 03 Mar, 10:55
Stefan Richter (JIRA) [jira] [Closed] (FLINK-5917) Remove MapState.size() Fri, 03 Mar, 13:23
Stefan Richter (JIRA) [jira] [Commented] (FLINK-4275) Generic Folding, Reducing and List states behave differently from other state backends Fri, 03 Mar, 15:50
Stefan Richter (JIRA) [jira] [Commented] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover Fri, 03 Mar, 15:53
Stefan Richter (JIRA) [jira] [Commented] (FLINK-3089) OperatorState timeout Fri, 03 Mar, 15:54
Stefan Richter (JIRA) [jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer Fri, 03 Mar, 15:56
Stefan Richter (JIRA) [jira] [Created] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend Fri, 03 Mar, 17:25
Stefan Richter (JIRA) [jira] [Created] (FLINK-5979) Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3) Tue, 07 Mar, 10:59
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation Thu, 09 Mar, 09:20
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5991) Expose Broadcast Operator State through public APIs Thu, 09 Mar, 13:58
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Fri, 10 Mar, 11:00
Stefan Richter (JIRA) [jira] [Assigned] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length Tue, 14 Mar, 13:39
Stefan Richter (JIRA) [jira] [Commented] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length Tue, 14 Mar, 13:39
Stefan Richter (JIRA) [jira] [Created] (FLINK-6048) Asynchronous snapshots for heap-based operator state backends Tue, 14 Mar, 15:53
Stefan Richter (JIRA) [jira] [Created] (FLINK-6049) Parallelize execution of (async) snapshots in AsyncCheckpointRunnable Tue, 14 Mar, 16:07
Stefan Richter (JIRA) [jira] [Commented] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 11:17
Stefan Richter (JIRA) [jira] [Assigned] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 11:19
Stefan Richter (JIRA) [jira] [Comment Edited] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 11:19
Stefan Richter (JIRA) [jira] [Commented] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 13:47
Stefan Richter (JIRA) [jira] [Closed] (FLINK-6061) NPE on TypeSerializer.serialize with a RocksDBStateBackend calling entries() on a keyed state in the open() function Wed, 15 Mar, 14:31
Stefan Richter (JIRA) [jira] [Closed] (FLINK-6044) TypeSerializerSerializationProxy.read() doesn't verify the read buffer length Wed, 15 Mar, 15:02
Stefan Richter (JIRA) [jira] [Closed] (FLINK-5979) Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3) Thu, 16 Mar, 17:39
Stefan Richter (JIRA) [jira] [Closed] (FLINK-5715) Asynchronous snapshotting for HeapKeyedStateBackend Thu, 16 Mar, 17:40
Stefan Richter (JIRA) [jira] [Assigned] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Fri, 17 Mar, 17:17
Stefan Richter (JIRA) [jira] [Closed] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Fri, 17 Mar, 17:17
Stefan Richter (JIRA) [jira] [Closed] (FLINK-4760) Kafka 09 Consumer failed to initialize state because of corrupted operator state and not able to recover Fri, 24 Mar, 17:07
Stefan Richter (JIRA) [jira] [Commented] (FLINK-5217) Deprecated interface Checkpointed make clear suggestion Mon, 27 Mar, 07:55
Stefan Richter (JIRA) [jira] [Created] (FLINK-6207) Duplicate type serializers for async snapshots of CopyOnWriteStateTable Tue, 28 Mar, 16:14
Stefan Richter (JIRA) [jira] [Closed] (FLINK-6207) Duplicate type serializers for async snapshots of CopyOnWriteStateTable Tue, 28 Mar, 17:38
Stefan Richter (JIRA) [jira] [Closed] (FLINK-6034) Add KeyedStateHandle for the snapshots in keyed streams Tue, 28 Mar, 18:10
Stefan Richter (JIRA) [jira] [Created] (FLINK-6220) Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable Thu, 30 Mar, 13:01
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3429: [FLINK-5937] [doc] Add documentation about the str... Fri, 03 Mar, 10:43
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5958] Asynchronous snapshots for heap-based... Fri, 03 Mar, 11:04
StefanRRichter [GitHub] flink issue #3466: [FLINK-5958] Asynchronous snapshots for heap-based keyed ... Fri, 03 Mar, 11:04
StefanRRichter [GitHub] flink issue #3462: [FLINK-5917][state] Remove size() method from MapState Fri, 03 Mar, 13:09
StefanRRichter [GitHub] flink issue #3462: [FLINK-5917][state] Remove size() method from MapState Fri, 03 Mar, 13:13
StefanRRichter [GitHub] flink pull request #3442: [FLINK-5778] [savepoints] Add savepoint serializer... Mon, 06 Mar, 14:03
StefanRRichter [GitHub] flink pull request #3442: [FLINK-5778] [savepoints] Add savepoint serializer... Mon, 06 Mar, 14:03
StefanRRichter [GitHub] flink pull request #3483: [FLINK-5979] Backwards compatibility for HeapKeyed... Tue, 07 Mar, 11:01
StefanRRichter [GitHub] flink issue #3483: [FLINK-5979] Backwards compatibility for HeapKeyedStateBa... Tue, 07 Mar, 11:02
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5715] Asynchronous snapshots for heap-based... Tue, 07 Mar, 16:26
StefanRRichter [GitHub] flink issue #3442: [FLINK-5778] [savepoints] Add savepoint serializer with r... Wed, 08 Mar, 13:52
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5715] Asynchronous snapshots for heap-based... Thu, 09 Mar, 10:17
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5715] Asynchronous snapshots for heap-based... Thu, 09 Mar, 10:19
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5715] Asynchronous snapshots for heap-based... Thu, 09 Mar, 10:26
StefanRRichter [GitHub] flink issue #3508: [FLINK-5991] [state-backend, streaming] Expose Broadcast ... Fri, 10 Mar, 10:51
StefanRRichter [GitHub] flink pull request #3466: [FLINK-5715] Asynchronous snapshots for heap-based... Fri, 10 Mar, 12:49
StefanRRichter [GitHub] flink pull request #3523: [FLINK-5985] Report no task states for stateless t... Mon, 13 Mar, 10:58
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks in... Mon, 13 Mar, 10:58
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks in... Tue, 14 Mar, 13:28
StefanRRichter [GitHub] flink pull request #3533: [FLINK-6044] Replace calls to InputStream#read(...... Tue, 14 Mar, 13:49
StefanRRichter [GitHub] flink issue #3533: [FLINK-6044] Replace calls to InputStream#read(...) with ... Tue, 14 Mar, 13:50
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks in... Tue, 14 Mar, 14:12
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks in... Tue, 14 Mar, 15:39
StefanRRichter [GitHub] flink pull request #3536: [FLINK-6048] Asynchronous snapshots for heap-based... Tue, 14 Mar, 16:01
StefanRRichter [GitHub] flink issue #3536: [FLINK-6048] Asynchronous snapshots for heap-based Operat... Tue, 14 Mar, 16:01
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks in... Wed, 15 Mar, 09:06
StefanRRichter [GitHub] flink pull request #3542: [FLINK-5985] [Backport for 1.2] Report no task sta... Wed, 15 Mar, 09:12
StefanRRichter [GitHub] flink pull request #3543: [FLINK-5985] [Backport for 1.2] Report no task sta... Wed, 15 Mar, 09:17
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks on... Wed, 15 Mar, 09:22
StefanRRichter [GitHub] flink issue #3523: [FLINK-5985] Report no task states for stateless tasks on... Wed, 15 Mar, 09:27
StefanRRichter [GitHub] flink pull request #3545: [FLINK-6061] Introduced IllegalStateException when... Wed, 15 Mar, 11:25
StefanRRichter [GitHub] flink issue #3545: [FLINK-6061] Introduced IllegalStateException when operat... Wed, 15 Mar, 14:24
StefanRRichter [GitHub] flink pull request #3545: [FLINK-6061] Introduced IllegalStateException when... Wed, 15 Mar, 14:30
StefanRRichter [GitHub] flink issue #3545: [FLINK-6061] Introduced IllegalStateException when operat... Wed, 15 Mar, 14:30
StefanRRichter [GitHub] flink pull request #3523: [FLINK-5985] Report no task states for stateless t... Wed, 15 Mar, 14:51
StefanRRichter [GitHub] flink issue #3533: [FLINK-6044] Replace calls to InputStream#read(...) with ... Wed, 15 Mar, 14:57
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 · 50 · 51 · 52 · 53 · 54 · 55 · 56 · 57 · 58 · 59 · 60 · 61 · 62 · 63 · 64 · 65 · 66 · 67 · 68 · 69 · 70 · 71 · 72 · 73 · 74 · 75 · 76 · 77 · 78 · 79 · Next »Thread · Author · Date
Box list
Apr 2020479
Mar 202012379
Feb 202010561
Jan 20208835
Dec 201913015
Nov 201911280
Oct 201911647
Sep 20198451
Aug 201910193
Jul 201911502
Jun 20198159
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