You are viewing a plain text version of this content. The canonical link for it is here.
- [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.
- Re: Tuple - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/01 13:04:46 UTC, 16 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: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] [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] [Created] (FLINK-2460) ReduceOnNeighborsWithExceptionITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/08/01 20:18:04 UTC, 0 replies.
- On integrating Flink with HBase - posted by Slim Baltagi <sb...@gmail.com> on 2015/08/02 10:03:31 UTC, 0 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.
- Re: Question about DataStream class hierarchy - posted by Stephan Ewen <se...@apache.org> on 2015/08/02 17:47:54 UTC, 0 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.
- Re: Question About "Preserve Partitioning" in Stream Iteration - posted by Stephan Ewen <se...@apache.org> on 2015/08/02 20:14:52 UTC, 7 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.
- New failing Kafka Test - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/03 00:38:51 UTC, 1 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.
- [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.
- Renaming log file? - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/03 11:46:48 UTC, 2 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.
- Wiki page for 0.10 release - posted by Fabian Hueske <fh...@gmail.com> on 2015/08/03 12:25:06 UTC, 0 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] [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] [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] [Created] (FLINK-2471) FileSinkFunction invoke performance optimize - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/08/03 14:50: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] [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.
- Failing Test - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/03 17:48:48 UTC, 1 replies.
- Re: A soft reminder - posted by Stephan Ewen <se...@apache.org> on 2015/08/03 20:35:21 UTC, 0 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.
- Re: Off-heap memory in Flink? - posted by Stephan Ewen <se...@apache.org> on 2015/08/03 20:45:24 UTC, 0 replies.
- Failing Test again - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/03 23:18:06 UTC, 12 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] [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.
- [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] [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] [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] [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: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.
- [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] [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.
- [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.
- Need help with CI problem - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/05 08:36:24 UTC, 1 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.
- 答复: Need help with CI problem - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/05 10:04:51 UTC, 1 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.
- FYI: Blog Post on Flink's Streaming Performance and Fault Tolerance - posted by Stephan Ewen <se...@apache.org> on 2015/08/05 16:11:29 UTC, 6 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.
- Re: Bug fix release 0.9.1 - posted by Maximilian Michels <mx...@apache.org> on 2015/08/06 10:07:29 UTC, 4 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:05 UTC, 0 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] [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.
- [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.
- [ANNOUNCE] Apache Mahout 0.10.2 Release - posted by Suneel Marthi <sm...@apache.org> on 2015/08/07 02:43:53 UTC, 0 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.
- [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.
- [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.
- [ANNOUNCE] Apache Mahout 0.11.0 Release - posted by Andrew Palumbo <ap...@outlook.com> on 2015/08/07 14:53:41 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] [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] [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.
- Parameter Server for Flink - posted by Sachin Goel <sa...@gmail.com> on 2015/08/08 04:04:35 UTC, 2 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.
- Some problems about Flink applications - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/08 11:15:56 UTC, 3 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.
- Failing test in Gelly - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/09 15:37:33 UTC, 7 replies.
- Cannot run WordCountExample in Intellij - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/09 23:24:06 UTC, 1 replies.
- [Proposal] Addition to Gelly - posted by Andra Lungu <lu...@gmail.com> on 2015/08/10 10:47:06 UTC, 10 replies.
- [jira] [Created] (FLINK-2503) Inconsistencies in FileInputFormat hierarchy - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/08/10 12:19:45 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:45 UTC, 0 replies.
- Re: New Flink Runtime Monitor Dashboard - posted by Stephan Ewen <se...@apache.org> on 2015/08/10 15:53:21 UTC, 1 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] [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:45 UTC, 0 replies.
- Re: add some new api to the scheduler in the job manager - posted by ankurcha <an...@malloc64.com> on 2015/08/11 10:22:12 UTC, 4 replies.
- netty channel for data transfer - posted by wangzhijiang999 <wa...@aliyun.com> on 2015/08/11 11:10:09 UTC, 1 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.
- Re: On some GUI tools for building Flink Streaming data flows... - posted by mnxfst <mn...@gmail.com> on 2015/08/11 12:04:11 UTC, 2 replies.
- 答复: Some problems about Flink applications - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/11 14:47:34 UTC, 2 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] [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.
- [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] [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.
- Multiple control flows in a program - posted by Sachin Goel <sa...@gmail.com> on 2015/08/12 01:34:40 UTC, 5 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.
- nightly builds - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/08/12 11:23:00 UTC, 1 replies.
- Improve performance of call system.currentTimeMillis() - posted by Fangfengbin <fa...@huawei.com> on 2015/08/12 11:33:02 UTC, 5 replies.
- Test about Improve performance of call system.currentTimeMillis() - posted by Fangfengbin <fa...@huawei.com> on 2015/08/13 08:35:21 UTC, 4 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.
- Builds Problems on Travis - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/13 14:19:27 UTC, 1 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.
- 答复: 答复: Some problems about Flink applications - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/13 15:24:34 UTC, 1 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](FLINK-2493) Simplify names of example program JARs - posted by Liang Chen <ch...@huawei.com> on 2015/08/14 00:32:55 UTC, 9 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.
- [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.
- Flink Forward webpage down - posted by Gábor Gévay <gg...@gmail.com> on 2015/08/14 11:05:37 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] [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.
- [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] [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.
- [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.
- [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] [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.
- [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.
- [ANNOUNCEMENT] Please add more Description and information to JIRA issues - posted by Henry Saputra <he...@gmail.com> on 2015/08/16 10:35:13 UTC, 3 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.
- Code style guideline for Scala - posted by Chiwan Park <ch...@apache.org> on 2015/08/16 12:14:09 UTC, 6 replies.
- [NOTICE] Reporting and fixing minor issues - posted by Stephan Ewen <se...@apache.org> on 2015/08/16 17:51:20 UTC, 5 replies.
- [FAILING TEST] BlobLibraryCacheManagerTest - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/16 23:04:06 UTC, 1 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:45 UTC, 0 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.
- [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.
- "main" java.lang.NoClassDefFoundError: scala/collection/Traversable - posted by Nyamath Ulla Khan <ul...@gmail.com> on 2015/08/17 21:39:18 UTC, 1 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] [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.
- Nested iterations not supported? - posted by Pieter-Jan Van Aeken <pi...@euranova.eu> on 2015/08/18 11:27:38 UTC, 3 replies.
- Some thoughts about query max && min block count in CompactingHashTable - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/18 11:33:52 UTC, 2 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.
- Encountered "TypeComparator creation has a bug" - posted by Chesnay Schepler <ch...@apache.org> on 2015/08/18 12:33:56 UTC, 1 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] [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] [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] [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:45 UTC, 0 replies.
- Driver Test Base issue - posted by Sachin Goel <sa...@gmail.com> on 2015/08/18 17:35:18 UTC, 4 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.
- A Question About Execution Schedule - posted by MaGuoWei <ma...@outlook.com> on 2015/08/19 05:45:10 UTC, 2 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:46 UTC, 0 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.
- DataStream API - What does "Beta" mean? - posted by ankurcha <an...@malloc64.com> on 2015/08/20 08:16:27 UTC, 3 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.
- [ANNOUNCE] New Committer Chesnay Schepler - posted by Robert Metzger <rm...@apache.org> on 2015/08/20 11:18:38 UTC, 14 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.
- Some new problems about flink-storm-compatibility - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/20 13:19:12 UTC, 6 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] [Created] (FLINK-2553) Example Jars not build correctly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/20 15:13:45 UTC, 0 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.
- [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:46 UTC, 0 replies.
- [FAILING TEST] StateCheckpoinedITCase - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/20 22:05:52 UTC, 10 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.
- Question about TypeInformation in DataSet - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/21 13:02:17 UTC, 1 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] [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.
- a problem about flink cluster - posted by 华文 <40...@qq.com> on 2015/08/21 17:08:16 UTC, 2 replies.
- Graph.fromDataSet function calls: flink-gelly - posted by Sachin Goel <sa...@gmail.com> on 2015/08/21 19:40:10 UTC, 2 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.
- Join hints for the Gelly functions - posted by Andra Lungu <lu...@gmail.com> on 2015/08/22 09:51:04 UTC, 4 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:46 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.
- Re: Gelly Blog Post - posted by Andra Lungu <lu...@gmail.com> on 2015/08/22 22:46:43 UTC, 9 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.
- [FAILING TEST] RandomSamplerTest - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/08/23 12:32:40 UTC, 1 replies.
- [jira] [Created] (FLINK-2564) Failing Test: RandomSamplerTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/08/23 12:35:45 UTC, 0 replies.
- Flink color scheme - posted by Kostas Tzoumas <kt...@apache.org> on 2015/08/23 15:36:26 UTC, 3 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.
- [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.
- [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.
- [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] [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] [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] [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] [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.
- [ANNOUNCE] Flink Forward 2015 program is online - posted by Kostas Tzoumas <kt...@apache.org> on 2015/08/25 17:01:46 UTC, 0 replies.
- [jira] [Created] (FLINK-2573) Add Kerberos test case - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/08/25 17:37:46 UTC, 0 replies.
- [DISCUSSION] Release current master as 0.9.1 (mod few changes) - posted by Stephan Ewen <se...@apache.org> on 2015/08/25 20:34:57 UTC, 22 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] [Created] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Ricky Pogalz (JIRA)" <ji...@apache.org> on 2015/08/26 11:01:45 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:47 UTC, 0 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] [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.
- [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.
- [VOTE] Release Apache Flink 0.9.1 (RC0) - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/27 13:32:43 UTC, 1 replies.
- Testing the 0.9.1 Candidate - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/27 13:38:31 UTC, 2 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] [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] [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.
- [RESULT] [VOTE] Release Apache Flink 0.9.1 (RC0) - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/27 16:21:50 UTC, 2 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.
- Apache Flink:ProgramInvocationException on Yarn - posted by Hanan Meyer <ha...@scalabill.it> on 2015/08/27 18:32:54 UTC, 29 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] [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] [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] [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] [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.
- Release 0.10.0 Milestone 1 Forked Off - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/28 12:33:39 UTC, 0 replies.
- [VOTE] Release Apache Flink 0.9.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/28 13:27:49 UTC, 8 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] [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.
- [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] [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] [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:46 UTC, 0 replies.
- Several Scala Tests not being executed by Maven - posted by Stephan Ewen <se...@apache.org> on 2015/08/29 15:13:29 UTC, 0 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.
- [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.
- Some questions about storm metrics - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/31 09:53:10 UTC, 3 replies.
- 答复: Some questions about storm metrics - posted by "huangwei (G)" <hu...@huawei.com> on 2015/08/31 13:01:53 UTC, 1 replies.
- [RESULT] [VOTE] Release Apache Flink 0.9.1 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2015/08/31 14:10:49 UTC, 0 replies.
- SGD Effective Learning Rate - posted by Trevor Grant <tr...@gmail.com> on 2015/08/31 17:42:26 UTC, 0 replies.