issues@flink.apache.org, 2015-09

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

- [GitHub] flink pull request: [FLINK-2125][streaming] Delimiter change from ... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/01 03:23:19 UTC, 6 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 03:23:46 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2590] fixing DataSetUtils.zipWithUnique... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/01 03:29:29 UTC, 7 replies.
- [jira] [Commented] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 03:29:45 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm... - posted by ffbin <gi...@git.apache.org> on 2015/09/01 05:16:12 UTC, 44 replies.
- [jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 05:16:46 UTC, 44 replies.
- [GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/01 09:46:40 UTC, 8 replies.
- [jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 09:46:45 UTC, 8 replies.
- [jira] [Created] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/01 10:49:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/01 11:05:45 UTC, 22 replies.
- [jira] [Assigned] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/01 11:05:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/01 11:18:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/01 11:49:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/01 11:54:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:00:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:01:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:03:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2596] Failing Test: RandomSamplerTest - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 12:15:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:15:47 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2372] Add new FlinkKafkaProducer - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 12:17:48 UTC, 7 replies.
- [jira] [Commented] (FLINK-2372) Update KafkaSink to use new Producer API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:18:45 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f... - posted by shghatge <gi...@git.apache.org> on 2015/09/01 12:24:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:24:46 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa... - posted by shghatge <gi...@git.apache.org> on 2015/09/01 12:27:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:27:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2480][test]add a test for Print Sink wi... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 12:29:45 UTC, 20 replies.
- [jira] [Commented] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:29:46 UTC, 20 replies.
- [GitHub] flink pull request: [FLINK-2545] add bucket member count verificat... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 12:30:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:31:45 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:33:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:33:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2602) Gelly algorithms obtain new execution environments. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:39:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2448]Create new Test environments on ge... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 12:40:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 12:40:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-2066) Make delay between execution retries configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:46:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 12:51:46 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2536][streaming]add a re-connect for so... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 13:24:54 UTC, 22 replies.
- [jira] [Commented] (FLINK-2536) Add a retry for SocketClientSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 13:25:45 UTC, 22 replies.
- [GitHub] flink pull request: [FLINK-2490][FIX]Remove the retryForever check... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/01 13:39:52 UTC, 13 replies.
- [jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 13:40:45 UTC, 13 replies.
- [jira] [Resolved] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/01 13:53:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2161] modified Scala shell start script... - posted by nikste <gi...@git.apache.org> on 2015/09/01 14:09:01 UTC, 2 replies.
- [jira] [Commented] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 14:09:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1730]Persist operator on Data Sets - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/01 15:54:18 UTC, 11 replies.
- [jira] [Commented] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 15:54:45 UTC, 11 replies.
- [jira] [Commented] (FLINK-2602) Gelly algorithms obtain new execution environments. - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/09/01 16:18:45 UTC, 3 replies.
- [jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/09/01 17:28:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2260) Have a complete model evaluation and selection framework for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/09/01 17:29:47 UTC, 1 replies.
- [jira] [Updated] (FLINK-1723) Add cross validation for model evaluation - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/09/01 17:30:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2583] Add Stream Sink For Rolling HDFS ... - posted by aljoscha <gi...@git.apache.org> on 2015/09/01 17:33:02 UTC, 28 replies.
- [jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 17:33:45 UTC, 28 replies.
- [GitHub] flink pull request: Framesize fix - posted by mxm <gi...@git.apache.org> on 2015/09/01 17:42:05 UTC, 7 replies.
- [jira] [Updated] (FLINK-2602) Gelly algorithms obtain new execution environments. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/01 17:49:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/01 18:47:19 UTC, 43 replies.
- [jira] [Commented] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 18:47:47 UTC, 19 replies.
- [jira] [Created] (FLINK-2603) Flink hangs before starting execution - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/01 19:51:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-2603) Flink hangs before starting execution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/01 20:43:46 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2373] Add configuration parameter to cr... - posted by akunft <gi...@git.apache.org> on 2015/09/01 21:05:54 UTC, 15 replies.
- [jira] [Commented] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 21:06:45 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by mjsax <gi...@git.apache.org> on 2015/09/01 21:07:29 UTC, 36 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/01 21:07:46 UTC, 36 replies.
- [jira] [Updated] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/01 21:15:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-2348) Instable (failing) Test - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/01 21:16:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/02 00:39:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/02 02:44:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2535) Fixed size sample algorithm optimization - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/09/02 09:02:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-2535) Fixed size sample algorithm optimization - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/09/02 09:10:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/02 09:36:45 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/02 09:38:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2584] Check for unshaded classes in fat... - posted by asfgit <gi...@git.apache.org> on 2015/09/02 09:44:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2604) Access to SessionID without holding lock in ZooKeeperLeaderElectionService - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/02 09:44:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2584) ASM dependency is not shaded away - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 09:44:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2379][ml]Add column wise statistics for... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/02 10:41:09 UTC, 0 replies.
- [jira] [Commented] (FLINK-2379) Add methods to evaluate field wise statistics over DataSet of vectors. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 10:41:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2606) Extend StormFileSpout to handle HDFS - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/02 10:51:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/02 11:57:31 UTC, 6 replies.
- [jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 11:57:45 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2472]Make JobClientActor poll JobManage... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/02 11:59:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 12:00:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/02 12:23:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2607][quickstart] ignore signature file... - posted by mxm <gi...@git.apache.org> on 2015/09/02 12:27:09 UTC, 4 replies.
- [jira] [Commented] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 12:27:45 UTC, 4 replies.
- [jira] [Created] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/02 12:55:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/02 13:27:45 UTC, 23 replies.
- [jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool - posted by "Behrouz Derakhshan (JIRA)" <ji...@apache.org> on 2015/09/02 13:52:46 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2603) Flink hangs before starting execution - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/02 14:55:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co... - posted by twalthr <gi...@git.apache.org> on 2015/09/02 15:13:40 UTC, 6 replies.
- [jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 15:13:45 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK1919] add HCatOutputFormat - posted by twalthr <gi...@git.apache.org> on 2015/09/02 15:32:46 UTC, 56 replies.
- [jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 15:33:45 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-2493] Simplify names of example program... - posted by chenliang613 <gi...@git.apache.org> on 2015/09/02 15:48:23 UTC, 14 replies.
- [jira] [Commented] (FLINK-2493) Simplify names of example program JARs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/02 15:48:46 UTC, 14 replies.
- [jira] [Resolved] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 15:55:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 15:56:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 15:56:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 15:56:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 15:57:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2601) IOManagerAsync may produce NPE during shutdown - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 16:14:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/02 16:18:46 UTC, 10 replies.
- [jira] [Created] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/02 17:17:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/02 18:12:46 UTC, 1 replies.
- [jira] [Closed] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/02 18:26:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE - posted by "Boyang Jerry Peng (JIRA)" <ji...@apache.org> on 2015/09/02 20:46:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE - posted by "Boyang Jerry Peng (JIRA)" <ji...@apache.org> on 2015/09/02 20:47:45 UTC, 0 replies.
- [GitHub] flink pull request: [Flink 2493] Simplify names of example program... - posted by chenliang613 <gi...@git.apache.org> on 2015/09/02 21:08:29 UTC, 3 replies.
- [jira] [Closed] (FLINK-2610) run method in AbstractStormSpoutWrapper causes NPE - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/02 21:12:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-1674) Add test with nested avro type - posted by "Ozturk Gokal (JIRA)" <ji...@apache.org> on 2015/09/02 22:01:46 UTC, 8 replies.
- [jira] [Updated] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/03 00:10:46 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2602) Gelly algorithms obtain new execution environments. - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/09/03 09:14:45 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2602) Gelly algorithms obtain new execution environments. - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/09/03 09:14:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2606) Extend StormFileSpout to handle HDFS - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/03 10:49:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2611) YARN reports failed final state for successful jobs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/03 10:51:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2612) ZooKeeperLeaderElectionITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/03 11:18:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2613) Print usage information for Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:24:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2614) Scala Shell's default local execution mode is broken - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:32:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2614) Scala Shell's default local execution mode is broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/03 11:35:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2614) Scala Shell's default local execution mode is broken - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:38:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:41:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file - posted by mxm <gi...@git.apache.org> on 2015/09/03 11:43:02 UTC, 3 replies.
- [jira] [Commented] (FLINK-2475) Rename Flink Client log file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/03 11:43:45 UTC, 3 replies.
- [jira] [Reopened] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:59:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:59:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 11:59:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/03 12:01:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2613) Print usage information for Scala Shell - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/09/03 12:18:45 UTC, 47 replies.
- [jira] [Closed] (FLINK-2475) Rename Flink Client log file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/03 13:15:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2615) Multiple restarts of Local Cluster for a single program - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/03 13:20:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2615) Multiple restarts of Local Cluster for a single program - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/03 13:20:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2615]Preserve executors for the entire ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/03 13:39:23 UTC, 5 replies.
- [jira] [Commented] (FLINK-2615) Multiple restarts of Local Cluster for a single program - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/03 13:39:46 UTC, 5 replies.
- [jira] [Created] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/03 14:01:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/09/03 15:11:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2605 Unclosed RandomAccessFile may leak ... - posted by tedyu <gi...@git.apache.org> on 2015/09/03 16:12:57 UTC, 6 replies.
- [GitHub] flink pull request: Implementation of distributed copying utility ... - posted by detonator413 <gi...@git.apache.org> on 2015/09/03 16:20:15 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F... - posted by fhueske <gi...@git.apache.org> on 2015/09/03 16:51:32 UTC, 14 replies.
- [jira] [Commented] (FLINK-2106) Add outer joins to Runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/03 16:51:45 UTC, 14 replies.
- [jira] [Created] (FLINK-2618) ExternalSortITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/03 17:19:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/09/03 17:43:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/09/03 17:45:45 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-1674] Add test with nested avro type - posted by vimalk78 <gi...@git.apache.org> on 2015/09/04 00:22:50 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2613) Print usage information for Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/04 09:40:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2274) Add a histogram method for DataSet[Double] - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/04 12:02:45 UTC, 2 replies.
- [jira] [Updated] (FLINK-2030) Implement an online histogram with Merging and equalization features - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/04 12:02:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2619) Some Scala Tests not being executed by Maven - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/04 12:02:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2030) Implement discrete and continuous histograms - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/04 12:03:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/04 12:06:45 UTC, 23 replies.
- [GitHub] flink pull request: Update FlinkTopology.java - posted by gcpagano <gi...@git.apache.org> on 2015/09/04 12:24:47 UTC, 1 replies.
- [jira] [Created] (FLINK-2620) StreamPartitioner is not properly initialized for shuffle and rebalance - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/04 13:53:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2621) Add support for positional arguments to ParameterTool - posted by "Behrouz Derakhshan (JIRA)" <ji...@apache.org> on 2015/09/04 14:12:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2621) Add support for positional arguments to ParameterTool - posted by "Behrouz Derakhshan (JIRA)" <ji...@apache.org> on 2015/09/04 14:14:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2621) Add support for positional arguments to ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/04 14:18:45 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-2621) Add support for positional arguments to ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/04 14:18:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/04 14:22:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2619) Some Scala Tests not being executed by Maven - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/04 15:41:45 UTC, 12 replies.
- [jira] [Created] (FLINK-2623) Extend API completeness check to check signatures - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/04 15:52:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/04 16:43:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2348) Instable (failing) Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/04 16:58:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/04 17:01:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/04 17:01:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1320] [core] Add an off-heap variant of... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/04 21:29:16 UTC, 19 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/09/04 21:29:45 UTC, 22 replies.
- [jira] [Resolved] (FLINK-2605) Unclosed RandomAccessFile may leak resource in StaticFileServerHandler - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/05 09:21:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2619) Some Scala Tests not being executed by Maven - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/05 10:22:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2625) Configuration not passed to JobGraphGenerator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/05 15:14:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2625] Configuration not passed to JobGr... - posted by greghogan <gi...@git.apache.org> on 2015/09/05 17:14:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-2625) Configuration not passed to JobGraphGenerator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/05 17:14:45 UTC, 3 replies.
- [jira] [Closed] (FLINK-2535) Fixed size sample algorithm optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/06 05:02:47 UTC, 0 replies.
- [jira] [Created] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/09/06 05:12:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2626][CORE]add averageaccumulator - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/06 06:17:20 UTC, 29 replies.
- [jira] [Commented] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/06 06:17:45 UTC, 29 replies.
- [jira] [Commented] (FLINK-1743) Add multinomial logistic regression to machine learning library - posted by "Ozturk Gokal (JIRA)" <ji...@apache.org> on 2015/09/06 20:57:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2017] Add predefined required parameter... - posted by mliesenberg <gi...@git.apache.org> on 2015/09/06 22:23:15 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/07 06:18:11 UTC, 43 replies.
- [jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/07 06:18:45 UTC, 43 replies.
- [jira] [Created] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/07 09:28:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/07 09:29:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/07 09:29:46 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2627][utils]Make Scala Data Set utils e... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/07 09:32:19 UTC, 31 replies.
- [jira] [Commented] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/07 09:32:45 UTC, 31 replies.
- [GitHub] flink pull request: [FLINK-1320] Add an off-heap variant of the ma... - posted by uce <gi...@git.apache.org> on 2015/09/07 10:43:09 UTC, 2 replies.
- [jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/07 10:45:45 UTC, 13 replies.
- [jira] [Created] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/07 10:50:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2348) IterateExampleITCase failing - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/07 10:55:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 14:29:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 14:31:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2625) Configuration not passed to JobGraphGenerator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 15:50:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2625) Configuration not passed to JobGraphGenerator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 15:52:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2567] - posted by StephanEwen <gi...@git.apache.org> on 2015/09/07 15:54:43 UTC, 9 replies.
- [jira] [Commented] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/07 15:54:46 UTC, 9 replies.
- [jira] [Assigned] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/09/07 16:04:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/07 16:22:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2630) Scala DataStream API does not have a project method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/07 16:25:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2003] [docs] Building on some encrypted... - posted by thvasilo <gi...@git.apache.org> on 2015/09/07 16:28:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-2003) Building on some encrypted filesystems leads to "File name too long" error - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/07 16:28:46 UTC, 3 replies.
- [jira] [Created] (FLINK-2631) StreamFold operator does not respect returns type and stores non serializable values - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/07 16:53:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/09/07 17:05:46 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2631] [streaming] Fixes the StreamFold ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/07 17:12:45 UTC, 9 replies.
- [jira] [Commented] (FLINK-2631) StreamFold operator does not respect returns type and stores non serializable values - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/07 17:12:45 UTC, 9 replies.
- [GitHub] flink pull request: [ML] : Lasso regression with distributed Frank... - posted by thomaspeel <gi...@git.apache.org> on 2015/09/07 17:29:56 UTC, 1 replies.
- [jira] [Closed] (FLINK-2372) Update KafkaSink to use new Producer API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:36:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2372) Update KafkaSink to use new Producer API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:36:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:38:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2626) Add a AverageAccumulator for FLINK-Accumulator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:38:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:39:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2628) Failing Test: StreamFaultToleranceTestBase.runCheckpointedProgram - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/07 17:39:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2632) Web Client does not respect the class loader of submitted jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/07 18:06:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2619] [tests] Fix for some unexecuted S... - posted by chiwanpark <gi...@git.apache.org> on 2015/09/07 18:13:35 UTC, 8 replies.
- [jira] [Created] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/08 01:02:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2633] [scala, types] Adds equals and ha... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/08 01:14:16 UTC, 16 replies.
- [jira] [Commented] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 01:14:45 UTC, 16 replies.
- [GitHub] flink pull request: Stale Synchronous Parallel Iterations - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/08 04:55:20 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos - posted by ankurcha <gi...@git.apache.org> on 2015/09/08 05:01:33 UTC, 6 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 05:01:46 UTC, 6 replies.
- [GitHub] flink pull request: Parameter Server: Distributed Key-Value store,... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/08 05:06:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-1743) Add multinomial logistic regression to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/08 10:16:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2630) Scala DataStream API does not have a project method - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/08 10:58:46 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 11:23:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 11:23:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li... - posted by andralungu <gi...@git.apache.org> on 2015/09/08 11:42:17 UTC, 1 replies.
- [jira] [Commented] (FLINK-2570) Add a Triangle Count Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 11:42:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-1931) Add ADMM to optimization framework - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/09/08 13:06:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2632) Web Client does not respect the class loader of submitted jobs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/08 13:13:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 13:14:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1931) Add ADMM to optimization framework - posted by "Dzenan (JIRA)" <ji...@apache.org> on 2015/09/08 13:19:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-1601) Sometimes the YARNSessionFIFOITCase fails on Travis - posted by "Behrouz Derakhshan (JIRA)" <ji...@apache.org> on 2015/09/08 13:26:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2360) EOFException - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 14:04:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2360) EOFException - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 14:05:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 14:05:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2634] [gelly] Added a vertex-centric Tr... - posted by andralungu <gi...@git.apache.org> on 2015/09/08 14:19:55 UTC, 23 replies.
- [jira] [Commented] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 14:20:45 UTC, 23 replies.
- [jira] [Resolved] (FLINK-2570) Add a Triangle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 14:24:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2635) Unify StreamInputProcessor and OneInputStreamTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 14:24:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2613) Print usage information for Scala Shell - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/09/08 14:26:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2636) Clean up StreamRecord and Watermark types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 14:27:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2635) Unify StreamInputProcessor and OneInputStreamTask - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/08 14:41:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2613] Print usage information for Scala... - posted by nikste <gi...@git.apache.org> on 2015/09/08 15:11:26 UTC, 34 replies.
- [jira] [Created] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/08 17:11:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/08 17:12:47 UTC, 1 replies.
- [jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers - posted by "Will Miao (JIRA)" <ji...@apache.org> on 2015/09/08 17:18:46 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2591]Add configuration parameter for de... - posted by willmiao <gi...@git.apache.org> on 2015/09/08 17:19:36 UTC, 7 replies.
- [jira] [Updated] (FLINK-2591) Add configuration parameter for default number of yarn containers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/08 17:21:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/08 17:21:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 17:22:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 17:22:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2632) Web Client does not respect the class loader of submitted jobs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/08 17:35:45 UTC, 8 replies.
- [jira] [Closed] (FLINK-2106) Add outer joins to Runtime - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/08 17:36:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/08 18:01:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/08 18:03:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/08 18:39:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2097] Implement job session management - posted by mxm <gi...@git.apache.org> on 2015/09/08 18:40:46 UTC, 7 replies.
- [jira] [Commented] (FLINK-2097) Add support for JobSessions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 18:41:45 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2152] [bugfix] Used a concurrent list i... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/08 18:52:56 UTC, 4 replies.
- [jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 18:53:45 UTC, 4 replies.
- [jira] [Created] (FLINK-2639) Building Flink for specific HDP versions fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/08 19:38:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2600] Enable test rerun for Elasticsear... - posted by aljoscha <gi...@git.apache.org> on 2015/09/08 20:44:56 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2638] [core] Add @SafeVarargs to the Ex... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/08 21:04:40 UTC, 3 replies.
- [jira] [Commented] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 21:04:46 UTC, 3 replies.
- [jira] [Resolved] (FLINK-1320) Add an off-heap variant of the managed memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:07:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1320) Add an off-heap variant of the managed memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:07:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2640) Integrate the off-heap configurations with YARN runner - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:09:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:10:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2636) Clean up StreamRecord and Watermark types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:11:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2635) Simplify StreamInputProcessor and OneInputStreamTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:11:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2636) Clean up StreamRecord and Watermark types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:11:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2635) Simplify StreamInputProcessor and StreamTwoInputProcessor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:12:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2635) Simplify StreamInputProcessor and StreamTwoInputProcessor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:12:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2635) Simplify StreamInputProcessor and StreamTwoInputProcessor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:12:47 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:16:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:16:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/08 21:17:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/08 22:40:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo... - posted by fhueske <gi...@git.apache.org> on 2015/09/08 23:35:05 UTC, 12 replies.
- [jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/08 23:35:45 UTC, 12 replies.
- [jira] [Commented] (FLINK-1919) Add HCatOutputFormat for Tuple data types - posted by "James Cao (JIRA)" <ji...@apache.org> on 2015/09/09 02:10:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2533] [core] Gap based random sample op... - posted by gallenvara <gi...@git.apache.org> on 2015/09/09 04:26:39 UTC, 13 replies.
- [jira] [Commented] (FLINK-2533) Gap based random sample optimization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 04:26:45 UTC, 13 replies.
- [jira] [Updated] (FLINK-2533) Gap based random sample optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/09 05:29:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/09 10:02:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/09 10:03:45 UTC, 29 replies.
- [jira] [Updated] (FLINK-2181) SessionWindowing example has a memleak - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/09/09 10:13:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2321] [ml] The seed for the SVM classif... - posted by fhueske <gi...@git.apache.org> on 2015/09/09 10:18:24 UTC, 3 replies.
- [jira] [Commented] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 10:18:46 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/09 10:20:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2640) Integrate the off-heap configurations with YARN runner - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/09 10:20:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2181) SessionWindowing example has a memleak - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/09 10:22:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/09 10:24:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/09 10:28:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-1737: Kronecker product - posted by rmetzger <gi...@git.apache.org> on 2015/09/09 10:32:09 UTC, 14 replies.
- [jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 10:32:45 UTC, 14 replies.
- [jira] [Reopened] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/09 10:57:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "Jonas Traub (JIRA)" <ji...@apache.org> on 2015/09/09 11:14:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/09 13:57:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE... - posted by fhueske <gi...@git.apache.org> on 2015/09/09 14:00:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 14:00:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2342] [ml] Add new fit operation and mo... - posted by fhueske <gi...@git.apache.org> on 2015/09/09 14:10:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 14:10:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2119] Add ExecutionGraph support for ba... - posted by fhueske <gi...@git.apache.org> on 2015/09/09 14:13:02 UTC, 4 replies.
- [jira] [Commented] (FLINK-2119) Add ExecutionGraph support for leg-wise scheduling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 14:13:45 UTC, 4 replies.
- [jira] [Created] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/09 14:13:46 UTC, 0 replies.
- [GitHub] flink pull request: Clean up naming of State/Checkpoint Interfaces - posted by fhueske <gi...@git.apache.org> on 2015/09/09 14:14:45 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave... - posted by chiwanpark <gi...@git.apache.org> on 2015/09/09 14:28:55 UTC, 12 replies.
- [jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 14:29:45 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-2617] Added static mutexes for configur... - posted by fhueske <gi...@git.apache.org> on 2015/09/09 14:54:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-2644) State partitioning does not respect the different partitioning of multiple inputs - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/09 15:24:45 UTC, 1 replies.
- [jira] [Created] (FLINK-2645) Accumulator exceptions are not properly forwarded - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/09 15:28:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2645) Accumulator exceptions are not properly forwarded - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/09 15:28:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2645][jobmanager] forward exceptions wh... - posted by mxm <gi...@git.apache.org> on 2015/09/09 15:30:20 UTC, 7 replies.
- [jira] [Commented] (FLINK-2645) Accumulator exceptions are not properly forwarded - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 15:30:45 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne... - posted by chiwanpark <gi...@git.apache.org> on 2015/09/09 15:42:12 UTC, 0 replies.
- [jira] [Commented] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 15:42:45 UTC, 12 replies.
- [jira] [Closed] (FLINK-1674) Add test with nested avro type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/09 16:13:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1297) Add support for tracking statistics of intermediate results - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/09 17:02:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2493) Simplify names of example program JARs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/09 17:02:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 17:14:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2647) Stream operators need to differentiate between close() and dispose() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 17:24:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/09 17:47:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi... - posted by chiwanpark <gi...@git.apache.org> on 2015/09/09 17:58:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/09 17:59:46 UTC, 2 replies.
- [jira] [Created] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/09 18:19:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2612) ZooKeeperLeaderElectionITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/09 18:23:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/09 18:29:45 UTC, 1 replies.
- [jira] [Reopened] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/09 18:44:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/09 18:47:46 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:17:46 UTC, 1 replies.
- [jira] [Closed] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:17:46 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2003) Building on some encrypted filesystems leads to "File name too long" error - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:17:48 UTC, 0 replies.
- [jira] [Closed] (FLINK-2003) Building on some encrypted filesystems leads to "File name too long" error - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:18:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:18:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2638) Add @SafeVarargs to the environment.fromElements(...) method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:18:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2619) Some Scala Tests not being executed by Maven - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:19:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2619) Some Scala Tests not being executed by Maven - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/09 20:19:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2649) Potential resource leak in JarHelper#unjar() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/09 23:30:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2650) Fix broken link in the Table API doc - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/10 06:47:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2650) Fix broken link in the Table API doc - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 10:01:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/10 10:19:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/10 10:20:46 UTC, 14 replies.
- [jira] [Created] (FLINK-2652) Failing PartitionRequestClientFactoryTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/10 10:23:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2639] Add repository for hdp specific j... - posted by rmetzger <gi...@git.apache.org> on 2015/09/10 11:10:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-2639) Building Flink for specific HDP versions fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 11:10:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-2555) Hadoop Input/Output Formats are unable to access secured HDFS clusters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 11:15:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2632) Web Client does not respect the class loader of submitted jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/10 11:46:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2650) Fix broken link in the Table API doc - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/10 12:44:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2650) Fix broken link in the Table API doc - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/10 12:44:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2632] Web Client does not respect the c... - posted by mjsax <gi...@git.apache.org> on 2015/09/10 13:42:55 UTC, 5 replies.
- [jira] [Closed] (FLINK-2645) Accumulator exceptions are not properly forwarded - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 14:34:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2631) StreamFold operator does not respect returns type and stores non serializable values - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 14:35:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 14:36:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2577] Fix Stalling Watermarks when Sour... - posted by fhueske <gi...@git.apache.org> on 2015/09/10 14:49:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-2577) Watermarks Stall When a Source Finishes Prematurely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 14:49:45 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2557] TypeExtractor properly returns Mi... - posted by fhueske <gi...@git.apache.org> on 2015/09/10 14:50:54 UTC, 10 replies.
- [jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 14:51:45 UTC, 10 replies.
- [jira] [Created] (FLINK-2653) Enable object reuse in MergeIterator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/10 15:33:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2632) Web Client does not respect the class loader of submitted jobs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 15:37:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2654) Add JavaDoc to ParameterTool class - posted by "Behrouz Derakhshan (JIRA)" <ji...@apache.org> on 2015/09/10 15:55:45 UTC, 0 replies.
- [GitHub] flink pull request: Add Scala version of GraphAlgorithm - posted by fhueske <gi...@git.apache.org> on 2015/09/10 16:09:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2655) Minimize intermediate merging of spilled buffers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/10 16:14:45 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2125 - posted by fhueske <gi...@git.apache.org> on 2015/09/10 16:21:33 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2653] Enable object reuse in MergeItera... - posted by greghogan <gi...@git.apache.org> on 2015/09/10 17:03:12 UTC, 9 replies.
- [jira] [Commented] (FLINK-2653) Enable object reuse in MergeIterator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 17:03:45 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2654][flink-java] Add JavaDoc to Parame... - posted by bderak <gi...@git.apache.org> on 2015/09/10 17:19:19 UTC, 12 replies.
- [jira] [Commented] (FLINK-2654) Add JavaDoc to ParameterTool class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 17:19:46 UTC, 12 replies.
- [jira] [Created] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/10 17:31:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/10 18:02:46 UTC, 38 replies.
- [jira] [Created] (FLINK-2657) Fix WebClient and CLI interaction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/10 18:49:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2656] Fix behavior of FlinkKafkaConsume... - posted by rmetzger <gi...@git.apache.org> on 2015/09/10 18:53:10 UTC, 8 replies.
- [jira] [Commented] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 18:53:45 UTC, 8 replies.
- [jira] [Commented] (FLINK-2657) Fix WebClient and CLI interaction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/10 18:59:46 UTC, 1 replies.
- [jira] [Closed] (FLINK-2577) Watermarks Stall When a Source Finishes Prematurely - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 19:08:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2639) Building Flink for specific HDP versions fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/10 19:10:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2655] Minimize intermediate merging of ... - posted by greghogan <gi...@git.apache.org> on 2015/09/10 19:12:38 UTC, 6 replies.
- [jira] [Commented] (FLINK-2655) Minimize intermediate merging of spilled buffers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/10 19:12:50 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/10 19:31:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2015/09/10 21:37:45 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2015/09/11 05:07:46 UTC, 0 replies.
- [GitHub] flink pull request: Getter for wrapped StreamExecutionEnvironment ... - posted by lofifnc <gi...@git.apache.org> on 2015/09/11 10:07:30 UTC, 7 replies.
- [GitHub] flink pull request: [hotfix][streaming]Improve throwing exception ... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/11 10:35:12 UTC, 5 replies.
- [jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "Vimal (JIRA)" <ji...@apache.org> on 2015/09/11 10:58:45 UTC, 8 replies.
- [jira] [Updated] (FLINK-2639) Building Flink for specific HDP versions fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 11:59:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2639) Building Flink for specific HDP versions fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 11:59:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2658) fieldsGrouping for multiple output streams fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/11 13:02:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 13:23:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/11 13:27:45 UTC, 2 replies.
- [jira] [Updated] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 13:32:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2647) Stream operators need to differentiate between close() and dispose() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/11 13:49:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2647) Stream operators need to differentiate between close() and dispose() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/11 13:53:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 14:11:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d... - posted by willmiao <gi...@git.apache.org> on 2015/09/11 14:16:50 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2399] Version checks for Job Manager an... - posted by fhueske <gi...@git.apache.org> on 2015/09/11 14:23:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-2399) Fail when actor versions don't match - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/11 14:23:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2658] fieldsGrouping for multiple outpu... - posted by mjsax <gi...@git.apache.org> on 2015/09/11 14:34:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-2658) fieldsGrouping for multiple output streams fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/11 14:34:45 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/11 14:40:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2230] handling null values for TupleSer... - posted by fhueske <gi...@git.apache.org> on 2015/09/11 15:35:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-2230) Add Support for Null-Values in TupleSerializer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/11 15:35:45 UTC, 3 replies.
- [jira] [Created] (FLINK-2659) Object reuse in UnionWithTempOperator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/11 15:57:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/11 16:17:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2654) Add JavaDoc to ParameterTool class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/11 16:29:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-2566) FlinkTopologyContext no populated completely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/11 19:48:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/09/12 05:32:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/09/12 05:33:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2661) Add a Node Splitting Technique to Overcome the Limitations of Skewed Graphs - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/12 13:06:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2659) Object reuse in UnionWithTempOperator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/12 16:55:45 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2537] Add scala examples.jar to build-t... - posted by chenliang613 <gi...@git.apache.org> on 2015/09/12 17:22:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-2537) Add scala examples.jar to build-target/examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/12 17:23:45 UTC, 5 replies.
- [jira] [Created] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/09/12 21:45:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2661] Added Node Splitting Methods - posted by andralungu <gi...@git.apache.org> on 2015/09/12 22:09:02 UTC, 4 replies.
- [jira] [Commented] (FLINK-2661) Add a Node Splitting Technique to Overcome the Limitations of Skewed Graphs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/12 22:09:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/09/13 09:56:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/09/13 09:58:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/13 10:09:45 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/14 06:31:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/14 06:35:46 UTC, 12 replies.
- [jira] [Created] (FLINK-2663) Update Gelly library methods to use any key type - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/14 06:58:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2641] integrate off-heap memory configu... - posted by mxm <gi...@git.apache.org> on 2015/09/14 10:30:31 UTC, 31 replies.
- [jira] [Created] (FLINK-2664) Remove partitioned states when set to null - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/14 11:26:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2665) ExecutionConfig is not serializable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/14 12:26:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2665) ExecutionConfig is not serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/14 12:32:45 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2664] [streaming] Allow partitioned sta... - posted by gyfora <gi...@git.apache.org> on 2015/09/14 13:26:49 UTC, 5 replies.
- [jira] [Commented] (FLINK-2664) Remove partitioned states when set to null - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/14 13:27:45 UTC, 5 replies.
- [jira] [Created] (FLINK-2666) Allow custom Timestamp extractors for Flink sources - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/14 14:47:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn... - posted by twalthr <gi...@git.apache.org> on 2015/09/14 15:37:10 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-2665] [api-breaking] [runtime] Makes Ex... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/14 17:02:38 UTC, 3 replies.
- [jira] [Closed] (FLINK-2658) fieldsGrouping for multiple output streams fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/14 18:02:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2664) Remove partitioned states when set to null - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/14 18:35:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2659] Fix object reuse in UnionWithTemp... - posted by greghogan <gi...@git.apache.org> on 2015/09/14 18:57:35 UTC, 2 replies.
- [jira] [Created] (FLINK-2667) Rework configuration parameters - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/14 19:11:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2667) Rework configuration parameters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/14 19:20:46 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2667) Rework configuration parameters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/14 19:21:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2668) ProjectOperator method to close projection - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/14 20:42:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2668) ProjectOperator method to close projection - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/14 20:43:45 UTC, 4 replies.
- [jira] [Closed] (FLINK-2661) Add a Node Splitting Technique to Overcome the Limitations of Skewed Graphs - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/14 21:35:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2668) ProjectOperator method to close projection - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/14 23:21:45 UTC, 4 replies.
- [jira] [Created] (FLINK-2669) Execution contains non-serializable field - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/14 23:58:45 UTC, 0 replies.
- [GitHub] flink pull request: Hits - posted by mfahimazizi <gi...@git.apache.org> on 2015/09/15 06:57:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-2669) Execution contains non-serializable field - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 08:20:46 UTC, 1 replies.
- [GitHub] flink pull request: [hotfix][Table API tests]add toDataSet in tabl... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/15 08:41:08 UTC, 7 replies.
- [jira] [Closed] (FLINK-2669) Execution contains non-serializable field - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/15 08:42:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2670) Instable Test S3FileSystemTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/15 09:04:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/15 09:08:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2672) Add partitioned output format to HDFS RollingSink - posted by "Mohamed Amine ABDESSEMED (JIRA)" <ji...@apache.org> on 2015/09/15 10:42:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2582) Document how to build Flink with other Scala versions - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/15 10:43:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2672) Add partitioned output format to HDFS RollingSink - posted by "Mohamed Amine ABDESSEMED (JIRA)" <ji...@apache.org> on 2015/09/15 10:44:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-1745) Add exact k-nearest-neighbours algorithm to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 10:47:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2640][yarn] integrate off-heap configur... - posted by mxm <gi...@git.apache.org> on 2015/09/15 12:26:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-2640) Integrate the off-heap configurations with YARN runner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/15 12:26:45 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2667) Rework configuration parameters - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/15 13:48:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2673) Scala API does not support Option type as key - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 13:59:47 UTC, 0 replies.
- [jira] [Created] (FLINK-2674) Rework windowing logic - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:08:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2675) Add utilities for scheduled triggers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:10:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2676) Add abstraction for keyed window state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:13:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2677) Add a general-purpose keyed-window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:14:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2677) Add a general-purpose keyed-window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:14:47 UTC, 1 replies.
- [jira] [Created] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 14:15:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2679) Scala API does not support Try type as keys - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 14:18:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2679) Scala API does not support Try type as key - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 14:18:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2681) Scala API does not support Either type to be used as key - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 14:19:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2680) Create a dedicated aligned-event time window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:19:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2682) Add a dedicated processing time aligned keyed window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:21:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:23:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2683) Add utilities for heap-backed keyed state in time panes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/15 14:30:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2550) Rework DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/15 14:44:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2383) Add new Window Operator that can use Timestamps/Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/15 14:44:46 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2668) ProjectOperator method to close projection - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/15 14:52:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2533) Gap based random sample optimization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/15 14:54:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2665) ExecutionConfig is not serializable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/15 14:55:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2655) Minimize intermediate merging of spilled buffers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/15 14:55:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/15 14:56:48 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2230) Add Support for Null-Values in TupleSerializer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/15 14:59:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/09/15 16:54:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/09/15 16:54:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2675] [streaming] Add utilities for sch... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/15 17:17:35 UTC, 9 replies.
- [jira] [Commented] (FLINK-2675) Add utilities for scheduled triggers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/15 17:17:45 UTC, 16 replies.
- [jira] [Closed] (FLINK-2633) OptionTypeInfo does not have proper equals and hashCode method - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 19:05:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2637] [api-breaking] [scala, types] Add... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/15 19:13:05 UTC, 20 replies.
- [jira] [Commented] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/15 19:13:46 UTC, 19 replies.
- [jira] [Created] (FLINK-2684) Make TypeInformation non-serializable again by removing Table API's need for it - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/15 19:19:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2684) Make TypeInformation non-serializable again by removing Table API's need for it - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/15 19:58:45 UTC, 5 replies.
- [jira] [Created] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/15 21:41:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/15 21:42:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/15 23:12:45 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/15 23:12:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2686) Extend JSON plan dump to contain channel info - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/15 23:22:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2566) FlinkTopologyContext not populated completely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/16 00:28:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2566] FlinkTopologyContext not populate... - posted by mjsax <gi...@git.apache.org> on 2015/09/16 00:42:24 UTC, 9 replies.
- [jira] [Commented] (FLINK-2566) FlinkTopologyContext not populated completely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/16 00:42:45 UTC, 9 replies.
- [jira] [Updated] (FLINK-2649) Potential resource leak in JarHelper#unjar() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/16 03:53:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2616) Failing Test: ZooKeeperLeaderElectionTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/16 08:23:46 UTC, 13 replies.
- [jira] [Commented] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/16 10:20:45 UTC, 4 replies.
- [jira] [Updated] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/16 10:43:46 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/16 10:43:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/16 10:47:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2348) IterateExampleITCase failing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 13:16:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 13:26:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2670) Instable Test S3FileSystemTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 13:55:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 13:55:46 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 13:56:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2670) Memory Manager memory release can get live-locked in case of concurrent modifications - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 14:41:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2670) Unstable CombineTaskTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 14:42:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/16 14:55:45 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/16 14:56:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2670) Unstable CombineTaskTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 15:04:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2687) Moniroting api / web dashboard: Create request handlers list subtask details and accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 15:38:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2688) Add documentation about monitoring api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/16 15:40:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1851] Add support for casting in Table ... - posted by aljoscha <gi...@git.apache.org> on 2015/09/16 15:52:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-1851) Java Table API does not support Casting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/16 15:52:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2689) Reusing null object for joins with SolutionSet - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/16 17:05:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2641) Integrate the off-heap memory configuration with the TaskManager start script - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/16 17:14:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-1851) Java Table API does not support Casting - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/16 17:15:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2659) Object reuse in UnionWithTempOperator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/16 17:18:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2689] [runtime] Fix reuse of null objec... - posted by fhueske <gi...@git.apache.org> on 2015/09/16 18:14:30 UTC, 5 replies.
- [jira] [Commented] (FLINK-2689) Reusing null object for joins with SolutionSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/16 18:14:45 UTC, 4 replies.
- [GitHub] flink pull request: FLINK-2595 Unclosed JarFile may leak resource ... - posted by tedyu <gi...@git.apache.org> on 2015/09/16 18:30:58 UTC, 4 replies.
- [jira] [Created] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/16 18:59:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/16 19:00:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/16 20:26:45 UTC, 10 replies.
- [GitHub] flink pull request: Feature/flink 2576 - posted by jkovacs <gi...@git.apache.org> on 2015/09/16 21:41:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/16 21:41:47 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-2357] Add the new web dashboard and mon... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/16 22:57:44 UTC, 11 replies.
- [jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/16 22:57:46 UTC, 12 replies.
- [jira] [Created] (FLINK-2691) Broken links to Python script on QuickStart doc - posted by "Felix Cheung (JIRA)" <ji...@apache.org> on 2015/09/17 01:42:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2691) Broken links to Python script on QuickStart doc - posted by "Felix Cheung (JIRA)" <ji...@apache.org> on 2015/09/17 01:43:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2691] fix broken links to Python script... - posted by felixcheung <gi...@git.apache.org> on 2015/09/17 02:05:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-2691) Broken links to Python script on QuickStart doc - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/17 02:05:46 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2410) PojoTypeInfo is not completely serializable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/09/17 14:50:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2637) Add abstract equals, hashCode and toString methods to TypeInformation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:44:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2691) Broken links to Python script on QuickStart doc - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:44:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2689) Reusing null object for joins with SolutionSet - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:45:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:46:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2659) Object reuse in UnionWithTempOperator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:48:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2640) Integrate the off-heap configurations with YARN runner - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/17 15:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/17 16:01:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2690] [api-breaking] [scala api] [java ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/17 16:15:06 UTC, 7 replies.
- [jira] [Created] (FLINK-2693) Refactor InvalidTypesException to be checked - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/17 16:44:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi... - posted by fhueske <gi...@git.apache.org> on 2015/09/17 16:51:32 UTC, 18 replies.
- [jira] [Created] (FLINK-2694) JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/17 16:59:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2653) Enable object reuse in MergeIterator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/17 17:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/17 17:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/17 17:09:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2697) Deadlock in StreamDiscretizer - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/17 17:15:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2688) Add documentation about monitoring api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:22:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2688) Add documentation about monitoring api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:22:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2687) Moniroting api / web dashboard: Create request handlers list subtask details and accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:23:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2687) Moniroting api / web dashboard: Create request handlers list subtask details and accumulators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:23:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2415) Link nodes in plan to vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:24:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2547) Provide Cluster Status Info - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:24:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2547) Provide Cluster Status Info - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:24:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2415) Link nodes in plan to vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:24:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2414) Extend job data in job list - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:25:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2414) Extend job data in job list - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:25:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2554) Add exception reporting handler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:26:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2554) Add exception reporting handler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:26:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:27:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/17 20:27:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2698) Add trailing newline to flink-conf.yaml - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/17 20:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2699) Flink is filling Spark JIRA with incorrect PR links - posted by "Patrick Wendell (JIRA)" <ji...@apache.org> on 2015/09/17 22:28:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2699) Flink is filling Spark JIRA with incorrect PR links - posted by "Patrick Wendell (JIRA)" <ji...@apache.org> on 2015/09/17 22:30:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2698] Add trailing newline to flink-con... - posted by greghogan <gi...@git.apache.org> on 2015/09/17 22:48:19 UTC, 3 replies.
- [jira] [Commented] (FLINK-2698) Add trailing newline to flink-conf.yaml - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/17 22:49:04 UTC, 3 replies.
- [jira] [Closed] (FLINK-2699) Flink is filling Spark JIRA with incorrect PR links - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/17 22:58:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2699) Flink is filling Spark JIRA with incorrect PR links - posted by "Patrick Wendell (JIRA)" <ji...@apache.org> on 2015/09/17 22:59:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode) - posted by "Lydia Ickler (JIRA)" <ji...@apache.org> on 2015/09/17 23:08:04 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode) - posted by "Lydia Ickler (JIRA)" <ji...@apache.org> on 2015/09/17 23:12:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2700) YarnSessionFIFOITCase.testJavaApi failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/18 11:17:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2471]Improve File Sink - posted by StephanEwen <gi...@git.apache.org> on 2015/09/18 11:31:17 UTC, 1 replies.
- [jira] [Commented] (FLINK-2471) FileSinkFunction invoke performance optimize - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 11:32:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 11:37:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2312][utils] Randomly Splitting a Data ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/18 11:46:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-2312) Random Splits - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 11:47:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2702) Add an implementation of distributed copying utility using Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 11:48:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/18 11:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 12:04:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2616] [test-stability] Hardens ZooKeepe... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/18 12:40:00 UTC, 5 replies.
- [jira] [Resolved] (FLINK-2698) Add trailing newline to flink-conf.yaml - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:52:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:53:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2698) Add trailing newline to flink-conf.yaml - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:53:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2701) Getter for wrapped Java StreamExecutionEnvironment in the Scala Api - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:53:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:54:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:54:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2627) Make Scala Data Set utils easier to access - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2702) Add an implementation of distributed copying utility using Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2702) Add an implementation of distributed copying utility using Flink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2704) Clean up naming of State/Checkpoint Interfaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 13:55:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2696] [test-stability] Hardens Zookeepe... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/18 14:38:35 UTC, 5 replies.
- [jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 14:39:04 UTC, 5 replies.
- [jira] [Created] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/18 15:26:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow... - posted by aalexandrov <gi...@git.apache.org> on 2015/09/18 15:45:07 UTC, 21 replies.
- [jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 15:46:04 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-2694] [test-stability] Hardens the JobM... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/18 15:53:28 UTC, 5 replies.
- [jira] [Commented] (FLINK-2694) JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 15:54:04 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2643] [build] Update Travis build matri... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/18 16:14:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/18 16:14:05 UTC, 6 replies.
- [jira] [Commented] (FLINK-2652) Failing PartitionRequestClientFactoryTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/18 16:31:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/18 17:08:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2583) Add Stream Sink For Rolling HDFS Files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 17:15:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2583) Add Stream Sink For Rolling HDFS Files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 17:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/18 17:20:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/18 17:54:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2697) Deadlock in StreamDiscretizer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/18 18:13:04 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2697) Deadlock in StreamDiscretizer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/18 18:13:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/18 18:59:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/18 18:59:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2707) Set state checkpointer before default state for PartitionedStreamOperatorState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/18 19:23:04 UTC, 0 replies.
- [GitHub] flink pull request: Windows - posted by StephanEwen <gi...@git.apache.org> on 2015/09/18 20:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/18 20:59:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2708) Potential null pointer dereference in JoinWithSolutionSetFirstDriver#run() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/18 21:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2709) line editing in scala shell - posted by "Matthew Farrellee (JIRA)" <ji...@apache.org> on 2015/09/18 23:06:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/19 10:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2710) SocketTextStreamFunctionTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/19 12:58:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2711) TaskManagerTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/19 13:38:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2710) SocketTextStreamFunctionTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/19 16:19:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2712) Add some description about tests to "How to Contribute" documentation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/19 18:39:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2357] [web dashboard] Fixed broken plan... - posted by iampeter <gi...@git.apache.org> on 2015/09/19 21:03:11 UTC, 2 replies.
- [jira] [Assigned] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/19 21:20:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1520] [gelly] Create a Graph from CSV f... - posted by vasia <gi...@git.apache.org> on 2015/09/19 21:46:09 UTC, 7 replies.
- [jira] [Created] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/19 23:00:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/19 23:01:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2709) line editing in scala shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/20 02:21:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2712) Add some description about tests to "How to Contribute" documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/20 03:12:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2713] [streaming] Include custom StateC... - posted by gyfora <gi...@git.apache.org> on 2015/09/20 08:43:05 UTC, 5 replies.
- [jira] [Commented] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/20 08:44:04 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2683] [runtime] Add dedicated operator ... - posted by gyfora <gi...@git.apache.org> on 2015/09/20 09:46:03 UTC, 9 replies.
- [jira] [Commented] (FLINK-2683) Add utilities for heap-backed keyed state in time panes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/20 09:46:04 UTC, 9 replies.
- [jira] [Created] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/20 09:47:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2715) Benchmark Triangle Count methods - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/20 09:56:04 UTC, 0 replies.
- [GitHub] flink pull request: - posted by uce <gi...@git.apache.org> on 2015/09/20 11:18:20 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2649 Potential resource leak in JarHelpe... - posted by tedyu <gi...@git.apache.org> on 2015/09/20 18:48:11 UTC, 3 replies.
- [jira] [Commented] (FLINK-2649) Potential resource leak in JarHelper#unjar() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/20 18:49:04 UTC, 3 replies.
- [jira] [Created] (FLINK-2716) Checksum method for DataSet and Graph - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/20 19:34:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2663) Update Gelly library methods to use any key type - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/20 20:53:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t... - posted by vasia <gi...@git.apache.org> on 2015/09/20 22:01:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-2663) Update Gelly library methods to use any key type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/20 22:02:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2717) CombineTaskTest sometimes fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/21 08:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2718) LeaserChangeCleanupTest sometimes fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/21 08:21:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/09/21 08:23:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco... - posted by uce <gi...@git.apache.org> on 2015/09/21 09:08:13 UTC, 6 replies.
- [jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/21 09:09:04 UTC, 6 replies.
- [jira] [Closed] (FLINK-2700) YarnSessionFIFOITCase.testJavaApi failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/21 11:15:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1931) Add ADMM to optimization framework - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/09/21 11:52:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2713] [streaming] Set state restore to ... - posted by gyfora <gi...@git.apache.org> on 2015/09/21 12:24:02 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2283] [streaming] Make grouped reduce/f... - posted by mbalassi <gi...@git.apache.org> on 2015/09/21 13:20:15 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2711) TaskManagerTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 13:32:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2711) TaskManagerTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 13:33:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2711) TaskManagerTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 13:33:04 UTC, 0 replies.
- [GitHub] flink pull request: Pull Request - posted by JonathanH5 <gi...@git.apache.org> on 2015/09/21 13:47:20 UTC, 15 replies.
- [jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/21 13:48:04 UTC, 38 replies.
- [jira] [Created] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/21 14:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/09/21 15:18:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2612) ZooKeeperLeaderElectionITCase failure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/21 15:18:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2618) ExternalSortITCase failure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/21 15:25:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/09/21 15:27:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/21 15:27:04 UTC, 4 replies.
- [jira] [Created] (FLINK-2721) Add Tuple meta information - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/21 16:12:04 UTC, 0 replies.
- [GitHub] flink pull request: Merge remote-tracking branch 'apache/master' - posted by aminouvic <gi...@git.apache.org> on 2015/09/21 16:39:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2536) Add a retry for SocketClientSink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 17:28:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2536) Add a retry for SocketClientSink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 17:28:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2710) SocketTextStreamFunctionTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 17:28:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/21 18:20:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2722] Use InetAddress.getLocalHost() as... - posted by rmetzger <gi...@git.apache.org> on 2015/09/21 18:21:56 UTC, 11 replies.
- [jira] [Commented] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/21 18:22:04 UTC, 12 replies.
- [jira] [Updated] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/21 18:25:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2723) CopyableValue method to copy into new instance - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/21 19:44:04 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/21 19:47:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2479] Refactor runtime.operators.* test... - posted by zentol <gi...@git.apache.org> on 2015/09/21 19:49:41 UTC, 2 replies.
- [jira] [Commented] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/21 19:50:05 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2713) Custom StateCheckpointers should be included in the snapshots - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/09/21 20:05:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2724) Object reuse not respected in GroupReduceCombineDriver and ReduceCombineDriver - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 21:30:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2725) Max/Min/Sum Aggregation of mutable types - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/21 22:11:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:37:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2724) Object reuse not respected in GroupReduceCombineDriver and ReduceCombineDriver - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:38:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2649) Potential resource leak in JarHelper#unjar() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:38:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2717) CombineTaskTest sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:38:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2724) Object reuse not respected in GroupReduceCombineDriver and ReduceCombineDriver - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:39:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2717) CombineTaskTest sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:39:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2649) Potential resource leak in JarHelper#unjar() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:39:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2710) SocketTextStreamFunctionTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:39:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2710) SocketTextStreamFunctionTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/21 23:39:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet. - posted by ChengXiangLi <gi...@git.apache.org> on 2015/09/22 11:04:44 UTC, 4 replies.
- [jira] [Commented] (FLINK-2549) Add topK operator for DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/22 11:05:04 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2705] [test-stability] Fixes Yarn crash... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/22 11:12:23 UTC, 6 replies.
- [jira] [Commented] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/22 11:13:04 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/22 12:04:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2726) Harmonise Yarn configuration methods to use a single configuration for all components - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/22 12:44:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ... - posted by JonathanH5 <gi...@git.apache.org> on 2015/09/22 13:17:18 UTC, 35 replies.
- [jira] [Created] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 13:30:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2727] [streaming] Add a base class for ... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/22 13:33:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/22 13:34:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2723) CopyableValue method to copy into new instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:32:04 UTC, 7 replies.
- [GitHub] flink pull request: [web-dashboard] Added task managers to the new... - posted by iampeter <gi...@git.apache.org> on 2015/09/22 14:35:18 UTC, 7 replies.
- [jira] [Created] (FLINK-2728) Add missing features to new web dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:48:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2729) Add TaskManager overview - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:48:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2731) Add JobManager log file access - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 14:51:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2729) Add TaskManager overview - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/22 14:58:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2675] [streaming] Integrate Timer Servi... - posted by aljoscha <gi...@git.apache.org> on 2015/09/22 15:01:14 UTC, 6 replies.
- [jira] [Created] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/22 15:19:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/22 15:33:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2734) ArrayKeySelector is wrong - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 15:53:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2734] [streaming] Fix ArrayKeySelector - posted by StephanEwen <gi...@git.apache.org> on 2015/09/22 15:54:09 UTC, 7 replies.
- [jira] [Commented] (FLINK-2734) ArrayKeySelector is wrong - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/22 15:55:04 UTC, 1 replies.
- [GitHub] flink pull request: [tests] Add RetryOnFailure annotation - posted by uce <gi...@git.apache.org> on 2015/09/22 16:07:54 UTC, 7 replies.
- [jira] [Created] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/22 17:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 17:37:04 UTC, 0 replies.
- [GitHub] flink pull request: [utils] Missing getters for ParameterTool - posted by mbalassi <gi...@git.apache.org> on 2015/09/22 17:37:22 UTC, 5 replies.
- [jira] [Created] (FLINK-2736) Failing KafkaConsumerTestBase.runCancelingOnEmptyInputTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/22 17:39:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 17:42:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2738) StackOverflow in case of unbounded restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/22 17:46:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 17:47:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2723] CopyableValue method to copy into... - posted by greghogan <gi...@git.apache.org> on 2015/09/22 18:13:40 UTC, 6 replies.
- [jira] [Created] (FLINK-2739) Release script depends on the order of parent module information - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/22 19:38:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2734) ArrayKeySelector returns wrong positions (or fails) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/22 20:23:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2729) Add TaskManager overview - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/09/22 20:31:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2097) Add support for JobSessions - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/22 22:00:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2731) Add JobManager log file access - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/22 22:19:05 UTC, 12 replies.
- [jira] [Created] (FLINK-2740) Create data consumer for Apache NiFi - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/09/22 22:51:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2740) Create data consumer for Apache NiFi - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/09/22 22:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2741) Use single log statement in TestLogger - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/22 23:36:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2734) ArrayKeySelector returns wrong positions (or fails) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/23 00:27:04 UTC, 5 replies.
- [jira] [Created] (FLINK-2742) Flink Configuration URL Not Found - posted by "dengjie (JIRA)" <ji...@apache.org> on 2015/09/23 08:51:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2736) Failing KafkaConsumerTestBase.runCancelingOnEmptyInputTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/23 10:06:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2742) Flink Configuration URL Not Found - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/23 10:10:04 UTC, 3 replies.
- [jira] [Closed] (FLINK-2742) Flink Configuration URL Not Found - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 10:11:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2741) Use single log statement in TestLogger - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/23 10:27:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2731) Add JobManager log file access - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/23 11:01:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-2729) Add TaskManager overview - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/23 11:48:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/09/23 11:54:04 UTC, 6 replies.
- [jira] [Created] (FLINK-2743) Add new RNG based on XORShift algorithm - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/23 11:59:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2694) JobManagerProcessReapingTest.testReapProcessOnFailure failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/23 12:15:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/23 12:15:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2705) Yarn fails with NoSuchMethodError when log level is set to DEBUG - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/23 12:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2744) Reduce number of concurrent test forks to 1 for the Kafka connector project - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 12:17:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/09/23 12:25:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/23 12:26:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2745) Create a new module for all Flink micro benchmark. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/23 12:33:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2746) Add RetryOnException annotation for tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 13:30:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2746] [tests] Add RetryOnException anno... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/23 13:32:50 UTC, 6 replies.
- [jira] [Commented] (FLINK-2746) Add RetryOnException annotation for tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/23 13:33:04 UTC, 6 replies.
- [jira] [Created] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/23 14:05:04 UTC, 0 replies.
- [GitHub] flink pull request: Harden Kafka Tests - posted by StephanEwen <gi...@git.apache.org> on 2015/09/23 14:08:06 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2746) Add RetryOnException annotation for tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 14:11:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2746) Add RetryOnException annotation for tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 14:12:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2731) Add JobManager log file access - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/23 14:28:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2616] [test-stability] Fixes ZooKeeperL... - posted by tillrohrmann <gi...@git.apache.org> on 2015/09/23 14:44:07 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2744) Reduce number of concurrent test forks to 1 for the Kafka connector project - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 15:28:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2744) Reduce number of concurrent test forks to 1 for the Kafka connector project - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 15:30:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 15:31:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/23 16:34:04 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2742) Flink Configuration URL Not Found - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/23 17:02:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2742) Broken link in setup quickstart - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/23 17:03:04 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2734) ArrayKeySelector returns wrong positions (or fails) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 17:18:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2734) ArrayKeySelector returns wrong positions (or fails) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 17:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/23 17:20:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 17:21:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 17:22:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 17:22:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/23 17:23:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-1526) Add Minimum Spanning Tree library method and example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/23 17:23:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/09/23 17:24:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/23 17:25:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2742) Broken link in setup quickstart - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 17:46:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2742) Broken link in setup quickstart - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 17:46:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2742) Broken link in setup quickstart - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 18:11:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 18:15:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/23 18:23:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2651] Add Netty to dependency managemen... - posted by uce <gi...@git.apache.org> on 2015/09/23 18:37:51 UTC, 12 replies.
- [jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/23 18:52:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2753) Add new window API to streaming API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:32:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2683) Add utilities for heap-backed keyed state in time panes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:32:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2682) Add a dedicated processing time aligned keyed window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:33:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2683) Add utilities for heap-backed keyed state in time panes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:33:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2682) Add a dedicated processing time aligned keyed window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 20:33:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/09/23 21:06:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2675) Add utilities for scheduled triggers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 21:15:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-2675) Add utilities for scheduled triggers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/23 21:15:07 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2753] [streaming] [api breaking] Add fi... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/23 21:27:03 UTC, 10 replies.
- [jira] [Commented] (FLINK-2753) Add new window API to streaming API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/23 21:27:04 UTC, 10 replies.
- [jira] [Commented] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/09/24 00:25:04 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2751] [Documentation] Add quickstart me... - posted by rerngvit <gi...@git.apache.org> on 2015/09/24 00:59:57 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2754] Add a new module for micro benchm... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/09/24 03:47:06 UTC, 7 replies.
- [jira] [Created] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/24 04:29:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2754] FixedLengthRecordSorter can not w... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/09/24 05:19:09 UTC, 3 replies.
- [jira] [Commented] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/24 05:20:04 UTC, 10 replies.
- [jira] [Updated] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/24 11:45:20 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1520) Read edges and vertices from CSV files - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/24 11:47:47 UTC, 0 replies.
- [jira] [Created] (FLINK-2755) Cluster Execution - /home/user/udfs.jar - posted by "dengjie (JIRA)" <ji...@apache.org> on 2015/09/24 11:52:35 UTC, 0 replies.
- [jira] [Created] (FLINK-2756) start/stop scripts fail in directories with spaces - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/24 12:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2757) DataSinkTaskTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/24 12:09:32 UTC, 0 replies.
- [jira] [Created] (FLINK-2758) TaskManagerRegistrationTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/24 12:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/24 12:31:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2751) Quickstart is in documentation but only linked through the Flink homepage - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/24 14:13:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2755) Cluster Execution - /home/user/udfs.jar - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/24 15:18:04 UTC, 0 replies.
- [GitHub] flink pull request: Fix of the RabbitMQ Java example (added braces... - posted by tipok <gi...@git.apache.org> on 2015/09/24 15:38:53 UTC, 3 replies.
- [jira] [Created] (FLINK-2760) Avoid uploading of already existing jars from the JobClient - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/24 15:59:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/24 16:14:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2432] Custom serializer support - posted by StephanEwen <gi...@git.apache.org> on 2015/09/24 17:13:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-2432) [py] Provide support for custom serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/24 17:13:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/24 17:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2762) Job Runtime: -1 ms - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/24 19:59:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1521) Some Chained Drivers do not respect object-reuse/non-reuse flag - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/24 23:10:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/24 23:42:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/25 10:35:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2761][scala-shell]Prevent creation of n... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/25 10:55:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/25 10:56:04 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2756) start/stop scripts fail in directories with spaces - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/25 11:24:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2753) Add new window API to streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/25 11:57:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/25 12:03:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2762) Job Runtime: -1 ms - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/25 12:05:04 UTC, 0 replies.
- [GitHub] flink pull request: [0.10.0-milestone-1] [hotfix] [webclient] WebC... - posted by mjsax <gi...@git.apache.org> on 2015/09/25 12:37:59 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2756] Fix start/stop scripts for paths ... - posted by fhueske <gi...@git.apache.org> on 2015/09/25 12:57:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-2756) start/stop scripts fail in directories with spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/25 12:58:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2561] Adda missing Gelly scala methods ... - posted by vasia <gi...@git.apache.org> on 2015/09/25 13:14:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/25 13:15:04 UTC, 6 replies.
- [jira] [Created] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/25 14:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2764) WebClient cannot display multiple Jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/25 15:21:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2677] Add a general-purpose keyed-windo... - posted by aljoscha <gi...@git.apache.org> on 2015/09/25 17:27:51 UTC, 6 replies.
- [jira] [Commented] (FLINK-2677) Add a general-purpose keyed-window operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/25 17:28:04 UTC, 6 replies.
- [jira] [Created] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.1 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/25 17:55:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2766) Bad ipv6 jomanager url - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/25 18:04:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2766) Bad ipv6 jomanager url - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/25 18:05:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2766) Bad ipv6 jomanager url - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/25 18:08:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2766) Bad ipv6 jomanager url - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/25 18:14:04 UTC, 3 replies.
- [jira] [Updated] (FLINK-2766) Bad ipv6 urls - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/25 18:19:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2767) Add support Scala 2.11 to Scala shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/25 19:38:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/09/25 20:05:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/25 23:57:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-714) Allow executing Cascading/Scalding jobs with Stratosphere - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2015/09/26 06:15:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/09/26 11:29:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-714) Allow executing Cascading/Scalding jobs with Stratosphere - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/26 13:49:04 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/26 13:55:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2769] [dashboard] Remove hard coded job... - posted by uce <gi...@git.apache.org> on 2015/09/26 14:33:34 UTC, 5 replies.
- [jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/26 14:34:04 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/26 14:48:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2770) KafkaITCase.testConcurrentProducerConsumerTopology fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/27 11:37:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2764] [WebClient] [0.10.0-milestone-1] ... - posted by mjsax <gi...@git.apache.org> on 2015/09/27 11:37:35 UTC, 6 replies.
- [jira] [Commented] (FLINK-2764) WebClient cannot display multiple Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/27 11:38:04 UTC, 7 replies.
- [jira] [Assigned] (FLINK-1966) Add support for predictive model markup language (PMML) - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/27 16:36:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2666) Allow custom Timestamp extractors for Flink sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/28 11:32:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/28 12:24:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/09/28 12:26:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/09/28 12:36:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/28 12:37:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/28 12:44:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/28 12:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2772) Introduce dedicated garbage collector config parameter and set default values for batch and streaming - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/28 12:58:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2561] Adds missing Gelly scala methods ... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/28 13:06:53 UTC, 4 replies.
- [jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Wilmer DAZA (JIRA)" <ji...@apache.org> on 2015/09/28 13:17:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/28 14:34:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2766) Bad ipv6 urls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/28 14:45:04 UTC, 6 replies.
- [jira] [Created] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/28 17:32:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2712) Add some description about tests to "How to Contribute" documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/28 18:05:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2677) Add a general-purpose keyed-window operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/28 18:17:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2753) Add new window API to streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/28 18:17:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/28 18:58:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/09/28 20:29:05 UTC, 2 replies.
- [jira] [Updated] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/28 20:35:04 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-2751][Documentation] Fix wrong java ver... - posted by rerngvit <gi...@git.apache.org> on 2015/09/28 20:37:25 UTC, 1 replies.
- [GitHub] flink pull request: [Flink-2768][Documentation] Fix wrong java ver... - posted by rerngvit <gi...@git.apache.org> on 2015/09/28 20:41:22 UTC, 6 replies.
- [jira] [Commented] (FLINK-2169) Add fromParquet() to TableEnvironment - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/09/28 21:07:04 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/28 21:14:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 21:36:04 UTC, 0 replies.
- [GitHub] flink pull request: [CLEANUP] Cleanup code as part of theme to be ... - posted by hsaputra <gi...@git.apache.org> on 2015/09/28 22:05:38 UTC, 0 replies.
- [jira] [Created] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/28 22:25:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/28 22:25:04 UTC, 9 replies.
- [jira] [Assigned] (FLINK-2762) Job Runtime: -1 ms - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 22:49:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 22:59:04 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 22:59:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 23:00:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2776) Print job id to standard out on CLI job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/09/28 23:25:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2775] [CLEANUP] Cleanup code as part of... - posted by hsaputra <gi...@git.apache.org> on 2015/09/29 03:13:33 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Wilmer DAZA (JIRA)" <ji...@apache.org> on 2015/09/29 08:54:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/09/29 09:10:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2776) Print job id to standard out on CLI job submission - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 09:54:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2777) The description of programming_guide.html has some issues - posted by "chenliang613 (JIRA)" <ji...@apache.org> on 2015/09/29 10:15:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 12:36:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 12:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2778) Add API for non-parallel non-keyed Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 13:52:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2779) Update documentation to reflect new Stream/Window API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 13:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2780) Remove Old Windowing Logic and API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 13:54:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:10:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2768) Wrong Java version requirements in "Quickstart: Scala API" page - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:11:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2756) start/stop scripts fail in directories with spaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2756) start/stop scripts fail in directories with spaces - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2723) CopyableValue method to copy into new instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:12:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2780) Remove Old Windowing Logic and API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:15:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2754) FixedLengthRecordSorter can not write to output cross MemorySegments. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:16:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2723) CopyableValue method to copy into new instance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:16:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2653) Enable object reuse in MergeIterator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:17:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2653) Enable object reuse in MergeIterator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:17:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:17:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2761) Prevent instantiation of new ExecutionEnvironments in the Scala Shell - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:17:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2766) Bad ipv6 urls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 14:19:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2777) The description of programming_guide.html has some issues - posted by "chenliang613 (JIRA)" <ji...@apache.org> on 2015/09/29 14:53:04 UTC, 3 replies.
- [jira] [Closed] (FLINK-2537) Add scala examples.jar to build-target/examples - posted by "chenliang613 (JIRA)" <ji...@apache.org> on 2015/09/29 14:55:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 15:24:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2779) Update documentation to reflect new Stream/Window API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 15:32:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2779) Update documentation to reflect new Stream/Window API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/09/29 15:32:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1753) Add more tests for Kafka Connectors - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 16:09:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1753) Add more tests for Kafka Connectors - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/09/29 16:10:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2781) Consolidate NetUtils - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 16:35:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2781] [core] Cleanup NetUtils. - posted by StephanEwen <gi...@git.apache.org> on 2015/09/29 16:41:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2781) Consolidate NetUtils - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/29 16:42:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2740) Create data consumer for Apache NiFi - posted by "Bryan Bende (JIRA)" <ji...@apache.org> on 2015/09/29 16:52:05 UTC, 10 replies.
- [jira] [Closed] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/09/29 17:20:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2725] Max/Min/Sum Aggregation of mutabl... - posted by greghogan <gi...@git.apache.org> on 2015/09/29 17:22:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-2725) Max/Min/Sum Aggregation of mutable types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/29 17:23:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2766] [core] Add proper handling for IP... - posted by StephanEwen <gi...@git.apache.org> on 2015/09/29 17:51:26 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2777] The description of programming_gu... - posted by chenliang613 <gi...@git.apache.org> on 2015/09/29 17:53:52 UTC, 2 replies.
- [jira] [Commented] (FLINK-2777) The description of programming_guide.html has some issues - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/29 17:54:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 18:44:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2782) Remove deprecated features for 0.10 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 19:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 19:58:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2784) Remove deprecated config keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 19:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/29 20:00:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/09/29 20:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/29 20:42:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1611) [REFACTOR] Rename classes and packages in test that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/29 20:58:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1704) Change AbstractFlinkYarnClient and AbstractFlinkYarnCluster from abstract to interface - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/29 20:58:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1611) [REFACTOR] Rename classes and packages that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/29 20:58:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2745) Create a new module for all Flink micro benchmark. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:03:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2745) Create a new module for all Flink micro benchmark. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:03:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2777) The description of programming_guide.html has some issues - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:04:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2777) The description of programming_guide.html has some issues - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:04:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:33:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2787) Prevent explicit use of RemoteEnvironment when running a job through the command line - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/29 21:35:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2703] Prepare Flink for using it with L... - posted by rmetzger <gi...@git.apache.org> on 2015/09/29 22:17:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/29 22:18:04 UTC, 5 replies.
- [GitHub] flink pull request: [hotfix] Simplify new windowing API - posted by aljoscha <gi...@git.apache.org> on 2015/09/29 22:29:44 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2778] Add API for non-parallel non-keye... - posted by aljoscha <gi...@git.apache.org> on 2015/09/29 22:30:48 UTC, 4 replies.
- [jira] [Commented] (FLINK-2778) Add API for non-parallel non-keyed Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/29 22:31:04 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2775) [CLEANUP] Cleanup code as part of theme to be more consistent on Utils classes - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/09/30 00:04:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/30 00:05:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2764) WebClient cannot display multiple Jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/09/30 00:13:05 UTC, 0 replies.
- [jira] [Moved] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/09/30 04:22:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2766) Bad ipv6 urls - posted by "Arsenii Krasikov (JIRA)" <ji...@apache.org> on 2015/09/30 10:18:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/30 10:25:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/30 10:41:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp... - posted by chiwanpark <gi...@git.apache.org> on 2015/09/30 10:46:33 UTC, 3 replies.
- [jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/30 10:47:04 UTC, 3 replies.
- [jira] [Updated] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/30 11:19:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/30 11:26:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1983) Remove dependencies on Record APIs for Spargel - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/09/30 11:27:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2790) Add high availability support for Yarn - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/09/30 14:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2791) ParallelMergeITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/30 14:38:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2791) ParallelMergeITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/09/30 14:39:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2792) Set log level of actor messages to TRACE - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/30 15:19:04 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2740 Adding flink-connector-nifi module ... - posted by bbende <gi...@git.apache.org> on 2015/09/30 15:50:18 UTC, 9 replies.
- [jira] [Commented] (FLINK-2792) Set log level of actor messages to TRACE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/09/30 16:10:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2782] Remove "degreeOfParallelism" API ... - posted by zentol <gi...@git.apache.org> on 2015/09/30 16:19:15 UTC, 1 replies.
- [jira] [Commented] (FLINK-2782) Remove deprecated features for 0.10 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/30 16:20:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2783] Remove "degreeOfParallelism" API ... - posted by zentol <gi...@git.apache.org> on 2015/09/30 16:20:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/30 16:21:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2666] Add timestamp extraction operator - posted by aljoscha <gi...@git.apache.org> on 2015/09/30 16:49:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2666) Allow custom Timestamp extractors for Flink sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/09/30 16:49:04 UTC, 0 replies.
- [GitHub] flink pull request: [dashboard] Redirect to leader in non-standalo... - posted by uce <gi...@git.apache.org> on 2015/09/30 17:01:59 UTC, 0 replies.
- [jira] [Updated] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/09/30 17:09:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2773] remove strict upper direct memory... - posted by mxm <gi...@git.apache.org> on 2015/09/30 17:09:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2561] [gelly] adds documentation for ge... - posted by vasia <gi...@git.apache.org> on 2015/09/30 17:56:31 UTC, 0 replies.
- [jira] [Created] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/09/30 18:08:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/09/30 21:45:04 UTC, 0 replies.