Mailing list archives: December 2015

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
Gábor Gévay Object reuse documentation should be improved Sun, 13 Dec, 18:24
Gábor Gévay Re: Object reuse documentation should be improved Mon, 14 Dec, 12:15
Gyula Fóra Monitoring backpressure Mon, 07 Dec, 08:45
Gyula Fóra Re: Monitoring backpressure Mon, 07 Dec, 10:48
Gyula Fóra Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:09
Gyula Fóra Flink shell in Jupyter Wed, 16 Dec, 15:22
Gyula Fóra Re: Flink shell in Jupyter Thu, 17 Dec, 13:24
Márton Balassi Re: Object reuse documentation should be improved Mon, 14 Dec, 12:20
Aljoscha Krettek Re: The null in Flink Tue, 08 Dec, 11:10
Aljoscha Krettek Re: Externalizing the Flink connectors Thu, 10 Dec, 15:12
Aljoscha Krettek [DISCUSS] Improving State/Timers/Windows Thu, 10 Dec, 15:47
Aljoscha Krettek Re: Flink and Clojure Thu, 10 Dec, 16:09
Aljoscha Krettek Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:02
Aljoscha Krettek Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:18
Aljoscha Krettek Re: Object reuse documentation should be improved Mon, 14 Dec, 10:33
Aljoscha Krettek Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:38
Aljoscha Krettek Re: Object reuse documentation should be improved Mon, 14 Dec, 16:20
Aljoscha Krettek [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Wed, 16 Dec, 14:26
Aljoscha Krettek Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Fri, 18 Dec, 13:52
Aljoscha Krettek Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Fri, 18 Dec, 14:29
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-3174) Add merging WindowAssigner Tue, 15 Dec, 15:04
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements Wed, 16 Dec, 10:34
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-3178) Make Closing Behavior of Window Operators Configurable Wed, 16 Dec, 10:47
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. Wed, 02 Dec, 05:56
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3139) NULL values handling in Table API Tue, 08 Dec, 06:05
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3140) NULL value data layout in Row Serializer/Comparator Tue, 08 Dec, 06:23
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3141) Design of NULL values handling in operation Tue, 08 Dec, 06:28
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure Thu, 03 Dec, 12:35
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3116) Remove RecordOperator Fri, 04 Dec, 14:29
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3165) [py] Add support for Windows OS Sun, 13 Dec, 13:11
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3167) Stopping start-local.bat doesn't shutdown JM on W10 Sun, 13 Dec, 19:56
Chiwan Park Re: Lack of review on PRs Sun, 06 Dec, 16:44
Edward Lee Why does Flink copy code from Spark? Sun, 27 Dec, 07:51
Fabian Hueske Re: Externalizing the Flink connectors Thu, 10 Dec, 14:45
Fabian Hueske Re: Apache Tinkerpop & Geode Integration? Tue, 15 Dec, 14:42
Fabian Hueske Re: Apache Tinkerpop & Geode Integration? Fri, 18 Dec, 10:42
Fabian Hueske Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Fri, 18 Dec, 11:10
Fabian Hueske Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Fri, 18 Dec, 14:01
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class Fri, 04 Dec, 12:03
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase Fri, 04 Dec, 12:07
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy Mon, 07 Dec, 16:08
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned Wed, 16 Dec, 20:02
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods Fri, 18 Dec, 15:51
Filip Leczycki (JIRA) [jira] [Created] (FLINK-3189) Error while parsing job arguments passed by CLI Mon, 21 Dec, 13:26
Fridtjof Sander (JIRA) [jira] [Created] (FLINK-3128) Add Isotonic Regression To ML Library Mon, 07 Dec, 12:44
Gabor Gevay (JIRA) [jira] [Created] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds Sun, 13 Dec, 17:12
GaoLun (JIRA) [jira] [Created] (FLINK-3192) Add explain support to print ast and sql physical execution. Fri, 25 Dec, 08:28
Greg Hogan Re: Diagnosing TaskManager disappearance Sat, 12 Dec, 11:53
Greg Hogan (JIRA) [jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager Fri, 11 Dec, 16:50
Greg Hogan (JIRA) [jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available Fri, 11 Dec, 17:08
Greg Hogan (JIRA) [jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors Fri, 11 Dec, 17:30
Greg Hogan (JIRA) [jira] [Created] (FLINK-3163) Configure Flink for NUMA systems Fri, 11 Dec, 18:46
Greg Hogan (JIRA) [jira] [Created] (FLINK-3164) Spread out scheduling strategy Fri, 11 Dec, 20:17
Gyula Fora (JIRA) [jira] [Created] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml Mon, 14 Dec, 14:29
Gyula Fora (JIRA) [jira] [Created] (FLINK-3193) Add optional bloomfilter to sql state backend Wed, 30 Dec, 16:50
Henry Saputra Re: Distributed DataFrame - ddf.io Fri, 04 Dec, 00:35
Henry Saputra Re: Externalizing the Flink connectors Sat, 12 Dec, 00:52
Henry Saputra Re: Externalizing the Flink connectors Mon, 14 Dec, 19:16
Henry Saputra 2015: A Year in Review for Apache Flink Thu, 31 Dec, 02:22
Humberto Moura Migrating Spark to Flink Tue, 08 Dec, 13:25
JOHN MILLER Fwd: DATA TRANSFORMATION PROBLEM Fri, 04 Dec, 15:39
James Thornton Re: Apache Tinkerpop & Geode Integration? Wed, 16 Dec, 19:21
Kashmar, Ali Re: Task Parallelism in a Cluster Tue, 01 Dec, 14:26
Kashmar, Ali Re: Task Parallelism in a Cluster Wed, 02 Dec, 15:06
Kashmar, Ali Re: Task Parallelism in a Cluster Wed, 09 Dec, 16:22
Kashmar, Ali Re: Task Parallelism in a Cluster Wed, 09 Dec, 19:49
Kashmar, Ali Re: Task Parallelism in a Cluster Fri, 11 Dec, 15:50
Kashmar, Ali Re: Task Parallelism in a Cluster Fri, 11 Dec, 17:03
Kashmar, Ali Re: Task Parallelism in a Cluster Mon, 14 Dec, 15:47
Kashmar, Ali No job recovery after job manager failure Wed, 16 Dec, 16:26
Kashmar, Ali Error due to Hadoop version mismatch Tue, 22 Dec, 15:10
Kashmar, Ali Re: Error due to Hadoop version mismatch Tue, 22 Dec, 15:28
Kashmar, Ali Re: Error due to Hadoop version mismatch Wed, 23 Dec, 14:53
Kostas Tzoumas Re: Distributed DataFrame - ddf.io Thu, 03 Dec, 16:48
Kostas Tzoumas Community choice for Hadoop Summit Europe 2016 Wed, 09 Dec, 09:52
Kostas Tzoumas Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:14
Kostas Tzoumas Re: [DISCUSS] Improving State/Timers/Windows Mon, 14 Dec, 10:46
Kostas Tzoumas [DISCUSS] Flink roadmap for 2016 Wed, 16 Dec, 14:12
Kostas Tzoumas Re: [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) Thu, 17 Dec, 10:15
Li, Chengxiang RE: The null in Flink Tue, 01 Dec, 03:09
Li, Chengxiang RE: The null in Flink Thu, 03 Dec, 08:42
Li, Chengxiang RE: The null in Flink Tue, 08 Dec, 06:18
Marius Melzer Incremental checkpoints for Flink Sat, 19 Dec, 16:04
Martin Junghanns (JIRA) [jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable Fri, 04 Dec, 15:18
Martin Junghanns (JIRA) [jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation Sat, 05 Dec, 09:29
Matthias J. Sax JobManagerCheckpointRecoveryITCase Tue, 08 Dec, 07:29
Matthias J. Sax New Blog Post Draft Wed, 09 Dec, 10:32
Matthias J. Sax Re: New Blog Post Draft Wed, 09 Dec, 12:20
Matthias J. Sax Re: New Blog Post Draft Thu, 10 Dec, 12:17
Matthias J. Sax Flink and Clojure Thu, 10 Dec, 16:05
Matthias J. Sax Re: Flink and Clojure Thu, 10 Dec, 16:15
Matthias J. Sax Re: Flink and Clojure Thu, 10 Dec, 23:22
Matthias J. Sax Re: New Blog Post Draft Fri, 11 Dec, 10:10
Matthias J. Sax Re: New Blog Post Draft Fri, 11 Dec, 10:25
Matthias J. Sax Re: Flink and Clojure Tue, 15 Dec, 14:01
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3142) CheckpointCoordinatorTest fails Tue, 08 Dec, 07:22
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest Tue, 15 Dec, 15:14
Maximilian Michels Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 01 Dec, 13:13
Maximilian Michels Re: New Blog Post Draft Wed, 09 Dec, 13:19
Maximilian Michels Externalizing the Flink connectors Thu, 10 Dec, 14:31
Box list
Jan 201741
Dec 2016366
Nov 2016429
Oct 2016552
Sep 2016426
Aug 2016586
Jul 2016455
Jun 2016386
May 2016405
Apr 2016535
Mar 2016421
Feb 2016502
Jan 2016389
Dec 2015259
Nov 2015589
Oct 2015589
Sep 2015449
Aug 2015478
Jul 2015503
Jun 2015880
May 2015491
Apr 2015583
Mar 2015716
Feb 2015545
Jan 2015600
Dec 2014303
Nov 2014375
Oct 2014283
Sep 2014430
Aug 2014314
Jul 2014390
Jun 2014990