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

---

- [GitHub] flink pull request: [FLINK-2452] [Gelly] adds a playcount threshol... - posted by vasia <gi...@git.apache.org> on 2015/08/01 01:42:47 UTC, 4 replies.
- [jira] [Commented] (FLINK-2452) Add a playcount threshold to the MusicProfiles example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/01 01:43:04 UTC, 4 replies.
- [jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 08:47:04 UTC, 8 replies.
- [jira] [Created] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/01 09:35:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2456][fix]add a repository ID for hadoo... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/01 11:04:30 UTC, 11 replies.
- [jira] [Commented] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/01 11:05:04 UTC, 11 replies.
- [jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 12:17:05 UTC, 2 replies.
- [jira] [Created] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/01 13:34:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2170) Add fromOrcFile() to TableEnvironment - posted by "Eric Falk (JIRA)" <ji...@apache.org> on 2015/08/01 14:59:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/01 15:41:07 UTC, 3 replies.
- [jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/01 15:42:04 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 16:03:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2458) Distributed Cache doesn't work with iterations. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 16:07:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2458) Distributed Cache doesn't work with iterations. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 16:17:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2458) Distributed Cache doesn't work with iterations. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/01 16:30:04 UTC, 27 replies.
- [jira] [Created] (FLINK-2459) Failure on recently added Client side logging test - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 17:45:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2459) Failure on recently added Client side logging test - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 17:46:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2458][FLINK-2449]Access distributed cac... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/01 18:02:45 UTC, 25 replies.
- [jira] [Commented] (FLINK-2459) Failure on recently added Client side logging test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/01 18:08:04 UTC, 12 replies.
- [jira] [Comment Edited] (FLINK-2459) Failure on recently added Client side logging test - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 18:14:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2459][cli]Cli API and doc fixes. - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/01 20:03:06 UTC, 8 replies.
- [jira] [Created] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 20:18:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2443) The Gather-Sum-Apply Version of Connected Components fails with NPE - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/01 23:22:04 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2414) Extend job data in job list - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/02 07:57:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-2414) Extend job data in job list - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/02 08:01:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/02 10:54:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/02 10:54:05 UTC, 17 replies.
- [jira] [Updated] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/02 10:56:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2457) Tuple.getTupleClass cannot generate Tuple0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/02 10:57:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-2170) Add fromOrcFile() to TableEnvironment - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/02 11:04:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/02 11:19:38 UTC, 48 replies.
- [jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 11:20:04 UTC, 48 replies.
- [jira] [Created] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 15:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2462) Wrong exception reporting in streaming jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:13:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2453) Update POM to use Java7 as the source and target version - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:14:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2438) Improve performance of channel events - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:16:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2438) Improve performance of channel events - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:16:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 17:16:59 UTC, 3 replies.
- [jira] [Commented] (FLINK-2442) PojoType fields not supported by field position keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 17:17:04 UTC, 3 replies.
- [jira] [Closed] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:19:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:19:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:20:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:20:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2455) Misleading I/O manager error log messages - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:24:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:31:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2461) RemoteExecutorHostnameResolutionTest and ClientHostnameResolutionTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 17:31:04 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 17:51:37 UTC, 3 replies.
- [jira] [Commented] (FLINK-2322) Unclosed stream may leak resource - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 17:52:04 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2357] [web dashboard] Shows job configu... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 17:58:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 17:59:04 UTC, 7 replies.
- [jira] [Created] (FLINK-2463) Chow execution config in dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 18:04:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 18:18:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 18:19:04 UTC, 4 replies.
- [GitHub] flink pull request: FLINK-2434:org.apache.hadoop:hadoop-yarn-commo... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 18:24:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 18:25:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 18:39:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 18:40:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 18:43:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2437] Fix default constructor detection... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 19:18:14 UTC, 9 replies.
- [jira] [Commented] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 19:19:04 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 19:24:42 UTC, 8 replies.
- [jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 19:25:05 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 19:28:27 UTC, 13 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 19:29:04 UTC, 13 replies.
- [jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 19:29:05 UTC, 4 replies.
- [jira] [Commented] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 19:31:04 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 19:35:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 19:36:04 UTC, 4 replies.
- [jira] [Commented] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 19:36:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2409] [webserver] Replaces ActorRefs wi... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 19:38:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 19:39:04 UTC, 3 replies.
- [GitHub] flink pull request: Stale Synchronous Parallel Iterations - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 20:01:11 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 20:02:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 20:03:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 20:42:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 20:42:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2463) Chow execution config in dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 20:43:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2463) Chow execution config in dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/02 20:44:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2425]Provide access to task manager con... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/02 20:50:38 UTC, 11 replies.
- [jira] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/02 20:51:04 UTC, 11 replies.
- [jira] [Created] (FLINK-2464) BufferSpillerTest sometimes fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/08/02 21:39:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2436) Make ByteStreamStateHandles more robust - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/08/02 22:40:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/02 23:38:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2464) BufferSpillerTest sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 00:03:05 UTC, 6 replies.
- [jira] [Closed] (FLINK-2433) Jekyll on windows for building local documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 00:57:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2433) Jekyll on windows for building local documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 00:57:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by hsaputra <gi...@git.apache.org> on 2015/08/03 08:35:19 UTC, 88 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/03 08:36:04 UTC, 88 replies.
- [jira] [Created] (FLINK-2465) SocketClientSink closeConnection function has memory leak - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/03 09:59:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2465] Fix SocketClientSink closeConnect... - posted by ffbin <gi...@git.apache.org> on 2015/08/03 10:21:54 UTC, 5 replies.
- [jira] [Commented] (FLINK-2465) SocketClientSink closeConnection function has memory leak - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/03 10:22:04 UTC, 5 replies.
- [jira] [Created] (FLINK-2466) Travis build failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/03 10:46:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2466) Travis build failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 11:35:04 UTC, 12 replies.
- [jira] [Created] (FLINK-2467) Example WordCountStorm.jar in not packaged correclty - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 11:58:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2467) Example WordCountStorm.jar is not packaged correctly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 11:59:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/03 12:00:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/03 12:01:04 UTC, 8 replies.
- [jira] [Created] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/03 12:35:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2173) Python uses different tmp file than Flink - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 13:14:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2469) JobManager crashes on Cancel - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 13:29:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2469) JobManager crashes on Cancel - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/03 13:44:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2470) Stream Iteration can Hang after some Data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/03 13:55:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2470) Stream Iteration can Hang after some Data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/03 13:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2471) FileSinkFunction invoke performance optimize - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/03 14:50:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2471]FileSinkFunction invoke performanc... - posted by ffbin <gi...@git.apache.org> on 2015/08/03 14:58:52 UTC, 11 replies.
- [jira] [Commented] (FLINK-2471) FileSinkFunction invoke performance optimize - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/03 14:59:04 UTC, 11 replies.
- [jira] [Closed] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/03 15:00:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-2401) Replace ActorRefs with ActorGateway in web server - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/03 15:01:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2472) Make the JobClientActor check periodically if the submitted Job is still running and if the JobManager is still alive - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/03 15:51: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 "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/03 15:52:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2467] Example WordCountStorm.jar is not... - posted by mjsax <gi...@git.apache.org> on 2015/08/03 16:18:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-2467) Example WordCountStorm.jar is not packaged correctly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/03 16:18:04 UTC, 4 replies.
- [jira] [Created] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 16:21:04 UTC, 0 replies.
- [GitHub] flink pull request: [WIP] User defined communication between tasks... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/03 18:43:32 UTC, 1 replies.
- [jira] [Created] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:45:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:51:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2473) Add a timeout to ActorSystem shutdown in the Client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:51:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:52:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:52:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2426) Create a read-only variant of the Configuration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:53:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2426) Create a read-only variant of the Configuration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:53:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2465) SocketClientSink closeConnection function has memory leak - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:54:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2465) SocketClientSink closeConnection function has memory leak - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 20:54:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2322) Unclosed stream may leak resource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 21:00:05 UTC, 0 replies.
- [jira] [Assigned] (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/08/03 21:35:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2095) Screenshots missing in webcient documentation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 22:13:07 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2095] Screenshots missing in webcient d... - posted by mjsax <gi...@git.apache.org> on 2015/08/03 22:13:48 UTC, 3 replies.
- [jira] [Commented] (FLINK-2095) Screenshots missing in webcient documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/03 22:14:09 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 22:38:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2456) The flink-hbase module dependencies hadoop-2 specifies a repository ID - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/03 22:38:06 UTC, 0 replies.
- [GitHub] flink pull request: User defined communication between parallel in... - posted by fhueske <gi...@git.apache.org> on 2015/08/03 23:03:16 UTC, 7 replies.
- [jira] [Created] (FLINK-2475) Rename Flink Client log and out file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 23:22:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2475) Rename Flink Client log and out file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/03 23:22:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-2095) Screenshots missing in webclient documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 00:30:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2095) Screenshots missing in webclient documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 00:31:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2422] [web client] adding redirect link - posted by fhueske <gi...@git.apache.org> on 2015/08/04 00:41:33 UTC, 1 replies.
- [jira] [Commented] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled in browser - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 00:42:06 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled in browser - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 00:47:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled in browser - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 00:49:07 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled in browser - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 00:50:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo... - posted by fhueske <gi...@git.apache.org> on 2015/08/04 00:54:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 00:55:04 UTC, 3 replies.
- [jira] [Created] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/04 04:44:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2477) Add test for SocketClientSink - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/04 04:45:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2477][Add]Add tests for SocketClientSin... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/04 05:32:22 UTC, 38 replies.
- [jira] [Commented] (FLINK-2477) Add test for SocketClientSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 05:33:04 UTC, 40 replies.
- [GitHub] flink pull request: Remove unwanted check null of input1 in Connec... - posted by ffbin <gi...@git.apache.org> on 2015/08/04 05:59:50 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2472]Make JobClientActor poll JobManage... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/04 06:13:10 UTC, 21 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/08/04 06:14:04 UTC, 21 replies.
- [jira] [Created] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2015/08/04 08:19:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/04 09:38:04 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/04 09:38:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/04 09:43:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2423] [streaming] ITCase for checkpoint... - posted by mbalassi <gi...@git.apache.org> on 2015/08/04 10:15:16 UTC, 11 replies.
- [jira] [Commented] (FLINK-2423) Properly test checkpoint notifications - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 10:16:05 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-1297] Added OperatorStatsAccumulator fo... - posted by tammymendt <gi...@git.apache.org> on 2015/08/04 10:19:17 UTC, 8 replies.
- [jira] [Commented] (FLINK-1297) Add support for tracking statistics of intermediate results - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 10:20:04 UTC, 8 replies.
- [jira] [Updated] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 10:21:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2457) Integrate Tuple0 - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/04 10:26:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 10:28:04 UTC, 5 replies.
- [jira] [Commented] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 10:29:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 10:29:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 10:29:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2477][ADD]Add tests for SocketClientSin... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/04 10:55:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/08/04 11:10:04 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/08/04 11:10:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/08/04 11:19:04 UTC, 3 replies.
- [jira] [Created] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/04 11:35:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/04 11:40:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API - posted by PieterJanVanAeken <gi...@git.apache.org> on 2015/08/04 11:41:03 UTC, 9 replies.
- [jira] [Commented] (FLINK-1962) Add Gelly Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 11:41:05 UTC, 23 replies.
- [jira] [Assigned] (FLINK-1680) Upgrade Flink dependencies for Tachyon to 0.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/04 12:17:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1680) Upgrade Flink dependencies for Tachyon to 0.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/04 12:17:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/04 12:20:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/04 12:26:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1681] Remove Record API from jdbc modul... - posted by zentol <gi...@git.apache.org> on 2015/08/04 12:48:59 UTC, 4 replies.
- [jira] [Commented] (FLINK-1681) Remove the old Record API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 12:49:04 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2457] Integrate Tuple0 - posted by mjsax <gi...@git.apache.org> on 2015/08/04 13:03:02 UTC, 46 replies.
- [jira] [Commented] (FLINK-2457) Integrate Tuple0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 13:03:04 UTC, 46 replies.
- [jira] [Created] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/04 13:21:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/04 13:34:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 13:43:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/04 13:47:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2481) Test at least once processing guarantee for streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 13:58:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2481) Test at least once processing guarantee for streaming - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 13:59:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2482) Document sreaming processing guarantees - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/04 14:01:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/04 14:21:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2483]Add default branch of switch(sched... - posted by ffbin <gi...@git.apache.org> on 2015/08/04 14:42:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 14:43:04 UTC, 4 replies.
- [jira] [Created] (FLINK-2484) BarrierBuffer does not properly clean up temp files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/04 15:20:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1882) Remove RemoteCollectorOutputFormat - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/04 15:34:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1882] Removed RemotedCollector - posted by zentol <gi...@git.apache.org> on 2015/08/04 15:36:32 UTC, 3 replies.
- [jira] [Commented] (FLINK-1882) Remove RemoteCollectorOutputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 15:37:04 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2447] [java api] TypeExtractor returns ... - posted by twalthr <gi...@git.apache.org> on 2015/08/04 15:39:53 UTC, 3 replies.
- [GitHub] flink pull request: [FLINk-1680] Remove Tachyon test, rename maven... - posted by rmetzger <gi...@git.apache.org> on 2015/08/04 15:54:55 UTC, 6 replies.
- [jira] [Commented] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/04 16:39:04 UTC, 5 replies.
- [jira] [Reopened] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/04 17:17:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/04 17:54:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 18:04:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2398][api-breaking] Introduce StreamGra... - posted by aljoscha <gi...@git.apache.org> on 2015/08/04 18:40:31 UTC, 19 replies.
- [jira] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/04 18:41:04 UTC, 21 replies.
- [jira] [Comment Edited] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/08/04 20:42:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2478) The page “FlinkML - Machine Learning for Flink“ https://ci.apache.org/projects/flink/flink-docs-master/libs/ml/ contains a dead link - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 20:48:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2005) Remove dependencies on Record APIs for flink-jdbc module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 21:08:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2442) PojoType fields not supported by field position keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 21:12:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/04 21:13:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 00:13:04 UTC, 27 replies.
- [jira] [Closed] (FLINK-2105) Implement Sort-Merge Outer Join algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 00:44:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2485) Handle removal of Java Unsafe in Java9 - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/05 01:22:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/05 01:31:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 01:32:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2486) Remove unwanted null check in removeInstance function - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/05 04:04:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2486]Remove unwanted null check in remo... - posted by ffbin <gi...@git.apache.org> on 2015/08/05 04:23:23 UTC, 4 replies.
- [jira] [Commented] (FLINK-2486) Remove unwanted null check in removeInstance function - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 04:24:04 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2480][TEST]Add test for PrintSinkFuncti... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/05 04:43:41 UTC, 1 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/08/05 04:44:04 UTC, 40 replies.
- [GitHub] flink pull request: [FLINK-2480][test]Add tests for PrintSinkFunct... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/05 05:04:47 UTC, 33 replies.
- [GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/08/05 05:30:06 UTC, 45 replies.
- [jira] [Commented] (FLINK-1901) Create sample operator for Dataset - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 05:31:04 UTC, 46 replies.
- [jira] [Created] (FLINK-2487) the array has out of bounds - posted by "zhangrucong (JIRA)" <ji...@apache.org> on 2015/08/05 09:16:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2432] Custom serializer support - posted by rmetzger <gi...@git.apache.org> on 2015/08/05 10:45:08 UTC, 7 replies.
- [jira] [Commented] (FLINK-2432) [py] Provide support for custom serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 10:46:04 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2387] add streaming test case for live ... - posted by fhueske <gi...@git.apache.org> on 2015/08/05 10:54:09 UTC, 9 replies.
- [jira] [Commented] (FLINK-2387) Add test for live accumulators in Streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 10:55:04 UTC, 9 replies.
- [GitHub] flink pull request: Serialized String comparison, Unicode support - posted by fhueske <gi...@git.apache.org> on 2015/08/05 11:25:27 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1851] Add support for casting in Table ... - posted by fhueske <gi...@git.apache.org> on 2015/08/05 11:31:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-1851) Java Table API does not support Casting - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 11:32:05 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout... - posted by mbalassi <gi...@git.apache.org> on 2015/08/05 12:03:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/05 12:04:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2487) the array has out of bounds - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 13:18:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source - posted by "Rico Bergmann (JIRA)" <ji...@apache.org> on 2015/08/05 13:37:04 UTC, 2 replies.
- [jira] [Created] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/05 14:35:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-1882) Remove RemoteCollectorOutputFormat - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 16:27:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2467) Example WordCountStorm.jar is not packaged correctly - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 16:29:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1882) Remove RemoteCollectorOutputFormat - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 16:29:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1680) Upgrade Flink dependencies for Tachyon to 0.6.0 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 16:30:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/05 16:49:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2459) Failure on recently added Client side logging test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 17:37:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2459) Failure on recently added Client side logging test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 17:37:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-885) Task cancellation fails in TempBarrier.close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 17:50:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-885) Task cancellation fails in TempBarrier.close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 17:50:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2464) BufferSpillerTest sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:21:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2464) BufferSpillerTest sometimes fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:21:06 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2484) BarrierBuffer does not properly clean up temp files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:24:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2484) BarrierBuffer does not properly clean up temp files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:24:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:25:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:25:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2466) Travis build failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:26:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2466) Travis build failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 20:26:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2360) EOFException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 21:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2489) Improve the streaming window join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 22:00:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2489) Improve the streaming window join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 22:02:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2361) CompactingHashTable loses entries - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 22:17:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2361) CompactingHashTable loses entries - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 22:17:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1916) EOFException when running delta-iteration job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/05 22:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/06 10:29:06 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2396) Review the datasets of dynamic path and static path in iteration. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/06 10:45:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2431] Refactor PlanBinder/OperationInfo - posted by mxm <gi...@git.apache.org> on 2015/08/06 11:04:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2431) [py] refactor PlanBinder/OperationInfo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 11:04:05 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2490][FIX]Remove the retryForever check... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/06 11:07:09 UTC, 71 replies.
- [jira] [Commented] (FLINK-2490) Remove unwanted boolean check in function SocketTextStreamFunction.streamFromSocket - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 11:08:04 UTC, 71 replies.
- [jira] [Created] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/06 11:50:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2466) Travis build failure - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/06 13:45:04 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2464) BufferSpillerTest sometimes fails - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/06 14:15:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2466) Travis build failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 14:30:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/06 14:31:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2307] Drop Java 6 support - posted by StephanEwen <gi...@git.apache.org> on 2015/08/06 14:55:41 UTC, 7 replies.
- [jira] [Commented] (FLINK-2307) Drop Java 6 support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 14:56:04 UTC, 7 replies.
- [jira] [Created] (FLINK-2492) Rename remaining runtime classes from "match" to "join" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 15:18:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2286] [streaming] Wrapped ParallelMerge... - posted by gaborhermann <gi...@git.apache.org> on 2015/08/06 16:02:55 UTC, 2 replies.
- [jira] [Commented] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 16:03:05 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2454) Update Travis file to run build using Java7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 16:25:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2454) Update Travis file to run build using Java7 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 16:25:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2453) Update POM to use Java7 as the source and target version - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 16:25:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2453) Update POM to use Java7 as the source and target version - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 16:28:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2307) Drop Java 6 support - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 16:31:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2492] [runtime] Rename former 'match' c... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/06 17:00:35 UTC, 4 replies.
- [jira] [Commented] (FLINK-2492) Rename remaining runtime classes from "match" to "join" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 17:01:05 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/06 18:54:28 UTC, 7 replies.
- [jira] [Commented] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 18:55:04 UTC, 7 replies.
- [jira] [Closed] (FLINK-2492) Rename remaining runtime classes from "match" to "join" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:00:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2492) Rename remaining runtime classes from "match" to "join" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:00:07 UTC, 0 replies.
- [jira] [Closed] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:02:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2240) Use BloomFilter to minimize probe side records which are spilled to disk in Hybrid-Hash-Join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:02:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:04:08 UTC, 0 replies.
- [jira] [Closed] (FLINK-100) Pact API Proposal: Add keyless CoGroup (send all to a single group) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:04:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:07:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-202) Workset Iterations: "No Match Found" Behaviour of Solution Set Join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:12:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-266) Warn user if cluster did not come up as expected - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:13:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-202) Workset Iterations: "No Match Found" Behaviour of Solution Set Join - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:13:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-266) Warn user if cluster did not come up as expected - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:14:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:17:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-509) Move virtual machines building process / hosting to Amazon S3 / EC2 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:17:07 UTC, 0 replies.
- [jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:20:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:20:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-655) Add support for both single and set of broadcast values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:23:04 UTC, 1 replies.
- [GitHub] flink pull request: [WIP][FLINK-2386] Add new Kafka Consumers - posted by rmetzger <gi...@git.apache.org> on 2015/08/06 19:42:37 UTC, 6 replies.
- [jira] [Commented] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/06 19:43:05 UTC, 32 replies.
- [jira] [Resolved] (FLINK-841) Updating a non-existing key in solution set yields a NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:45:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-841) Updating a non-existing key in solution set yields a NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:45:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-848) Move combine() from GroupReduceFunction to Interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:47:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-848) Move combine() from GroupReduceFunction to Interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:47:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-701) Change new Java API functions to SAMs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:47:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-854) Web interface: show runtime of subtasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:50:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-854) Web interface: show runtime of subtasks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:50:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-871) Create a documentation distribution together with other release artifacts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:51:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-871) Create a documentation distribution together with other release artifacts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:51:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-915) Introduce two in one progress bars - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:52:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-915) Introduce two in one progress bars - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:53:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:54:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:54:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-967) Make intermediate results a first-class citizen in the JobGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:56:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-967) Make intermediate results a first-class citizen in the JobGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:57:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-981) Support for generated Cloudera Hadoop configuration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:57:07 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:59:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1013) ArithmeticException: / by zero in MutableHashTable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 19:59:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1028) Certain exceptions are not visibly reported to the user - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:00:04 UTC, 1 replies.
- [jira] [Closed] (FLINK-981) Support for generated Cloudera Hadoop configuration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/06 20:00:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1082) WebClient improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:02:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1083) WebInterface improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:02:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-1082) WebClient improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:02:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-1083) WebInterface improvements - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:03:28 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1116) Packaged Scala Examples do not work due to missing test data - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:03:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-1135) Blog post with topic "Accessing Data Stored in Hive with Flink" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:03:30 UTC, 0 replies.
- [jira] [Closed] (FLINK-1116) Packaged Scala Examples do not work due to missing test data - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:03:30 UTC, 0 replies.
- [jira] [Commented] (FLINK-1138) Allow users to specify methods instead of fields in key expressions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:19:11 UTC, 2 replies.
- [jira] [Created] (FLINK-2493) Simplify names of example program JARs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/06 20:23:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2314] - posted by sheetalparade <gi...@git.apache.org> on 2015/08/06 21:57:38 UTC, 3 replies.
- [jira] [Created] (FLINK-2494) Fix StreamGraph getJobGraph bug - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/07 04:47:45 UTC, 0 replies.
- [GitHub] flink pull request: Fix StreamGraph getJobGraph bug - posted by ffbin <gi...@git.apache.org> on 2015/08/07 05:12:01 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2494 ]Fix StreamGraph getJobGraph bug - posted by zentol <gi...@git.apache.org> on 2015/08/07 07:48:23 UTC, 7 replies.
- [jira] [Commented] (FLINK-2494) Fix StreamGraph getJobGraph bug - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/07 07:48:45 UTC, 7 replies.
- [jira] [Created] (FLINK-2495) Add a null point check in API DataStream.union - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/07 09:34:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2495][fix]Add a null point check in API... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/07 09:42:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-2495) Add a null point check in API DataStream.union - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/07 09:42:45 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-2495) Add a null point check in API DataStream.union - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/07 11:00:52 UTC, 0 replies.
- [jira] [Updated] (FLINK-2452) Add a playcount threshold to the MusicProfiles example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/07 12:04:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2452) Add a playcount threshold to the MusicProfiles example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/07 12:05:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2451] [gelly] examples and library clea... - posted by vasia <gi...@git.apache.org> on 2015/08/07 12:13:48 UTC, 8 replies.
- [jira] [Commented] (FLINK-2451) Cleanup Gelly examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/07 12:14:45 UTC, 8 replies.
- [jira] [Commented] (FLINK-2493) Simplify names of example program JARs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/07 12:31:45 UTC, 10 replies.
- [jira] [Created] (FLINK-2496) Expose Task Manager configuration to Runtime Context - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/07 13:48:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2243) Add finite spout functionality to Storm compatibility layer - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/07 14:54:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/07 15:45:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2496) Expose Task Manager configuration to Runtime Context - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/07 15:46:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2497) Rework streaming iteration flow control - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/08/07 16:25:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2498) GroupReduceITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/07 16:46:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2498) GroupReduceITCase failure - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/07 17:13:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2107) Implement Hash Outer Join algorithm - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/07 18:20:47 UTC, 2 replies.
- [jira] [Created] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node - posted by "Chen He (JIRA)" <ji...@apache.org> on 2015/08/08 00:18:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node - posted by "Chen He (JIRA)" <ji...@apache.org> on 2015/08/08 00:19:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa... - posted by shghatge <gi...@git.apache.org> on 2015/08/08 02:16:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/08 02:17:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2500) Some reviews to improve code quality - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/08 02:28:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2500][Streaming]remove a unwanted "if" ... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/08 03:38:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-2500) Some reviews to improve code quality - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/08 03:38:45 UTC, 5 replies.
- [jira] [Created] (FLINK-2501) [py] Remove the need to specify types for transformations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/08 09:40:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/08 19:48:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2501) [py] Remove the need to specify types for transformations - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/08 20:32:45 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/08 22:27:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-655) Add support for both single and set of broadcast values - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/09 12:03:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2502) FiniteStormSpout documenation does not render correclty - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/09 14:21:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2502] FiniteStormSpout documenation doe... - posted by mjsax <gi...@git.apache.org> on 2015/08/09 14:24:48 UTC, 2 replies.
- [jira] [Commented] (FLINK-2502) FiniteStormSpout documenation does not render correclty - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/09 14:25:45 UTC, 2 replies.
- [jira] [Updated] (FLINK-2502) FiniteStormSpout documenation does not render correclty - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/09 14:30:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe... - posted by vasia <gi...@git.apache.org> on 2015/08/09 20:15:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/09 20:16:45 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode... - posted by vasia <gi...@git.apache.org> on 2015/08/09 20:22:50 UTC, 0 replies.
- [jira] [Commented] (FLINK-1885) Bulk mode for gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/09 20:23:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1707][WIP]Add an Affinity Propagation L... - posted by vasia <gi...@git.apache.org> on 2015/08/09 20:25:46 UTC, 3 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/09 20:26:45 UTC, 3 replies.
- [jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/09 21:00:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1528) Add local clustering coefficient library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/09 21:01:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1528) Add local clustering coefficient library method and example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/09 21:02:45 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-2030][ml]Data Set Statistics and Histog... - posted by chiwanpark <gi...@git.apache.org> on 2015/08/10 09:34:54 UTC, 72 replies.
- [jira] [Created] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/08/10 12:19:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/10 12:31:46 UTC, 0 replies.
- [GitHub] flink pull request: Parameter Server: Distributed Key-Value store,... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/10 12:59:00 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API v2 - posted by PieterJanVanAeken <gi...@git.apache.org> on 2015/08/10 14:09:00 UTC, 13 replies.
- [jira] [Assigned] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2015/08/10 15:17:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2277] In Scala API delta Iterations can... - posted by PieterJanVanAeken <gi...@git.apache.org> on 2015/08/10 15:18:58 UTC, 4 replies.
- [jira] [Commented] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/10 15:19:45 UTC, 4 replies.
- [jira] [Resolved] (FLINK-1138) Allow users to specify methods instead of fields in key expressions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 15:50:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1138) Allow users to specify methods instead of fields in key expressions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 15:50:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2387) Add test for live accumulators in Streaming - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/10 15:51:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:38:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:38:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-1177) Mark HDFS setup as optional in cluster setup instructions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:38:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-705) Check if TPC-H resources can be added - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:40:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-705) Check if TPC-H resources can be added - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:40:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2497) Rework streaming iteration flow control - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:43:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2498) GroupReduceITCase failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 16:44:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 17:17:45 UTC, 9 replies.
- [jira] [Assigned] (FLINK-2493) Simplify names of example program JARs - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/10 19:59:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2314] - Added Checkpointing to File Sou... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/10 20:22:16 UTC, 7 replies.
- [jira] [Resolved] (FLINK-2498) GroupReduceITCase failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 20:49:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2498) GroupReduceITCase failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 20:49:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 20:58:46 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 21:35:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2483) Add default branch of switch(scheduleMode) in scheduleForExecution function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/10 21:35:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2357] Update Node installation instruct... - posted by ebautistabar <gi...@git.apache.org> on 2015/08/10 22:26:54 UTC, 2 replies.
- [jira] [Created] (FLINK-2505) HDFSTest failure: VM crash - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/11 00:14:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2505) HDFSTest failure: VM crash - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/11 00:15:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-2505) HDFSTest failure: VM crash - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/11 00:21:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/11 03:33:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-2077) Rework Path class and add extend support for Windows paths - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/08/11 05:11:45 UTC, 14 replies.
- [jira] [Created] (FLINK-2506) HBase table that is distributed over more than 1 region server - posted by "Lydia Ickler (JIRA)" <ji...@apache.org> on 2015/08/11 08:22:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2506) HBase table that is distributed over more than 1 region server (Flink Cluster-Mode) - posted by "Lydia Ickler (JIRA)" <ji...@apache.org> on 2015/08/11 08:39:45 UTC, 0 replies.
- [jira] [Updated] (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/08/11 08:43:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode) - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/08/11 09:06:46 UTC, 4 replies.
- [jira] [Updated] (FLINK-1901) Create sample operator for Dataset - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/08/11 10:20:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2077) Rework Path class and add extend support for Windows paths - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/11 10:21:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/11 10:53:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/11 11:19:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2507]Rename the function tansformAndEmi... - posted by ffbin <gi...@git.apache.org> on 2015/08/11 13:11:15 UTC, 4 replies.
- [jira] [Commented] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/11 13:11:46 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2502) FiniteStormSpout documenation does not render correclty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:15:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2502) FiniteStormSpout documenation does not render correclty - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:15:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2500) Some reviews to improve code quality - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:16:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2500) Some reviews to improve code quality - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:16:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:17:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2277) In Scala API delta Iterations can not be set to unmanaged - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 13:19:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 14:54:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2423) Properly test checkpoint notifications - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/11 15:56:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2509) Improve error messages when user code classes are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 16:09:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2509] Add class loader info to exceptio... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/11 16:12:21 UTC, 10 replies.
- [jira] [Commented] (FLINK-2509) Improve error messages when user code classes are not found - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/11 16:12:45 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-2501) [py] Remove the need to specify types for transformations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/11 16:49:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 18:02:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-2510) KafkaConnector should access partition metadata from master/cluster - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/11 18:04:46 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-Gelly] [example] added missing assumpti... - posted by andralungu <gi...@git.apache.org> on 2015/08/11 20:25:04 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f... - posted by andralungu <gi...@git.apache.org> on 2015/08/11 20:46:56 UTC, 2 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/11 20:47:47 UTC, 2 replies.
- [GitHub] flink pull request: Hits - posted by andralungu <gi...@git.apache.org> on 2015/08/11 20:52:21 UTC, 0 replies.
- [jira] [Created] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/08/11 22:16:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/11 22:39:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/11 22:46:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2511) Potential resource leak due to unclosed InputStream in FlinkZooKeeperQuorumPeer.java - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/11 22:48:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2162) Implement adaptive learning rate strategies for SGD - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2015/08/12 01:29:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2512) Add client.close() before throw RuntimeException - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/12 04:23:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2512]Add client.close() before throw Ru... - posted by ffbin <gi...@git.apache.org> on 2015/08/12 04:39:24 UTC, 12 replies.
- [jira] [Commented] (FLINK-2512) Add client.close() before throw RuntimeException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/12 04:39:46 UTC, 17 replies.
- [jira] [Closed] (FLINK-2487) the array has out of bounds - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/12 07:43:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2509) Improve error messages when user code classes are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/12 10:07:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2509) Improve error messages when user code classes are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/12 10:07:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2507) Rename the function tansformAndEmit in org.apache.flink.stormcompatibility.wrappers.AbstractStormCollector - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/12 11:35:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2399] Version checks for Job Manager an... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/12 11:49:00 UTC, 23 replies.
- [jira] [Commented] (FLINK-2399) Fail when actor versions don't match - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/12 11:49:46 UTC, 23 replies.
- [jira] [Commented] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/12 12:14:45 UTC, 5 replies.
- [jira] [Updated] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/12 12:31:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/12 12:32:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/12 12:44:45 UTC, 6 replies.
- [GitHub] flink pull request: [CLEANUP] Add space between quotes and plus si... - posted by hsaputra <gi...@git.apache.org> on 2015/08/12 18:26:39 UTC, 9 replies.
- [jira] [Assigned] (FLINK-2501) [py] Remove the need to specify types for transformations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/12 22:43:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne... - posted by kno10 <gi...@git.apache.org> on 2015/08/13 00:42:39 UTC, 8 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/08/13 00:42:46 UTC, 10 replies.
- [jira] [Updated] (FLINK-2493) Simplify names of example program JARs - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/13 06:17:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2306] Add support for named streams in ... - posted by mjsax <gi...@git.apache.org> on 2015/08/13 09:50:08 UTC, 6 replies.
- [jira] [Commented] (FLINK-2306) Add support for named streams in Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/13 09:50:45 UTC, 6 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/08/13 10:23:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/13 11:57:46 UTC, 7 replies.
- [jira] [Created] (FLINK-2513) Extend state handle provider interface to list all state handles - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/13 13:55:47 UTC, 0 replies.
- [jira] [Created] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/13 14:30:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/13 14:30:46 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/13 15:46:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/13 15:47:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/13 15:47:46 UTC, 0 replies.
- [GitHub] flink pull request: Framesize fix - posted by kl0u <gi...@git.apache.org> on 2015/08/13 16:36:18 UTC, 6 replies.
- [jira] [Created] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/13 16:54:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2516) Remove unwanted log.isInfoEnabled check - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/14 03:52:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2516]Remove unwanted log.isInfoEnabled ... - posted by ffbin <gi...@git.apache.org> on 2015/08/14 04:00:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-2516) Remove unwanted log.isInfoEnabled check - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/14 04:00:48 UTC, 5 replies.
- [GitHub] flink pull request: Minor fix to streaming guide - posted by nezihyigitbasi <gi...@git.apache.org> on 2015/08/14 10:36:24 UTC, 0 replies.
- [jira] [Created] (FLINK-2517) Wrong KafkaSink arguments in streaming guide - posted by "Nezih Yigitbasi (JIRA)" <ji...@apache.org> on 2015/08/14 10:37:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2517] Minor fix to streaming guide - posted by StephanEwen <gi...@git.apache.org> on 2015/08/14 11:30:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-2517) Wrong KafkaSink arguments in streaming guide - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 11:30:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2518) Avoid predetermination of ports for network services - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/14 12:04:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2519) BarrierBuffers get stuck infinitely when some inputs end early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 12:16:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2520) StreamFaultToleranceTestBase does not allow for multiple tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:22:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2517) Wrong KafkaSink arguments in streaming guide - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:27:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2519) BarrierBuffers get stuck infinitely when some inputs end early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:27:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2519) BarrierBuffers get stuck infinitely when some inputs end early - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:27:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:30:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2515) CheckpointCoordinator triggers checkpoints even if not all sources are running any more - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 13:30:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2520) StreamFaultToleranceTestBase does not allow for multiple tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/14 13:42:45 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-2286] [0.9.1] ParallelMerge fix - posted by mbalassi <gi...@git.apache.org> on 2015/08/14 13:55:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/14 14:08:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2521) Add automatic test name logging for tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/14 14:44:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/08/14 15:14:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2521] [tests] Adds automatic test name ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/08/14 15:20:59 UTC, 5 replies.
- [jira] [Commented] (FLINK-2521) Add automatic test name logging for tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/14 15:21:45 UTC, 5 replies.
- [jira] [Created] (FLINK-2523) Increase interrupt timeout in Task Canceling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 16:52:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 16:56:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 17:00:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2291] [runtime] Adds high availability ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/08/14 17:31:03 UTC, 8 replies.
- [jira] [Commented] (FLINK-2291) Use ZooKeeper to elect JobManager leader and send information to TaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/14 17:31:46 UTC, 8 replies.
- [jira] [Resolved] (FLINK-2431) [py] refactor PlanBinder/OperationInfo - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:38:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2431) [py] refactor PlanBinder/OperationInfo - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:38:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2457) Integrate Tuple0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:39:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2457) Integrate Tuple0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:39:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:40:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 20:40:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2495) Add a null point check in API DataStream.union - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 23:31:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2495) Add a null point check in API DataStream.union - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 23:31:47 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2462) Wrong exception reporting in streaming jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 23:32:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2482) Document sreaming processing guarantees - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/14 23:32:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2462] [streaming] Major cleanup of stre... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/14 23:49:11 UTC, 14 replies.
- [jira] [Commented] (FLINK-2462) Wrong exception reporting in streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/14 23:49:46 UTC, 14 replies.
- [jira] [Created] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/15 04:58:45 UTC, 0 replies.
- [GitHub] flink pull request: some small changes for easier understanding. - posted by chenliang613 <gi...@git.apache.org> on 2015/08/15 07:15:21 UTC, 4 replies.
- [jira] [Created] (FLINK-2526) Add catch{} for task when it stop running - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/15 08:57:45 UTC, 0 replies.
- [GitHub] flink pull request: Some updates for programming_guide.md - posted by chenliang613 <gi...@git.apache.org> on 2015/08/15 09:04:52 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2526]Add try-catch for task when it sto... - posted by ffbin <gi...@git.apache.org> on 2015/08/15 09:06:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-2526) Add catch{} for task when it stop running - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/15 09:07:45 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2478]fix the array may have out of boun... - posted by Rucongzhang <gi...@git.apache.org> on 2015/08/15 11:53:27 UTC, 3 replies.
- [jira] [Created] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/15 12:22:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 17:02:45 UTC, 7 replies.
- [jira] [Resolved] (FLINK-2516) Remove unwanted log.isInfoEnabled check - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 18:33:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2516) Remove unwanted log.isInfoEnabled check - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 18:33:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2486) Remove unwanted null check in removeInstance function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 19:09:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-2486) Remove unwanted null check in removeInstance function - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 19:09:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-2334) IOException: Channel to path could not be opened - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 19:21:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-2512) Add client.close() before throw RuntimeException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 20:32:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2512) Add client.close() before throw RuntimeException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/15 20:32:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2528) MatchTaskTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/16 04:51:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2529) fix on some unused code for flink-runtime - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/16 05:52:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2529][runtime]remove some unused code - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/16 06:01:34 UTC, 6 replies.
- [jira] [Commented] (FLINK-2529) fix on some unused code for flink-runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/16 06:01:45 UTC, 6 replies.
- [jira] [Created] (FLINK-2530) optimize equal() of AcknowledgeCheckpoint - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/16 09:44:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2531) combining the "if" branch to improve the performance - posted by "zhangrucong (JIRA)" <ji...@apache.org> on 2015/08/16 09:54:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2531) combining the "if" branch to improve the performance - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/16 09:56:45 UTC, 5 replies.
- [jira] [Closed] (FLINK-2531) combining the "if" branch to improve the performance - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/16 09:58:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2530) optimize equal() of AcknowledgeCheckpoint - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/16 10:00:49 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2531]combining the if branch to improve... - posted by Rucongzhang <gi...@git.apache.org> on 2015/08/16 10:24:13 UTC, 3 replies.
- [jira] [Reopened] (FLINK-2531) combining the "if" branch to improve the performance - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/16 10:26:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2530]optimize equal() of AcknowledgeChe... - posted by ffbin <gi...@git.apache.org> on 2015/08/16 10:26:48 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/16 10:36:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2532) The function name and the variable name are same, it is confusing - posted by "zhangrucong (JIRA)" <ji...@apache.org> on 2015/08/16 10:52:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2496) Expose Task Manager configuration to Runtime Context - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/16 10:59:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/16 11:00:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/16 11:01:45 UTC, 16 replies.
- [GitHub] flink pull request: [flink-2532]fix the function name and the vari... - posted by Rucongzhang <gi...@git.apache.org> on 2015/08/16 11:10:22 UTC, 4 replies.
- [jira] [Updated] (FLINK-2529) fix on some unused code for flink-runtime - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/16 11:25: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/08/16 12:14:46 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2527] [gelly] Ensure that VertexUpdateF... - posted by ggevay <gi...@git.apache.org> on 2015/08/16 15:49:17 UTC, 4 replies.
- [jira] [Updated] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/16 19:29:45 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2458) Distributed Cache doesn't work with iterations. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/16 19:47:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/16 19:47:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/16 19:47:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2458) Distributed Cache doesn't work with iterations. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/16 19:47:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2386] Rework Kafka consumer for Flink - posted by StephanEwen <gi...@git.apache.org> on 2015/08/17 00:23:08 UTC, 8 replies.
- [jira] [Created] (FLINK-2533) Gap based random sample optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/17 04:56:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2534) Improve execution code in CompactingHashTable.java - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/17 05:02:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2535) Fixed size sample algorithm optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/17 05:14:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2534][RUNTIME]Improve in CompactingHash... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/17 05:32:47 UTC, 8 replies.
- [jira] [Commented] (FLINK-2534) Improve execution code in CompactingHashTable.java - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/17 05:33:45 UTC, 8 replies.
- [jira] [Commented] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/17 06:35:46 UTC, 28 replies.
- [jira] [Commented] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/17 09:09:46 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/17 09:18:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/17 11:17:45 UTC, 1 replies.
- [jira] [Issue Comment Deleted] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/17 11:23:45 UTC, 1 replies.
- [jira] [Created] (FLINK-2536) Add a retry for SocketClientSink - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/08/17 11:25:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2536][streaming]add a re-connect for so... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/17 11:34:06 UTC, 56 replies.
- [jira] [Commented] (FLINK-2536) Add a retry for SocketClientSink - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/17 11:34:45 UTC, 56 replies.
- [jira] [Closed] (FLINK-2530) optimize equal() of AcknowledgeCheckpoint - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/17 11:38:46 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/17 11:56:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2448]Clear cache file list in Execution... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/17 12:08:01 UTC, 17 replies.
- [jira] [Resolved] (FLINK-855) Web interface: flow vs stack layout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:52:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-855) Web interface: flow vs stack layout - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:52:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:54:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:54:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:54:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2365) Review of How to contribute page - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:55:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2365) Review of How to contribute page - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:55:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2415) Link nodes in plan to vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:57:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2415) Link nodes in plan to vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 12:58:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2415) Link nodes in plan to vertices - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 13:01:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2462) Wrong exception reporting in streaming jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:16:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2534) Improve execution code in CompactingHashTable.java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:16:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2534) Improve execution code in CompactingHashTable.java - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:16:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2462) Wrong exception reporting in streaming jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:16:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:19:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2527) If a VertexUpdateFunction calls setNewVertexValue more than once, the MessagingFunction will only see the first value set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/17 14:19:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2517) Wrong KafkaSink arguments in streaming guide - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/17 16:11:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1028) Certain exceptions are not visibly reported to the user - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/17 18:28:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2537) Add scala examples.jar to build-target/examples - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/17 20:23:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2537) Add scala examples.jar to build-target/examples - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/17 20:24:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/17 20:48:46 UTC, 8 replies.
- [jira] [Issue Comment Deleted] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/17 20:48:48 UTC, 4 replies.
- [jira] [Updated] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/17 20:50:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2526) Add catch{} for task when it stop running - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/18 02:59:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2538) Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/08/18 04:32:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2366) HA Without ZooKeeper - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/08/18 08:00:50 UTC, 10 replies.
- [jira] [Created] (FLINK-2539) More unified code style for Scala code - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/18 10:45:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/18 11:44:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/18 13:03:45 UTC, 3 replies.
- [jira] [Created] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/18 13:17:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/18 13:25:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2542) It should be documented that it is required from a join key to override hashCode(), when it is not a POJO - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/18 13:27:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2521) Add automatic test name logging for tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/18 13:36:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/18 14:08:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/18 14:23:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 14:28:46 UTC, 8 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/08/18 14:31:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2015/08/18 14:51:45 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2379][ml]Add column wise statistics for... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/18 15:34:32 UTC, 0 replies.
- [jira] [Closed] (FLINK-2532) The function name and the variable name are same, it is confusing - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/18 15:42:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/18 16:17:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/18 16:27:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2544) Some test cases using PowerMock fail with Java 8u20 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:27:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2529) fix on some unused code for flink-runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:39:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2529) fix on some unused code for flink-runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:39:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1962) Add Gelly Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:40:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-1962) Add Gelly Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:40:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2477) Add test for SocketClientSink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:41:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2477) Add test for SocketClientSink - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 16:41:46 UTC, 0 replies.
- [GitHub] flink pull request: Add Scala version of GraphAlgorithm - posted by PieterJanVanAeken <gi...@git.apache.org> on 2015/08/18 17:01:35 UTC, 14 replies.
- [jira] [Created] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/08/18 21:00:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/18 21:09:45 UTC, 8 replies.
- [jira] [Commented] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Min Jiang (JIRA)" <ji...@apache.org> on 2015/08/18 23:55:45 UTC, 15 replies.
- [GitHub] flink pull request: Path refactor - posted by gallenvara <gi...@git.apache.org> on 2015/08/19 05:00:16 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2077] [core] Rework Path class and add ... - posted by gallenvara <gi...@git.apache.org> on 2015/08/19 05:24:38 UTC, 10 replies.
- [jira] [Issue Comment Deleted] (FLINK-2366) HA Without ZooKeeper - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/08/19 05:29:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2537) Add scala examples.jar to build-target/examples - posted by "chenliang (JIRA)" <ji...@apache.org> on 2015/08/19 10:02:45 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/19 10:47:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2030][FLINK-2274][ml]Online Histograms ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/08/19 13:31:07 UTC, 133 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/08/19 13:31:46 UTC, 134 replies.
- [jira] [Comment Edited] (FLINK-2366) HA Without ZooKeeper - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/08/19 15:17:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2528) MatchTaskTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/19 15:31:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2528) DriverTestBase tests fail spuriously - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/19 15:32:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/19 15:38:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2528) DriverTestBase tests fail spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/19 16:00:50 UTC, 0 replies.
- [jira] [Created] (FLINK-2546) The webclient does not allow users to save the execution plan - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/19 16:31:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2547) Provide Cluster Status Info - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/19 16:31:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2548) VertexCentricIteration should avoid doing a coGroup with the edges and the solution set - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/19 18:40:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/19 18:43:46 UTC, 1 replies.
- [jira] [Closed] (FLINK-2514) Local and Remote environment behave differently when re-triggering execution. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/19 18:43:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/19 18:44:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/19 18:44:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2548) VertexCentricIteration should avoid doing a coGroup with the edges and the solution set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/19 18:51:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/20 00:19:46 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/20 00:20:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2540] [optimizer] [runtime] Propagate u... - posted by uce <gi...@git.apache.org> on 2015/08/20 03:57:05 UTC, 5 replies.
- [jira] [Created] (FLINK-2549) Add topK operator for DataSet - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/20 05:24:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2549) Add topK operator for DataSet - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/20 05:40:45 UTC, 4 replies.
- [jira] [Reopened] (FLINK-2468) StreamCheckpointingITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/20 06:28:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave... - posted by rmetzger <gi...@git.apache.org> on 2015/08/20 10:26:18 UTC, 5 replies.
- [jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/20 10:26:45 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2506) HBase connection closing down (table distributed over more than 1 region server - Flink Cluster-Mode) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 10:33:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2550) Rework DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 11:02:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2550) Rework DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 11:09:46 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2549) Add topK operator for DataSet - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/20 11:18:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/20 11:26:45 UTC, 43 replies.
- [jira] [Assigned] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/20 11:34:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2551) Fix Several Bugs in Input/Output Formats - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 11:43:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2551) Fix Several Bugs in Input/Output Formats - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 11:47:45 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-2551) Fix Several Bugs in Input/Output Formats - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 11:47:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/20 14:01:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/20 14:02:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/20 14:14:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/20 14:18:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2553) Example Jars not build correctly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/20 15:13:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2553) Example Jars not build correctly - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/20 15:28:45 UTC, 20 replies.
- [jira] [Created] (FLINK-2554) Add exception reporting handler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/20 17:06:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2553] Example Jars not build correctly - posted by mjsax <gi...@git.apache.org> on 2015/08/20 17:46:03 UTC, 18 replies.
- [jira] [Created] (FLINK-2555) Hadoop Input/Output Formats are unable to access secured HDFS clusters - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/20 19:50:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/20 21:11:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2556) Fix/Refactor pre-flight Key validation - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/21 00:42:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2555] Properly pass security credential... - posted by rmetzger <gi...@git.apache.org> on 2015/08/21 12:39:19 UTC, 14 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/08/21 12:39:45 UTC, 14 replies.
- [jira] [Created] (FLINK-2557) Manal type information via "returns" fails in DataSet API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/21 13:33:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/21 13:34:45 UTC, 2 replies.
- [jira] [Updated] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/21 13:39:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/21 13:53:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2558) Add Streaming Connector for Elasticsearch - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/21 14:06:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2559) Fix Javadoc Code Examples - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/21 14:09:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1901) Create sample operator for Dataset - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/21 15:45:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/21 15:54:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2386] Add new KafkaConsumer, based on K... - posted by rmetzger <gi...@git.apache.org> on 2015/08/21 15:59:53 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-2558] Add Streaming Connector for Elast... - posted by aljoscha <gi...@git.apache.org> on 2015/08/21 17:36:04 UTC, 10 replies.
- [jira] [Commented] (FLINK-2558) Add Streaming Connector for Elasticsearch - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/21 17:36:45 UTC, 10 replies.
- [jira] [Resolved] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/21 17:56:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2540) LocalBufferPool.requestBuffer gets into infinite loop - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/21 17:57:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2306) Add support for named streams in Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/21 19:41:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2306) Add support for named streams in Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/21 19:41:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-1383) Move the hadoopcompatibility package name to just hadoop - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/21 23:06:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/22 01:54:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2560] Flink-Avro Plugin cannot be handl... - posted by mjsax <gi...@git.apache.org> on 2015/08/22 01:57:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/22 01:58:45 UTC, 3 replies.
- [jira] [Updated] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/22 02:01:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/08/22 12:46:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/08/22 13:34:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/22 19:25:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/22 19:33:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2439) [py] Expand DataSet feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/22 20:31:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2440) [py] Expand Environment feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/22 20:34:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2432) [py] Provide support for custom serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/22 20:34:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1945) Make python tests less verbose - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/22 20:35:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2562) [py] Implement KeySelectors - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/22 20:37:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2451) Cleanup Gelly examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/22 21:42:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2563) Gelly's Graph Algorithm Interface is limites - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/23 10:08:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2563) Gelly's Graph Algorithm Interface is limited - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/23 10:08:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/23 12:35:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2563) Gelly's Graph Algorithm Interface is limited - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/23 12:43:45 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2563) Gelly's Graph Algorithm Interface is limited - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/08/23 12:50:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2548) In a VertexCentricIteration, the run time of one iteration should be proportional to the size of the workset - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/08/23 14:18:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2541) TypeComparator creation fails for T2, byte[]> - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/23 15:37:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2565) Support primitive arrays as keys - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/23 15:38:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2563] [gelly] changed Graph's run() to ... - posted by vasia <gi...@git.apache.org> on 2015/08/23 16:35:43 UTC, 3 replies.
- [jira] [Created] (FLINK-2566) FlinkTopologyContext no populated completely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/23 17:04:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2565] Support primitive Arrays as keys - posted by zentol <gi...@git.apache.org> on 2015/08/23 17:49:21 UTC, 19 replies.
- [jira] [Commented] (FLINK-2565) Support primitive arrays as keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/23 17:49:45 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-2556] Refactor/Fix pre-flight Key valid... - posted by zentol <gi...@git.apache.org> on 2015/08/23 17:55:39 UTC, 7 replies.
- [jira] [Commented] (FLINK-2556) Fix/Refactor pre-flight Key validation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/23 17:55:45 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram... - posted by chiwanpark <gi...@git.apache.org> on 2015/08/23 18:09:35 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2560) Flink-Avro Plugin cannot be handled by Eclipse - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/23 18:54:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/23 18:54:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2557) Manual type information via "returns" fails in DataSet API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/23 19:56:45 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-2557] TypeExtractor properly returns Mi... - posted by zentol <gi...@git.apache.org> on 2015/08/23 21:51:57 UTC, 7 replies.
- [jira] [Updated] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/08/23 22:29:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "Andreas Kunft (JIRA)" <ji...@apache.org> on 2015/08/24 04:29:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/24 11:04:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm... - posted by ffbin <gi...@git.apache.org> on 2015/08/24 11:12:38 UTC, 50 replies.
- [jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/24 11:12:45 UTC, 50 replies.
- [jira] [Assigned] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/24 11:36:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/24 11:41:45 UTC, 11 replies.
- [jira] [Created] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/24 11:47:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2564] Failing Test: RandomSamplerTest - posted by ChengXiangLi <gi...@git.apache.org> on 2015/08/24 11:52:34 UTC, 10 replies.
- [jira] [Commented] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Tamara (JIRA)" <ji...@apache.org> on 2015/08/24 11:55:45 UTC, 7 replies.
- [jira] [Updated] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/24 11:56:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-1540) JobManagerFailsITCase Startup timed out on travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/24 12:23:45 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2567) CsvParser: Quotes cannot be escaped inside quoted fields - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/24 12:29:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2543] Fix user object deserialization f... - posted by rmetzger <gi...@git.apache.org> on 2015/08/24 14:45:58 UTC, 42 replies.
- [GitHub] flink pull request: [scripts] resolve base path of symlinked execu... - posted by mxm <gi...@git.apache.org> on 2015/08/24 14:51:40 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2089] [runtime] Fix illegal state in Re... - posted by uce <gi...@git.apache.org> on 2015/08/24 14:53:02 UTC, 6 replies.
- [jira] [Created] (FLINK-2568) Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/24 16:19:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2568) Flink fat jar is missing org.w3c.dom.ElementTraversal in some environments. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/24 16:19: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/08/24 16:31:29 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2460] [runtime] Check parent state in i... - posted by uce <gi...@git.apache.org> on 2015/08/24 17:40:30 UTC, 6 replies.
- [jira] [Created] (FLINK-2569) CsvReader support for ValueTypes - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/08/24 18:17:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2569) CsvReader support for ValueTypes - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/08/24 18:20:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-1730) Add a FlinkTools.persist style method to the Data Set. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/24 19:16:46 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2106] Runtime part - posted by r-pogalz <gi...@git.apache.org> on 2015/08/25 00:15:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2106] [runtime] add Left-, Right- and F... - posted by chiwanpark <gi...@git.apache.org> on 2015/08/25 04:47:53 UTC, 41 replies.
- [jira] [Assigned] (FLINK-2569) CsvReader support for ValueTypes - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/25 05:32:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2563) Gelly's Graph Algorithm Interface is limited - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 10:46:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2570) Add a Triangle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 10:51:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2558) Add Streaming Connector for Elasticsearch - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/25 10:51:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/25 10:59:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2569] [core] Add CsvReader support for ... - posted by chiwanpark <gi...@git.apache.org> on 2015/08/25 11:15:58 UTC, 12 replies.
- [jira] [Commented] (FLINK-2569) CsvReader support for ValueTypes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/25 11:16:45 UTC, 12 replies.
- [jira] [Assigned] (FLINK-2570) Add a Triangle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 11:29:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2528) DriverTestBase tests fail spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/25 13:31:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 14:11:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 14:12:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2570] [gelly] Added a Triangle Count Li... - posted by andralungu <gi...@git.apache.org> on 2015/08/25 14:14:05 UTC, 11 replies.
- [jira] [Commented] (FLINK-2570) Add a Triangle Count Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/25 14:14:45 UTC, 11 replies.
- [jira] [Updated] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 14:15:49 UTC, 2 replies.
- [jira] [Updated] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 14:16:46 UTC, 2 replies.
- [jira] [Created] (FLINK-2571) Add task hooks support in Storm-compatibility - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/25 14:32:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2571) Add task hooks support in Storm-compatibility - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/25 14:44:53 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2386] Add new Kafka Consumer for Flink ... - posted by rmetzger <gi...@git.apache.org> on 2015/08/25 15:12:07 UTC, 4 replies.
- [jira] [Updated] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 15:37:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2570) Add a Triangle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 15:41:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2572) Resolve base path of symlinked executable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 15:49:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2572) Resolve base path of symlinked executable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/25 15:50:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2097) Add support for JobSessions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 15:54:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1513) Remove GlobalConfiguration Singleton - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 15:58:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 15:59:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:01:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1129) The Plan Visualizer Cuts of the Lower Part of Certain Operators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:02:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-1129) The Plan Visualizer Cuts of the Lower Part of Certain Operators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:02:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-1675) Rework Accumulators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:06:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1675) Rework Accumulators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:06:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2528) DriverTestBase tests fail spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/25 16:06:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2528) DriverTestBase tests fail spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/25 16:07:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1297) Add support for tracking statistics of intermediate results - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:07:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-1240) We cannot use sortGroup on a global reduce - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:10:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1278) Remove the Record special code paths - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:11:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-1610) Java docs do not build - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:13:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1613) Cannost submit to remote ExecutionEnvironment from IDE - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:15:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-1702) Authenticate via Kerberos from the client only - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:16:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:18:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1851) Java Table API does not support Casting - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:21:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-1778) Improve normalized keys in composite key case - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/25 16:30:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2542) It should be documented that it is required from a join key to override hashCode(), when it is not a POJO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:56:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-1778) Improve normalized keys in composite key case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 16:57:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 17:01:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 17:01:46 UTC, 1 replies.
- [jira] [Updated] (FLINK-2538) Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 17:11:45 UTC, 1 replies.
- [jira] [Created] (FLINK-2573) Add Kerberos test case - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/25 17:37:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2394] [fix] HadoopOutputFormats use cor... - posted by fhueske <gi...@git.apache.org> on 2015/08/25 17:45:24 UTC, 5 replies.
- [jira] [Commented] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/25 17:45:47 UTC, 5 replies.
- [jira] [Resolved] (FLINK-82) (Hash) Aggregators (fold style) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:11:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-82) (Hash) Aggregators (fold style) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:13:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-555) debian: add /usr/share/stratosphere-dist/bin/stratosphere to path - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:18:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-557) debian: permissions and users - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:19:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1011) Sometimes Flow/Stack Layout is not presented in Dashboard's history - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:25:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1158) Logging property files missing in project created by archetypes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:30:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-1195) Improvement of benchmarking infrastructure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:32:45 UTC, 2 replies.
- [jira] [Resolved] (FLINK-1426) JobManager AJAX requests sometimes fail - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:35:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1558) Spurious failure in PipelinedPartitionQueueTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:40:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1639) Document the Flink deployment scripts to make sure others know how to make release - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:43:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1929) Add code to cleanly stop a running streaming topology - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:45:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:48:46 UTC, 5 replies.
- [jira] [Commented] (FLINK-1158) Logging property files missing in project created by archetypes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/25 18:51:45 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1158) Logging property files missing in project created by archetypes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/25 18:51:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2276) Travis build error - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:58:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 18:59:47 UTC, 1 replies.
- [jira] [Updated] (FLINK-2474) Occasional failures in PartitionedStateCheckpointingITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 19:11:45 UTC, 1 replies.
- [jira] [Updated] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 19:12:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 19:15:45 UTC, 4 replies.
- [jira] [Updated] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/25 19:15:46 UTC, 1 replies.
- [GitHub] flink pull request: [hotfix] Allow setting FLINK_CONF_DIR by hand - posted by aljoscha <gi...@git.apache.org> on 2015/08/25 19:28:36 UTC, 9 replies.
- [jira] [Updated] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 21:04:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/08/25 21:17:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2574) Remove Spargel from master in next release - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/08/26 08:14:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 09:18:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2555) Hadoop Input/Output Formats are unable to access secured HDFS clusters - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 10:24:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2538) Potential resource leak in ClassLoaderUtil#getUserCodeClassLoaderInfo() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 10:40:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2270) Error in KafkaSource Documentation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 10:56:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/26 10:58:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2106) Add outer joins to Runtime - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/26 10:58:46 UTC, 1 replies.
- [jira] [Created] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/26 11:01:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/08/26 11:58:45 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/26 12:20:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 12:27:47 UTC, 0 replies.
- [jira] [Created] (FLINK-2577) Watermarks Stall When a Source Finishes Prematurely - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/26 12:38:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2089) "Buffer recycled" IllegalStateException during cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 12:38:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2512] [bugfix] Used a concurrent list i... - posted by andralungu <gi...@git.apache.org> on 2015/08/26 13:28:44 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 14:27:45 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Jonathan Hasenburg (JIRA)" <ji...@apache.org> on 2015/08/26 14:33:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2125 - posted by tillrohrmann <gi...@git.apache.org> on 2015/08/26 14:39:23 UTC, 0 replies.
- [jira] [Updated] (FLINK-2575) Don't activate hash table bloom filter optimisation by default - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 14:39:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/26 14:39:46 UTC, 6 replies.
- [jira] [Commented] (FLINK-2106) Add outer joins to Runtime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/26 15:17:45 UTC, 18 replies.
- [jira] [Created] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/26 15:17:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/26 15:18:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co... - posted by tillrohrmann <gi...@git.apache.org> on 2015/08/26 15:52:53 UTC, 0 replies.
- [jira] [Updated] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/26 16:03:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2152] [bugfix] Used a concurrent list i... - posted by mjsax <gi...@git.apache.org> on 2015/08/26 16:10:17 UTC, 7 replies.
- [jira] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/26 16:10:46 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2326) Mutitenancy on Yarn - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/26 16:21:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2545) NegativeArraySizeException while creating hash table bloom filters - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/26 16:27:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/26 16:28:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2555) Hadoop Input/Output Formats are unable to access secured HDFS clusters - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 16:32:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/26 16:37:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2567] - posted by tammymendt <gi...@git.apache.org> on 2015/08/26 16:45:10 UTC, 5 replies.
- [jira] [Commented] (FLINK-2326) Mutitenancy on Yarn - posted by "LINTE (JIRA)" <ji...@apache.org> on 2015/08/26 16:52:46 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-2577] Fix Stalling Watermarks when Sour... - posted by aljoscha <gi...@git.apache.org> on 2015/08/26 17:00:48 UTC, 1 replies.
- [jira] [Commented] (FLINK-2577) Watermarks Stall When a Source Finishes Prematurely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/26 17:01:45 UTC, 1 replies.
- [GitHub] flink pull request: Getter for wrapped StreamExecutionEnvironment ... - posted by lofifnc <gi...@git.apache.org> on 2015/08/26 17:24:37 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2572) Resolve base path of symlinked executable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 17:39:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2326] Write yarn properties file to tem... - posted by rmetzger <gi...@git.apache.org> on 2015/08/26 18:12:49 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-2356] Add shutdown hook to CheckpointCo... - posted by uce <gi...@git.apache.org> on 2015/08/26 18:45:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2356) Resource leak in checkpoint coordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/26 18:45:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-2455) Misleading I/O manager error log messages - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 19:01:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/26 19:25:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2189) NullPointerException in MutableHashTable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/26 19:25:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/26 19:38:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/26 19:38:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2356) Resource leak in checkpoint coordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/26 19:59:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK1919] add HCatOutputFormat - posted by jamescao <gi...@git.apache.org> on 2015/08/27 05:46:05 UTC, 27 replies.
- [GitHub] flink pull request: ByteOrder.nativeOrder() can get the native Byt... - posted by sirinath <gi...@git.apache.org> on 2015/08/27 08:12:17 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2373] Add configuration parameter to cr... - posted by akunft <gi...@git.apache.org> on 2015/08/27 08:14:10 UTC, 5 replies.
- [jira] [Created] (FLINK-2579) StreamExecutionEnvironment & ExecutionEnvironment do not share interface but have a lot in common - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/08/27 09:22:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2580) HadoopDataOutputStream does not expose enough methods of org.apache.hadoop.fs.FSDataOutputStream - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/08/27 09:27:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2545] add bucket member count verificat... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/08/27 10:38:37 UTC, 6 replies.
- [jira] [Commented] (FLINK-2579) StreamExecutionEnvironment & ExecutionEnvironment do not share interface but have a lot in common - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 11:02:45 UTC, 1 replies.
- [jira] [Created] (FLINK-2581) Add warning to the YARN client when using an older Hadoop version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/27 11:30:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2493] Simplify names of example program... - posted by chenliang613 <gi...@git.apache.org> on 2015/08/27 12:14:24 UTC, 4 replies.
- [GitHub] flink pull request: New Partitioner for better load balancing for ... - posted by anisnasir <gi...@git.apache.org> on 2015/08/27 13:01:02 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2569) CsvReader support for ValueTypes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:34:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2569) CsvReader support for ValueTypes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:34:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:35:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:35:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2276) Travis build error - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:36:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2276) Travis build error - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:36:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:37:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2578) Failing-Test: TaskAsyncCallTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 13:37:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1725]- New Partitioner for better load ... - posted by mbalassi <gi...@git.apache.org> on 2015/08/27 14:22:13 UTC, 7 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/08/27 14:22:46 UTC, 7 replies.
- [jira] [Created] (FLINK-2582) Document how to build Flink with other Scala versions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 14:30:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2582) Document how to build Flink with other Scala versions - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/27 14:43:46 UTC, 5 replies.
- [jira] [Created] (FLINK-2583) Add Stream Sink For Rolling HDFS Files - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/27 15:00:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/27 15:13:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2553) Example Jars not build correctly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 15:20:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2553) Example Jars not build correctly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 15:20:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2582] [docs] Add documentation how to b... - posted by StephanEwen <gi...@git.apache.org> on 2015/08/27 15:21:35 UTC, 2 replies.
- [jira] [Created] (FLINK-2584) ASM dependency is not shaded away - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/27 16:00:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2585) KafkaSource not working - posted by "Boyang Jerry Peng (JIRA)" <ji...@apache.org> on 2015/08/27 16:54:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2585) KafkaSource not working - posted by "Boyang Jerry Peng (JIRA)" <ji...@apache.org> on 2015/08/27 16:56:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-2585) KafkaSource not working - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/27 17:14:46 UTC, 23 replies.
- [jira] [Commented] (FLINK-2584) ASM dependency is not shaded away - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/27 17:35:46 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2499] [scripts] Warning message for hos... - posted by mbalassi <gi...@git.apache.org> on 2015/08/27 17:38:45 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-2585) KafkaSource not working - posted by "Boyang Jerry Peng (JIRA)" <ji...@apache.org> on 2015/08/27 17:38:46 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2585) KafkaSource not working - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/27 17:50:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 18:54:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/27 19:21:47 UTC, 3 replies.
- [jira] [Updated] (FLINK-2566) FlinkTopologyContext no populated completely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/27 19:23:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/27 19:23:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2338) Shut down "Storm Topologies" cleanly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/27 19:24:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2584) ASM dependency is not shaded away - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 19:44:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2584) ASM dependency is not shaded away - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 19:44:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2585) KafkaSource not working - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/27 21:55:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/27 23:31:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2565) Support primitive arrays as keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:42:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2565) Support primitive arrays as keys - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:42:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2556) Fix/Refactor pre-flight Key validation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:43:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2556) Fix/Refactor pre-flight Key validation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:43:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2326) Mutitenancy on Yarn - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:46:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2326) Mutitenancy on Yarn - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:46:47 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:47:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2587) FlinkKafkaConsumer may fail with a NPE - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/27 23:47:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2499) start-cluster.sh can start multiple TaskManager on the same node - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/08/28 00:21:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2588) Implement KillOptions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/28 03:11:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2588) Implement KillOptions - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/28 03:17:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly - posted by "Arnaud Linz (JIRA)" <ji...@apache.org> on 2015/08/28 09:15:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/08/28 09:20:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/08/28 10:12:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/08/28 10:14:45 UTC, 5 replies.
- [jira] [Updated] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/28 10:17:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2590) DataSetUtils.zipWithUniqueID creates duplicate IDs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/28 11:14:46 UTC, 12 replies.
- [jira] [Created] (FLINK-2591) Add configuration parameter for default number of yarn containers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/28 15:46:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2591) Add configuration parameter for default number of yarn containers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/28 15:47:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2592) Rework of FlinkMiniCluster - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/28 15:49:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2593) Revisit Flink's shading policy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/28 16:00:51 UTC, 0 replies.
- [jira] [Created] (FLINK-2594) Provide a getAccumulators method on the client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/28 17:39:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2594][client] implement a method to ret... - posted by mxm <gi...@git.apache.org> on 2015/08/28 17:40:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-2594) Provide a getAccumulators method on the client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/28 17:40:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2595) Unclosed JarFile may leak resource in ClassLoaderUtilsTest - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/08/28 18:05:47 UTC, 0 replies.
- [jira] [Closed] (FLINK-2594) Provide a getAccumulators method on the client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/28 19:35:45 UTC, 0 replies.
- [jira] [Created] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/28 23:48:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/28 23:50:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2480][test]add a test for Print Sink wi... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/08/29 08:53:33 UTC, 2 replies.
- [jira] [Commented] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/08/29 08:59:45 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/29 09:16:45 UTC, 2 replies.
- [jira] [Created] (FLINK-2597) Add a test for Avro-serialized Kafka messages - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/29 11:59:45 UTC, 0 replies.
- [GitHub] flink pull request: - posted by StephanEwen <gi...@git.apache.org> on 2015/08/29 14:44:56 UTC, 8 replies.
- [jira] [Assigned] (FLINK-2475) Rename Flink Client log file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/29 16:47:45 UTC, 0 replies.
- [jira] [Updated] (FLINK-2475) Rename Flink Client log file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/29 16:47:45 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2475] Rename Flink Client log file - posted by mjsax <gi...@git.apache.org> on 2015/08/29 17:32:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-2475) Rename Flink Client log file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/29 17:33:45 UTC, 1 replies.
- [jira] [Closed] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/29 17:51:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2590] fixing DataSetUtils.zipWithUnique... - posted by s1ck <gi...@git.apache.org> on 2015/08/30 00:09:17 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-2584] Check for unshaded classes in fat... - posted by rmetzger <gi...@git.apache.org> on 2015/08/30 13:22:52 UTC, 4 replies.
- [jira] [Created] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/08/30 15:46:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2125][streaming] Delimiter change from ... - posted by ogokal <gi...@git.apache.org> on 2015/08/30 20:08:49 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/30 20:47:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2543) State handling does not support deserializing classes through the UserCodeClassloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/30 20:47:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-1737: Kronecker product - posted by daniel-pape <gi...@git.apache.org> on 2015/08/30 22:49:14 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2596) Failing Test: RandomSamplerTest - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/08/31 07:58:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2596] Failing Test: RandomSamplerTest - posted by ChengXiangLi <gi...@git.apache.org> on 2015/08/31 08:00:14 UTC, 2 replies.
- [jira] [Created] (FLINK-2599) Failing Test: SlotCountExceedingParallelismTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/31 09:42:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2291) Use ZooKeeper to elect JobManager leader and send information to TaskManagers - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/08/31 12:32:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2599) Failing Test: SlotCountExceedingParallelismTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/08/31 14:02:46 UTC, 0 replies.
- [GitHub] flink pull request: [core][runtime] move SerializedValueTest from ... - posted by mxm <gi...@git.apache.org> on 2015/08/31 14:11:19 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2372] Add new FlinkKafkaProducer - posted by rmetzger <gi...@git.apache.org> on 2015/08/31 15:07:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-2372) Update KafkaSink to use new Producer API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/08/31 15:08:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2599) Failing Test: SlotCountExceedingParallelismTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/31 15:09:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-2599) Failing Test: SlotCountExceedingParallelismTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/08/31 17:24:46 UTC, 0 replies.