Mailing list archives: December 2015

Site index · List index
Message list1 · 2 · 3 · 4 · Next »Thread · Author · Date
RE: The null in Flink
Li, Chengxiang   RE: The null in Flink Tue, 01 Dec, 03:09
Stephan Ewen     Re: The null in Flink Wed, 02 Dec, 10:27
Li, Chengxiang       RE: The null in Flink Thu, 03 Dec, 08:42
Li, Chengxiang         RE: The null in Flink Tue, 08 Dec, 06:18
Aljoscha Krettek           Re: The null in Flink Tue, 08 Dec, 11:10
Roman Shaposhnik FOSDEM 2016 - take action by 4th of December 2015 Tue, 01 Dec, 06:30
[jira] [Created] (FLINK-3092) Scala API quick start word count example is broken
madhukara phatak (JIRA)   [jira] [Created] (FLINK-3092) Scala API quick start word count example is broken Tue, 01 Dec, 06:33
[jira] [Created] (FLINK-3093) Introduce annotations for interface stability
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3093) Introduce annotations for interface stability Tue, 01 Dec, 11:30
Re: Tagging Flink classes with InterfaceAudience and InterfaceStability
Maximilian Michels   Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 01 Dec, 13:13
Robert Metzger     Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 01 Dec, 13:20
Robert Metzger       Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 15 Dec, 14:27
Maximilian Michels         Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 15 Dec, 14:46
[jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory
Till Rohrmann (JIRA)   [jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory Tue, 01 Dec, 13:18
Re: Task Parallelism in a Cluster
Kashmar, Ali   Re: Task Parallelism in a Cluster Tue, 01 Dec, 14:26
Ufuk Celebi     Re: Task Parallelism in a Cluster Tue, 01 Dec, 14:44
Stephan Ewen     Re: Task Parallelism in a Cluster Tue, 01 Dec, 15:01
Till Rohrmann       Re: Task Parallelism in a Cluster Wed, 02 Dec, 08:39
Kashmar, Ali         Re: Task Parallelism in a Cluster Wed, 02 Dec, 15:06
Stephan Ewen           Re: Task Parallelism in a Cluster Tue, 08 Dec, 20:35
Kashmar, Ali             Re: Task Parallelism in a Cluster Wed, 09 Dec, 16:22
Stephan Ewen               Re: Task Parallelism in a Cluster Wed, 09 Dec, 17:36
Kashmar, Ali                 Re: Task Parallelism in a Cluster Wed, 09 Dec, 19:49
Stephan Ewen                   Re: Task Parallelism in a Cluster Thu, 10 Dec, 15:16
Kashmar, Ali                     Re: Task Parallelism in a Cluster Fri, 11 Dec, 15:50
Stephan Ewen                       Re: Task Parallelism in a Cluster Fri, 11 Dec, 16:23
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
[jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable Tue, 01 Dec, 18:24
[jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints Tue, 01 Dec, 18:26
Re: could you please add me Contributor list?
jun aoki   Re: could you please add me Contributor list? Tue, 01 Dec, 19:48
[jira] [Created] (FLINK-3097) Add support for custom functions in Table API
Timo Walther (JIRA)   [jira] [Created] (FLINK-3097) Add support for custom functions in Table API Tue, 01 Dec, 22:32
[jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error.
Chengxiang Li (JIRA)   [jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. Wed, 02 Dec, 05:56
[jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows
Welly Tambunan (JIRA)   [jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows Wed, 02 Dec, 11:16
[jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster
Maximilian Michels (JIRA)   [jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster Wed, 02 Dec, 16:25
[jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record
Sanjar Akhmedov (JIRA)   [jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record Wed, 02 Dec, 16:43
[jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer Wed, 02 Dec, 18:02
[jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized
Ted Yu (JIRA)   [jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized Wed, 02 Dec, 22:09
[jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle()
Ted Yu (JIRA)   [jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() Wed, 02 Dec, 22:12
Nam-Luc Tran Distributed DataFrame - ddf.io Thu, 03 Dec, 10:23
Kostas Tzoumas   Re: Distributed DataFrame - ddf.io Thu, 03 Dec, 16:48
Henry Saputra     Re: Distributed DataFrame - ddf.io Fri, 04 Dec, 00:35
[jira] [Created] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session
Ufuk Celebi (JIRA)   [jira] [Created] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session Thu, 03 Dec, 11:00
[jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure Thu, 03 Dec, 12:35
[jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor
Ufuk Celebi (JIRA)   [jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor Thu, 03 Dec, 12:56
[jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method
Vasia Kalavri (JIRA)   [jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method Thu, 03 Dec, 16:28
[jira] [Created] (FLINK-3109) Join two streams with two different cache time
Wang Yangjun (JIRA)   [jira] [Created] (FLINK-3109) Join two streams with two different cache time Thu, 03 Dec, 21:27
[jira] [Created] (FLINK-3110) Add support for the partition-centric iterations
Vasia Kalavri (JIRA)   [jira] [Created] (FLINK-3110) Add support for the partition-centric iterations Fri, 04 Dec, 09:52
[jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager
Ufuk Celebi (JIRA)   [jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager Fri, 04 Dec, 10:26
[jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class
Fabian Hueske (JIRA)   [jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class Fri, 04 Dec, 12:03
[jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase
Fabian Hueske (JIRA)   [jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase Fri, 04 Dec, 12:07
[jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism
Maximilian Michels (JIRA)   [jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism Fri, 04 Dec, 12:14
[jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X
Maximilian Michels (JIRA)   [jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X Fri, 04 Dec, 14:18
[jira] [Created] (FLINK-3116) Remove RecordOperator
Chesnay Schepler (JIRA)   [jira] [Created] (FLINK-3116) Remove RecordOperator Fri, 04 Dec, 14:29
[jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported
Maximilian Michels (JIRA)   [jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported Fri, 04 Dec, 15:15
[jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable
Martin Junghanns (JIRA)   [jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable Fri, 04 Dec, 15:18
Fwd: DATA TRANSFORMATION PROBLEM
JOHN MILLER   Fwd: DATA TRANSFORMATION PROBLEM Fri, 04 Dec, 15:39
[jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat
Nick Dimiduk (JIRA)   [jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat Fri, 04 Dec, 17:35
[jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number
Ufuk Celebi (JIRA)   [jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number Fri, 04 Dec, 17:55
[jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data Fri, 04 Dec, 21:21
[jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation
Martin Junghanns (JIRA)   [jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation Sat, 05 Dec, 09:29
[jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer
Robert Metzger (JIRA)   [jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Sat, 05 Dec, 09:52
[jira] [Created] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc.
Sachin Goel (JIRA)   [jira] [Created] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc. Sat, 05 Dec, 15:11
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