Mailing list archives: December 2015

Site index · List index
Message list1 · 2 · 3 · Next »Thread · Author · Date
Li, Chengxiang RE: The null in Flink Tue, 01 Dec, 03:09
Roman Shaposhnik FOSDEM 2016 - take action by 4th of December 2015 Tue, 01 Dec, 06:30
madhukara phatak (JIRA) [jira] [Created] (FLINK-3092) Scala API quick start word count example is broken Tue, 01 Dec, 06:33
Robert Metzger (JIRA) [jira] [Created] (FLINK-3093) Introduce annotations for interface stability Tue, 01 Dec, 11:30
Maximilian Michels Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 01 Dec, 13:13
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory Tue, 01 Dec, 13:18
Robert Metzger Re: Tagging Flink classes with InterfaceAudience and InterfaceStability Tue, 01 Dec, 13:20
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
Robert Metzger (JIRA) [jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable Tue, 01 Dec, 18:24
Robert Metzger (JIRA) [jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints Tue, 01 Dec, 18:26
jun aoki Re: could you please add me Contributor list? Tue, 01 Dec, 19:48
Timo Walther (JIRA) [jira] [Created] (FLINK-3097) Add support for custom functions in Table API Tue, 01 Dec, 22:32
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. Wed, 02 Dec, 05:56
Till Rohrmann Re: Task Parallelism in a Cluster Wed, 02 Dec, 08:39
Stephan Ewen Re: The null in Flink Wed, 02 Dec, 10:27
Welly Tambunan (JIRA) [jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows Wed, 02 Dec, 11:16
Kashmar, Ali Re: Task Parallelism in a Cluster Wed, 02 Dec, 15:06
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster Wed, 02 Dec, 16:25
Sanjar Akhmedov (JIRA) [jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record Wed, 02 Dec, 16:43
Robert Metzger (JIRA) [jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer Wed, 02 Dec, 18:02
Ted Yu (JIRA) [jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized Wed, 02 Dec, 22:09
Ted Yu (JIRA) [jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() Wed, 02 Dec, 22:12
Li, Chengxiang RE: The null in Flink Thu, 03 Dec, 08:42
Nam-Luc Tran Distributed DataFrame - ddf.io Thu, 03 Dec, 10:23
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
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure Thu, 03 Dec, 12:35
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor Thu, 03 Dec, 12:56
Vasia Kalavri (JIRA) [jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method Thu, 03 Dec, 16:28
Kostas Tzoumas Re: Distributed DataFrame - ddf.io Thu, 03 Dec, 16:48
Wang Yangjun (JIRA) [jira] [Created] (FLINK-3109) Join two streams with two different cache time Thu, 03 Dec, 21:27
Henry Saputra Re: Distributed DataFrame - ddf.io Fri, 04 Dec, 00:35
Vasia Kalavri (JIRA) [jira] [Created] (FLINK-3110) Add support for the partition-centric iterations Fri, 04 Dec, 09:52
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager Fri, 04 Dec, 10:26
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
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism Fri, 04 Dec, 12:14
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X Fri, 04 Dec, 14:18
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3116) Remove RecordOperator Fri, 04 Dec, 14:29
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported Fri, 04 Dec, 15:15
Martin Junghanns (JIRA) [jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable Fri, 04 Dec, 15:18
JOHN MILLER Fwd: DATA TRANSFORMATION PROBLEM Fri, 04 Dec, 15:39
Nick Dimiduk (JIRA) [jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat Fri, 04 Dec, 17:35
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
Robert Metzger (JIRA) [jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data Fri, 04 Dec, 21:21
Martin Junghanns (JIRA) [jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation Sat, 05 Dec, 09:29
Robert Metzger (JIRA) [jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer Sat, 05 Dec, 09:52
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
Sachin Goel Lack of review on PRs Sat, 05 Dec, 16:00
Chiwan Park Re: Lack of review on PRs Sun, 06 Dec, 16:44
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3125) Web dashboard does not start when log files are not found Sun, 06 Dec, 17:18
Robert Metzger (JIRA) [jira] [Created] (FLINK-3126) Remove accumulator type from "value" in web frontend Sun, 06 Dec, 17:23
Stephan Ewen Re: Lack of review on PRs Sun, 06 Dec, 19:59
Gyula Fóra Monitoring backpressure Mon, 07 Dec, 08:45
Stephan Ewen Re: Monitoring backpressure Mon, 07 Dec, 09:51
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3127) Measure backpressure in Flink jobs Mon, 07 Dec, 10:11
Gyula Fóra Re: Monitoring backpressure Mon, 07 Dec, 10:48
Till Rohrmann Re: Lack of review on PRs Mon, 07 Dec, 12:08
Fridtjof Sander (JIRA) [jira] [Created] (FLINK-3128) Add Isotonic Regression To ML Library Mon, 07 Dec, 12:44
Robert Metzger (JIRA) [jira] [Created] (FLINK-3129) Add tooling to ensure interface stability Mon, 07 Dec, 13:35
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3130) Visualize throughput of tasks Mon, 07 Dec, 13:43
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3131) Expose checkpoint metrics Mon, 07 Dec, 13:46
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3132) Restructure streaming guide Mon, 07 Dec, 13:53
Nyamath Ulla Khan Re: [jira] [Created] (FLINK-3132) Restructure streaming guide Mon, 07 Dec, 14:03
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API Mon, 07 Dec, 15:47
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3134) Make YarnJobManager's allocate call asynchronous Mon, 07 Dec, 16:06
Fabian Hueske (JIRA) [jira] [Created] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy Mon, 07 Dec, 16:08
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import Mon, 07 Dec, 19:24
Ted Yu (JIRA) [jira] [Created] (FLINK-3137) Missing break in OutputEmitter ctor Mon, 07 Dec, 20:50
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3138) Method References are not supported as lambda expressions Mon, 07 Dec, 22:10
Chengxiang Li (JIRA) [jira] [Created] (FLINK-3139) NULL values handling in Table API Tue, 08 Dec, 06:05
Li, Chengxiang RE: The null in Flink Tue, 08 Dec, 06:18
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
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3142) CheckpointCoordinatorTest fails Tue, 08 Dec, 07:22
Matthias J. Sax JobManagerCheckpointRecoveryITCase Tue, 08 Dec, 07:29
Aljoscha Krettek Re: The null in Flink Tue, 08 Dec, 11:10
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 Tue, 08 Dec, 12:32
Humberto Moura Migrating Spark to Flink Tue, 08 Dec, 13:25
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3144) [storm] LocalCluster prints nothing without a configured logger Tue, 08 Dec, 14:05
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3145) Storm examples can't be run without flink-java as dependency Tue, 08 Dec, 16:28
Robert Metzger Re: Migrating Spark to Flink Tue, 08 Dec, 16:29
Robert Metzger (JIRA) [jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x Tue, 08 Dec, 17:46
Nick Dimiduk (JIRA) [jira] [Created] (FLINK-3147) HadoopOutputFormatBase should expose CLOSE_MUTEX for subuclasses Tue, 08 Dec, 18:02
Nick Dimiduk (JIRA) [jira] [Created] (FLINK-3148) Support configured serializers for shipping UDFs Tue, 08 Dec, 18:37
Nick Dimiduk flink-dist packaging including unshaded classes Tue, 08 Dec, 20:25
Stephan Ewen Re: Task Parallelism in a Cluster Tue, 08 Dec, 20:35
jun aoki (JIRA) [jira] [Created] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found Wed, 09 Dec, 00:07
Robert Metzger (JIRA) [jira] [Created] (FLINK-3150) Make YARN container invocation configurable Wed, 09 Dec, 08:53
Robert Metzger (JIRA) [jira] [Created] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) Wed, 09 Dec, 09:17
Kostas Tzoumas Community choice for Hadoop Summit Europe 2016 Wed, 09 Dec, 09:52
Timo Walther (JIRA) [jira] [Created] (FLINK-3152) Support all comparisons for Date type Wed, 09 Dec, 10:22
Matthias J. Sax New Blog Post Draft Wed, 09 Dec, 10:32
Timo Walther (JIRA) [jira] [Created] (FLINK-3153) Support all comparisons for String type Wed, 09 Dec, 10:33
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 Wed, 09 Dec, 11:03
Robert Metzger Re: New Blog Post Draft Wed, 09 Dec, 11:10
Slim Baltagi Re: New Blog Post Draft Wed, 09 Dec, 11:14
Stephan Ewen Re: flink-dist packaging including unshaded classes Wed, 09 Dec, 11:29
Maximilian Michels (JIRA) [jira] [Created] (FLINK-3155) Update Flink docker version to latest stable Flink version Wed, 09 Dec, 11:38
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