flink-dev 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) [jira] [Created] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-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) 答复: Need help with CI problem Wed, 05 Aug, 08:04
Stephan Ewen Re: 答复: Need help with CI problem 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
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Aug 2018261
Jul 2018578
Jun 2018433
May 2018483
Apr 2018266
Mar 2018522
Feb 2018441
Jan 2018287
Dec 2017261
Nov 2017306
Oct 2017301
Sep 2017280
Aug 2017381
Jul 2017579
Jun 2017626
May 2017619
Apr 2017352
Mar 2017605
Feb 2017562
Jan 2017581
Dec 2016366
Nov 2016429
Oct 2016554
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
May 2014184
Apr 201415