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

---

- [jira] [Updated] (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, 1 replies.
- [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.
- [GitHub] flink pull request: [FLINK-2141] Allow GSA's Gather to perform thi... - posted by shghatge <gi...@git.apache.org> on 2015/07/01 03:16:58 UTC, 18 replies.
- [jira] [Commented] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 03:17:04 UTC, 18 replies.
- [jira] [Comment Edited] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 10:08:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 10:08:04 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-2298] Allow setting a custom applicatio... - posted by mxm <gi...@git.apache.org> on 2015/07/01 10:17:32 UTC, 10 replies.
- [jira] [Commented] (FLINK-2298) Allow setting custom YARN application names through the CLI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 10:18:04 UTC, 10 replies.
- [jira] [Commented] (FLINK-2302) Allow multiple instances to run on single host - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/01 10:22:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 10:24:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/01 10:30:04 UTC, 24 replies.
- [jira] [Assigned] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/01 10:34:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2274) Add a histogram method for DataSet[Double] in DataSetUtils - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/01 10:35:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2297] [ml] Add threshold setting for SV... - posted by tillrohrmann <gi...@git.apache.org> on 2015/07/01 10:39:15 UTC, 38 replies.
- [jira] [Commented] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 10:40:04 UTC, 38 replies.
- [GitHub] flink pull request: [FLINK-2138] Added custom partitioning to Data... - posted by rmetzger <gi...@git.apache.org> on 2015/07/01 10:47:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-2138) PartitionCustom for streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 10:48:04 UTC, 3 replies.
- [GitHub] flink pull request: [storm-contrib] added named attribute access t... - posted by rmetzger <gi...@git.apache.org> on 2015/07/01 10:52:20 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2157] [ml] [WIP] Create evaluation fram... - posted by tillrohrmann <gi...@git.apache.org> on 2015/07/01 10:56:50 UTC, 75 replies.
- [jira] [Commented] (FLINK-2157) Create evaluation framework for ML library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 10:57:05 UTC, 75 replies.
- [GitHub] flink pull request: [FLINK-2175] Allow multiple jobs in single jar... - posted by rmetzger <gi...@git.apache.org> on 2015/07/01 11:00:14 UTC, 1 replies.
- [jira] [Commented] (FLINK-2175) Allow multiple jobs in single jar file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 11:01:04 UTC, 1 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] [Assigned] (FLINK-2303) Add count method to GroupedDataStream - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/07/01 11:13:04 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.
- [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] [Commented] (FLINK-1991) Return Table as DataSet - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/07/01 13:29:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2175) Allow multiple jobs in single jar file - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 14:43:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2176) Add support for ProgramDesctiption interface in clients - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 14:44:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2304] Add named attribute access to Sto... - posted by mjsax <gi...@git.apache.org> on 2015/07/01 14:50:43 UTC, 11 replies.
- [jira] [Commented] (FLINK-2304) Add named attribute access to Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 14:51:05 UTC, 11 replies.
- [jira] [Commented] (FLINK-2176) Add support for ProgramDesctiption interface in clients - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/01 15:06:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2303) Add count method to GroupedDataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/01 15:20:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2298) Allow setting custom YARN application names through the CLI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/01 15:28:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2275] Migrate test from package 'org.ap... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/01 16:00:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 16:01:05 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2158] Add support for null to the DateS... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/01 16:04:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-2158) NullPointerException in DateSerializer. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 16:05:04 UTC, 1 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.
- [jira] [Comment Edited] (FLINK-2108) Add score function for Predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/01 16:32:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2108) Add score function for Predictors - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/01 16:37:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1967] Introduce (Event)time in Streamin... - posted by aljoscha <gi...@git.apache.org> on 2015/07/01 16:49:29 UTC, 58 replies.
- [jira] [Commented] (FLINK-1967) Introduce (Event)time in Streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 16:50:04 UTC, 58 replies.
- [jira] [Resolved] (FLINK-2303) Add count method to GroupedDataStream - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/07/01 17:02:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2308) Improve error messages on broken user-defined serialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/01 17:11:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2308) Improve error messages on broken user-defined serialization - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/01 17:12:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/01 17:49:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 17:50:04 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/01 17:51:50 UTC, 5 replies.
- [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 17:52:04 UTC, 5 replies.
- [jira] [Closed] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 17:57:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2275) Migrate test from package 'org.apache.flink.test.javaApiOperators' - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 17:57:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2308) Improve error messages on broken user-defined serialization - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 18:00:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2308) Improve error messages on broken user-defined serialization - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 18:00:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2158) NullPointerException in DateSerializer. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 18:01:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2158) NullPointerException in DateSerializer. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/01 18:01:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2093) Add a difference method to Gelly's Graph class - posted by "Shivani Ghatge (JIRA)" <ji...@apache.org> on 2015/07/01 18:02:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1520]Read edges and vertices from CSV f... - posted by shghatge <gi...@git.apache.org> on 2015/07/01 18:02:29 UTC, 25 replies.
- [jira] [Commented] (FLINK-1520) Read edges and vertices from CSV files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/01 18:03:04 UTC, 25 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.
- [jira] [Commented] (FLINK-2309) Use static code analysis to replace selector functions with field accesses. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/01 22:10:04 UTC, 1 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] [Updated] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/01 22:49:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2307) Drop Java 6 support - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/01 23:28:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2272] [ml] [docs] Move vision and roadm... - posted by chiwanpark <gi...@git.apache.org> on 2015/07/02 02:30:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/02 02:31:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1085] Unnecessary failing of GroupReduc... - posted by dabaitu <gi...@git.apache.org> on 2015/07/02 06:29:34 UTC, 10 replies.
- [jira] [Commented] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/02 06:30:04 UTC, 10 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.
- [GitHub] flink pull request: [FLINK-2311] Fixes 'flink-*' dependency scope ... - posted by aalexandrov <gi...@git.apache.org> on 2015/07/02 09:26:38 UTC, 14 replies.
- [jira] [Commented] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/02 09:27:04 UTC, 15 replies.
- [jira] [Updated] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided" - posted by "Alexander Alexandrov (JIRA)" <ji...@apache.org> on 2015/07/02 09:28:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2312) Random Splits - posted by "Maximilian Alber (JIRA)" <ji...@apache.org> on 2015/07/02 10:10:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2312) Random Splits - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/02 10:21:04 UTC, 12 replies.
- [GitHub] flink pull request: My branch - posted by samk3211 <gi...@git.apache.org> on 2015/07/02 11:18:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-2296) Checkpoint committing broken - posted by "Rico Bergmann (JIRA)" <ji...@apache.org> on 2015/07/02 11:37:04 UTC, 6 replies.
- [jira] [Comment Edited] (FLINK-2296) Checkpoint committing broken - posted by "Rico Bergmann (JIRA)" <ji...@apache.org> on 2015/07/02 11:38:04 UTC, 2 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.
- [jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/02 11:56:05 UTC, 5 replies.
- [GitHub] flink pull request: [Flink-Gelly] added missing assumption to the ... - posted by samk3211 <gi...@git.apache.org> on 2015/07/02 12:09:00 UTC, 1 replies.
- [GitHub] flink pull request: [Flink-Gelly] [example] added missing assumpti... - posted by samk3211 <gi...@git.apache.org> on 2015/07/02 13:55:11 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window - posted by "Gábor Hermann (JIRA)" <ji...@apache.org> on 2015/07/02 14:30:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/02 14:59:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/02 15:00:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2293) Division by Zero Exception - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/02 15:18:04 UTC, 10 replies.
- [jira] [Updated] (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-2314) Make Streaming File Sources Persistent - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/02 16:16:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2305] Add documenation about Storm comp... - posted by mjsax <gi...@git.apache.org> on 2015/07/02 18:31:31 UTC, 12 replies.
- [jira] [Commented] (FLINK-2305) Add documenation about Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/02 18:32:04 UTC, 12 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.
- [GitHub] flink pull request: Hits - posted by vasia <gi...@git.apache.org> on 2015/07/02 22:40:14 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2150] Added zipWithUniqueIds - posted by vasia <gi...@git.apache.org> on 2015/07/02 22:42:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/02 22:43:04 UTC, 3 replies.
- [jira] [Updated] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/02 23:32:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2150) Add a library method that assigns unique Long values to vertices - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/02 23:32:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2285] [streaming] Removed duplicate cal... - posted by asfgit <gi...@git.apache.org> on 2015/07/03 08:43:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-2285) Active policy emits elements of the last window twice - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/03 08:44:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2285) Active policy emits elements of the last window twice - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/07/03 08:47:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1645) Move StreamingClassloaderITCase to flink-streaming - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/03 09:56:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2252) Reduce local input split assignment log level from INFO to DEBUG - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/03 10:35:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2257) Open and close of RichWindowFunctions is not called - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/07/03 10:38: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.
- [GitHub] flink pull request: [FLINK-2200] Add Flink with Scala 2.11 in Mave... - posted by chiwanpark <gi...@git.apache.org> on 2015/07/03 12:23:10 UTC, 22 replies.
- [GitHub] flink pull request: [wip] [FLINK-2288] [FLINK-2302] Setup ZooKeepe... - posted by uce <gi...@git.apache.org> on 2015/07/03 17:02:39 UTC, 19 replies.
- [jira] [Commented] (FLINK-2288) Setup ZooKeeper for distributed coordination - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/03 17:03:04 UTC, 19 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.
- [GitHub] flink pull request: Collect(): Fixing the akka.framesize size limi... - posted by kl0u <gi...@git.apache.org> on 2015/07/05 17:10:33 UTC, 17 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] [Commented] (FLINK-2319) Collect size limitation due to akka. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/05 20:04:04 UTC, 1 replies.
- [GitHub] flink pull request: [Flink-2030][ml]Online Histogram: Discrete and... - posted by thvasilo <gi...@git.apache.org> on 2015/07/06 10:38:38 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2240] Use BloomFilter to filter probe r... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/07/06 10:51:14 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/07/06 10:52:04 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne... - posted by thvasilo <gi...@git.apache.org> on 2015/07/06 11:03:09 UTC, 15 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/07/06 11:04:04 UTC, 15 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.
- [jira] [Closed] (FLINK-2311) Set flink-* dependencies in flink-contrib as "provided" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/06 13:56:04 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2321] [ml] The seed for the SVM classif... - posted by thvasilo <gi...@git.apache.org> on 2015/07/06 15:48:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/06 15:49:05 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-2208] Fix IBM Java integration bug - posted by StephanEwen <gi...@git.apache.org> on 2015/07/07 11:12:43 UTC, 4 replies.
- [jira] [Commented] (FLINK-2208) Build error for Java IBM - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 11:13:04 UTC, 4 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.
- [jira] [Assigned] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/07 11:55:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/07 11:56:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2323] [api-breaking] Rename OperatorSta... - posted by gyfora <gi...@git.apache.org> on 2015/07/07 12:03:24 UTC, 2 replies.
- [jira] [Commented] (FLINK-2323) Rename OperatorState methods to .value() and .update(..) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 12:04:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2292) Report accumulators periodically while job is running - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 12:17:04 UTC, 56 replies.
- [jira] [Updated] (FLINK-2319) Collect size limitation due to akka. - posted by "Kostas (JIRA)" <ji...@apache.org> on 2015/07/07 12:23:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2323) Rename OperatorState methods to .value() and .update(..) - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/07 12:48:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1943) Add Gelly-GSA compiler and translation tests - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/07 14:54:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2324) Rework partitioned state storage - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/07/07 15:18:04 UTC, 27 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.
- [jira] [Commented] (FLINK-2326) Mutitenancy on Yarn - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/07 16:49:05 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2242] deprecate RemoteCollector interfa... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/07 16:54:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-2242) Deprecate RemoteCollector - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 16:55:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2000] [table] Add sql style aggregation... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/07 16:56:05 UTC, 1 replies.
- [jira] [Commented] (FLINK-2000) Add SQL-style aggregations for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 16:57:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2180] [streaming] Iteration test fix - posted by gyfora <gi...@git.apache.org> on 2015/07/07 19:06:38 UTC, 5 replies.
- [jira] [Commented] (FLINK-2180) Streaming iterate test fails spuriously - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/07 19:07:05 UTC, 5 replies.
- [jira] [Resolved] (FLINK-2242) Deprecate RemoteCollector - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 11:10:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2242) Deprecate RemoteCollector - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 11:10:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2274) Add a histogram method for DataSet[Double] - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/08 11:13:04 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2293) Division by Zero Exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 11:14:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-1723) Add cross validation for model evaluation - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/07/08 11:14:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2293) Division by Zero Exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 11:15:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f... - posted by thvasilo <gi...@git.apache.org> on 2015/07/08 11:22:27 UTC, 15 replies.
- [jira] [Commented] (FLINK-1723) Add cross validation for model evaluation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 11:23:04 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa... - posted by shghatge <gi...@git.apache.org> on 2015/07/08 13:46:37 UTC, 18 replies.
- [jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 13:47:04 UTC, 18 replies.
- [jira] [Commented] (FLINK-2322) Unclosed stream may leak resource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/08 15:43:04 UTC, 7 replies.
- [jira] [Updated] (FLINK-2322) Unclosed stream may leak resource - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/08 15:43:05 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2235] fix calculation of free memory fo... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/08 15:54:00 UTC, 5 replies.
- [jira] [Commented] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 15:54:04 UTC, 5 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.
- [GitHub] flink pull request: FLINK-2125 - posted by rmetzger <gi...@git.apache.org> on 2015/07/08 16:35:25 UTC, 2 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 16:36:04 UTC, 2 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.
- [GitHub] flink pull request: [tools] Make release script a bit more flexibl... - posted by rmetzger <gi...@git.apache.org> on 2015/07/08 17:09:52 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2329] [runtime] Introduces InstanceGate... - posted by tillrohrmann <gi...@git.apache.org> on 2015/07/08 17:11:30 UTC, 7 replies.
- [jira] [Commented] (FLINK-2329) Refactor RPCs from within the ExecutionGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 17:12:04 UTC, 7 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:05 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] [Commented] (FLINK-2331) Whitelist some exceptions to be valid in YARN logs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/08 19:27:05 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2124] [streaming] Fix behavior of FromE... - posted by asfgit <gi...@git.apache.org> on 2015/07/08 20:31:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/08 20:32:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2208) Build error for Java IBM - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:32:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2208) Build error for Java IBM - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:33:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2302) Allow multiple instances to run on single host - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:34:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2302) Allow multiple instances to run on single host - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:34:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2288) Setup ZooKeeper for distributed coordination - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:35:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2288) Setup ZooKeeper for distributed coordination - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:36:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2327) Log the limit of open file handles at startup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:36:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2327) Log the limit of open file handles at startup - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:36:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2331) Whitelist some exceptions to be valid in YARN logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:37:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2331) Whitelist some exceptions to be valid in YARN logs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:37:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:38:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:39:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2330) Make FromElementsFunction checkpointable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:39:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2330) Make FromElementsFunction checkpointable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/08 20:39:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2293) Division by Zero Exception - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/08 22:58:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2280] GenericTypeComparator.compare() r... - posted by fhueske <gi...@git.apache.org> on 2015/07/09 02:29:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-2280) GenericTypeComparator.compare() does not respect ascending flag - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/09 02:30:04 UTC, 3 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] [Closed] (FLINK-1764) Rework record copying logic in streaming API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:44:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1421) Implement a SAMOA Adapter for Flink Streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:45:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1239) Fix iteration example getting stuck with large input - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:47:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2261) Remove reduce/aggregation from DataStream - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:47:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:49:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 10:49: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] [Closed] (FLINK-2280) GenericTypeComparator.compare() does not respect ascending flag - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/09 11:07:04 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] [Commented] (FLINK-2336) ArrayIndexOufOBoundsException in TypeExtractor when mapping - posted by "William Saar (JIRA)" <ji...@apache.org> on 2015/07/09 13:30:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2162) Implement adaptive learning rate strategies for SGD - posted by "Ventura Del Monte (JIRA)" <ji...@apache.org> on 2015/07/09 14:10:04 UTC, 1 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.
- [jira] [Updated] (FLINK-2338) Shut down "Storm Topologies" cleanly - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/09 14:28:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2162) Implement adaptive learning rate strategies for SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/09 14:31:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2008][FLINK-2296] Fix checkpoint commit... - posted by rmetzger <gi...@git.apache.org> on 2015/07/09 14:58:42 UTC, 9 replies.
- [jira] [Commented] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/09 14:59:04 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2292][FLINK-1573] add live per-task acc... - posted by mxm <gi...@git.apache.org> on 2015/07/09 15:46:44 UTC, 55 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] [Commented] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/09 16:49:05 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.
- [jira] [Commented] (FLINK-2340) Provide standalone mode for web interface of the JobManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/09 18:16:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2341) Deadlock in SpilledSubpartitionViewAsyncIO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/09 18:24:05 UTC, 1 replies.
- [GitHub] flink pull request: [doc] Fix wordcount example in YARN setup - posted by jkirsch <gi...@git.apache.org> on 2015/07/10 00:14:52 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/10 10:54:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2339) Prevent asynchronous checkpoint calls from overtaking each other - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/10 10:54:05 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-gelly] Added local clustering coefficie... - posted by samk3211 <gi...@git.apache.org> on 2015/07/10 11:44:42 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-2342] [ml] Add new fit operation and mo... - posted by thvasilo <gi...@git.apache.org> on 2015/07/10 12:09:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 12:10:04 UTC, 0 replies.
- [GitHub] flink pull request: Make streaming iterations more robust - posted by gyfora <gi...@git.apache.org> on 2015/07/10 13:35:55 UTC, 5 replies.
- [jira] [Commented] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 13:36:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime - posted by "Johann Kovacs (JIRA)" <ji...@apache.org> on 2015/07/10 14:42:05 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by mjsax <gi...@git.apache.org> on 2015/07/10 15:16:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 15:17:04 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, 0 replies.
- [GitHub] flink pull request: [FLINK-2343] [scripts] Make CMS the default GC... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/10 16:42:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-2343) Change default garbage collector in streaming environments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 16:43:04 UTC, 10 replies.
- [jira] [Closed] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/10 16:46:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2108] [ml] [WIP] Add score function for... - posted by thvasilo <gi...@git.apache.org> on 2015/07/10 16:58:37 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2337] Multiple SLF4J bindings using Sto... - posted by mjsax <gi...@git.apache.org> on 2015/07/10 16:58:48 UTC, 6 replies.
- [jira] [Commented] (FLINK-2337) Multiple SLF4J bindings using Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 16:59:04 UTC, 6 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.
- [jira] [Updated] (FLINK-2218) Web client cannot distinguesh between Flink options and program arguments - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/10 20:05:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2218] Web client cannot distinguesh bet... - posted by mjsax <gi...@git.apache.org> on 2015/07/10 21:09:50 UTC, 16 replies.
- [jira] [Commented] (FLINK-2218) Web client cannot distinguesh between Flink options and program arguments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/10 21:10:04 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-2243] [storm-compat] Added finite spout... - posted by mjsax <gi...@git.apache.org> on 2015/07/11 16:27:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-2243) Add finite spout functionality to Storm compatibility layer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/11 16:28:07 UTC, 3 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] [Commented] (FLINK-2345) Zero Configuration Cluster Setup - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/11 16:59:04 UTC, 2 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.
- [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.
- [jira] [Updated] (FLINK-2347) Rendering problem with Documentation website - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/11 21:03:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2347) Rendering problem with Documentation website - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/07/11 21:05:04 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2141) Allow GSA's Gather to perform this operation in more than one direction - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/12 11:33:04 UTC, 0 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] [Updated] (FLINK-2348) Instable (failing) Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/12 15:32:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2348) 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-2349) Instable (failing) Test - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/12 15:35:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2346) Mesos clustering - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 15:40:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2349) Instable (failing) Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 16:22:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2349) Instable (failing) Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 17:48:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2349) Instable (failing) Test - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/12 17:48:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/12 19:43:04 UTC, 1 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] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "Daniel Pape (JIRA)" <ji...@apache.org> on 2015/07/12 21:52:04 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2347) Rendering problem with Documentation website - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/13 10:12:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/13 11:08:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2347) Rendering problem with Documentation website - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/13 11:17: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.
- [GitHub] flink pull request: [FLINK-1963] Improve distinct() transformation - posted by pp86 <gi...@git.apache.org> on 2015/07/13 14:08:02 UTC, 26 replies.
- [jira] [Commented] (FLINK-1963) Improve distinct() transformation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/13 14:08:04 UTC, 27 replies.
- [jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 15:57:04 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2305) Add documenation about Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 16:11:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2305) Add documenation about Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 16:12:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 17:50:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1085) Unnecessary failing of GroupReduceCombineDriver - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 17:50:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2337) Multiple SLF4J bindings using Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 17:51:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2337) Multiple SLF4J bindings using Storm compatibility layer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 17:51:06 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/13 18:45:12 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/13 18:45:57 UTC, 0 replies.
- [jira] [Commented] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/13 18:47:04 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2296) Checkpoint committing broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:56:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2296) Checkpoint committing broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:56:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2008) PersistentKafkaSource is sometimes emitting tuples multiple times - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:56:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2329) Refactor RPCs from within the ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:57:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2329) Refactor RPCs from within the ExecutionGraph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:57:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:58:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2235) Local Flink cluster allocates too much memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/13 18:58:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2148) Approximately calculate the number of distinct elements of a stream - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/13 21:57:05 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2105: Implement Sort-Merge Outer Join al... - posted by r-pogalz <gi...@git.apache.org> on 2015/07/13 23:36:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-2105) Implement Sort-Merge Outer Join algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/13 23:37:05 UTC, 26 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.
- [GitHub] flink pull request: [FLINK-2353] Respect JobConfigurable interface... - posted by fhueske <gi...@git.apache.org> on 2015/07/14 01:04:07 UTC, 7 replies.
- [jira] [Commented] (FLINK-2353) Hadoop mapred IOFormat wrappers do not respect JobConfigurable interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 01:05:04 UTC, 7 replies.
- [GitHub] flink pull request: Updated method documentation in joinDataSet.sc... - posted by peedeeX21 <gi...@git.apache.org> on 2015/07/14 10:41:20 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1528][Gelly] Added Local Clustering Coe... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/14 11:14:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-1528) Add local clustering coefficient library method and example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 11:15:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2353) Hadoop mapred IOFormat wrappers do not respect JobConfigurable interface - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/14 11:23:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-938] Auomatically configure the jobmana... - posted by uce <gi...@git.apache.org> on 2015/07/14 11:27:14 UTC, 7 replies.
- [jira] [Commented] (FLINK-938) Change start-cluster.sh script so that users don't have to configure the JobManager address - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 11:28:04 UTC, 7 replies.
- [GitHub] flink pull request: Addde HBase OutputFormat example (Flink-1828) - posted by StephanEwen <gi...@git.apache.org> on 2015/07/14 11:31:49 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2343) Change default garbage collector in streaming environments - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/14 11:39:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1321) New web interface, contains parts from WebInfoServer and WebClient - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 12:21:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2347) Rendering problem with Documentation website - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/14 15:09: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.
- [GitHub] flink pull request: [FLINK-2148] [contrib] Exact and approximate c... - posted by ggevay <gi...@git.apache.org> on 2015/07/14 15:51:49 UTC, 7 replies.
- [jira] [Commented] (FLINK-2148) Approximately calculate the number of distinct elements of a stream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 15:52:04 UTC, 7 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] [Commented] (FLINK-2355) Job hanging in collector, waiting for request buffer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/14 17:26:07 UTC, 6 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] [Commented] (FLINK-2354) Recover running jobs on JobManager failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/14 17:40:05 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] [Updated] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 17:57:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2357) New JobManager Runtime Web Frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 17:58:09 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-297] [web frontend] First part of JobMa... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/14 18:03:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-297) Redesign GUI client-server model - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 18:04:04 UTC, 4 replies.
- [jira] [Closed] (FLINK-1938) Add Grunt for building the front-end - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 18:07:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1938) Add Grunt for building the front-end - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/14 18:07: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:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2359] [java api] Add factory methods to... - posted by ggevay <gi...@git.apache.org> on 2015/07/14 18:51:50 UTC, 9 replies.
- [jira] [Commented] (FLINK-2359) Add factory methods to the Java TupleX types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/14 18:52:06 UTC, 12 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] [Updated] (FLINK-2361) flatMap + distinct gives eroneous results for big data sets - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/14 23:32:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/14 23:32: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.
- [jira] [Commented] (FLINK-2361) flatMap + distinct gives erroneous results for big data sets - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/15 00:47:04 UTC, 8 replies.
- [GitHub] flink pull request: Update README.md - posted by chenliag613 <gi...@git.apache.org> on 2015/07/15 09:20:18 UTC, 5 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.
- [GitHub] flink pull request: [FLINK-2363] [docs] First part of internals - ... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/15 11:28:53 UTC, 14 replies.
- [jira] [Commented] (FLINK-2363) Add an end-to-end overview of program execution in Flink to the docs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/15 11:29:04 UTC, 14 replies.
- [GitHub] flink pull request: [taskmanager] do not process message if not co... - posted by mxm <gi...@git.apache.org> on 2015/07/15 12:26:38 UTC, 4 replies.
- [jira] [Commented] (FLINK-1748) Integrate PageRank implementation into machine learning library - posted by "Rohit Shinde (JIRA)" <ji...@apache.org> on 2015/07/15 14:40:07 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2105] Implement Sort-Merge Outer Join a... - posted by fhueske <gi...@git.apache.org> on 2015/07/15 15:15:55 UTC, 25 replies.
- [jira] [Updated] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 15:51:04 UTC, 2 replies.
- [jira] [Commented] (FLINK-2229) Data sets involving non-primitive arrays cannot be unioned - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 15:55:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2292) Report accumulators periodically while job is running - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 16:02:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1573) Add per-job metrics to flink. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 16:02:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1573) Add per-job metrics to flink. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 16:02:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-1573) Add per-job metrics to flink. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/15 16:06:04 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Document some missing configuration par... - posted by rmetzger <gi...@git.apache.org> on 2015/07/15 16:09:43 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2362) distinct is missing in DataSet API documentation - posted by "pietro pinoli (JIRA)" <ji...@apache.org> on 2015/07/15 17:21:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2335) Rework iteration construction in StreamGraph - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/15 18:02:04 UTC, 0 replies.
- [jira] [Created] (FLINK-2364) Link to Guide is Broken - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/15 20:24:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1943] [gelly] Added GSA compiler and tr... - posted by vasia <gi...@git.apache.org> on 2015/07/15 21:08:09 UTC, 2 replies.
- [jira] [Commented] (FLINK-1943) Add Gelly-GSA compiler and translation tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/15 21:09:04 UTC, 2 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.
- [jira] [Updated] (FLINK-2366) HA Without ZooKeeper - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/16 09:15:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2366) HA Without ZooKeeper - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/16 09:26:04 UTC, 14 replies.
- [jira] [Updated] (FLINK-1748) Integrate PageRank implementation into machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/16 09:59:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1748) Integrate PageRank implementation into machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/16 10:05:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2332] [runtime] Adds leader session IDs... - posted by tillrohrmann <gi...@git.apache.org> on 2015/07/16 10:42:12 UTC, 15 replies.
- [jira] [Commented] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/16 10:43:04 UTC, 15 replies.
- [jira] [Resolved] (FLINK-2364) Link to Guide is Broken - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/16 11:14:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2364) Link to Guide is Broken - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/07/16 11:54:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2300) Links on FAQ page not rendered correctly - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/16 12:39:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2365) Review of How to contribute page - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/16 12:41:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2267) Support multi-class scoring for binary classification scores - posted by "Rohit Shinde (JIRA)" <ji...@apache.org> on 2015/07/16 12:53:04 UTC, 2 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.
- [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/07/16 14:16:05 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2368][ml]Adds convergence criteria [WIP... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/16 15:53:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-2368) Add a convergence criteria - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/16 15:54:04 UTC, 5 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:05 UTC, 0 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] [Updated] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/16 22:57:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-685) Add support for semi-joins - posted by "pietro pinoli (JIRA)" <ji...@apache.org> on 2015/07/17 01:35:05 UTC, 3 replies.
- [jira] [Closed] (FLINK-1963) Improve distinct() transformation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/17 01:51:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2352) [Graph Visualization] Integrate Gelly with Gephi - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/17 09:11:04 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] [Commented] (FLINK-2369) On Windows, in testFailingSortingDataSinkTask the temp file is not removed - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/17 13:26: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.
- [GitHub] flink pull request: [FLINK-2374] Under Windows, skip tests that us... - posted by ggevay <gi...@git.apache.org> on 2015/07/17 14:24:34 UTC, 3 replies.
- [jira] [Commented] (FLINK-2374) File.setWritable doesn't work on Windows, which makes several tests fail - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/17 14:25:04 UTC, 5 replies.
- [jira] [Closed] (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:55:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2367) “flink-xx-jobmanager-linux-3lsu.log" file can't auto be recovered/detected after mistaking delete - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/17 15:15:05 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2359) Add factory methods to the Java TupleX types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/17 15:25:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2371) AccumulatorLiveITCase fails - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/17 15:28: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:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "Shivani Ghatge (JIRA)" <ji...@apache.org> on 2015/07/17 16:25:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "Shivani Ghatge (JIRA)" <ji...@apache.org> on 2015/07/17 16:27:04 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2376] Raise the time limit in testFindC... - posted by ggevay <gi...@git.apache.org> on 2015/07/17 18:39:23 UTC, 2 replies.
- [jira] [Commented] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/17 18:40:04 UTC, 2 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] [Assigned] (FLINK-2312) Random Splits - posted by "pietro pinoli (JIRA)" <ji...@apache.org> on 2015/07/17 19:35:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2312][ml][WIP] Randomly Splitting a Dat... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/17 20:46:22 UTC, 2 replies.
- [GitHub] flink pull request: [Flink-1727][ml]Decision tree[WIP] - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/17 21:15:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2368][ml][WIP]Adds convergence criteria - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/17 21:21:58 UTC, 0 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/07/18 02:12:04 UTC, 0 replies.
- [jira] [Comment Edited] (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/18 02:15: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.
- [GitHub] flink pull request: [FLINK-2362] - distinct is missing in DataSet ... - posted by pp86 <gi...@git.apache.org> on 2015/07/20 00:56:37 UTC, 6 replies.
- [jira] [Commented] (FLINK-2362) distinct is missing in DataSet API documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/20 00:57:04 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2075] Add Approximate Adamic Adar Simil... - posted by shghatge <gi...@git.apache.org> on 2015/07/20 01:02:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/20 01:03:04 UTC, 1 replies.
- [jira] [Updated] (FLINK-2379) Add methods to evaluate field wise statistics over DataSet of vectors. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/20 09:41:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/20 10:31:05 UTC, 5 replies.
- [jira] [Resolved] (FLINK-2027) Flink website does not provide link to source repo - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/20 10:32:04 UTC, 0 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] [Assigned] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/20 12:19:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2299) The slot on which the task maanger was scheduled was killed - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/20 13:02:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2375] Add Approximate Adamic Adar Simil... - posted by andralungu <gi...@git.apache.org> on 2015/07/20 14:28:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-2375) Add Approximate Adamic Adar Similarity method using BloomFilters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/20 14:28:09 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2377] Add reader.close() to readAllResu... - posted by ggevay <gi...@git.apache.org> on 2015/07/20 14:42:18 UTC, 3 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] [Assigned] (FLINK-2381) Possible class not found Exception on failed partition producer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/20 15:03:04 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] [Assigned] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/20 17:55:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2371] improve AccumulatorLiveITCase - posted by mxm <gi...@git.apache.org> on 2015/07/20 18:09:22 UTC, 14 replies.
- [jira] [Commented] (FLINK-2371) AccumulatorLiveITCase fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/20 18:10:04 UTC, 15 replies.
- [jira] [Assigned] (FLINK-685) Add support for semi-joins - posted by "pietro pinoli (JIRA)" <ji...@apache.org> on 2015/07/21 03:01:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1901) Create sample operator for Dataset - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/07/21 08:54:04 UTC, 35 replies.
- [jira] [Updated] (FLINK-1901) Create sample operator for Dataset - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/21 09:39:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/21 11:37:05 UTC, 9 replies.
- [jira] [Resolved] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:50:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:50:09 UTC, 0 replies.
- [jira] [Closed] (FLINK-2301) In BarrierBuffer newer Barriers trigger old Checkpoints - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:52:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:52:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2290) CoRecordReader Does Not Read Events From Both Inputs When No Elements Arrive - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:52:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-1967) Introduce (Event)time in Streaming - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/21 12:53:04 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.
- [jira] [Comment Edited] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/21 14:03:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/21 14:24:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2312) Random Splits - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/21 15:22:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1818] Added api to cancel job from clie... - posted by mjsax <gi...@git.apache.org> on 2015/07/21 15:36:35 UTC, 8 replies.
- [jira] [Commented] (FLINK-1818) Provide API to cancel running job - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 15:37:04 UTC, 9 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 16:15:04 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] [Resolved] (FLINK-2371) AccumulatorLiveITCase fails - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/21 16:39:04 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] [Commented] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/21 17:24:04 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2018 Add ParameterUtil.fromGenericOption... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/21 17:30:13 UTC, 1 replies.
- [jira] [Commented] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 17:31:11 UTC, 1 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] [Resolved] (FLINK-2382) Live Metric Reporting Does Not Work for Two-Input StreamTasks - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/21 17:43:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2387] add streaming test case for live ... - posted by mxm <gi...@git.apache.org> on 2015/07/21 17:53:00 UTC, 3 replies.
- [jira] [Commented] (FLINK-2387) Add test for live accumulators in Streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 17:53:05 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2312][utils] Randomly Splitting a Data ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/21 18:20:33 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2205] Fix confusing entries in JM UI Jo... - posted by ebautistabar <gi...@git.apache.org> on 2015/07/21 19:36:57 UTC, 7 replies.
- [jira] [Commented] (FLINK-2205) Confusing entries in JM Webfrontend Job Configuration section - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 19:37:05 UTC, 7 replies.
- [GitHub] flink pull request: FLINK-2322 Unclosed stream may leak resource - posted by tedyu <gi...@git.apache.org> on 2015/07/21 20:14:43 UTC, 6 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] [Updated] (FLINK-2388) JobManager should try retrieving jobs from archive - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/21 20:18:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1938] Add Grunt for building the front-... - posted by asfgit <gi...@git.apache.org> on 2015/07/21 21:11:08 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1228] Add REST Interface to JobManager - posted by asfgit <gi...@git.apache.org> on 2015/07/21 21:11:08 UTC, 0 replies.
- [jira] [Commented] (FLINK-1938) Add Grunt for building the front-end - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 21:12:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-1228) Add REST Interface to JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/21 21:12:07 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:12:09 UTC, 0 replies.
- [jira] [Closed] (FLINK-2377) AbstractTestBase.deleteAllTempFiles sometimes fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:13:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2362) distinct is missing in DataSet API documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:13:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2362) distinct is missing in DataSet API documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:13:06 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1943) Add Gelly-GSA compiler and translation tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:14:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2376) testFindConnectableAddress sometimes fails on Windows because of the time limit - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:14:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1943) Add Gelly-GSA compiler and translation tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:14:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2198) BlobManager tests fail on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:15:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2198) BlobManager tests fail on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:15:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:16:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2018) Add ParameterUtil.fromGenericOptionsParser() for compatibility to Hadoop's argument parser - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:16:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2358) Add Netty-HTTP based server and server handlers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:18:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2358) Add Netty-HTTP based server and server handlers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:18: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] [Resolved] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/21 21:21:05 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:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1658] Rename AbstractEvent to AbstractT... - posted by mjsax <gi...@git.apache.org> on 2015/07/21 23:43:40 UTC, 4 replies.
- [jira] [Assigned] (FLINK-1267) Add crossGroup operator - posted by "pietro pinoli (JIRA)" <ji...@apache.org> on 2015/07/22 01:28:04 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.
- [jira] [Comment Edited] (FLINK-1901) Create sample operator for Dataset - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/07/22 04:06:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/22 10:29:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2388) JobManager should try retrieving jobs from archive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/22 10:55:05 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-2388] return AccumulatorResultsNotFound... - posted by mxm <gi...@git.apache.org> on 2015/07/22 10:55:05 UTC, 13 replies.
- [GitHub] flink pull request: [FLINK-1927][py] Operator distribution rework - posted by zentol <gi...@git.apache.org> on 2015/07/22 10:57:49 UTC, 5 replies.
- [jira] [Commented] (FLINK-1927) [Py] Rework operator distribution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/22 10:58:04 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2173) Python uses different tmp file than Flink - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/22 10:58:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2346) Mesos clustering - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/22 11:10:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2391]Fix Storm-compatibility FlinkTopol... - posted by ffbin <gi...@git.apache.org> on 2015/07/22 11:43:16 UTC, 17 replies.
- [jira] [Commented] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/22 11:44:04 UTC, 21 replies.
- [jira] [Closed] (FLINK-2371) AccumulatorLiveITCase fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/22 12:00:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2388) JobManager should try retrieving jobs from archive - posted by "Enrique Bautista Barahona (JIRA)" <ji...@apache.org> on 2015/07/22 13:11:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-1658) Rename AbstractEvent to AbstractTaskEvent and AbstractJobEvent - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/22 14:35:05 UTC, 0 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] [Resolved] (FLINK-2218) Web client cannot distinguesh between Flink options and program arguments - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/22 14:45:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2304) Add named attribute access to Storm compatibility layer - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/07/22 14:46:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2097] Implement job session management - posted by uce <gi...@git.apache.org> on 2015/07/22 15:42:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-2097) Add support for JobSessions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/22 15:43:04 UTC, 2 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.
- [GitHub] flink pull request: [FLINK-2385] [scala api] Add parenthesis to Sc... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/22 17:27:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-2385) Scala DataSet.distinct should have parenthesis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/22 17:28:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2393) Add a "stateless at-least-once" mode for streaming - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/22 17:39:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2388) JobManager should try retrieving jobs from archive - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/22 19:47:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2373) Add configuration parameter to createRemoteEnvironment method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/22 20:11:05 UTC, 1 replies.
- [jira] [Resolved] (FLINK-1818) Provide API to cancel running job - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/22 20:18:37 UTC, 0 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] [Commented] (FLINK-2384) Deadlock during partition spilling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 12:04:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2395) Check Scala catch blocks for Throwable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 12:14:04 UTC, 2 replies.
- [jira] [Updated] (FLINK-2213) Configure number of vcores - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 12:20:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1863) RemoteInputChannelTest.testConcurrentOnBufferAndRelease fails on travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 12:20:05 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.
- [jira] [Closed] (FLINK-2389) Add dashboard frontend architecture amd build infrastructue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 14:50:04 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2385] [scala api] [api breaking] Add pa... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/23 14:56:15 UTC, 2 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.
- [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] [Commented] (FLINK-2398) Decouple StreamGraph Building from the API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/23 16:14:04 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2397) Unify two backend servers to one server - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 16:17:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2397) Unify two backend servers to one server - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 16:17: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] [Commented] (FLINK-2400) TaskTest.testExecutionFailesAfterCanceling fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 16:36:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2400) TaskTest.testExecutionFailesAfterCanceling fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/23 16:49:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/23 17:28:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2332) Assign session IDs to JobManager and TaskManager messages - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/23 17:43: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] [Closed] (FLINK-2385) Scala DataSet.distinct should have parenthesis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 17:53:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2385) Scala DataSet.distinct should have parenthesis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/23 17:53:05 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] [Reopened] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Johannes Günther (JIRA)" <ji...@apache.org> on 2015/07/23 21:52: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] [Commented] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/23 23:33:05 UTC, 2 replies.
- [jira] [Updated] (FLINK-2106) Add outer joins to API, Optimizer, and Runtime - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/24 01:50: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.
- [jira] [Resolved] (FLINK-2381) Possible class not found Exception on failed partition producer - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/24 13:58:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2341) Deadlock in SpilledSubpartitionViewAsyncIO - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/24 14:02:04 UTC, 0 replies.
- [GitHub] flink pull request: Framesize fix - posted by kl0u <gi...@git.apache.org> on 2015/07/24 14:06:02 UTC, 38 replies.
- [jira] [Commented] (FLINK-2166) Add fromCsvFile() to TableEnvironment - posted by "James Cao (JIRA)" <ji...@apache.org> on 2015/07/24 15:50:05 UTC, 10 replies.
- [jira] [Commented] (FLINK-2399) Fail when actor versions don't match - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/24 17:03:04 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2231] Create a Serializer for Scala Enu... - posted by aalexandrov <gi...@git.apache.org> on 2015/07/24 18:56:49 UTC, 7 replies.
- [jira] [Commented] (FLINK-2231) Create a Serializer for Scala Enumerations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/24 18:57:05 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2386) Implement Kafka connector using the new Kafka Consumer API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/25 11:52:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/25 13:56:04 UTC, 5 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] [Assigned] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/25 19:43:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1815) Add methods to read and write a Graph as adjacency list - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/25 19:44:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2405] [streaming] Added stateful functi... - posted by gyfora <gi...@git.apache.org> on 2015/07/25 21:09:17 UTC, 14 replies.
- [jira] [Commented] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/25 21:10:04 UTC, 14 replies.
- [jira] [Assigned] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/25 23:32:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2403) Rework partitioned state checkpointing logic - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/26 11:50:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2324] [streaming] Partitioned state che... - posted by gyfora <gi...@git.apache.org> on 2015/07/26 18:21:38 UTC, 26 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.
- [GitHub] flink pull request: [FLINK-2406] [FLINK-2402] Abstract the Barrier... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/27 00:17:05 UTC, 20 replies.
- [jira] [Commented] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/27 00:17:05 UTC, 20 replies.
- [GitHub] flink pull request: FLINK-2166. Add fromCsvFile() method to TableE... - posted by jamescao <gi...@git.apache.org> on 2015/07/27 02:51:53 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1962] Add Gelly Scala API - posted by vasia <gi...@git.apache.org> on 2015/07/27 09:43:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-1962) Add Gelly Scala API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/27 09:44:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/27 09:59:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2163) VertexCentricConfigurationITCase sometimes fails on Travis - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/27 09:59:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/27 10:00:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2127) The GSA Documentation has trailing

s - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/27 10:17:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2213) Configure number of vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/27 10:55:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/27 10:59:04 UTC, 16 replies.
- [jira] [Commented] (FLINK-2360) EOFException - posted by "Stefan Bunk (JIRA)" <ji...@apache.org> on 2015/07/27 11:08:04 UTC, 0 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] [Comment Edited] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/27 13:50:05 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2409) Old JM web interface is sending cancel messages w/o leader ID - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/27 13:51:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2408] Define all maven properties outsi... - posted by rmetzger <gi...@git.apache.org> on 2015/07/27 13:51:33 UTC, 7 replies.
- [jira] [Commented] (FLINK-2408) Some maven properties are defined in build profiles only - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/27 13:52:04 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2161] modified Scala shell start script... - posted by nikste <gi...@git.apache.org> on 2015/07/27 13:59:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-2161) Flink Scala Shell does not support external jars (e.g. Gelly, FlinkML) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/27 14:00:05 UTC, 0 replies.
- [jira] [Comment Edited] (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/27 14:03:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2404]Primitive add methods to Accumulat... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/27 14:28:39 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.
- [GitHub] flink pull request: [FLINK-2410] [java api] PojoTypeInfo is not co... - posted by twalthr <gi...@git.apache.org> on 2015/07/27 14:37:24 UTC, 5 replies.
- [jira] [Commented] (FLINK-2410) PojoTypeInfo is not completely serializable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/27 14:38:04 UTC, 7 replies.
- [jira] [Issue Comment Deleted] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException - posted by "fangfengbin (JIRA)" <ji...@apache.org> on 2015/07/27 14:40:04 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2399] Version checks for Job Manager an... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/27 15:54:49 UTC, 7 replies.
- [jira] [Updated] (FLINK-2411) Add basic graph summarization algorithm - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/07/27 17:43:04 UTC, 6 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.
- [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.
- [GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow... - posted by twalthr <gi...@git.apache.org> on 2015/07/28 00:06:02 UTC, 0 replies.
- [jira] [Commented] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/28 00:06:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/28 09:38:04 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2404]Primitive add methods for Accumula... - posted by mxm <gi...@git.apache.org> on 2015/07/28 10:36:04 UTC, 7 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:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2412) Index Out of Bounds Exception - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/28 13:26:04 UTC, 4 replies.
- [jira] [Commented] (FLINK-2412) Index Out of Bounds Exception - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/28 13:35:04 UTC, 5 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.
- [jira] [Assigned] (FLINK-2412) Index Out of Bounds Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/28 16:39:04 UTC, 0 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:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2419) DataStream sinks lose key information - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/28 16:55:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2419) DataStream sinks lose key information - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/28 16:58:05 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-2419) DataStream sinks lose key information - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/28 17:00:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2419) DataStream sinks lose key information - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/28 17:17:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/28 17:26:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/28 17:27:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2422) Web client is showing a blank page if "Meta refresh" is disabled in browser - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/28 17:27:05 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-2422] [web client] adding redirect link - posted by buzdin <gi...@git.apache.org> on 2015/07/28 18:08:10 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/07/28 18:09:04 UTC, 1 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.
- [jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files. - posted by "niraj rai (JIRA)" <ji...@apache.org> on 2015/07/28 20:39:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2419] Add test for sinks after keyBy an... - posted by gyfora <gi...@git.apache.org> on 2015/07/28 22:03:07 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos - posted by ankurcha <gi...@git.apache.org> on 2015/07/29 01:11:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/29 01:12:05 UTC, 3 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:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2404) LongCounters should have an "addValue()" method for primitive longs - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/29 02:24:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1901] [core] Create sample operator for... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/07/29 09:55:15 UTC, 14 replies.
- [jira] [Resolved] (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/29 10:49:04 UTC, 0 replies.
- [jira] [Closed] (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/29 10:49:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:51:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2420) OutputFlush thread in stream writers does not propagate exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:51:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:51:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2421) StreamRecordSerializer incorrectly duplicates and misses tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:51:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:53:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2406) Abstract BarrierBuffer to an exchangeable BarrierHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:53:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2402) Add a non-blocking BarrierTracker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:53:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2402) Add a non-blocking BarrierTracker - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 10:53:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2424) InstantiationUtil.serializeObject(Object) does not close output stream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 11:07:04 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] [Commented] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/29 11:58:04 UTC, 8 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] [Commented] (FLINK-2152) Provide zipWithIndex utility in flink-contrib - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/29 13:27:04 UTC, 1 replies.
- [jira] [Assigned] (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/29 14:13:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 14:18:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2391) Storm-compatibility:method FlinkTopologyBuilder.createTopology() throws java.lang.NullPointerException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 14:18:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2231) Create a Serializer for Scala Enumerations - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/07/29 14:34:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2425) Give access to TaskManager config and hostname in the Runtime Environment - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/29 14:39: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.
- [GitHub] flink pull request: Cascading changes for compatibility - posted by mxm <gi...@git.apache.org> on 2015/07/29 15:16:42 UTC, 3 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] [Updated] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/07/29 15:28:04 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2407] [streaming] Add an API switch to ... - posted by StephanEwen <gi...@git.apache.org> on 2015/07/29 16:05:33 UTC, 6 replies.
- [jira] [Commented] (FLINK-2407) Add an API switch to select between "exactly once" and "at least once" fault tolerance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/29 16:06:05 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2425]Provide access to task manager con... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/29 17:16:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2424) InstantiationUtil.serializeObject(Object) does not close output stream - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/29 18:42:06 UTC, 0 replies.
- [jira] [Resolved] (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/29 18:46:05 UTC, 0 replies.
- [jira] [Closed] (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/29 18:47: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] [Closed] (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:15:04 UTC, 0 replies.
- [jira] [Deleted] (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:16:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2419) DataStream sinks lose key information - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/29 20:49:06 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.
- [GitHub] flink pull request: [FLINK-2357] [web dashboard] Shows job configu... - posted by ebautistabar <gi...@git.apache.org> on 2015/07/29 23:20:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1919) Add HCatOutputFormat for Tuple data types - posted by "James Cao (JIRA)" <ji...@apache.org> on 2015/07/30 03:50:05 UTC, 2 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.
- [GitHub] flink pull request: [FLINK-2433][docs]Add script to build local do... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/30 06:19:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-2433) Jekyll on windows for building local documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/30 06:20:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2417) Travis build failure on flink-tachyon - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/30 10:00:11 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.
- [GitHub] flink pull request: FLINK-2434:org.apache.hadoop:hadoop-yarn-commo... - posted by caofangkun <gi...@git.apache.org> on 2015/07/30 10:11:29 UTC, 0 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/07/30 10:12:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2238][api]Add env.fromCollection(set) m... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/30 10:25:56 UTC, 0 replies.
- [jira] [Commented] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/30 10:26:04 UTC, 5 replies.
- [jira] [Updated] (FLINK-1919) Add HCatOutputFormat for Tuple data types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/30 11:16:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2248]Add flag to disable sysout logging... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/30 11:43:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-2248) Allow disabling of sdtout logging output - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/30 11:44:06 UTC, 23 replies.
- [GitHub] flink pull request: [FLINK-2238][scala api]Add env.fromCollection(... - posted by fhueske <gi...@git.apache.org> on 2015/07/30 11:52:19 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2248][client]Add flag to disable sysout... - posted by mxm <gi...@git.apache.org> on 2015/07/30 11:54:02 UTC, 22 replies.
- [jira] [Resolved] (FLINK-2384) Deadlock during partition spilling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/30 12:02:04 UTC, 0 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] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/07/30 12:49:05 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:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2436) Make ByteStreamStateHandles more robust - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/30 14:45:05 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2436] [streaming] Make ByteStreamStateH... - posted by gyfora <gi...@git.apache.org> on 2015/07/30 14:50:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/30 16:50:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2405) Add stateful transformations using lambdas to the Streaming Scala API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/30 16:51:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/07/30 16:51:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2324) Rework partitioned state storage - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/30 16:52:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2015/07/30 16:53:04 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2409] [webserver] Replaces ActorRefs wi... - posted by tillrohrmann <gi...@git.apache.org> on 2015/07/30 16:59:58 UTC, 1 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/07/30 17:00:05 UTC, 1 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.
- [GitHub] flink pull request: [FLINK-2437] Fix default constructor detection... - posted by ggevay <gi...@git.apache.org> on 2015/07/30 17:52:39 UTC, 2 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/07/30 17:53:05 UTC, 3 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] [Resolved] (FLINK-1927) [Py] Rework operator distribution - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/30 19:14:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2173) Python uses different tmp file than Flink - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/30 19:15:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2431] Refactor PlanBinder/OperationInfo - posted by zentol <gi...@git.apache.org> on 2015/07/30 20:07:19 UTC, 0 replies.
- [jira] [Commented] (FLINK-2431) [py] refactor PlanBinder/OperationInfo - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/30 20:08:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2432] Custom serializer support - posted by zentol <gi...@git.apache.org> on 2015/07/30 20:10:32 UTC, 0 replies.
- [jira] [Commented] (FLINK-2432) [py] Provide support for custom serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/30 20:11:05 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:06 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2412) Index Out of Bounds Exception - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/07/30 21:35:04 UTC, 0 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.
- [GitHub] flink pull request: [FLINK-2442] [fix] FieldPositionKeys support P... - posted by fhueske <gi...@git.apache.org> on 2015/07/31 00:24:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2442) PojoType fields not supported by field position keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/31 00:25:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2238) Scala ExecutionEnvironment.fromCollection does not work with Sets - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 00:40:04 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.
- [GitHub] flink pull request: [FLINK-2446] Fix SocketTextStreamFunction has ... - posted by ffbin <gi...@git.apache.org> on 2015/07/31 04:59:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/31 04:59:06 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2446]Fix SocketTextStreamFunction has m... - posted by ffbin <gi...@git.apache.org> on 2015/07/31 06:25:18 UTC, 3 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] [Updated] (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 10:00:10 UTC, 2 replies.
- [jira] [Commented] (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/07/31 10:14: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] [Updated] (FLINK-2412) Race leading to IndexOutOfBoundsException when querying for buffer while releasing SpillablePartition - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/31 10:31: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.
- [jira] [Resolved] (FLINK-2412) Race leading to IndexOutOfBoundsException when querying for buffer while releasing SpillablePartition - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/07/31 11:04:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2361) CompactingHashTable loses entries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 11:07:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-1665) Add optional annotations for POJOs to specify the order of fields - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 11:08:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-1666) Clean-up Field Expression Code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 11:08:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/07/31 11:17:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2423) Properly test checkpoint notifications - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/07/31 11:24:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2360) EOFException - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/07/31 12:25:04 UTC, 0 replies.
- [jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 12:36:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2394) HadoopOutFormat OutputCommitter is default to FileOutputCommiter - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/07/31 12:36:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/07/31 14:30:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1819][core]Allow access to RuntimeConte... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/07/31 14:45:32 UTC, 3 replies.
- [jira] [Commented] (FLINK-1819) Allow access to RuntimeContext from Input and OutputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/07/31 14:46:04 UTC, 3 replies.
- [jira] [Updated] (FLINK-2248) Allow disabling of sdtout logging output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/31 15:51:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2248) Allow disabling of sdtout logging output - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/07/31 15:52:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2449) DistCache doesn't work with JavaProgram Collection tests - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/07/31 17:12:04 UTC, 4 replies.
- [GitHub] flink pull request: Stale Synchronous Parallel Iterations - posted by nltran <gi...@git.apache.org> on 2015/07/31 17:46:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2446) SocketTextStreamFunction has memory leak when reconnect server - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/07/31 17:51:04 UTC, 0 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] [Updated] (FLINK-2452) Add a playcount threshold to the MusicProfiles example - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/31 18:20:04 UTC, 0 replies.
- [jira] [Commented] (FLINK-2443) The Gather-Sum-Apply Version of Connected Components fails with NPE - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/07/31 18:37:05 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.
- [jira] [Commented] (FLINK-2314) Make Streaming File Sources Persistent - posted by "Sheetal Parade (JIRA)" <ji...@apache.org> on 2015/07/31 22:02:04 UTC, 0 replies.