issues@flink.apache.org, 2015-02

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

- [GitHub] flink pull request: [FLINK-1201] Add flink-gelly to flink-addons (... - posted by fhueske <gi...@git.apache.org> on 2015/02/01 11:47:45 UTC, 21 replies.
- [jira] [Commented] (FLINK-1201) Graph API for Flink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/01 11:48:34 UTC, 23 replies.
- [jira] [Commented] (FLINK-1462) Add documentation guide for the graph API - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/01 18:12:34 UTC, 15 replies.
- [GitHub] flink pull request: Corrected some typos in comments (removed doub... - posted by asfgit <gi...@git.apache.org> on 2015/02/01 21:50:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1419] [runtime] DC properly synchronize... - posted by fhueske <gi...@git.apache.org> on 2015/02/02 00:24:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 00:24:34 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1419) DistributedCache doesn't preserver files for subsequent operations - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/02 00:44:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1465) GlobalBufferPool reports negative memory allocation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 06:53:35 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1350][FLINK-1359][Distributed runtime] ... - posted by uce <gi...@git.apache.org> on 2015/02/02 07:41:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-1350) Add blocking intermediate result partitions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 07:42:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1105] Add support for locally sorted ou... - posted by rmetzger <gi...@git.apache.org> on 2015/02/02 10:46:09 UTC, 4 replies.
- [jira] [Commented] (FLINK-1105) Add support for locally sorted output - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 10:46:35 UTC, 4 replies.
- [GitHub] flink pull request: Add support for Subclasses, Interfaces, Abstra... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/02 11:08:11 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-1465) GlobalBufferPool reports negative memory allocation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 15:43:34 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1458) Interfaces and abstract classes are not valid types - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/02 15:47:35 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1458] Allow Interfaces and abstract typ... - posted by aljoscha <gi...@git.apache.org> on 2015/02/02 16:11:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-1458) Interfaces and abstract classes are not valid types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 16:12:34 UTC, 5 replies.
- [jira] [Assigned] (FLINK-1465) GlobalBufferPool reports negative memory allocation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 16:32: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.
- [GitHub] flink pull request: [FLINK-1369] [types] Add support for Subclasse... - posted by fhueske <gi...@git.apache.org> on 2015/02/02 16:46:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-1369) The Pojo Serializers/Comparators fail when using Subclasses or Interfaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 16:47:34 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1093) Add non-multiplexing NetworkConnectionManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 18:10:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-819) OutOfMemoryError from TaskManager is causing hard to understand exceptions and blocking JobManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/02 18:12:34 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.
- [GitHub] flink pull request: [FLINK-1318] CsvInputFormat: Made quoted strin... - posted by fhueske <gi...@git.apache.org> on 2015/02/02 18:42:15 UTC, 5 replies.
- [jira] [Commented] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 18:42:35 UTC, 5 replies.
- [GitHub] flink pull request: FLINK-1452: Rename 'flink-addons' to 'flink-st... - posted by fhueske <gi...@git.apache.org> on 2015/02/02 18:56:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-1452) Add "flink-contrib" maven module and README.md with the rules - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 18:56:35 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1452) Add "flink-contrib" maven module and README.md with the rules - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/02 19:44:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA... - posted by rmetzger <gi...@git.apache.org> on 2015/02/02 20:22:20 UTC, 38 replies.
- [jira] [Commented] (FLINK-377) Create a general purpose framework for language bindings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 20:22:34 UTC, 38 replies.
- [GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma... - posted by hsaputra <gi...@git.apache.org> on 2015/02/02 20:28:42 UTC, 0 replies.
- [jira] [Commented] (FLINK-1320) Add an off-heap variant of the managed memory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/02 20:29:34 UTC, 0 replies.
- [GitHub] flink pull request: [Discuss] Simplify SplittableIterator interfac... - posted by fhueske <gi...@git.apache.org> on 2015/02/03 00:28:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-1303) HadoopInputFormat does not work with Scala API - posted by "Yiannis Gkoufas (JIRA)" <ji...@apache.org> on 2015/02/03 01:46:35 UTC, 5 replies.
- [jira] [Updated] (FLINK-1314) Update website about #flink chat room in freenode IRC - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/03 02:56:34 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1314) Update website about #flink chat room in freenode IRC - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/03 02:58:35 UTC, 0 replies.
- [GitHub] flink pull request: Allow KeySelectors to implement ResultTypeQuer... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 09:51:34 UTC, 7 replies.
- [GitHub] flink pull request: Improved exception for missing type of InputFo... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 10:22:06 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1376] [runtime] Add proper shared slot ... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 10:27:08 UTC, 6 replies.
- [jira] [Commented] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 10:27:35 UTC, 8 replies.
- [jira] [Created] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/03 10:36:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 10:37:34 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-1437][Java API] Fixes copy() methods in... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 10:44:35 UTC, 2 replies.
- [jira] [Commented] (FLINK-1437) Bug in PojoSerializer's copy() method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 10:45:34 UTC, 7 replies.
- [jira] [Resolved] (FLINK-1105) Add support for locally sorted output - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/03 11:14:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1193][java-api][scala-api] Complete sup... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 11:41:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 11:42:34 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1464] Add ResultTypeQueryable interface... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/03 11:58:03 UTC, 1 replies.
- [jira] [Commented] (FLINK-1464) Added ResultTypeQueryable interface to TypeSerializerInputFormat. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 11:58:35 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1165] No createCollectionsEnvironment i... - posted by asfgit <gi...@git.apache.org> on 2015/02/03 13:23:59 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1165) No createCollectionsEnvironment in Java API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 13:24:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-1165) No createCollectionsEnvironment in Java API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 13:24:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 13:25:35 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1193) InvalidTypesException for Array[Array[Tuple2[Int, Double]]] - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 13:26:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1437) Bug in PojoSerializer's copy() method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 13:28:34 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1471) Allow KeySelectors to implement ResultTypeQueryable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/03 14:11:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1464) Added ResultTypeQueryable interface to TypeSerializerInputFormat. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/03 14:11:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1330] [build] Build creates a link in t... - posted by asfgit <gi...@git.apache.org> on 2015/02/03 14:39:42 UTC, 3 replies.
- [jira] [Commented] (FLINK-1330) Restructure directory layout - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 14:40:34 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1330) Restructure directory layout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 14:45:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1326) The output serializers may consume excessive memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 14:48:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/03 15:28:34 UTC, 2 replies.
- [jira] [Resolved] (FLINK-758) Add count method to DataSet and implement CountOperator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/03 16:11:34 UTC, 0 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:34 UTC, 0 replies.
- [jira] [Resolved] (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/03 17:15:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1314) Update website about #flink chat room in freenode IRC - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/03 17:54:34 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-592] Add support for Kerberos secured Y... - posted by rmetzger <gi...@git.apache.org> on 2015/02/03 18:28:33 UTC, 7 replies.
- [jira] [Commented] (FLINK-592) Add support for secure YARN clusters with Kerberos Auth - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/03 18:28:37 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-1471][java-api] Fixes wrong input valid... - posted by twalthr <gi...@git.apache.org> on 2015/02/03 22:55:47 UTC, 9 replies.
- [jira] [Resolved] (FLINK-1314) Update website about #flink chat room in freenode IRC - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/04 00:56:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1442] Reduce memory consumption of arch... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/04 10:45:54 UTC, 20 replies.
- [jira] [Commented] (FLINK-1442) Archived Execution Graph consumes too much memory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/04 10:46:34 UTC, 20 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] [Resolved] (FLINK-1473) Simplify SplittableIterator interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/04 15:22:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1473) Simplify SplittableIterator interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/04 15:23:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-592) Add support for secure YARN clusters with Kerberos Auth - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/04 15:59:34 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.
- [GitHub] flink pull request: [FLINK1443] Add support for replicating input ... - posted by fhueske <gi...@git.apache.org> on 2015/02/04 16:29:59 UTC, 3 replies.
- [GitHub] flink pull request: [docs] add documentation for FLink GCE setup u... - posted by mxm <gi...@git.apache.org> on 2015/02/04 16:33:08 UTC, 3 replies.
- [jira] [Closed] (FLINK-1474) Cross produces wrong results for non-tiny inputs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 17:26:35 UTC, 0 replies.
- [GitHub] flink pull request: Qa bot - posted by flinkqa <gi...@git.apache.org> on 2015/02/04 17:27:48 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1396][FLINK-1303] Hadoop Input/Output d... - posted by aljoscha <gi...@git.apache.org> on 2015/02/04 17:54:32 UTC, 14 replies.
- [jira] [Commented] (FLINK-1396) Add hadoop input formats directly to the user API. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/04 17:54:35 UTC, 14 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.
- [jira] [Resolved] (FLINK-823) Improve Semantic Annotations - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 20:53:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-837) Allow FunctionAnnotations on Methods - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 21:06:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-1388) POJO support for writeAsCsv - posted by "Adnan Khan (JIRA)" <ji...@apache.org> on 2015/02/04 22:29:34 UTC, 16 replies.
- [jira] [Updated] (FLINK-1388) POJO support for writeAsCsv - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 22:31:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-178) Memory-Temping Data Sink / Source - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 22:56:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-1180) Add support for Hadoop MapReduce.* API Mappers and Reducers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 23:04:36 UTC, 1 replies.
- [jira] [Closed] (FLINK-1296) Add support for very large record for sorting - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 23:15:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-454) Add ProgramInput/OutputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 23:22:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-1466) Add InputFormat to read HCatalog tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 23:33:35 UTC, 0 replies.
- [jira] [Closed] (FLINK-228) Evaluate HCatalog - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/04 23:33:35 UTC, 0 replies.
- [jira] [Created] (FLINK-1476) Flink VS Spark on loop test - posted by "xuhong (JIRA)" <ji...@apache.org> on 2015/02/05 04:22:34 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] [Updated] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/05 09:49:34 UTC, 3 replies.
- [jira] [Commented] (FLINK-1476) Flink VS Spark on loop test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 09:50:34 UTC, 5 replies.
- [jira] [Resolved] (FLINK-837) Allow FunctionAnnotations on Methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 10:18:34 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] [Resolved] (FLINK-1477) YARN Client: Use HADOOP_HOME if set - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/05 11:16:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1318) Make quoted String parsing optional and configurable for CSVInputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/05 11:33:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1443) Add replicated data source - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/05 11:34: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:35 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1415] Akka cleanups - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/05 12:21:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-1415) Akka cleanups - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 12:21:35 UTC, 1 replies.
- [jira] [Updated] (FLINK-1288) YARN ApplicationMaster sometimes fails to allocate the specified number of workers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 13:34:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1299) Remove default values for JobManager and TaskManager heap sizes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 13:38:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1442) Archived Execution Graph consumes too much memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 13:40:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1299) Remove default values for JobManager and TaskManager heap sizes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/05 13:42:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1463] Fix stateful/stateless Serializer... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/05 14:06:58 UTC, 7 replies.
- [jira] [Commented] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 14:07:34 UTC, 7 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.
- [jira] [Commented] (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:13:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1319) Add static code analysis for UDFs - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/02/05 14:31:34 UTC, 0 replies.
- [GitHub] flink pull request: yarn client tests - posted by StephanEwen <gi...@git.apache.org> on 2015/02/05 14:35:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-883) Use MiniYARNCluster to test the Flink YARN client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 14:35:35 UTC, 1 replies.
- [jira] [Resolved] (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:46:34 UTC, 0 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.
- [GitHub] flink pull request: Port FLINK-1391 and FLINK-1392 to "release-0.8... - posted by rmetzger <gi...@git.apache.org> on 2015/02/05 14:59:57 UTC, 2 replies.
- [jira] [Commented] (FLINK-1391) Kryo fails to properly serialize avro collection types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 15:00:38 UTC, 9 replies.
- [jira] [Closed] (FLINK-1415) Akka cleanups - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 15:01: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.
- [GitHub] flink pull request: [FLINK-1422] Add withParameters() to documenta... - posted by zentol <gi...@git.apache.org> on 2015/02/05 15:41:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-1422) Missing usage example for "withParameters" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 15:41:34 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1481] Fixes flakey JobManagerITCase - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/05 15:50:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-1481) Flakey JobManagerITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 15:51:35 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1480) Test Flink against Hadoop 2.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/05 16:29:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1166] Add qa-check.sh tool - posted by rmetzger <gi...@git.apache.org> on 2015/02/05 17:32:24 UTC, 10 replies.
- [jira] [Commented] (FLINK-1166) Add a QA bot to Flink that is testing pull requests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 17:32:35 UTC, 11 replies.
- [jira] [Closed] (FLINK-1481) Flakey JobManagerITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 17:57:34 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1482] [runtime] Adds shutdown hook to d... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/05 18:32:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-1482) BlobStore does not delete directories when process is killed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 18:32:37 UTC, 2 replies.
- [jira] [Closed] (FLINK-1482) BlobStore does not delete directories when process is killed - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/05 18:37:34 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] [Updated] (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:41:34 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/05 19:41:36 UTC, 1 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:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1484] Adds explicit disconnect message ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/05 21:05:57 UTC, 11 replies.
- [jira] [Commented] (FLINK-1484) JobManager restart does not notify the TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/05 21:06:34 UTC, 14 replies.
- [GitHub] flink pull request: Typo in - Join with Join-Function - posted by jkirsch <gi...@git.apache.org> on 2015/02/05 21:51:36 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.
- [jira] [Updated] (FLINK-1485) Typo in Documentation - Join with Join-Function - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/05 21:58:36 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1478) Add strictly local input split assignment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/06 10:05:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1445) Add support to enforce local input split assignment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/06 10:06:35 UTC, 0 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] [Commented] (FLINK-1486) Add a string to the print method to identify output - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/06 13:06:34 UTC, 10 replies.
- [jira] [Commented] (FLINK-1470) JobManagerITCase fails on Travis - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/06 13:48:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/06 13:58:34 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1486) Add a string to the print method to identify output - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/06 14:24: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.
- [GitHub] flink pull request: [FLINK-785] Chained AllReduce - posted by zentol <gi...@git.apache.org> on 2015/02/06 14:40:12 UTC, 5 replies.
- [jira] [Commented] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/06 14:40:34 UTC, 14 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] [Resolved] (FLINK-1488) JobManager web interface logfile access broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/06 14:50:35 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.
- [jira] [Commented] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/06 15:22:51 UTC, 15 replies.
- [GitHub] flink pull request: Remove 'incubator-' prefix from README.md. - posted by aalexandrov <gi...@git.apache.org> on 2015/02/06 15:23:12 UTC, 2 replies.
- [jira] [Closed] (FLINK-1470) JobManagerITCase fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/06 15:42:34 UTC, 0 replies.
- [jira] [Resolved] (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 16:03:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1485] Typo in Documentation - Join with... - posted by fhueske <gi...@git.apache.org> on 2015/02/06 16:15:03 UTC, 3 replies.
- [jira] [Commented] (FLINK-1485) Typo in Documentation - Join with Join-Function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/06 16:15:34 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1485) Typo in Documentation - Join with Join-Function - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/06 16:16:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1486] add print method for prefixing a ... - posted by mxm <gi...@git.apache.org> on 2015/02/06 17:00:41 UTC, 7 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.
- [jira] [Updated] (FLINK-456) Optional runtime statistics collection - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/06 18:12:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-456) Optional runtime statistics / metrics collection - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/06 18:12:35 UTC, 0 replies.
- [jira] [Assigned] (FLINK-456) Optional runtime statistics / metrics collection - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/06 18:12:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1438) ClassCastException for Custom InputSplit in local mode and invalid type code in distributed mode - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/06 18:48:34 UTC, 0 replies.
- [GitHub] flink pull request: Remove unused enum values from Aggregations en... - posted by hsaputra <gi...@git.apache.org> on 2015/02/06 19:11:48 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-1476) Flink VS Spark on loop test - posted by "xuhong (JIRA)" <ji...@apache.org> on 2015/02/07 07:51:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-1476) Flink VS Spark on loop test - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/07 10:11:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1390) java.lang.ClassCastException: X cannot be cast to X - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/07 10:20:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1438) ClassCastException for Custom InputSplit in local mode and invalid type code in distributed mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/07 20:41:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-98) Temp Files are not removed if job fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:21:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:29:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:29:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1396) Add hadoop input formats directly to the user API. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:29:36 UTC, 0 replies.
- [jira] [Updated] (FLINK-1340) Project restructure - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:30:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:33:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1309) Upload Flink logo with Flink name - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:34:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1278) Remove the Record special code paths - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:34:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:34:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1294) Add Performance and Tuning Guide to documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:34:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1256) Use Kryo for user code object serialization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:35:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1116) Packaged Scala Examples do not work due to missing test data - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:35:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-871) Create a documentation distribution together with other release artifacts - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:38:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-687) Add support for outer-joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:40:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-603) Add Spargel GAS pattern - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:40:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-685) Add support for semi-joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:40:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-788) Enable combiner for Reduce with Broadcast Variable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:41:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:41:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-1219) Add support for Apache Tez as execution engine - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/08 00:42:35 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1179] Add button to JobManager web inte... - posted by chiwanpark <gi...@git.apache.org> on 2015/02/08 08:54:59 UTC, 12 replies.
- [jira] [Commented] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/08 08:55:34 UTC, 12 replies.
- [jira] [Commented] (FLINK-1493) Support for streaming jobs preserving global ordering of records - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/02/08 19:19:34 UTC, 3 replies.
- [GitHub] flink pull request: Add support for strictly local input splits - posted by StephanEwen <gi...@git.apache.org> on 2015/02/08 19:45:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-703) Use complete element as join key. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/02/09 01:52:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1478] Add support for strictly local in... - posted by rmetzger <gi...@git.apache.org> on 2015/02/09 10:11:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-1478) Add strictly local input split assignment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/09 10:12:34 UTC, 5 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] [Commented] (FLINK-1475) Minimize log output of yarn test cases - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 11:52:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1475) Minimize log output of yarn test cases - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 11:52:35 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1492] Fix exceptions on blob store shut... - posted by uce <gi...@git.apache.org> on 2015/02/09 11:53:42 UTC, 13 replies.
- [jira] [Commented] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 13:10:34 UTC, 4 replies.
- [jira] [Updated] (FLINK-1342) Quickstart's assembly can possibly filter out user's code - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 13:15:34 UTC, 1 replies.
- [jira] [Commented] (FLINK-1494) Build fails on BlobCacheTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/09 13:35:34 UTC, 0 replies.
- [jira] [Closed] (FLINK-1494) Build fails on BlobCacheTest - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/09 13:39:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1463) RuntimeStatefulSerializerFactory declares ClassLoader as transient but later tries to use it - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/09 13:40:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1479) The spawned threads in the sorter have no context class loader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 13:50:34 UTC, 0 replies.
- [jira] [Updated] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 14:00:38 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1396) Add hadoop input formats directly to the user API. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/09 14:45:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1303) HadoopInputFormat does not work with Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/09 14:45:35 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.
- [jira] [Updated] (FLINK-1391) Kryo fails to properly serialize avro collection types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 14:50:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-1392) Serializing Protobuf - issue 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 14:51:35 UTC, 1 replies.
- [jira] [Commented] (FLINK-1392) Serializing Protobuf - issue 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 14:51:36 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1495][yarn] Make Akka timeout configura... - posted by rmetzger <gi...@git.apache.org> on 2015/02/09 14:53:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-1495) Make Akka timeout configurable in YARN client. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/09 14:53:35 UTC, 3 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.
- [jira] [Commented] (FLINK-1497) No documentation on MiniCluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/09 15:54:34 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1478) Add strictly local input split assignment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/09 16:02:34 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1489] Fixes blocking scheduleOrUpdateCo... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/09 17:37:29 UTC, 11 replies.
- [jira] [Commented] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/09 17:37:34 UTC, 11 replies.
- [jira] [Closed] (FLINK-1376) SubSlots are not properly released in case that a TaskManager fatally fails, leaving the system in a corrupted state - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/09 17:50:35 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:37 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] [Resolved] (FLINK-1498) Spurious failures on Travis for I/O heavy tasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/09 19:01:36 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1495) Make Akka timeout configurable in YARN client. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 19:07:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-456) Integrate runtime metrics / statistics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/09 19:08:36 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:35 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] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/09 21:45:34 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1444][api-extending] Add support for sp... - posted by fhueske <gi...@git.apache.org> on 2015/02/09 23:06:42 UTC, 3 replies.
- [jira] [Commented] (FLINK-1444) Add data properties for data sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/09 23:07:35 UTC, 3 replies.
- [jira] [Commented] (FLINK-703) Use complete element as join key. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/10 00:36:34 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1496] [distributed runtime] Fix loss of... - posted by uce <gi...@git.apache.org> on 2015/02/10 09:55:24 UTC, 2 replies.
- [jira] [Commented] (FLINK-1496) Events at unitialized input channels are lost - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/10 09:55:35 UTC, 2 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] [Commented] (FLINK-1432) CombineTaskTest.testCancelCombineTaskSorting sometimes fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/10 10:35: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:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1508) Remove AkkaUtils.ask to encourage explicit future handling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/10 13:27:11 UTC, 7 replies.
- [jira] [Resolved] (FLINK-1369) The Pojo Serializers/Comparators fail when using Subclasses or Interfaces - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/10 14:14:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1461) Add sortPartition operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/10 16:02:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1343) Branching Join Program Deadlocks - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/10 16:27:11 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1492) Exceptions on shutdown concerning BLOB store cleanup - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/10 16:48:11 UTC, 0 replies.
- [jira] [Created] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/10 18:33:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1461][api-extending] Add SortPartition ... - posted by fhueske <gi...@git.apache.org> on 2015/02/11 09:35:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-1461) Add sortPartition operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/11 09:36:11 UTC, 3 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.
- [GitHub] flink pull request: [FLINK-1510] Make AvroInputFormat splittable - posted by rmetzger <gi...@git.apache.org> on 2015/02/11 10:34:59 UTC, 6 replies.
- [jira] [Commented] (FLINK-1510) Make AvroInputFormat splittable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/11 10:35:13 UTC, 6 replies.
- [jira] [Commented] (FLINK-1511) Scala classes not identified as Pojos - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/02/11 10:43:11 UTC, 3 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.
- [jira] [Assigned] (FLINK-1511) Scala classes not identified as Pojos - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/11 11:07:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1496) Events at unitialized input channels are lost - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/11 11:17:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1511) Scala classes not identified as Pojos - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/11 11:17:12 UTC, 0 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] [Commented] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 12:40:11 UTC, 25 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:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1514) [Gelly] Add a Gather-Sum-Apply iteration method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 12:59:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-603) Add Spargel GAS pattern - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 13:05:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-603) Add Spargel GAS pattern - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 13:05:12 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] [Updated] (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:12 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] [Reopened] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/11 14:27:11 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1455) ExternalSortLargeRecordsITCase.testSortWithShortMediumAndLargeRecords: Potential Memory leak - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/11 14:29:11 UTC, 0 replies.
- [jira] [Commented] (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:30: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:11 UTC, 0 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] [Commented] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/11 15:19:11 UTC, 9 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:11 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] [Assigned] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/11 15:55:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/11 15:56:12 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] [Commented] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/11 15:57: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-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] [Assigned] (FLINK-785) Add Chained operators for AllReduce and AllGroupReduce - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/11 15:59:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/11 15:59: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.
- [jira] [Updated] (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 16:07:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1524) Job Manager does not handle the RequestArchivedJobs message - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/11 16:27:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 17:06:11 UTC, 2 replies.
- [jira] [Commented] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 17:08:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 17:08:12 UTC, 0 replies.
- [GitHub] flink pull request: support for secure HDFS access using kerberos - posted by mxm <gi...@git.apache.org> on 2015/02/11 17:16:20 UTC, 1 replies.
- [jira] [Commented] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/11 17:22:11 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1508] Removes AkkaUtil.ask - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/11 17:25:13 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1504] support for secure HDFS access us... - posted by rmetzger <gi...@git.apache.org> on 2015/02/11 17:30:43 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1489) Failing JobManager due to blocking calls in Execution.scheduleOrUpdateConsumers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 17:36:11 UTC, 0 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.
- [jira] [Updated] (FLINK-1499) Make TaskManager to disconnect from JobManager in case of a restart - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/11 18:05:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1504) Add support for accessing secured HDFS clusters in standalone mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 18:24:13 UTC, 0 replies.
- [jira] [Closed] (FLINK-1491) Inconsistent logging between Akka and other components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/11 18:57:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1515) [Gelly] Enable access to aggregators and broadcast sets in vertex-centric iteration - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/11 20:23:11 UTC, 13 replies.
- [jira] [Updated] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/11 20:30:12 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1530) Cache ExecutionConfig in AbstractInvokable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/11 20:44:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1529] [jobmanager] Improve error handli... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/11 20:48:18 UTC, 11 replies.
- [jira] [Commented] (FLINK-1529) Improve JobManager startup robustness - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/11 20:49:11 UTC, 11 replies.
- [jira] [Resolved] (FLINK-1411) PlanVisualizer is not working - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/11 22:16:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1512) Add CsvReader for reading into POJOs. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/02/12 06:45:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1512) Add CsvReader for reading into POJOs. - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/02/12 06:48:12 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1436] refactor CLiFrontend to provide m... - posted by mxm <gi...@git.apache.org> on 2015/02/12 11:34:19 UTC, 5 replies.
- [jira] [Commented] (FLINK-1436) Command-line interface verbose option & error reporting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/12 11:35:11 UTC, 5 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] [Updated] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/12 11:42:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-1437) Bug in PojoSerializer's copy() method - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/02/12 11:42:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/12 12:10:11 UTC, 11 replies.
- [jira] [Resolved] (FLINK-1432) CombineTaskTest.testCancelCombineTaskSorting sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/12 12:21:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1525) Provide utils to pass -D parameters to UDFs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/12 12:23:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1391] Register common Avro types at Kry... - posted by rmetzger <gi...@git.apache.org> on 2015/02/12 12:33:29 UTC, 5 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.
- [GitHub] flink pull request: [FLINK-1533] [runtime] Fixes NPE in the schedu... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/12 14:55:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-1533) NullPointerException in SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/12 14:56:12 UTC, 3 replies.
- [GitHub] flink pull request: [builds] Print Java process stack traces of st... - posted by uce <gi...@git.apache.org> on 2015/02/12 15:24:03 UTC, 4 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, 0 replies.
- [jira] [Updated] (FLINK-1534) GSoC project: Distributed pattern matching over Flink streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/12 15:28:11 UTC, 0 replies.
- [GitHub] flink pull request: [builds] Notify dev@f.a.o about travis-ci buil... - posted by uce <gi...@git.apache.org> on 2015/02/12 15:33:14 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1510) Make AvroInputFormat splittable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/12 15:41:13 UTC, 0 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] [Resolved] (FLINK-1424) bin/flink run does not recognize -c parameter anymore - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/12 16:38:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1531] Fixes KryoSerializer's EOFExcepti... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/12 16:57:52 UTC, 5 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.
- [jira] [Closed] (FLINK-1531) Custom Kryo Serializer fails in itertation scenario - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/12 18:42:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1533) NullPointerException in SlotSharingGroupAssignment.addSharedSlotAndAllocateSubSlot - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/12 18:43:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/02/12 20:35:13 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1436) Command-line interface verbose option & error reporting - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/12 21:15:11 UTC, 0 replies.
- [GitHub] flink commit comment: 988602b031b63deb9640b115b798e9ae54fb7357 - posted by mbalassi <gi...@git.apache.org> on 2015/02/12 22:17:25 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1521] Chained operators respect reuse - posted by zentol <gi...@git.apache.org> on 2015/02/13 01:01:34 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-785] Chained AllReduce / AllGroupReduce... - posted by zentol <gi...@git.apache.org> on 2015/02/13 01:04:00 UTC, 8 replies.
- [jira] [Resolved] (FLINK-1339) Adding a latest symbolic link to current doc version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/13 09:35:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "Carsten Brandt (JIRA)" <ji...@apache.org> on 2015/02/13 12:10:11 UTC, 3 replies.
- [jira] [Commented] (FLINK-1532) AggregatorsITCase fails spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/13 12:24:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/13 12:30:11 UTC, 1 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] [Closed] (FLINK-1517) Modify inputiterator for streaming so the channel index of the last record is accessible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/13 15:13:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1537) GSoC project: Machine learning with Apache Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/13 16:12:11 UTC, 1 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-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/13 17:06: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] [Updated] (FLINK-1541) GSoC project: Distributed profiling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/13 17:07:11 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] [Resolved] (FLINK-1529) Improve JobManager startup robustness - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/13 17:36:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1532) AggregatorsITCase fails spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/13 17:37:11 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.
- [jira] [Assigned] (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:54:11 UTC, 0 replies.
- [jira] [Commented] (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:55:11 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1417] Automatically register types with... - posted by rmetzger <gi...@git.apache.org> on 2015/02/13 18:44:11 UTC, 11 replies.
- [jira] [Commented] (FLINK-1417) Automatically register nested types at Kryo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/13 18:44:12 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-1543] Adds better exception handling in... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/13 18:54:05 UTC, 10 replies.
- [jira] [Commented] (FLINK-1543) Proper exception handling in actors - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/13 18:54:11 UTC, 12 replies.
- [jira] [Assigned] (FLINK-1539) Runtime context not initialized when running streaming PojoExample - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/13 19:16:12 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.
- [GitHub] flink pull request: StreamWindow abstraction + modular window comp... - posted by gyfora <gi...@git.apache.org> on 2015/02/13 20:47:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-1539) Runtime context not initialized when running streaming PojoExample - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/13 20:55:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1176) Add operator for global reduce/aggregations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/13 20:56:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-1538) GSoC project: Spatial Data Processing Library - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/13 21:42:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1542] Test case at BlobUtilsTest should... - posted by hsaputra <gi...@git.apache.org> on 2015/02/13 22:47:34 UTC, 7 replies.
- [jira] [Comment Edited] (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 23:00:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1107) Document how to use Avro files and the Hadoop Input Format Wrappers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/13 23:28: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.
- [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] [Commented] (FLINK-1547) Disable automated ApplicationMaster restart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/14 17:21:11 UTC, 3 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.
- [jira] [Closed] (FLINK-1508) Remove AkkaUtils.ask to encourage explicit future handling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/14 18:12:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1543) Proper exception handling in actors - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/14 18:12:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1539) Runtime context not initialized when running streaming PojoExample - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/14 20:14:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1546) Failed job causes JobManager to shutdown due to uncatched WebFrontend exception - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/14 20:14:12 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1179) Add button to JobManager web interface to request stack trace of a TaskManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/14 21:07:12 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1549] Adds proper exception handling to... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/14 23:46:07 UTC, 4 replies.
- [jira] [Commented] (FLINK-1549) Add proper exception handling for YarnJobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/14 23:46:11 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1487] Fixes ScheduleIsolatedTasksTest.t... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/15 11:04:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-1362) Spurious errors in execution state messaging between TaskManager and JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/15 11:16:11 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1545] Fixes AsynchronousFileIOChannelsT... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/15 12:38:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-1545) Spurious failure of AsynchronousFileIOChannelsTest.testExceptionForwardsToClose - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/15 12:38:11 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-1303) HadoopInputFormat does not work with Scala API - posted by "Yiannis Gkoufas (JIRA)" <ji...@apache.org> on 2015/02/15 13:57:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/15 16:11: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, 0 replies.
- [jira] [Commented] (FLINK-1551) Fix History view of JobManager web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/15 19:06:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1487) Failing SchedulerIsolatedTasksTest.testScheduleQueueing test case - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/15 19:35:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1545) Spurious failure of AsynchronousFileIOChannelsTest.testExceptionForwardsToClose - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/15 19:39:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1528] Added local clustering coefficien... - posted by balidani <gi...@git.apache.org> on 2015/02/15 20:04:53 UTC, 4 replies.
- [jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/15 20:05:11 UTC, 7 replies.
- [GitHub] flink pull request: Fix standalone plan visualizer for 0.8 branch - posted by StephanEwen <gi...@git.apache.org> on 2015/02/15 21:08:02 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1515]Splitted runVertexCentricIteration... - posted by martinkiefer <gi...@git.apache.org> on 2015/02/15 21:46:39 UTC, 10 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] [Commented] (FLINK-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/15 22:47:11 UTC, 3 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.
- [jira] [Closed] (FLINK-1551) Fix History view of JobManager web interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/16 10:29:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1231] Add test for streaming remote exe... - posted by mbalassi <gi...@git.apache.org> on 2015/02/16 10:31:07 UTC, 1 replies.
- [jira] [Commented] (FLINK-1231) Add test for streaming remote execution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 10:31:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-1362) Spurious errors in execution state messaging between TaskManager and JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/16 13:20:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1552) Allow secondary sorts in Vertex Centric Iteration - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/16 14:42:11 UTC, 3 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.
- [GitHub] flink pull request: [FLINK-1554] Allows the LocalFlinkMiniCluster ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/16 15:07:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-1554) LocalFlinkMiniCluster cannot start multiple local TaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 15:08:11 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1454] [job client] Improve error handli... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/16 15:14:47 UTC, 2 replies.
- [jira] [Closed] (FLINK-1231) Add test for streaming remote execution - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/16 15:27:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1176) Add operator for global reduce/aggregations - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/16 15:29:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1539) Runtime context not initialized when running streaming PojoExample - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/16 15:31:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-947] Add a declarative expression API - posted by aljoscha <gi...@git.apache.org> on 2015/02/16 15:35:17 UTC, 10 replies.
- [jira] [Commented] (FLINK-947) Add support for "Named Datasets" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 15:36:11 UTC, 10 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.
- [GitHub] flink pull request: [FLINK-1556] Corrects faulty JobClient behavio... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/16 16:31:40 UTC, 6 replies.
- [jira] [Commented] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 16:32:11 UTC, 8 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:12 UTC, 0 replies.
- [GitHub] flink pull request: [builds] Allow to upload build artifacts to S3 - posted by uce <gi...@git.apache.org> on 2015/02/16 17:34:18 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-1514][Gelly] Add a Gather-Sum-Apply ite... - posted by balidani <gi...@git.apache.org> on 2015/02/16 18:12:19 UTC, 22 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:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1454) CliFrontend blocks for 100 seconds when submitting to a non-existent JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 20:47:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1559) Normalize all Akka URLs to use IP addresses, not hostnames - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 20:48:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1542) Test case at BlobUtilsTest should not assume user could not create new item in root directory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/16 20:55:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1557] Move JobManager web frontend serv... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/16 21:06:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-1557) Move WebFrontend out of JobManager Actor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 21:06:11 UTC, 1 replies.
- [GitHub] flink pull request: Add auto-parallelism to Jobs (0.8 branch) - posted by StephanEwen <gi...@git.apache.org> on 2015/02/16 22:04:41 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-1466] Add HCatInputFormats to read from... - posted by fhueske <gi...@git.apache.org> on 2015/02/16 22:45:30 UTC, 5 replies.
- [jira] [Commented] (FLINK-1466) Add InputFormat to read HCatalog tables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/16 22:46:11 UTC, 5 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.
- [jira] [Resolved] (FLINK-1557) Move WebFrontend out of JobManager Actor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 10:51:11 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1561] [build system] Use a fresh fork f... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/17 11:18:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-1561) Improve build server robustness by not reusing JVMs in integration tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/17 11:19:11 UTC, 3 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.
- [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:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-1564) Make sure BLOB client downloads files only once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:49:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1564) Make sure BLOB client downloads files only once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/17 11:50: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] [Commented] (FLINK-1563) NullPointer during state update call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 12:02:13 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:11 UTC, 0 replies.
- [jira] [Closed] (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/17 13:26:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1563) NullPointer during state update call - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 13:26:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1549) Add proper exception handling for YarnJobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 13:27:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1554) LocalFlinkMiniCluster cannot start multiple local TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 13:27:11 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] [Commented] (FLINK-1566) WindowIntegrationTest fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/17 13:33:11 UTC, 1 replies.
- [jira] [Assigned] (FLINK-952) TypeExtractor requires the argument types of the UDF to be identical to the parameter types - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 13:45:13 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.
- [jira] [Closed] (FLINK-1351) Inconclusive error when TaskManager cannot connect to JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/17 14:07:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1567] Add switch to use the AvroSeriali... - posted by rmetzger <gi...@git.apache.org> on 2015/02/17 14:13:54 UTC, 10 replies.
- [jira] [Commented] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/17 14:14:11 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-1522][gelly] Added test for SSSP Exampl... - posted by andralungu <gi...@git.apache.org> on 2015/02/17 14:20:32 UTC, 6 replies.
- [jira] [Commented] (FLINK-1522) Add tests for the library methods and examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/17 14:21:12 UTC, 10 replies.
- [jira] [Issue Comment Deleted] (FLINK-1522) Add tests for the library methods and examples - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/02/17 15:38:37 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1522) Add tests for the library methods and examples - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/02/17 15:48:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 17:00:13 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/17 17:16:11 UTC, 0 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:11 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] [Updated] (FLINK-1576) Change the Gelly 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, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-1388) POJO support for writeAsCsv - posted by "Adnan Khan (JIRA)" <ji...@apache.org> on 2015/02/17 23:08:13 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1388) POJO support for writeAsCsv - posted by "Adnan Khan (JIRA)" <ji...@apache.org> on 2015/02/17 23:11:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1574) Flink fails due to non-initialized RuntimeContext in CombiningUnilateralSortMerger - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/17 23:30:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Fay Beligianni (JIRA)" <ji...@apache.org> on 2015/02/18 00:13:12 UTC, 10 replies.
- [jira] [Closed] (FLINK-1575) JobManagerConnectionTest.testResolveUnreachableActorRemoteHost times out on travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 10:40:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1573) Add per-job metrics to flink. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 11:05: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] [Commented] (FLINK-1577) Misleading error messages when cancelling tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/18 11:41:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1566) WindowIntegrationTest fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/18 12:07: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.
- [jira] [Resolved] (FLINK-1561) Improve build server robustness by not reusing JVMs in integration tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 12:43:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1564) Make sure BLOB client downloads files only once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 12:44:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1562) Introduce retries for fetching data from the BLOB manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 12:45:11 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1552) Allow secondary sorts in Vertex Centric Iteration - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/18 12:48:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1548) [DISCUSS] Make Scala implicit parameters explicit in the runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 13:07:11 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/18 13:08:13 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1555] Add serializer hierarchy debug ut... - posted by rmetzger <gi...@git.apache.org> on 2015/02/18 13:29:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-1555) Add utility to log the serializers of composite types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/18 13:30:12 UTC, 3 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.
- [jira] [Commented] (FLINK-1579) Create a Flink History Server - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 14:28:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1578) Overhaul BLOB manager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/18 15:07:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1201) Graph API for Flink - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/18 15:27:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1395) Add Jodatime support to Kryo - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 16:39:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1392) Serializing Protobuf - issue 1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 16:40:14 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1391) Kryo fails to properly serialize avro collection types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 16:41:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1417) Automatically register nested types at Kryo - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 16:42:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1567) Add option to switch between Avro and Kryo serialization for GenericTypes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/18 16:49:11 UTC, 0 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] [Updated] (FLINK-1582) SocketStream gets stuck when socket closes - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/18 18:12:11 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Fay Beligianni (JIRA)" <ji...@apache.org> on 2015/02/18 18:14:11 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.
- [GitHub] flink pull request: Remove extra space after open parenthesis in I... - posted by hsaputra <gi...@git.apache.org> on 2015/02/18 20:03:53 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1483] IOManager puts temp files in dedi... - posted by StephanEwen <gi...@git.apache.org> on 2015/02/18 20:07:09 UTC, 5 replies.
- [jira] [Commented] (FLINK-1483) Temporary channel files are not properly deleted when Flink is terminated - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/18 20:07:11 UTC, 5 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.
- [GitHub] flink pull request: [FLINK-1584] Fixes TaskManagerFailsITCase - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/19 11:30:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-1584) Spurious failure of TaskManagerFailsITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/19 11:31:13 UTC, 5 replies.
- [jira] [Resolved] (FLINK-1483) Temporary channel files are not properly deleted when Flink is terminated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/19 11:55:11 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.
- [jira] [Commented] (FLINK-1585) Fix computation of TaskManager memory for Mini Cluster (tests) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/19 14:39:11 UTC, 0 replies.
- [GitHub] flink pull request: Added Local Clustering Coefficient Example (He... - posted by balidani <gi...@git.apache.org> on 2015/02/19 15:03:03 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1501] Add metrics library for monitorin... - posted by rmetzger <gi...@git.apache.org> on 2015/02/19 15:27:27 UTC, 10 replies.
- [jira] [Commented] (FLINK-1501) Integrate metrics library and report basic metrics to JobManager web interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/19 15:28:11 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-1484] [FLINK-1499] Adds explicit discon... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/19 16:34:14 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1582][streaming]Allow SocketStream to r... - posted by qmlmoon <gi...@git.apache.org> on 2015/02/19 17:38:45 UTC, 5 replies.
- [jira] [Commented] (FLINK-1582) SocketStream gets stuck when socket closes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/19 17:39:12 UTC, 6 replies.
- [GitHub] flink pull request: Small UI css class fix - posted by cebe <gi...@git.apache.org> on 2015/02/19 18:11:28 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1512] Add CsvReader for reading into PO... - posted by chiwanpark <gi...@git.apache.org> on 2015/02/19 18:42:36 UTC, 3 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] [Updated] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Carsten Brandt (JIRA)" <ji...@apache.org> on 2015/02/20 04:50:13 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/02/20 06:42:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-1587) coGroup throws NoSuchElementException on iterator.next() - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/02/20 06:48:11 UTC, 5 replies.
- [jira] [Resolved] (FLINK-1585) Fix computation of TaskManager memory for Mini Cluster (tests) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/20 10:56:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1499) Make TaskManager to disconnect from JobManager in case of a restart - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/20 10:57:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1484) JobManager restart does not notify the TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/20 10:58:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1556) JobClient does not wait until a job failed completely if submission exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/20 10:59:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1584) Spurious failure of TaskManagerFailsITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/20 11:00:24 UTC, 0 replies.
- [jira] [Updated] (FLINK-1586) Add support for iteration visualization for Streaming programs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 11:27:11 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.
- [jira] [Assigned] (FLINK-1589) Add option to pass Configuration to LocalExecutor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/20 12:33:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1589] Add option to pass configuration ... - posted by rmetzger <gi...@git.apache.org> on 2015/02/20 12:45:04 UTC, 7 replies.
- [jira] [Commented] (FLINK-1589) Add option to pass Configuration to LocalExecutor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/20 12:45:12 UTC, 7 replies.
- [jira] [Updated] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/02/20 13:50:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1451) Enable parallel execution of streaming file sources - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 14:29:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1555) Add utility to log the serializers of composite types - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/20 15:25:11 UTC, 0 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:11 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.
- [GitHub] flink pull request: [FLINK-1505] Separate reader API from result c... - posted by uce <gi...@git.apache.org> on 2015/02/20 16:10:48 UTC, 5 replies.
- [jira] [Commented] (FLINK-1505) Separate buffer reader and channel consumption logic - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/20 16:11:11 UTC, 5 replies.
- [jira] [Resolved] (FLINK-1461) Add sortPartition operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/20 16:14:14 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1466) Add InputFormat to read HCatalog tables - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/20 16:15:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1444) Add data properties for data sources - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/20 16:15:13 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:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1594) DataStreams don't support self-join - posted by "Daniel Bali (JIRA)" <ji...@apache.org> on 2015/02/20 16:47:12 UTC, 1 replies.
- [jira] [Commented] (FLINK-1594) DataStreams don't support self-join - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/20 18:57:11 UTC, 0 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.
- [jira] [Updated] (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.
- [jira] [Updated] (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 22:57:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1462] Gelly documentation - posted by vasia <gi...@git.apache.org> on 2015/02/21 19:51:37 UTC, 13 replies.
- [jira] [Assigned] (FLINK-1586) Add support for iteration visualization for Streaming programs - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/02/21 19:52:12 UTC, 0 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.
- [jira] [Updated] (FLINK-1596) FileIOChannel introduces space in temp file name - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/02/21 21:23:11 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1596] remove space in filename - posted by jkirsch <gi...@git.apache.org> on 2015/02/21 21:34:38 UTC, 5 replies.
- [jira] [Commented] (FLINK-1596) FileIOChannel introduces space in temp file name - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/21 21:35:11 UTC, 10 replies.
- [jira] [Updated] (FLINK-1422) Missing usage example for "withParameters" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/21 22:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-1592) Refactor StreamGraph to store vertex IDs as Integers instead of Strings - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/22 14:53:11 UTC, 0 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.
- [jira] [Assigned] (FLINK-1520) Read edges and vertices from CSV files - posted by "Carsten Brandt (JIRA)" <ji...@apache.org> on 2015/02/22 19:17:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1586] [streaming] Add support for itera... - posted by senorcarbone <gi...@git.apache.org> on 2015/02/22 22:09:55 UTC, 2 replies.
- [jira] [Commented] (FLINK-1586) Add support for iteration visualization for Streaming programs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/22 22:10:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 09:31:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1162) Cannot serialize Scala classes with Avro serializer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 09:35:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-567) Yarn Application Master throws no exception when it has no write permission to HDFS - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 09:45:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1308) Flink logo in documentation does not link to website home - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 09:51:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1289) Broken links to k-means examples in website - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 09:56:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1590) Log environment information also in YARN mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 10:06:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-1590) Log environment information also in YARN mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 10:07:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1505) Separate buffer reader and channel consumption logic - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/23 10:25:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1597) VertexCentricIterations create inefficient execution plans - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/23 10:49:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1597) VertexCentricIterations create inefficient execution plans - posted by "Martin Kiefer (JIRA)" <ji...@apache.org> on 2015/02/23 10:50:12 UTC, 0 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] [Updated] (FLINK-1553) Kafka connectors rework - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/02/23 14:04:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1553] [streaming] Reworked Kafka connec... - posted by gaborhermann <gi...@git.apache.org> on 2015/02/23 14:10:57 UTC, 4 replies.
- [jira] [Commented] (FLINK-1553) Kafka connectors rework - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/23 14:11:12 UTC, 4 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] [Updated] (FLINK-1599) TypeComperator with no keys and comparators matches some elements - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/23 14:40:11 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] [Assigned] (FLINK-1370) Build website automatically - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/23 15:27: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.
- [jira] [Resolved] (FLINK-1255) Problems with generic types in Scala API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/23 16:37:12 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1342) Quickstart's assembly can possibly filter out user's code - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/23 16:47:13 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1526] Added MinSpanningTree example, li... - posted by andralungu <gi...@git.apache.org> on 2015/02/23 17:16:25 UTC, 3 replies.
- [jira] [Commented] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/23 17:17:12 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/02/23 17:20:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/02/23 17:31:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe... - posted by vasia <gi...@git.apache.org> on 2015/02/23 18:12:14 UTC, 2 replies.
- [jira] [Closed] (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/23 19:06:12 UTC, 0 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] [Updated] (FLINK-1383) Move the hadoopcompatibility package name to just hadoop - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/24 01:45:12 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] [Commented] (FLINK-1602) Remove 0.6-incubating from Flink website SVN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/24 10:03:04 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1414) Remove quickstart-*.sh from git source and put them to the website's svn - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/02/24 10:45:04 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.
- [jira] [Updated] (FLINK-1604) Livelock in PartitionRequestClientFactory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 10:51:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1603) Update how to contribute doc to include information to send Github PR instead of attaching patch - posted by "Max Michels (JIRA)" <ji...@apache.org> on 2015/02/24 11:45:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1596) FileIOChannel introduces space in temp file name - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 13:32:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1598) Give better error messages when serializers run out of space. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 13:33:04 UTC, 0 replies.
- [jira] [Resolved] (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/24 13:34:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1519) Web frontend task state mismatch when cancelling - posted by "Mingliang Qi (JIRA)" <ji...@apache.org> on 2015/02/24 14:00:07 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1519] Added canceling state to web inte... - posted by qmlmoon <gi...@git.apache.org> on 2015/02/24 15:06:17 UTC, 2 replies.
- [jira] [Commented] (FLINK-1519) Web frontend task state mismatch when cancelling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/24 15:07:04 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1604) Livelock in PartitionRequestClientFactory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 16:14:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 16:17:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1516) JobManagerFailsITCase: akka.actor.InvalidActorNameException: actor name [jobmanager] is not unique! - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/24 16:18:04 UTC, 0 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:05 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.
- [GitHub] flink pull request: [FLINK-1568] [FLINK-1604] [FLINK-1606] [FLINK-... - posted by tillrohrmann <gi...@git.apache.org> on 2015/02/24 16:42:30 UTC, 6 replies.
- [jira] [Commented] (FLINK-1568) Add failure-case tests for data exchange - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/24 16:43:04 UTC, 7 replies.
- [GitHub] flink pull request: fixed package statement - posted by mjsax <gi...@git.apache.org> on 2015/02/24 19:43:26 UTC, 4 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] [Updated] (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:43:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-1608) TaskManagers may pick wrong network interface when starting before JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 22:00:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-1580) Cleanup TaskManager initialization logic - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 22:16:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1590) Log environment information also in YARN mode - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/24 22:16:05 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.
- [GitHub] flink pull request: [FLINK-1609] FileSystem.getHomeDirectory() - posted by zentol <gi...@git.apache.org> on 2015/02/25 08:39:56 UTC, 3 replies.
- [jira] [Commented] (FLINK-1609) FileSystem doesn't expose current user's home directory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/25 08:40:04 UTC, 3 replies.
- [jira] [Assigned] (FLINK-1594) DataStreams don't support self-join - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/02/25 10:27:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1606) JobManagerFailsITCase fails spuriously for the Hadoop-2.0.0-alpha build profile on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/25 11:16:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1607) SimpleRecoveryITCase fails spuriously on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/25 11:17:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1604) Livelock in PartitionRequestClientFactory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/25 11:18:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1609) FileSystem doesn't expose current user's home directory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/25 11:49:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1519) Web frontend task state mismatch when cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/02/25 12:05:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1450) Add Fold operator to the Streaming api - posted by "amit pal (JIRA)" <ji...@apache.org> on 2015/02/25 12:32:06 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1582) SocketStream gets stuck when socket closes - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/02/25 13:49:05 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1472] Fixed Web frontend config overvie... - posted by qmlmoon <gi...@git.apache.org> on 2015/02/25 18:21:51 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1472) Web frontend config overview shows wrong value - posted by "Mingliang Qi (JIRA)" <ji...@apache.org> on 2015/02/25 18:22:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/25 18:22:05 UTC, 1 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] [Updated] (FLINK-1611) Rename classes and packages that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/25 19:08:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1610) Java docs do not build - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/25 20:05:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1587][gelly] Added additional check for... - posted by andralungu <gi...@git.apache.org> on 2015/02/26 00:40:49 UTC, 2 replies.
- [jira] [Closed] (FLINK-1012) Update documentation to include code style guidelines for Java and Scala - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/02/26 02:20: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] [Reopened] (FLINK-1584) Spurious failure of TaskManagerFailsITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/02/26 10:12:04 UTC, 0 replies.
- [GitHub] flink pull request: Implement the convenience methods count and co... - posted by mxm <gi...@git.apache.org> on 2015/02/26 11:00:05 UTC, 8 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.
- [jira] [Assigned] (FLINK-1523) Vertex-centric iteration extensions - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/02/26 15:50:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/02/26 18:16:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-1462) Add documentation guide for the graph API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/02/27 08:09:05 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-1522][FLINK-1576] Updated LabelPropagat... - posted by balidani <gi...@git.apache.org> on 2015/02/27 12:02:02 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1569) Object reuse mode is not working with KeySelector functions. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/02/27 14:57:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1219] Add support for Apache Tez as exe... - posted by ktzoumas <gi...@git.apache.org> on 2015/02/27 15:58:52 UTC, 4 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.
- [GitHub] flink pull request: [FLINK-1615] [java api] SimpleTweetInputFormat - posted by Elbehery <gi...@git.apache.org> on 2015/02/27 17:41:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1615) Introduces a new InputFormat for Tweets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/02/27 17:42:04 UTC, 0 replies.
- [GitHub] flink pull request: Fix typos in iterations.md file - posted by hsaputra <gi...@git.apache.org> on 2015/02/28 02:24:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-1586) Add support for iteration visualization for Streaming programs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/28 21:05:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1553) Kafka connectors rework - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/02/28 21:05:05 UTC, 0 replies.