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
Greg Hogan (JIRA) [jira] [Closed] (FLINK-6128) Optimize JVM options for improve test performance Fri, 24 Mar, 16:25
Greg Hogan (JIRA) [jira] [Closed] (FLINK-5890) GatherSumApply broken when object reuse enabled Fri, 24 Mar, 16:25
Greg Hogan (JIRA) [jira] [Commented] (FLINK-6185) Input readers and output writers/formats need to support gzip Sat, 25 Mar, 14:19
Greg Hogan (JIRA) [jira] [Commented] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes Sat, 25 Mar, 15:02
Greg Hogan (JIRA) [jira] [Comment Edited] (FLINK-5754) released tag missing .gitigonore .travis.yml .gitattributes Sat, 25 Mar, 15:03
Greg Hogan (JIRA) [jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field Sun, 26 Mar, 16:57
Greg Hogan (JIRA) [jira] [Assigned] (FLINK-6176) Add JARs to CLASSPATH deterministically Sun, 26 Mar, 19:44
Greg Hogan (JIRA) [jira] [Closed] (FLINK-5911) Command-line parameters Mon, 27 Mar, 10:57
Greg Hogan (JIRA) [jira] [Created] (FLINK-6195) Move gelly-examples jar from opt to examples Mon, 27 Mar, 13:42
Greg Hogan (JIRA) [jira] [Updated] (FLINK-6195) Move gelly-examples jar from opt to examples Mon, 27 Mar, 14:02
Greg Hogan (JIRA) [jira] [Updated] (FLINK-5913) Example drivers Mon, 27 Mar, 17:05
Greg Hogan (JIRA) [jira] [Updated] (FLINK-6176) Add JARs to CLASSPATH deterministically Tue, 28 Mar, 15:19
Greg Hogan (JIRA) [jira] [Commented] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field Thu, 30 Mar, 14:39
Greg Hogan (JIRA) [jira] [Commented] (FLINK-6221) Add Promethus support to metrics Thu, 30 Mar, 17:23
Greg Hogan (JIRA) [jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts Fri, 31 Mar, 15:00
Greg Hogan (JIRA) [jira] [Updated] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Fri, 31 Mar, 16:37
Greg Hogan (JIRA) [jira] [Closed] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode Fri, 31 Mar, 16:37
Greg Hogan (JIRA) [jira] [Closed] (FLINK-3695) ValueArray types Fri, 31 Mar, 16:41
Greg Hogan (JIRA) [jira] [Closed] (FLINK-5912) Inputs for CSV and graph generators Fri, 31 Mar, 16:42
Greg Hogan (JIRA) [jira] [Closed] (FLINK-5913) Example drivers Fri, 31 Mar, 16:43
Greg Hogan (JIRA) [jira] [Closed] (FLINK-4949) Refactor Gelly driver inputs Fri, 31 Mar, 20:36
Guowei Ma (JIRA) [jira] [Created] (FLINK-6072) TestCase CheckpointStateRestoreTest::testSetState should be fail Thu, 16 Mar, 10:04
Guowei Ma (JIRA) [jira] [Commented] (FLINK-5892) Recover job state at the granularity of operator Tue, 28 Mar, 00:55
Gyula Fora (JIRA) [jira] [Created] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Tue, 07 Mar, 16:07
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Wed, 08 Mar, 09:41
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Wed, 08 Mar, 09:53
Gyula Fora (JIRA) [jira] [Created] (FLINK-5996) Jobmanager HA should not crash on lost ZK node Wed, 08 Mar, 10:03
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Wed, 08 Mar, 11:17
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5996) Jobmanager HA should not crash on lost ZK node Wed, 08 Mar, 11:18
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Wed, 08 Mar, 15:28
Gyula Fora (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 09 Mar, 12:24
Gyula Fora (JIRA) [jira] [Commented] (FLINK-5985) Flink treats every task as stateful (making topology changes impossible) Thu, 09 Mar, 14:19
Gyula Fora (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 12:08
Gyula Fora (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 13:32
Gyula Fora (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Thu, 23 Mar, 15:27
Gyula Fora (JIRA) [jira] [Commented] (FLINK-6006) Kafka Consumer can lose state if queried partition list is incomplete on restore Fri, 24 Mar, 08:47
Haohui Mai (JIRA) [jira] [Updated] (FLINK-3679) Allow Kafka consumer to skip corrupted messages Thu, 02 Mar, 21:33
Haohui Mai (JIRA) [jira] [Created] (FLINK-5954) Always assign names to the window in the Stream SQL APi Fri, 03 Mar, 01:38
Haohui Mai (JIRA) [jira] [Updated] (FLINK-5954) Always assign names to the window in the Stream SQL API Fri, 03 Mar, 01:45
Haohui Mai (JIRA) [jira] [Assigned] (FLINK-5998) Un-fat Hadoop from Flink fat jar Thu, 09 Mar, 02:36
Haohui Mai (JIRA) [jira] [Assigned] (FLINK-5829) Bump Calcite version to 1.12 once available Thu, 09 Mar, 21:59
Haohui Mai (JIRA) [jira] [Created] (FLINK-6011) Support TUMBLE, HOP, SESSION window in streaming SQL Thu, 09 Mar, 22:05
Haohui Mai (JIRA) [jira] [Created] (FLINK-6012) Support WindowStart / WindowEnd functions in stream SQL Thu, 09 Mar, 22:25
Haohui Mai (JIRA) [jira] [Created] (FLINK-6033) Support UNNEST query in the stream SQL api Mon, 13 Mar, 20:47
Haohui Mai (JIRA) [jira] [Updated] (FLINK-6033) Support UNNEST query in the stream SQL API Mon, 13 Mar, 20:47
Haohui Mai (JIRA) [jira] [Commented] (FLINK-6033) Support UNNEST query in the stream SQL API Mon, 13 Mar, 20:54
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5570) Support register external catalog to table environment Thu, 16 Mar, 21:52
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar Tue, 21 Mar, 03:51
Haohui Mai (JIRA) [jira] [Commented] (FLINK-6102) Update protobuf to latest version Tue, 21 Mar, 06:25
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5570) Support register external catalog to table environment Thu, 23 Mar, 22:30
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available Sat, 25 Mar, 08:08
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5829) Bump Calcite version to 1.12 once available Mon, 27 Mar, 19:51
Haohui Mai (JIRA) [jira] [Created] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1 Tue, 28 Mar, 21:55
Haohui Mai (JIRA) [jira] [Commented] (FLINK-6209) StreamPlanEnvironment always has a parallelism of 1 Tue, 28 Mar, 21:58
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5668) passing taskmanager configuration through taskManagerEnv instead of file Wed, 29 Mar, 09:17
Haohui Mai (JIRA) [jira] [Created] (FLINK-6217) ContaineredTaskManagerParameters sets off heap memory size incorrectly Wed, 29 Mar, 23:21
Haohui Mai (JIRA) [jira] [Commented] (FLINK-5998) Un-fat Hadoop from Flink fat jar Fri, 31 Mar, 16:57
Ilya Ganelin (JIRA) [jira] [Created] (FLINK-5944) Flink should support reading Snappy Files Wed, 01 Mar, 18:41
Ilya Ganelin (JIRA) [jira] [Updated] (FLINK-5944) Flink should support reading Snappy Files Wed, 01 Mar, 19:53
Ivan Mushketyk (JIRA) [jira] [Assigned] (FLINK-3414) Add Scala API for CEP's pattern definition Wed, 15 Mar, 21:58
Ivan Mushketyk (JIRA) [jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition Wed, 15 Mar, 21:58
Jakub Nowacki (JIRA) [jira] [Created] (FLINK-6098) Cassandra sink freezes after write error Fri, 17 Mar, 09:42
Jakub Nowacki (JIRA) [jira] [Commented] (FLINK-6098) Cassandra sink freezes after write error Fri, 17 Mar, 12:48
Jakub Nowacki (JIRA) [jira] [Commented] (FLINK-6098) Cassandra sink freezes after write error Fri, 17 Mar, 13:23
Jamie Grier (JIRA) [jira] [Commented] (FLINK-3026) Publish the flink docker container to the docker registry Tue, 07 Mar, 00:17
Jamie Grier (JIRA) [jira] [Created] (FLINK-6199) Single outstanding Async I/O operation per key Mon, 27 Mar, 18:22
Jark Wu (JIRA) [jira] [Closed] (FLINK-5794) update the documentation about “UDF/UDTF" support have parameters constructor. Thu, 02 Mar, 02:55
Jayson Minard (JIRA) [jira] [Created] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Sat, 04 Mar, 13:05
Jayson Minard (JIRA) [jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Sat, 04 Mar, 13:08
Jayson Minard (JIRA) [jira] [Comment Edited] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Sat, 04 Mar, 13:11
Jayson Minard (JIRA) [jira] [Updated] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Sun, 05 Mar, 05:31
Jayson Minard (JIRA) [jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Mon, 06 Mar, 15:58
Jayson Minard (JIRA) [jira] [Comment Edited] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Mon, 06 Mar, 15:58
Jayson Minard (JIRA) [jira] [Comment Edited] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Mon, 06 Mar, 16:02
Jayson Minard (JIRA) [jira] [Commented] (FLINK-5964) Change TypeSerializers to allow construction of immutable types Mon, 06 Mar, 16:02
Jing Fan (JIRA) [jira] [Created] (FLINK-6225) Support Row Stream for CassandraSink Fri, 31 Mar, 04:24
Joan Goyeau (JIRA) [jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts Fri, 31 Mar, 14:24
Joan Goyeau (JIRA) [jira] [Commented] (FLINK-5005) Publish Scala 2.12 artifacts Fri, 31 Mar, 15:32
Joshua Griffith (JIRA) [jira] [Created] (FLINK-6051) Wrong metric scope names in documentation Tue, 14 Mar, 17:02
Joshua Griffith (JIRA) [jira] [Created] (FLINK-6221) Add Promethus support to metrics Thu, 30 Mar, 16:15
Joshua Griffith (JIRA) [jira] [Commented] (FLINK-6221) Add Promethus support to metrics Thu, 30 Mar, 20:05
Julien Preisner (JIRA) [jira] [Created] (FLINK-6062) Re-read a Kafka topic at the reception of an event Wed, 15 Mar, 12:28
Julien Preisner (JIRA) [jira] [Updated] (FLINK-6062) Re-read a Kafka topic at the reception of an event Wed, 15 Mar, 13:39
Julien Preisner (JIRA) [jira] [Updated] (FLINK-6062) Re-read a Kafka topic at the reception of an event Wed, 15 Mar, 13:40
Julien Preisner (JIRA) [jira] [Updated] (FLINK-6062) Re-read a Kafka topic at the reception of an event Wed, 15 Mar, 13:40
Kate Eri (JIRA) [jira] [Commented] (FLINK-1750) Add canonical correlation analysis (CCA) to machine learning library Thu, 23 Mar, 17:04
Kostas Kloudas (JIRA) [jira] [Assigned] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator. Wed, 01 Mar, 13:20
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState(). Thu, 02 Mar, 10:22
Kostas Kloudas (JIRA) [jira] [Updated] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState(). Thu, 02 Mar, 10:25
Kostas Kloudas (JIRA) [jira] [Updated] (FLINK-5951) Register legacy windowOp timers with timer service in the restoreState(). Thu, 02 Mar, 10:28
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-5937) Add documentation about the task lifecycle. Fri, 03 Mar, 12:03
Kostas Kloudas (JIRA) [jira] [Closed] (FLINK-5937) Add documentation about the task lifecycle. Fri, 03 Mar, 12:44
Kostas Kloudas (JIRA) [jira] [Assigned] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing Wed, 08 Mar, 11:10
Kostas Kloudas (JIRA) [jira] [Created] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 15:39
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 16:02
Kostas Kloudas (JIRA) [jira] [Comment Edited] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 16:04
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-6007) ConcurrentModificationException in WatermarkCallbackService Thu, 09 Mar, 16:13
Kostas Kloudas (JIRA) [jira] [Closed] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing Fri, 10 Mar, 22:21
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-5874) Reject arrays as keys in DataStream API to avoid inconsistent hashing Fri, 10 Mar, 22:21
Kostas Kloudas (JIRA) [jira] [Commented] (FLINK-6024) Need more fine-grained info for "InvalidProgramException: This type (...) cannot be used as key" Mon, 13 Mar, 13:11
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
Jan 20207620
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