dev@flink.apache.org, 2015-02

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: Kicking off the Machine Learning Library - posted by Till Rohrmann <ti...@gmail.com> on 2015/02/02 08:50:22 UTC, 3 replies.
- Re: ReduceGroup fails on server - posted by Arvid Heise <ar...@gmail.com> on 2015/02/02 12:48:25 UTC, 1 replies.
- [jira] [Created] (FLINK-1468) Config parse failure fails task manager startup w/o an error message - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 16:01:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1469) Initialize network environment at task manager startup - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 16:34:34 UTC, 0 replies.
- Re: YARN ITCases fail, master broken? - posted by Ufuk Celebi <uc...@apache.org> on 2015/02/02 18:29:08 UTC, 1 replies.
- [jira] [Created] (FLINK-1470) JobManagerITCase fails on Travis - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/02 18:34:34 UTC, 0 replies.
- Task manager memory configuration with intermediate results - posted by Ufuk Celebi <u....@fu-berlin.de> on 2015/02/02 18:45:31 UTC, 3 replies.
- [jira] [Created] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/03 10:36:35 UTC, 0 replies.
- Re: Design Question in Expression API - posted by Fabian Hueske <fh...@gmail.com> on 2015/02/03 10:39:03 UTC, 1 replies.
- [jira] [Created] (FLINK-1472) Web frontend config overview shows wrong value - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/03 16:19:35 UTC, 0 replies.
- Re: Drafting a roadmap for Flink - posted by Henry Saputra <he...@gmail.com> on 2015/02/04 06:33:59 UTC, 4 replies.
- Sorting of fields - posted by Timo Walther <tw...@apache.org> on 2015/02/04 14:38:43 UTC, 3 replies.
- Cluster execution - Jobmanager unreachable - posted by Chesnay Schepler <ch...@fu-berlin.de> on 2015/02/04 14:49:45 UTC, 11 replies.
- January 2015 in the Flink community - posted by Kostas Tzoumas <kt...@apache.org> on 2015/02/04 14:52:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1473) Simplify SplittableIterator interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/04 15:20:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1474) Cross produces wrong results for non-tiny inputs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 16:04:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1475) Minimize log output of yarn test cases - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/04 19:26:35 UTC, 0 replies.
- suitable implementation tasks / student projects? - posted by Adnan Khan <kh...@gmail.com> on 2015/02/04 20:35:46 UTC, 3 replies.
- [jira] [Created] (FLINK-1476) Flink VS Spark on loop test - posted by "xuhong (JIRA)" <ji...@apache.org> on 2015/02/05 04:22:35 UTC, 0 replies.
- Re: [jira] [Created] (FLINK-1462) Add documentation guide for the graph API - posted by Ufuk Celebi <uc...@apache.org> on 2015/02/05 07:37:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1477) YARN Client: Use HADOOP_HOME if set - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/05 10:49:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1478) Add strictly local input split assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 12:06:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1479) The spawned threads in the sorter have no context class loader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 14:12:35 UTC, 0 replies.
- Planning Release 0.8.1 - posted by Robert Metzger <rm...@apache.org> on 2015/02/05 14:27:29 UTC, 17 replies.
- [jira] [Created] (FLINK-1480) Test Flink against Hadoop 2.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/05 14:54:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1481) Flakey JobManagerITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 15:23:34 UTC, 0 replies.
- Question about StreamRecord.uid in flink-streaming - posted by Aljoscha Krettek <al...@apache.org> on 2015/02/05 16:20:19 UTC, 1 replies.
- [DISCUSS] Be more patient with PR and patches in the review - posted by Henry Saputra <he...@gmail.com> on 2015/02/05 17:03:03 UTC, 4 replies.
- [jira] [Created] (FLINK-1482) BlobStore does not delete directories when process is killed - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 18:09:35 UTC, 0 replies.
- Fwd: [jira] [Created] (MRQL-66) Add support for MRQL streaming in Flink streaming mode - posted by Robert Metzger <rm...@apache.org> on 2015/02/05 18:18:44 UTC, 0 replies.
- [jira] [Created] (FLINK-1483) Temporary channel files are not properly deleted when Flink is terminated - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 18:39:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1484) JobManager restart does not notify the TaskManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 21:03:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1485) Typo in Documentation - Join with Join-Function - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/05 21:54:39 UTC, 0 replies.
- Edit permission - posted by Raymond Zhang <xi...@gmail.com> on 2015/02/05 23:28:16 UTC, 1 replies.
- Fwd: Google Summer of Code 2015 is coming - posted by Henry Saputra <he...@gmail.com> on 2015/02/06 04:07:32 UTC, 13 replies.
- Eclipse JDT, Java 8, lambdas - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/02/06 12:27:54 UTC, 12 replies.
- [jira] [Created] (FLINK-1486) Add a string to the print method to identify output - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/06 12:55:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/06 14:24:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1488) JobManager web interface logfile access broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/06 14:47:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/06 15:05:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1490) Incorrect local output sort for tuple position keys with nested tuples - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/06 15:09:36 UTC, 0 replies.
- [jira] [Created] (FLINK-1491) Inconsistent logging between Akka and other components - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/06 15:16:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/06 15:19:34 UTC, 0 replies.
- Streaming fault tolerance with event sending - posted by Hermann Gábor <re...@gmail.com> on 2015/02/06 17:13:58 UTC, 0 replies.
- [jira] [Created] (FLINK-1493) Support for streaming jobs preserving global ordering of records - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/06 17:37:34 UTC, 0 replies.
- Re: [jira] [Commented] (FLINK-1319) Add static code analysis for UDFs - posted by Fabian Hueske <fh...@gmail.com> on 2015/02/08 00:02:24 UTC, 0 replies.
- Memory segment error when migrating functional code from Flink 0.9 to 0.8 - posted by Andra Lungu <lu...@gmail.com> on 2015/02/09 09:56:05 UTC, 3 replies.
- [jira] [Created] (FLINK-1494) Build fails on BlobCacheTest - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/09 11:50:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1495) Make Akka timeout configurable in YARN client. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 14:46:34 UTC, 0 replies.
- Events not received - posted by Hermann Gábor <re...@gmail.com> on 2015/02/09 15:06:48 UTC, 5 replies.
- [jira] [Created] (FLINK-1496) Events at unitialized input channels are lost - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/09 15:23:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1497) No documentation on MiniCluster - posted by "Sergey Dudoladov (JIRA)" <ji...@apache.org> on 2015/02/09 15:24:34 UTC, 0 replies.
- [DISCUSS] Distributed TPC-H DataGenerator for flink-contrib - posted by Robert Metzger <rm...@apache.org> on 2015/02/09 16:03:07 UTC, 7 replies.
- [jira] [Created] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/09 16:26:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1499) Make TaskManager to disconnect from TaskManager in case of a restart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/09 17:53:36 UTC, 0 replies.
- [jira] [Created] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/09 18:20:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 19:10:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 19:12:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/09 19:25:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 19:59:38 UTC, 0 replies.
- [jira] [Created] (FLINK-1505) Separate buffer reader and channel consumption logic - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/10 10:04:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1506) Add buffer/event wrapper for runtime results - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/10 10:27:34 UTC, 0 replies.
- [jira] [Created] (FLINK-1507) Allow to configure produced intermediate result type via ExecutionConfig - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/10 10:33:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1508) Remove AkkaUtils.ask to encourage explicit future handling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/10 12:07:35 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.8.1 (RC0) - posted by Robert Metzger <rm...@apache.org> on 2015/02/10 17:31:35 UTC, 5 replies.
- [jira] [Created] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/10 18:33:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1510) Make AvroInputFormat splittable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 09:43:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1511) Scala classes not identified as Pojos - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/11 10:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1512) Add CsvReader for reading into POJOs. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 10:23:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1513) Remove GlobalConfiguration Singleton - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/11 10:59:12 UTC, 0 replies.
- Gelly is in! - posted by Stephan Ewen <se...@apache.org> on 2015/02/11 11:53:12 UTC, 12 replies.
- [jira] [Created] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 12:38:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1515) [Gelly] Enable access to aggregators and broadcast sets in vertex-centric iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 12:56:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1516) JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique! - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 13:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/11 14:16:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1518) Laggy task cancelling on task managers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/11 14:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1519) Web frontend task state mismatch when cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/11 15:02:12 UTC, 0 replies.
- kryoException : Buffer underflow - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/02/11 15:02:17 UTC, 10 replies.
- [jira] [Created] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 15:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/11 15:12:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1522) Add tests for the library methods and examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 15:40:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1523) Vertex-centric iteration extensions - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 15:46:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message - posted by "Sergey Dudoladov (JIRA)" <ji...@apache.org> on 2015/02/11 15:50:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 15:56:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 15:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1527) Incomplete Accumulator documentation (no mention of the shorthand methods) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 15:58:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1528) Add local clustering coefficient library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 16:03:13 UTC, 0 replies.
- Merge guidelines / policies - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/02/11 16:41:31 UTC, 5 replies.
- [jira] [Created] (FLINK-1529) Improve JobManager startup robustness - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/11 17:47:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1530) Cache ExecutionConfig in AbstractInvokable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/11 17:56:12 UTC, 0 replies.
- Fixed the Release 0.8 branch - posted by Stephan Ewen <se...@apache.org> on 2015/02/12 11:22:43 UTC, 2 replies.
- [VOTE][CANCEL] Release Apache Flink 0.8.1 (RC0) - posted by Robert Metzger <rm...@apache.org> on 2015/02/12 11:23:15 UTC, 0 replies.
- [jira] [Created] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/12 11:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1532) AggregatorsITCase fails spuriously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/12 14:05:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1533) NullPointerException in SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/12 14:51:11 UTC, 0 replies.
- Re: Master not building and how to notice it faster in the future - posted by Ufuk Celebi <uc...@apache.org> on 2015/02/12 15:03:15 UTC, 2 replies.
- [jira] [Created] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/12 15:24:12 UTC, 2 replies.
- [jira] [Created] (FLINK-1535) Use usercode class loader to serialize/deserialize accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/12 15:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1536) GSoC project: Graph partitioning operators for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/12 18:36:11 UTC, 0 replies.
- Getting fail test at BlobUtilsTest.testExceptionOnCreateStorageDirectoryFailure from master - posted by Henry Saputra <he...@gmail.com> on 2015/02/13 01:47:06 UTC, 9 replies.
- [VOTE] Release Apache Flink 0.8.1 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2015/02/13 09:50:43 UTC, 2 replies.
- [jira] [Created] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/13 14:39:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1538) Spatial Data Processing Library - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/13 16:31:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1539) Runtime context not initialized when running streaming PojoExample - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/13 16:42:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1541) GSoC project: Distributed profiling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/13 17:06:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/13 17:06:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/13 17:15:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1543) Proper exception handling in actors - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/13 17:38:12 UTC, 0 replies.
- Sorry about the "Merge branch 'master' of " commit message - posted by Henry Saputra <he...@gmail.com> on 2015/02/13 18:35:07 UTC, 0 replies.
- [jira] [Created] (FLINK-1544) Extend streaming aggregation tests to include POJOs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/13 20:03:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1545) Spurious failure of AsynchronousFileIOChannelsTest.testExceptionForwardsToClose - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/14 11:28:11 UTC, 0 replies.
- Streaming Windowing rework (runtime + api) - posted by Gyula Fóra <gy...@apache.org> on 2015/02/14 11:52:30 UTC, 0 replies.
- Measuring Iteration Timings - posted by "Kirschnick, Johannes" <jo...@tu-berlin.de> on 2015/02/14 16:31:51 UTC, 3 replies.
- [jira] [Created] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/14 17:04:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1547) Disable automated ApplicationMaster restart - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/14 17:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1548) [DISCUSS] Make Scala implicit parameters explicit in the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/14 17:28:11 UTC, 0 replies.
- [DISCUSS] Scala code style - explicit vs implicit code behavior - posted by Stephan Ewen <se...@apache.org> on 2015/02/14 17:38:07 UTC, 7 replies.
- [Gelly]Distributed Minimum Spanning Tree Example - posted by Andra Lungu <lu...@gmail.com> on 2015/02/14 18:55:11 UTC, 2 replies.
- [jira] [Created] (FLINK-1549) Add proper exception handling for YarnJobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/14 23:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1550) Show JVM Metrics for JobManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/15 16:11:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1551) Fix History view of JobManager web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/15 19:00:14 UTC, 1 replies.
- [jira] [Created] (FLINK-1552) Allow secondary sorts in Vertex Centric Iteration - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/15 22:16:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1553) Kafka connectors rework - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/02/16 09:05:12 UTC, 0 replies.
- [CANCEL] [VOTE] Release Apache Flink 0.8.1 (RC1) - posted by Robert Metzger <rm...@apache.org> on 2015/02/16 13:48:56 UTC, 0 replies.
- [jira] [Created] (FLINK-1554) LocalFlinkMiniCluster cannot start multiple local TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/16 15:05:11 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.8.1 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2015/02/16 15:54:03 UTC, 6 replies.
- [jira] [Created] (FLINK-1555) Add utility to log the serializers of composite types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/16 16:01:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/16 16:21:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1557) Move WebFrontend out of JobManager Actor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 16:47:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 17:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1559) Normalize all Akka URLs to use IP addresses, not hostnames - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 18:50:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1560) Add ITCases for streaming examples - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/16 23:24:11 UTC, 0 replies.
- [DISCUSS] Create a shaded Hadoop fat jar to resolve library version conflicts - posted by Stephan Ewen <se...@apache.org> on 2015/02/17 09:40:20 UTC, 5 replies.
- [jira] [Created] (FLINK-1561) Improve build server robustness by not reusing JVMs in integration tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:09:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1562) Introduce retries for fetching data from the BLOB manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1563) NullPointer during state update call - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:23:11 UTC, 0 replies.
- [DISCUSS] Dedicated streaming mode and start scripts - posted by Stephan Ewen <se...@apache.org> on 2015/02/17 11:28:58 UTC, 11 replies.
- [jira] [Created] (FLINK-1564) Make sure BLOB client downloads files only once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:48:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1565) Document object reuse behavior - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/17 12:00:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1566) WindowIntegrationTest fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 12:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 12:15:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1568) Add failure-case tests for data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/17 13:30:14 UTC, 0 replies.
- [jira] [Created] (FLINK-1569) Object reuse mode is not working with KeySelector functions. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 13:50:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1570) Add failure-case tests for pipelined data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/17 13:54:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1571) Add failure-case tests for blocking data exchange - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/17 13:55:12 UTC, 0 replies.
- Re: Scala Style Template - posted by Robert Metzger <rm...@apache.org> on 2015/02/17 16:46:08 UTC, 8 replies.
- [jira] [Created] (FLINK-1572) Output directories are created before input paths are checked - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 17:39:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1573) Add per-job metrics to flink. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 18:18:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1574) Flink fails due to non-initialized RuntimeContext in CombiningUnilateralSortMerger - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/17 18:54:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1575) JobManagerConnectionTest.testResolveUnreachableActorRemoteHost times out on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 19:04:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1576) Change the examples to be consistent with the other Flink examples - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/02/17 19:26:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1577) Misleading error messages when cancelling tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/18 11:40:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1578) Overhaul BLOB manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 12:33:11 UTC, 0 replies.
- Snapshot broken? - posted by Arvid Heise <ar...@gmail.com> on 2015/02/18 13:14:52 UTC, 4 replies.
- [jira] [Created] (FLINK-1579) Create a Flink History Server - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 14:23:11 UTC, 0 replies.
- [SUGGESTION] Push latest doc to Flink website - posted by Henry Saputra <he...@gmail.com> on 2015/02/18 16:30:54 UTC, 6 replies.
- [jira] [Created] (FLINK-1580) Cleanup TaskManager initialization logic - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/18 17:59:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1581) Configure DeathWatch parameters properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/18 18:08:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1582) SocketStream gets stuck when socket closes - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/18 18:09:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1583) TaskManager reregistration in case of a restart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/18 18:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1584) Spurious failure of TaskManagerFailsITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/19 11:05:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1585) Fix computation of TaskManager memory for Mini Cluster (tests) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/19 14:38:11 UTC, 0 replies.
- [RESULT] [VOTE] Release Apache Flink 0.8.1 (RC2) - posted by Robert Metzger <rm...@apache.org> on 2015/02/19 17:15:34 UTC, 0 replies.
- [DISCUSS] Gelly iteration abstractions - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/02/19 21:03:30 UTC, 11 replies.
- [jira] [Created] (FLINK-1586) Add support for iteration visualization for Streaming programs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/19 23:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Carsten Brandt (JIRA)" <ji...@apache.org> on 2015/02/20 04:48:13 UTC, 0 replies.
- [jira] [Created] (FLINK-1588) Load flink configuration also from classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/20 12:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1589) Add option to pass Configuration to LocalExecutor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/20 12:03:11 UTC, 0 replies.
- Question about Hadoop profiles in POM - posted by Dániel Bali <ba...@gmail.com> on 2015/02/20 13:05:07 UTC, 3 replies.
- [jira] [Created] (FLINK-1590) Log environment information also in YARN mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/20 15:31:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1591) Remove window merge before flatten as an optimization - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 15:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 15:55:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1593) Improve exception handling int Streaming runtime - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 16:05:14 UTC, 0 replies.
- [jira] [Created] (FLINK-1594) DataStreams don't support self-join - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/02/20 16:41:13 UTC, 2 replies.
- Stale Synchronous Parallel iterations in Flink - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/02/20 17:27:38 UTC, 4 replies.
- [jira] [Created] (FLINK-1595) Add a complex integration test for Streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 22:57:12 UTC, 0 replies.
- [DISCUSS] Should we improve the structure of our Gelly test suite? - posted by Andra Lungu <lu...@gmail.com> on 2015/02/21 18:00:25 UTC, 1 replies.
- [jira] [Created] (FLINK-1596) FileIOChannel introduces space in temp file name - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/21 21:12:11 UTC, 0 replies.
- Flink GZip support - posted by Karim Alaa <ka...@gmail.com> on 2015/02/22 10:02:56 UTC, 2 replies.
- Deprecated error building flink - posted by Dulaj Viduranga <vi...@icloud.com> on 2015/02/22 12:55:51 UTC, 8 replies.
- Could not build up connection to JobManager - Error - posted by Dulaj Viduranga <vi...@icloud.com> on 2015/02/22 16:35:42 UTC, 3 replies.
- [jira] [Created] (FLINK-1597) VertexCentricIterations create inefficient execution plans - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/22 17:12:11 UTC, 0 replies.
- [DISCUSS] Iterative streaming example - posted by Szabó Péter <ne...@gmail.com> on 2015/02/23 11:27:22 UTC, 5 replies.
- [jira] [Created] (FLINK-1598) Give better error messages when serializers run out of space. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/23 13:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1599) TypeComperator - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/23 14:37:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1600) Failure when submitting a job leaves user code libraries in the BLOB manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/23 15:01:12 UTC, 0 replies.
- [jira] [Created] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/23 16:23:13 UTC, 0 replies.
- Could not build up connection to JobManager - posted by Dulaj Viduranga <vi...@icloud.com> on 2015/02/23 18:04:56 UTC, 23 replies.
- Question about scheduling in 0.7 - posted by Nico Scherer <jd...@live.de> on 2015/02/23 22:21:50 UTC, 2 replies.
- [DISCUSS] Discourage using the same class names even though in different packages - posted by Henry Saputra <he...@gmail.com> on 2015/02/24 01:24:30 UTC, 6 replies.
- [jira] [Created] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/24 01:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1603) Update how to contribute doc to include information to send Github PR instead of attaching patch - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/24 01:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1604) Livelock in PartitionRequestClientFactory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 10:47:04 UTC, 0 replies.
- Operating on Serialized Data - posted by "Kirschnick, Johannes" <jo...@tu-berlin.de> on 2015/02/24 11:13:45 UTC, 3 replies.
- [jira] [Created] (FLINK-1605) Create a shaded Hadoop fat jar to resolve library version conflicts - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/24 14:12:04 UTC, 0 replies.
- Subscribe request from a developer - posted by Rahul Kumar Singh <ra...@sigmoidanalytics.com> on 2015/02/24 14:57:24 UTC, 0 replies.
- Apache Flink GSOC 2015 - posted by Kanwarpal Singh <ka...@gmail.com> on 2015/02/24 15:58:39 UTC, 1 replies.
- [jira] [Created] (FLINK-1606) JobManagerFailsITCase fails spuriously for the Hadoop-2.0.0-alpha build profile on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 16:32:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1607) SimpleRecoveryITCase fails spuriously on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 16:35:04 UTC, 0 replies.
- Flink Master broken... - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/02/24 17:29:23 UTC, 8 replies.
- k-means example behavior - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/02/24 18:57:32 UTC, 3 replies.
- [jira] [Created] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 21:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1609) FileSystem doesn't expose current user's home directory - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/25 08:36:04 UTC, 0 replies.
- Understanding and Contributing to Flink - posted by amit pal <am...@gmail.com> on 2015/02/25 11:09:02 UTC, 4 replies.
- Log4j configuration JUnit vs. Scalatest in IntelliJ - posted by Ufuk Celebi <uc...@apache.org> on 2015/02/25 14:02:02 UTC, 2 replies.
- Questions about flink-streaming-examples - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/02/25 16:13:20 UTC, 12 replies.
- [jira] [Created] (FLINK-1610) Java docs do not build - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/25 16:14:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1611) Rename classes and packages with Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/25 19:05:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1612) Add guidelines to avoid duplicate class names and more JavaDoc for new addition - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/26 06:39:04 UTC, 0 replies.
- [jira] [Created] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/02/26 14:37:05 UTC, 0 replies.
- gelli graph algorithm - posted by Martin Neumann <mn...@spotify.com> on 2015/02/26 17:11:31 UTC, 4 replies.
- Drop support for CDH4 / Hadoop 2.0.0-alpha - posted by Robert Metzger <rm...@apache.org> on 2015/02/26 17:57:52 UTC, 3 replies.
- Contributing to Flink - posted by "Rai, Niraj" <ni...@intel.com> on 2015/02/26 22:45:36 UTC, 4 replies.
- Flink Streaming parallelism bug report - posted by Szabó Péter <ne...@gmail.com> on 2015/02/27 09:54:00 UTC, 4 replies.
- [DISCUSS] URI NullPointerException in TestBaseUtils - posted by Szabó Péter <ne...@gmail.com> on 2015/02/27 10:30:49 UTC, 3 replies.
- Re: Tweets Custom Input Format - posted by Mustafa Elbehery <el...@gmail.com> on 2015/02/27 10:37:43 UTC, 5 replies.
- [jira] [Created] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/27 11:26:05 UTC, 0 replies.
- [jira] [Created] (FLINK-1615) Introduces a new InputFormat for Tweets - posted by "mustafa elbehery (JIRA)" <ji...@apache.org> on 2015/02/27 11:56:04 UTC, 0 replies.
- Thoughts About Object Reuse and Collection Execution - posted by Aljoscha Krettek <al...@apache.org> on 2015/02/27 15:36:15 UTC, 3 replies.
- [jira] [Created] (FLINK-1616) Action "list -r" gives IOException when there are running jobs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/27 16:02:04 UTC, 0 replies.
- Queries regarding RDFs with Flink - posted by santosh_rajaguru <sa...@gmail.com> on 2015/02/27 16:48:02 UTC, 0 replies.