You are viewing a plain text version of this content. The canonical link for it is here.
- [jira] [Created] (FLINK-2302) Allow multiple instances to run on single host - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/01 00:54:04 UTC, 0 replies.
- Re: Replacing Checkpointed interface with field annotations - posted by Maximilian Michels <mx...@apache.org> on 2015/07/01 10:10:01 UTC, 9 replies.
- Re: Flink 0.9 built with Scala 2.11 - posted by Robert Metzger <rm...@apache.org> on 2015/07/01 10:28:45 UTC, 8 replies.
- [jira] [Created] (FLINK-2303) Add count method to GroupedDataStream - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/07/01 11:07:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2304) Add named attribute access to Storm compatibility layer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 11:27:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2305) Add documenation about Storm compatibility layer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 11:29:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2306) Add support for named streams in Storm compatibility layer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 11:39:05 UTC, 0 replies.
- Re: Failing Builds on Travis - posted by Robert Metzger <rm...@apache.org> on 2015/07/01 12:44:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2307) Drop Java 6 support - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/01 12:45:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2308) Improve error messages on broken user-defined serialization - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 16:07:04 UTC, 0 replies.
- Hadoopinputformat for numpy und .mat matrices - posted by Felix Neutatz <ne...@googlemail.com> on 2015/07/01 17:05:47 UTC, 1 replies.
- [jira] [Created] (FLINK-2309) Use static code analysis to replace selector functions with field accesses. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 19:22:04 UTC, 0 replies.
- [ml] Convergence Criterias - posted by Sachin Goel <sa...@gmail.com> on 2015/07/01 21:23:10 UTC, 7 replies.
- [jira] [Created] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/01 22:48:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided" - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/07/02 09:23:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2312) Random Splits - posted by "Maximilian Alber (JIRA)" <ji...@apache.org> on 2015/07/02 10:10:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2313) Change Streaming Driver Execution Model - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/02 11:53:04 UTC, 0 replies.
- Recording breaking changes to Streaming API - posted by Stephan Ewen <se...@apache.org> on 2015/07/02 12:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/02 16:16:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/02 20:00:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2316) Optimize the SCA for bytecode generated by Scala - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/07/02 21:14:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2317) Stream Jobs with Windows Leave Lingering State - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/03 10:39:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/05 00:12:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2319) Collect size limitation due to akka. - posted by "Kostas (JIRA)" <ji...@apache.org> on 2015/07/05 19:53:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2320) Enable DataSet DataStream Joins - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/06 13:41:04 UTC, 0 replies.
- Redesigned "Features" page - posted by Stephan Ewen <se...@apache.org> on 2015/07/06 15:22:27 UTC, 12 replies.
- Read 727 gz files () - posted by Felix Neutatz <ne...@googlemail.com> on 2015/07/06 15:31:25 UTC, 4 replies.
- [jira] [Created] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/06 15:45:04 UTC, 0 replies.
- Design documents for consolidated DataStream API - posted by Stephan Ewen <se...@apache.org> on 2015/07/06 20:34:35 UTC, 22 replies.
- How do network transmissions in Flink work? - posted by Niklas Semmler <ni...@inet.tu-berlin.de> on 2015/07/06 20:36:51 UTC, 4 replies.
- Flink on Wikipedia - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/06 23:45:43 UTC, 10 replies.
- [jira] [Created] (FLINK-2322) Unclosed stream may leak resource - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/07/07 01:00:07 UTC, 0 replies.
- [jira] [Created] (FLINK-2323) Rename OperatorState methods to .value() and .update(..) - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/07 10:32:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2324) Rework partitioned state storage - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/07 10:34:04 UTC, 0 replies.
- [jira] [Created] (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/07/07 11:49:04 UTC, 0 replies.
- [Gelly] Help with GSA compiler tests - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/07/07 15:20:21 UTC, 4 replies.
- Rework of streaming iteration API - posted by Gyula Fóra <gy...@apache.org> on 2015/07/07 15:57:35 UTC, 11 replies.
- [jira] [Created] (FLINK-2326) Mutitenancy on Yarn - posted by "LINTE (JIRA)" <ji...@apache.org> on 2015/07/07 16:36:07 UTC, 0 replies.
- Building several models in parallel - posted by Felix Neutatz <ne...@googlemail.com> on 2015/07/07 17:32:12 UTC, 7 replies.
- [jira] [Created] (FLINK-2327) Log the limit of open file handles at startup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 15:49:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/08 16:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2329) Refactor RPCs from within the ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/08 16:55:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2330) Make FromElementsFunction checkpointable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 19:04:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2331) Whitelist some exceptions to be valid in YARN logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 19:25:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/08 19:25:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2333) Stream Data Sink that periodically rolls files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/09 10:03:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2334) IOException: Channel to path could not be opened - posted by "David Heller (JIRA)" <ji...@apache.org> on 2015/07/09 11:01:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2335) Rework iteration construction in StreamGraph - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 12:51:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2336) ArrayIndexOufOBoundsException in TypeExtractor when mapping - posted by "William Saar (JIRA)" <ji...@apache.org> on 2015/07/09 13:25:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2337) Multiple SLF4J bindings using Storm compatibility layer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/09 14:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2338) Shut down "Storm Topologies" clenaly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/09 14:24:04 UTC, 0 replies.
- Does DataSet job also use Barriers to ensure "exactly once."? - posted by 马国维 <ma...@outlook.com> on 2015/07/09 14:43:43 UTC, 0 replies.
- Re: Does DataSet job also use Barriers to ensure "exactly once."? - posted by Kostas Tzoumas <kt...@apache.org> on 2015/07/09 14:47:29 UTC, 8 replies.
- [jira] [Created] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/09 16:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2340) Provide standalone mode for web interface of the JobManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/09 16:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2341) Deadlock in SpilledSubpartitionViewAsyncIO - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/09 17:03:04 UTC, 0 replies.
- serialization issue - posted by Felix Neutatz <ne...@googlemail.com> on 2015/07/09 21:42:26 UTC, 2 replies.
- [jira] [Created] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/10 12:03:08 UTC, 0 replies.
- Documentation Webpage Rendering Problem - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/10 14:00:08 UTC, 8 replies.
- Passing around huge hash sets - posted by Andra Lungu <lu...@gmail.com> on 2015/07/10 14:35:49 UTC, 2 replies.
- [jira] [Created] (FLINK-2343) Change default garbage collector in streaming environments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/10 16:36:04 UTC, 1 replies.
- [jira] [Created] (FLINK-2344) Deprecate/Remove the old Pact Pair type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/10 19:27:04 UTC, 0 replies.
- Failing tests - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/11 01:31:55 UTC, 1 replies.
- [jira] [Created] (FLINK-2345) Zero Configuration Cluster Setup - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/11 16:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2346) Mesos clustering - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/11 17:01:05 UTC, 0 replies.
- The documentation site is cut on the top - posted by Henry Saputra <he...@gmail.com> on 2015/07/11 19:32:37 UTC, 6 replies.
- Question regarding HBase and machine-learning - posted by Lydia Ickler <ic...@googlemail.com> on 2015/07/11 19:41:07 UTC, 1 replies.
- [jira] [Created] (FLINK-2347) Rendering problem with Documentation website - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/11 21:02:04 UTC, 0 replies.
- Github behind aft-git - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/12 14:24:54 UTC, 3 replies.
- [jira] [Created] (FLINK-2348) Instable (failing) Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/12 15:31:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2349) Instable (failing) Test - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/12 15:35:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2350) Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 19:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 20:00:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/13 11:28:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2353) Hadoop mapred IOFormat wrappers do not respect JobConfigurable interface - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/14 00:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2354) Recover running jobs on JobManager failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/14 15:31:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2355) Job hanging in collector, waiting for request buffer - posted by "William Saar (JIRA)" <ji...@apache.org> on 2015/07/14 17:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2356) Resource leak in checkpoint coordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/14 17:39:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 17:56:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2358) Add Netty-HTTP based server and server handlers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 18:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2359) Add factory methods to the Java TupleX types - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/14 18:32:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2360) EOFException - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/14 21:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2361) flatMap + distict gives eroneous results for big data sets - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/14 23:31:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2362) distinct is missing in DataSet API documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/15 00:37:05 UTC, 0 replies.
- Re: Student looking to contribute to Stratosphere - posted by Rohit Shinde <ro...@gmail.com> on 2015/07/15 05:26:05 UTC, 7 replies.
- Hadoop 2.5.2 compatible - flink - posted by santosh_rajaguru <sa...@gmail.com> on 2015/07/15 10:13:38 UTC, 2 replies.
- [jira] [Created] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/15 11:22:04 UTC, 0 replies.
- Read XML from HDFS - posted by santosh_rajaguru <sa...@gmail.com> on 2015/07/15 12:15:36 UTC, 3 replies.
- [jira] [Created] (FLINK-2364) Link to Guide is Broken - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/15 20:24:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2365) Review of How to contribute page - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/16 00:22:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2366) HA Without ZooKeeper - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/16 09:10:05 UTC, 0 replies.
- Failing Test - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/16 11:30:15 UTC, 8 replies.
- [jira] [Created] (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/07/16 14:13:04 UTC, 0 replies.
- Extending StreamExecutionEnvironment - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/16 15:38:38 UTC, 1 replies.
- [jira] [Created] (FLINK-2368) Add a convergence criteria - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/16 15:51:05 UTC, 0 replies.
- [DISCUSS] Unifying client code - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/16 16:45:16 UTC, 8 replies.
- [jira] [Created] (FLINK-2369) On Windows, in testFailingSortingDataSinkTask the temp file is not removed - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/16 17:43:06 UTC, 0 replies.
- Exception during job submission in RemoteEnvironment - posted by Andreas Kunft <an...@tu-berlin.de> on 2015/07/16 18:01:12 UTC, 1 replies.
- [jira] [Created] (FLINK-2370) Unify Client Code - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/16 18:26:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2371) AccumulatorLiveITCase fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/17 11:25:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2372) Update KafkaSink to use new Producer API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/17 12:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "Andreas Kunft (JIRA)" <ji...@apache.org> on 2015/07/17 12:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2374) File.setWritable doesn't work on Windows, which makes several tests fail - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/17 14:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "Shivani Ghatge (JIRA)" <ji...@apache.org> on 2015/07/17 16:25:04 UTC, 0 replies.
- Failing tests on Windows - posted by Gábor Gévay <gg...@gmail.com> on 2015/07/17 17:53:52 UTC, 4 replies.
- [jira] [Created] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/17 18:16:05 UTC, 0 replies.
- Communicating between nodes at runtime - posted by Sachin Goel <sa...@gmail.com> on 2015/07/17 18:19:29 UTC, 5 replies.
- [jira] [Created] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/17 18:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2378) complexIntegrationTest1 and testGroupByFeedback sometimes fail on Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/17 18:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2379) Add methods to evaluate field wise statistics over DataSet of vectors. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/19 22:43:04 UTC, 0 replies.
- Benchmarks of Flink, supporting Flink in BigDataBench - posted by Xinhui Tian <ti...@ict.ac.cn> on 2015/07/20 09:47:11 UTC, 3 replies.
- [jira] [Created] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/20 11:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2381) Possible class not found Exception on failed partition producer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/20 15:02:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/20 17:06:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2383) Add new Window Operator that can use Timestamps/Watermarks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:59:04 UTC, 0 replies.
- Re: Error while deserializing event - posted by Stephan Ewen <se...@apache.org> on 2015/07/21 15:04:49 UTC, 0 replies.
- [jira] [Created] (FLINK-2384) Deadlock during partition spilling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/21 16:20:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2385) Scala DataSet.distinct should have parenthesis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 16:58:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/21 17:10:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2387) Add test for live accumulators in Streaming - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/21 17:41:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2388) JobManager should try retrieving jobs from archive - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/21 20:17:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:20:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/21 22:24:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException - posted by "Huang Wei (JIRA)" <ji...@apache.org> on 2015/07/22 04:00:07 UTC, 0 replies.
- Theoretical complexity of a coGroup - posted by Andra Lungu <lu...@gmail.com> on 2015/07/22 10:56:41 UTC, 1 replies.
- [jira] [Created] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/22 14:42:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/22 17:24:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/07/22 17:27:04 UTC, 0 replies.
- Windowing Design Document - posted by Aljoscha Krettek <al...@apache.org> on 2015/07/22 18:15:10 UTC, 0 replies.
- New Flink Runtime Monitor Dashboard - posted by Stephan Ewen <se...@apache.org> on 2015/07/22 18:22:03 UTC, 6 replies.
- Any planning for Apache Flink 1.0 release? - posted by Slim Baltagi <sb...@gmail.com> on 2015/07/22 21:41:08 UTC, 2 replies.
- Re: Thoughts About Streaming - posted by Aljoscha Krettek <al...@apache.org> on 2015/07/23 10:47:25 UTC, 6 replies.
- [jira] [Created] (FLINK-2395) Check Scala catch blocks for Throwable - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/23 11:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2396) Review the datasets of dynamic path and static path in iteration. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/07/23 12:21:05 UTC, 0 replies.
- Erroneous link to "Flink on Windows" guide - posted by Samia Khalid <sa...@gmail.com> on 2015/07/23 14:40:39 UTC, 1 replies.
- [jira] [Created] (FLINK-2397) Unify two backend servers to one server - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 14:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/23 15:25:04 UTC, 0 replies.
- Guide/design doc for streaming operator states - posted by Gyula Fóra <gy...@apache.org> on 2015/07/23 15:55:36 UTC, 3 replies.
- [jira] [Created] (FLINK-2399) Fail when actor versions don't match - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 16:08:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2400) TaskTest.testExecutionFailesAfterCanceling fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 16:30:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2401) Replace ActorRefs with ActorGateway in web server - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/23 17:46:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2402) Add a non-blocking BarrierTracker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 18:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2403) Rework partitioned state checkpointing logic - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/23 21:56:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/24 10:44:04 UTC, 0 replies.
- Flink contributor list - posted by Kostas Tzoumas <kt...@apache.org> on 2015/07/24 11:34:46 UTC, 8 replies.
- Extending the streaming scala api with stateful functions - posted by Gyula Fóra <gy...@apache.org> on 2015/07/24 17:38:43 UTC, 4 replies.
- A soft reminder - posted by Andra Lungu <lu...@gmail.com> on 2015/07/24 18:56:43 UTC, 8 replies.
- [jira] [Created] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/25 16:47:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/26 23:36:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2407) Add an API switch to select between "exactly once" and "at least once" fault tolerance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/26 23:39:04 UTC, 0 replies.
- [ANNOUNCE] Distributed stream and graph processing with Apache Flink Bay Area meetup - posted by Henry Saputra <he...@gmail.com> on 2015/07/27 01:30:38 UTC, 0 replies.
- add some new api to the scheduler in the job manager - posted by MaGuoWei <ma...@outlook.com> on 2015/07/27 03:51:24 UTC, 7 replies.
- Getting an eeror while running the code - posted by bharathkarnam <ma...@gmail.com> on 2015/07/27 06:41:57 UTC, 3 replies.
- [jira] [Created] (FLINK-2408) Some maven properties are defined in build profiles only - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/27 12:14:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/27 12:34:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2410) PojoTypeInfo is not completely serializable - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/07/27 14:32:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2411) Add basic graph summarization algorithm - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/07/27 17:43:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2412) Index Out of Bounds Exception - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/27 19:58:04 UTC, 0 replies.
- Travis build failure - posted by Sachin Goel <sa...@gmail.com> on 2015/07/27 21:47:00 UTC, 6 replies.
- [jira] [Created] (FLINK-2413) Provide real vertex data - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/07/27 22:23:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2414) Extend job data in job list - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/07/27 22:39:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2415) Link nodes in plan to vertices - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/07/27 22:49:05 UTC, 0 replies.
- streaming iteration - posted by MaGuoWei <ma...@outlook.com> on 2015/07/28 03:38:28 UTC, 1 replies.
- [jira] [Created] (FLINK-2416) Expose vertex using with the new URL scheme - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/07/28 10:26:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2417) Travis build failure on flink-tachyon - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/28 11:11:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2418) Add an end-to-end streaming fault tolerance test for the Checkpointed interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/28 15:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2419) DataStream sinks lose key information - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/28 15:38:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/28 15:39:04 UTC, 0 replies.
- [Gelly] Re-organize / cleanup examples and library - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/07/28 16:14:55 UTC, 7 replies.
- [jira] [Created] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/28 16:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/28 17:27:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2423) Properly test checkpoint notifications - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/28 19:14:04 UTC, 0 replies.
- Revert 78fd2146dd until we have consensus for FLINK-2419? - posted by Robert Metzger <rm...@apache.org> on 2015/07/28 20:01:09 UTC, 9 replies.
- Question about DataStream class hierarchy - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/28 21:57:05 UTC, 6 replies.
- [jira] [Created] (FLINK-2424) InstantiationUtil.serializeObject(Object) does not close output stream - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/29 01:39:05 UTC, 0 replies.
- Broken links - posted by Michael Huelfenhaus <m....@davengo.com> on 2015/07/29 10:59:09 UTC, 0 replies.
- [jira] [Created] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 11:54:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2426) Create a read-only variant of the Configuration - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 11:57:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2427) Allow the BarrierBuffer to maintain multiple queues of blocked inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 12:15:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 14:48:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 15:27:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2430) Potential race condition when restart all is called for a Twill runnable - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/29 19:09:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2431) [py] refactor PlanBinder/OperationInfo - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/29 23:14:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2432) [py] Provide support for custom serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/29 23:16:04 UTC, 0 replies.
- On some GUI tools for building Flink Streaming data flows... - posted by Slim Baltagi <sb...@gmail.com> on 2015/07/30 05:50:40 UTC, 1 replies.
- [jira] [Created] (FLINK-2433) Jekyll on windows for building local documentation - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/30 06:18:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2434) org.apache.hadoop:hadoop-yarn-common:jar with value 'jersey-test-framework-grizzly2+' does not match a valid id pattern - posted by "caofangkun (JIRA)" <ji...@apache.org> on 2015/07/30 10:03:04 UTC, 0 replies.
- question about SlidingPreReducer.java - posted by MaGuoWei <ma...@outlook.com> on 2015/07/30 11:33:20 UTC, 6 replies.
- [jira] [Created] (FLINK-2435) Add support for custom CSV field parsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/30 12:30:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2436) Make ByteStreamStateHandles more robust - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/30 14:08:04 UTC, 0 replies.
- Hello guys, I have met a problem when use mvn to build flink on mac - posted by skaterQiang <xq...@163.com> on 2015/07/30 15:29:19 UTC, 2 replies.
- [jira] [Created] (FLINK-2437) TypeExtractor.analyzePojo has some problems around the default constructor detection - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/30 17:39:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2438) Improve performance of channel events - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/30 19:06:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2439) [py] Expand DataSet feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/30 20:47:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2440) [py] Expand Environment feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/30 20:50:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2441) [py] Introduce an OpInfo object on the python side - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/30 21:05:04 UTC, 0 replies.
- Types in the Python API - posted by Gyula Fóra <gy...@gmail.com> on 2015/07/30 21:17:02 UTC, 14 replies.
- [jira] [Created] (FLINK-2442) PojoType fields not supported by field position keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/30 23:19:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2443) The Gather-Sum-Apply Version of Connected Components fails with NPE - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/30 23:55:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2444) Add tests for HadoopInputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 01:15:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 01:17:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/07/31 03:53:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2447) TypeExtractor returns wrong type info when a Tuple has two fields of the same POJO type - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/31 09:59:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2448) registerCacheFile fails with MultipleProgramsTestbase - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/31 10:24:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/31 10:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2450) IndexOutOfBoundsException in KryoSerializer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/31 10:51:04 UTC, 0 replies.
- Bug fix release 0.9.1 - posted by Ufuk Celebi <uc...@apache.org> on 2015/07/31 11:34:34 UTC, 1 replies.
- Question About "Preserve Partitioning" in Stream Iteration - posted by Aljoscha Krettek <al...@apache.org> on 2015/07/31 11:51:51 UTC, 9 replies.
- Off-heap memory in Flink? - posted by Slim Baltagi <sb...@gmail.com> on 2015/07/31 11:57:35 UTC, 3 replies.
- [jira] [Created] (FLINK-2451) Cleanup Gelly examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/31 18:08:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2452) Add a playcount threshold to the MusicProfiles examples - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/31 18:19:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2453) Update POM to use Java7 as the source and target version - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/31 19:09:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2454) Update Travis file to run build using Java7 - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/31 19:09:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2455) Misleading I/O manager error log messages - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/31 19:25:04 UTC, 0 replies.
- Tuple - posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de> on 2015/07/31 21:37:04 UTC, 2 replies.