Mailing list archives: February 2016

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · 6 · Next »Thread · Author · Date
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3308) [py] Remove debug mode Mon, 01 Feb, 09:02
Fridtjof Sander DataExchangeMode.BATCH in iterations Mon, 01 Feb, 10:47
Chesnay Schepler (JIRA) [jira] [Created] (FLINK-3309) [py] Resolve maven warnings Mon, 01 Feb, 11:05
Fabian Hueske Re: DataExchangeMode.BATCH in iterations Mon, 01 Feb, 11:21
Fridtjof Sander Re: DataExchangeMode.BATCH in iterations Mon, 01 Feb, 12:04
Hilmi Yildirim JobClientActorSubmissionTimeoutException Mon, 01 Feb, 13:39
Till Rohrmann Re: JobClientActorSubmissionTimeoutException Mon, 01 Feb, 13:50
Hilmi Yildirim Re: JobClientActorSubmissionTimeoutException Mon, 01 Feb, 13:53
Till Rohrmann Re: JobClientActorSubmissionTimeoutException Mon, 01 Feb, 14:17
Hilmi Yildirim Re: JobClientActorSubmissionTimeoutException Mon, 01 Feb, 15:45
Ufuk Celebi Re: JobClientActorSubmissionTimeoutException Mon, 01 Feb, 18:01
Ufuk Celebi [DISCUSS] Release 0.10.2 Mon, 01 Feb, 19:07
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3310) Add back pressure statistics to web frontend Mon, 01 Feb, 19:12
Robert Metzger (JIRA) [jira] [Created] (FLINK-3311) Add a connector for streaming data into Cassandra Mon, 01 Feb, 19:56
Nick Dimiduk Re: [DISCUSS] Release 0.10.2 Mon, 01 Feb, 20:57
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3312) Add convenience accessor methods for extended state interface Mon, 01 Feb, 20:58
Maximilian Michels Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 09:44
Fabian Hueske Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 09:50
Till Rohrmann Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 10:07
Stephan Ewen Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 10:43
Robert Metzger (JIRA) [jira] [Created] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException Tue, 02 Feb, 10:56
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly Tue, 02 Feb, 11:17
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-3315) Fix Slot Sharing in Streaming API Tue, 02 Feb, 11:23
Theodore Vasiloudis (JIRA) [jira] [Created] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken Tue, 02 Feb, 12:41
Ufuk Celebi Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 12:57
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3317) Add timeout handler to CEP operator Tue, 02 Feb, 13:34
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3318) Add support for quantifiers to CEP's pattern API Tue, 02 Feb, 13:42
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3319) Add or operator to CEP's pattern API Tue, 02 Feb, 13:50
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3320) Add not operator to CEP's pattern API Tue, 02 Feb, 13:53
Gabor Gevay (JIRA) [jira] [Created] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it Tue, 02 Feb, 14:21
Gabor Gevay (JIRA) [jira] [Created] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs Tue, 02 Feb, 15:26
Gábor Gévay Re: Memory manager behavior in iterative jobs Tue, 02 Feb, 15:27
Robert Metzger Re: [DISCUSS] Release 0.10.2 Tue, 02 Feb, 16:30
Robert Metzger Re: Release Flink 1.0.0 Tue, 02 Feb, 18:12
Greg Hogan Limitations on grouped ReduceFunction Tue, 02 Feb, 20:54
Stephan Ewen Re: Limitations on grouped ReduceFunction Wed, 03 Feb, 08:12
Matthias J. Sax Connector Documentation missing Wed, 03 Feb, 13:24
Suneel Marthi Re: Connector Documentation missing Wed, 03 Feb, 13:45
Matthias J. Sax Re: Connector Documentation missing Wed, 03 Feb, 14:11
Maximilian Michels Re: Connector Documentation missing Wed, 03 Feb, 14:18
Matthias J. Sax Re: Connector Documentation missing Wed, 03 Feb, 14:21
Maximilian Michels Re: Connector Documentation missing Wed, 03 Feb, 14:29
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3323) Nifi connector not documented Wed, 03 Feb, 14:33
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3324) Flume connector not documented Wed, 03 Feb, 14:33
Ted Yu (JIRA) [jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState() Wed, 03 Feb, 14:42
Farouk Salem (JIRA) [jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic Wed, 03 Feb, 15:36
Kostas (JIRA) [jira] [Created] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. Wed, 03 Feb, 17:53
Ufuk Celebi Re: [DISCUSS] Release 0.10.2 Wed, 03 Feb, 18:31
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime Wed, 03 Feb, 20:06
Ted Yu (JIRA) [jira] [Created] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() Wed, 03 Feb, 23:56
Chiwan Park (JIRA) [jira] [Created] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML Thu, 04 Feb, 04:05
Robert Metzger (JIRA) [jira] [Created] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers Thu, 04 Feb, 08:09
Robert Metzger (JIRA) [jira] [Created] (FLINK-3332) Provide an exactly-once Cassandra connector Thu, 04 Feb, 10:21
Gabor Gevay (JIRA) [jira] [Created] (FLINK-3333) Documentation about object reuse should be improved Thu, 04 Feb, 10:37
Gyula Fora (JIRA) [jira] [Created] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp Thu, 04 Feb, 12:31
Greg Hogan (JIRA) [jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled Thu, 04 Feb, 13:45
Ufuk Celebi [VOTE] Release Apache Flink 0.10.2 (RC1) Thu, 04 Feb, 14:18
Ufuk Celebi Re: [DISCUSS] Release 0.10.2 Thu, 04 Feb, 14:19
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream Thu, 04 Feb, 17:28
Greg Hogan (JIRA) [jira] [Created] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found Thu, 04 Feb, 17:39
Shikhar Bhushan (JIRA) [jira] [Created] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException Thu, 04 Feb, 18:14
Shikhar Bhushan (JIRA) [jira] [Created] (FLINK-3339) Checkpointing NPE when using filterWithState Thu, 04 Feb, 19:11
Greg Hogan (JIRA) [jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers Thu, 04 Feb, 22:17
Shikhar Bhushan (JIRA) [jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka Fri, 05 Feb, 06:08
Matthias J. Sax New instable test? Fri, 05 Feb, 10:06
Ufuk Celebi (JIRA) [jira] [Created] (FLINK-3342) Operator checkpoint statistics state size overflow Fri, 05 Feb, 10:49
Fabian Hueske Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Fri, 05 Feb, 11:17
Ufuk Celebi Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Fri, 05 Feb, 11:45
Farouk Salem (JIRA) [jira] [Created] (FLINK-3343) Exception while using Kafka 0.9 connector Fri, 05 Feb, 12:28
Matthias J. Sax Re: New instable test? Fri, 05 Feb, 12:41
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow Fri, 05 Feb, 12:49
Maximilian Michels Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Fri, 05 Feb, 12:51
Stephan Ewen Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Fri, 05 Feb, 13:09
Fabian Hueske Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Fri, 05 Feb, 13:17
Robert Metzger [ANNOUNCE] Please annotate public interfaces! Fri, 05 Feb, 14:07
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3345) Restart TaskManager in case of a Akka quarantine event Fri, 05 Feb, 14:47
Till Rohrmann (JIRA) [jira] [Created] (FLINK-3346) Replace Akka death watch with own heartbeats Fri, 05 Feb, 14:58
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine Fri, 05 Feb, 15:03
Dongwon Kim Want Flink startup issues :-) Fri, 05 Feb, 16:14
Maximilian Michels Re: [ANNOUNCE] Please annotate public interfaces! Fri, 05 Feb, 16:24
Stephan Ewen Re: DataExchangeMode.BATCH in iterations Fri, 05 Feb, 16:35
Flavio Pompermaier (JIRA) [jira] [Created] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation Fri, 05 Feb, 16:52
Riccardo Diomedi (JIRA) [jira] [Created] (FLINK-3349) planVisualizer doesn't work! Fri, 05 Feb, 17:14
Fabian Hueske Re: [ANNOUNCE] Please annotate public interfaces! Fri, 05 Feb, 19:38
Fabian Hueske Re: Want Flink startup issues :-) Fri, 05 Feb, 19:55
Matthias J. Sax Re: Want Flink startup issues :-) Fri, 05 Feb, 20:30
Robert Metzger Re: Want Flink startup issues :-) Fri, 05 Feb, 20:32
Dongwon Kim Re: Want Flink startup issues :-) Sat, 06 Feb, 06:31
Chiwan Park Re: Want Flink startup issues :-) Sat, 06 Feb, 13:00
Dongwon Kim Re: Want Flink startup issues :-) Sat, 06 Feb, 13:10
Stephan Ewen Re: [ANNOUNCE] Please annotate public interfaces! Sat, 06 Feb, 14:17
Stephan Ewen Re: [ANNOUNCE] Please annotate public interfaces! Sat, 06 Feb, 14:27
Stephan Ewen (JIRA) [jira] [Created] (FLINK-3350) Increase timeouts on Travis Builds Sat, 06 Feb, 14:47
Stephan Ewen Re: [VOTE] Release Apache Flink 0.10.2 (RC1) Sat, 06 Feb, 16:34
Gyula Fora (JIRA) [jira] [Created] (FLINK-3351) RocksDB Backend cannot determine correct local db path Sat, 06 Feb, 20:12
Gyula Fora (JIRA) [jira] [Created] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path Sat, 06 Feb, 21:20
Stefano Baghino Tips for testing Sat, 06 Feb, 21:31
Stefano Baghino (JIRA) [jira] [Created] (FLINK-3353) CSV-related tests may fail depending on locale Sat, 06 Feb, 21:56
Gyula Fora (JIRA) [jira] [Created] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size Sat, 06 Feb, 22:30
Gyula Fora (JIRA) [jira] [Created] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend Sat, 06 Feb, 23:05
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