Mailing list archives: August 2015

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Huang Wei (JIRA) [jira] [Created] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID Sat, 01 Aug, 07:35
Matthias J. Sax Re: Tuple Sat, 01 Aug, 11:04
Chesnay Schepler Re: Tuple Sat, 01 Aug, 11:30
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0 Sat, 01 Aug, 11:34
Matthias J. Sax Re: Tuple Sat, 01 Aug, 11:38
Stephan Ewen Re: Tuple Sat, 01 Aug, 13:38
Sachin Goel (JIRA) [jira] [Created] (FLINK-2458) Distributed Cache doesn't work with iterations. Sat, 01 Aug, 14:07
Sachin Goel (JIRA) [jira] [Created] (FLINK-2459) Failure on recently added Client side logging test Sat, 01 Aug, 15:45
Sachin Goel (JIRA) [jira] [Created] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure Sat, 01 Aug, 18:18
Slim Baltagi On integrating Flink with HBase Sun, 02 Aug, 08:03
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest Sun, 02 Aug, 13:57
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2462) Wrong exception reporting in streaming jobs Sun, 02 Aug, 15:13
Stephan Ewen Re: Question about DataStream class hierarchy Sun, 02 Aug, 15:47
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2463) Chow execution config in dashboard Sun, 02 Aug, 16:04
Stephan Ewen Re: Question About "Preserve Partitioning" in Stream Iteration Sun, 02 Aug, 18:14
Gyula Fóra Re: Question About "Preserve Partitioning" in Stream Iteration Sun, 02 Aug, 19:22
Matthias J. Sax Re: Tuple Sun, 02 Aug, 19:24
Gyula Fora (JIRA) [jira] [Created] (FLINK-2464) BufferSpillerTest sometimes fails Sun, 02 Aug, 19:39
Aljoscha Krettek Re: Question About "Preserve Partitioning" in Stream Iteration Sun, 02 Aug, 20:03
Stephan Ewen Re: Question About "Preserve Partitioning" in Stream Iteration Sun, 02 Aug, 22:13
Chesnay Schepler Re: Tuple Sun, 02 Aug, 22:22
Matthias J. Sax New failing Kafka Test Sun, 02 Aug, 22:38
Matthias J. Sax Re: Tuple Sun, 02 Aug, 22:45
Stephan Ewen Re: Tuple Sun, 02 Aug, 22:48
Matthias J. Sax Re: Tuple Sun, 02 Aug, 23:01
Stephan Ewen Re: Tuple Sun, 02 Aug, 23:02
Aljoscha Krettek Re: Question About "Preserve Partitioning" in Stream Iteration Mon, 03 Aug, 07:41
fangfengbin (JIRA) [jira] [Created] (FLINK-2465) SocketClientSink closeConnection function has memory leak Mon, 03 Aug, 07:59
Gyula Fóra Re: Question About "Preserve Partitioning" in Stream Iteration Mon, 03 Aug, 08:21
Stephan Ewen Re: Question About "Preserve Partitioning" in Stream Iteration Mon, 03 Aug, 08:24
Gyula Fóra Re: Question About "Preserve Partitioning" in Stream Iteration Mon, 03 Aug, 08:25
Sachin Goel (JIRA) [jira] [Created] (FLINK-2466) Travis build failure Mon, 03 Aug, 08:46
Matthias J. Sax Renaming log file? Mon, 03 Aug, 09:46
Stephan Ewen Re: Renaming log file? Mon, 03 Aug, 09:54
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2467) Example WordCountStorm.jar in not packaged correclty Mon, 03 Aug, 09:58
Fabian Hueske Wiki page for 0.10 release Mon, 03 Aug, 10:25
Sachin Goel (JIRA) [jira] [Created] (FLINK-2468) StreamCheckpointingITCase failure Mon, 03 Aug, 10:35
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2469) JobManager crashes on Cancel Mon, 03 Aug, 11:29
Aljoscha Krettek (JIRA) [jira] [Created] (FLINK-2470) Stream Iteration can Hang after some Data Mon, 03 Aug, 11:55
Maximilian Michels Re: Renaming log file? Mon, 03 Aug, 12:21
fangfengbin (JIRA) [jira] [Created] (FLINK-2471) FileSinkFunction invoke performance optimize Mon, 03 Aug, 12:50
Till Rohrmann (JIRA) [jira] [Created] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive Mon, 03 Aug, 13:51
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client Mon, 03 Aug, 14:21
Matthias J. Sax Failing Test Mon, 03 Aug, 15:48
Stephan Ewen Re: Failing Test Mon, 03 Aug, 16:41
Stephan Ewen Re: A soft reminder Mon, 03 Aug, 18:35
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase Mon, 03 Aug, 18:45
Stephan Ewen Re: Off-heap memory in Flink? Mon, 03 Aug, 18:45
Matthias J. Sax Failing Test again Mon, 03 Aug, 21:18
Matthias J. Sax (JIRA) [jira] [Created] (FLINK-2475) Rename Flink Client log and out file Mon, 03 Aug, 21:22
Henry Saputra Re: Failing Test again Mon, 03 Aug, 21:23
Matthias J. Sax Re: Failing Test again Mon, 03 Aug, 21:28
fangfengbin (JIRA) [jira] [Created] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream Tue, 04 Aug, 02:44
Huang Wei (JIRA) [jira] [Created] (FLINK-2477) Add test for SocketClientSink Tue, 04 Aug, 02:45
Slim Baltagi (JIRA) =?utf-8?Q?[jira]_[Created]_(FLINK-2478)_The_page_=E2=80=9C?= =?utf-8?Q?FlinkML_-_Machine_Learning_for_Flink=E2=80=9C__ht?= =?utf-8?Q?tps://ci.apache.org/projects/flink/flink-?= =?utf-8?Q?docs-master/libs/ml/_contains_a_dead_link?= Tue, 04 Aug, 06:19
Aljoscha Krettek Re: Failing Test again Tue, 04 Aug, 06:57
Matthias J. Sax Re: Failing Test again Tue, 04 Aug, 08:23
Ricky Pogalz (JIRA) [jira] [Created] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class Tue, 04 Aug, 09:35
Aljoscha Krettek Re: Failing Test again Tue, 04 Aug, 09:41
Stephan Ewen Re: Failing Test again Tue, 04 Aug, 10:11
Gyula Fóra Re: Failing Test again Tue, 04 Aug, 10:14
Stephan Ewen Re: Failing Test again Tue, 04 Aug, 10:21
Chesnay Schepler Re: Failing Test again Tue, 04 Aug, 10:27
Matthias J. Sax Re: Tuple Tue, 04 Aug, 11:08
Huang Wei (JIRA) [jira] [Created] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api Tue, 04 Aug, 11:21
Chesnay Schepler Re: Tuple Tue, 04 Aug, 11:27
Aljoscha Krettek Re: Tuple Tue, 04 Aug, 11:32
Matthias J. Sax Re: Tuple Tue, 04 Aug, 11:34
Matthias J. Sax Re: Tuple Tue, 04 Aug, 11:34
Matthias J. Sax Re: Tuple Tue, 04 Aug, 11:34
Stephan Ewen Re: Failing Test again Tue, 04 Aug, 11:57
Márton Balassi (JIRA) [jira] [Created] (FLINK-2481) Test at least once processing guarantee for streaming Tue, 04 Aug, 11:58
Márton Balassi (JIRA) [jira] [Created] (FLINK-2482) Document sreaming processing guarantees Tue, 04 Aug, 12:01
Robert Metzger Re: Failing Test again Tue, 04 Aug, 12:09
fangfengbin (JIRA) [jira] [Created] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function Tue, 04 Aug, 12:21
Matthias J. Sax Re: Tuple Tue, 04 Aug, 12:25
Chesnay Schepler Re: Tuple Tue, 04 Aug, 12:31
Matthias J. Sax Re: Tuple Tue, 04 Aug, 12:51
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2484) BarrierBuffer does not properly clean up temp files Tue, 04 Aug, 13:20
Aljoscha Krettek Re: Failing Test again Tue, 04 Aug, 13:54
Henry Saputra (JIRA) [jira] [Created] (FLINK-2485) Handle removal of Java Unsafe in Java9 Tue, 04 Aug, 23:22
fangfengbin (JIRA) [jira] [Created] (FLINK-2486) Remove unwanted null check in removeInstance function Wed, 05 Aug, 02:04
huangwei (G) Need help with CI problem Wed, 05 Aug, 06:36
zhangrucong (JIRA) [jira] [Created] (FLINK-2487) the array has out of bounds Wed, 05 Aug, 07:16
Robert Metzger Re: Need help with CI problem Wed, 05 Aug, 07:55
huangwei (G) =?utf-8?B?562U5aSNOiBOZWVkIGhlbHAgd2l0aCBDSSBwcm9ibGVt?= Wed, 05 Aug, 08:04
Stephan Ewen =?UTF-8?B?UmU6IOetlOWkjTogTmVlZCBoZWxwIHdpdGggQ0kgcHJvYmxlbQ==?= Wed, 05 Aug, 10:14
Robert Metzger (JIRA) [jira] [Created] (FLINK-2488) Expose attemptNumber in RuntimeContext Wed, 05 Aug, 12:35
Stephan Ewen FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Wed, 05 Aug, 14:11
Stephan Ewen Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Wed, 05 Aug, 14:25
Hawin Jiang Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Wed, 05 Aug, 17:10
Ankur Chauhan Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Wed, 05 Aug, 17:18
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2489) Improve the streaming window join Wed, 05 Aug, 20:00
Theodore Vasiloudis Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Wed, 05 Aug, 21:08
Sachin Goel Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Thu, 06 Aug, 02:51
Maximilian Michels Re: Bug fix release 0.9.1 Thu, 06 Aug, 08:07
Huang Wei (JIRA) [jira] [Created] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket Thu, 06 Aug, 08:29
Robert Metzger (JIRA) [jira] [Created] (FLINK-2491) Operators are not participating in state checkpointing in some cases Thu, 06 Aug, 09:50
Stephan Ewen Re: FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance Thu, 06 Aug, 13:04
Stephan Ewen (JIRA) [jira] [Created] (FLINK-2492) Rename remaining runtime classes from "match" to "join" Thu, 06 Aug, 13:18
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