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

---

- [GitHub] flink pull request: [FLINK-2773] remove strict upper direct memory... - posted by asfgit <gi...@git.apache.org> on 2015/10/01 01:07:36 UTC, 3 replies.
- [jira] [Commented] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 01:08:04 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 01:09:04 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 01:10:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2783] Remove "degreeOfParallelism" API ... - posted by hsaputra <gi...@git.apache.org> on 2015/10/01 07:15:03 UTC, 2 replies.
- [jira] [Commented] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 07:15:04 UTC, 1 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 09:16:04 UTC, 10 replies.
- [jira] [Resolved] (FLINK-2781) Consolidate NetUtils - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 09:18:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2781) Consolidate NetUtils - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 09:29:04 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2766) Bad ipv6 urls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 09:29:04 UTC, 0 replies.
- [jira] [Closed] (FLINK-2766) Bad ipv6 urls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 09:29:04 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2561] [gelly] adds documentation for ge... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 09:51:01 UTC, 1 replies.
- [GitHub] flink pull request: [hotfix] Simplify new windowing API - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 09:56:27 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2781] [core] Cleanup NetUtils. - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 09:58:17 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2778] Add API for non-parallel non-keye... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 10:09:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-2778) Add API for non-parallel non-keyed Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 10:09:38 UTC, 4 replies.
- [jira] [Created] (FLINK-2794) Exactly-once support - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 10:20:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2725] Max/Min/Sum Aggregation of mutabl... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 10:25:15 UTC, 7 replies.
- [jira] [Commented] (FLINK-2725) Max/Min/Sum Aggregation of mutable types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 10:25:26 UTC, 7 replies.
- [jira] [Updated] (FLINK-2794) Document exactly-once support for sources and sinks - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 10:26:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2613] Print usage information for Scala... - posted by tillrohrmann <gi...@git.apache.org> on 2015/10/01 10:32:28 UTC, 50 replies.
- [jira] [Commented] (FLINK-2613) Print usage information for Scala Shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 10:33:26 UTC, 50 replies.
- [GitHub] flink pull request: [FLINK-2766] [core] Add proper handling for IP... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 10:44:38 UTC, 1 replies.
- [jira] [Commented] (FLINK-2766) Bad ipv6 urls - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 10:45:26 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2767] [scala shell] Add Scala 2.11 supp... - posted by rmetzger <gi...@git.apache.org> on 2015/10/01 10:55:19 UTC, 8 replies.
- [jira] [Commented] (FLINK-2767) Add support Scala 2.11 to Scala shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 10:55:27 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-1789] [core] [runtime] [java-api] Allow... - posted by mxm <gi...@git.apache.org> on 2015/10/01 11:20:10 UTC, 24 replies.
- [jira] [Assigned] (FLINK-2794) Document exactly-once support for sources and sinks - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/10/01 11:20:26 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/10/01 11:20:27 UTC, 24 replies.
- [jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/01 11:31:26 UTC, 11 replies.
- [jira] [Commented] (FLINK-2762) Job Runtime: -1 ms - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 11:54:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 11:55:26 UTC, 16 replies.
- [jira] [Resolved] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:00:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2783) Remove "degreeOfParallelism" API calls - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:00:29 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:00:29 UTC, 1 replies.
- [jira] [Closed] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:00:29 UTC, 0 replies.
- [jira] [Closed] (FLINK-2778) Add API for non-parallel non-keyed Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:01:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2778) Add API for non-parallel non-keyed Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/01 12:01:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2792) Set log level of actor messages to TRACE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/01 12:12:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2795) Print JobExecutionResult for interactively invoked jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 12:12:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2795) Print JobExecutionResult for interactively invoked jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 12:12:27 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2740 Adding flink-connector-nifi module ... - posted by rmetzger <gi...@git.apache.org> on 2015/10/01 12:26:44 UTC, 17 replies.
- [jira] [Commented] (FLINK-2740) Create data consumer for Apache NiFi - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 12:27:26 UTC, 18 replies.
- [jira] [Reopened] (FLINK-2561) Sync Gelly Java and Scala APIs - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/01 12:48:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/01 13:19:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2785] [gelly] implements fromCsvReader ... - posted by vasia <gi...@git.apache.org> on 2015/10/01 15:14:05 UTC, 17 replies.
- [jira] [Commented] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 15:14:26 UTC, 17 replies.
- [jira] [Created] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 15:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 15:48:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2748] accumulator fetch failure leads t... - posted by mxm <gi...@git.apache.org> on 2015/10/01 16:19:26 UTC, 6 replies.
- [jira] [Commented] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 16:19:27 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2793] [dashboard] Redirect to leader in... - posted by rmetzger <gi...@git.apache.org> on 2015/10/01 16:29:05 UTC, 25 replies.
- [jira] [Commented] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 16:29:27 UTC, 25 replies.
- [jira] [Created] (FLINK-2798) Prepare new web dashboard for executing in on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/01 16:51:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2798) Prepare new web dashboard for executing in on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/01 16:51:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2798) Prepare new web dashboard for executing in on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/01 16:51:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2666] Add timestamp extraction operator - posted by gyfora <gi...@git.apache.org> on 2015/10/01 17:38:53 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2591] Add configuration parameter for d... - posted by rmetzger <gi...@git.apache.org> on 2015/10/01 17:39:21 UTC, 5 replies.
- [jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 17:39:27 UTC, 5 replies.
- [jira] [Commented] (FLINK-2666) Allow custom Timestamp extractors for Flink sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 17:39:27 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1599] TypeComperator with no keys and c... - posted by mxm <gi...@git.apache.org> on 2015/10/01 17:47:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-1599) TypeComperator with no keys and comparators matches some elements - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/01 17:47:26 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2780) Remove Old Windowing Logic and API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/01 17:54:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2791) ParallelMergeITCase failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/01 18:06:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2782] Remove "degreeOfParallelism" API ... - posted by mxm <gi...@git.apache.org> on 2015/10/01 18:11:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-2782) Remove deprecated features for 0.10 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 18:12:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2727] [streaming] Add a base class for ... - posted by mxm <gi...@git.apache.org> on 2015/10/01 18:18:34 UTC, 3 replies.
- [jira] [Commented] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 18:19:26 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2743] Add XORShfitRandom and use it in ... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/01 18:49:03 UTC, 7 replies.
- [jira] [Commented] (FLINK-2743) Add new RNG based on XORShift algorithm - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 18:49:27 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2779][FLINK-2794][streaming][docs] New ... - posted by ktzoumas <gi...@git.apache.org> on 2015/10/01 20:03:53 UTC, 33 replies.
- [jira] [Commented] (FLINK-2779) Update documentation to reflect new Stream/Window API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 20:04:27 UTC, 33 replies.
- [GitHub] flink pull request: [FLINK-2663] [gelly] Changes library methods t... - posted by vasia <gi...@git.apache.org> on 2015/10/01 21:24:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-2663) Update Gelly library methods to use any key type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 21:24:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2663) Update Gelly library methods to use any key type - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/01 21:57:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1984] Integrate Flink with Apache Mesos - posted by hsaputra <gi...@git.apache.org> on 2015/10/01 23:42:33 UTC, 9 replies.
- [jira] [Commented] (FLINK-1984) Integrate Flink with Apache Mesos - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/01 23:43:26 UTC, 9 replies.
- [jira] [Created] (FLINK-2799) Yarn tests cannot be executed with DEBUG log level - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/02 01:46:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2066) Make delay between execution retries configurable - posted by "Chengxuan Wang (JIRA)" <ji...@apache.org> on 2015/10/02 07:53:26 UTC, 20 replies.
- [jira] [Comment Edited] (FLINK-2066) Make delay between execution retries configurable - posted by "Chengxuan Wang (JIRA)" <ji...@apache.org> on 2015/10/02 08:00:32 UTC, 1 replies.
- [jira] [Updated] (FLINK-2066) Make delay between execution retries configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 09:43:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2800) kryo serialization problem - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/10/02 09:46:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2801) Rework Storm Compatibility Tests - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 10:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/02 10:24:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2525]Add configuration support in Storm... - posted by asfgit <gi...@git.apache.org> on 2015/10/02 10:50:55 UTC, 0 replies.
- [jira] [Commented] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 10:51:26 UTC, 1 replies.
- [jira] [Closed] (FLINK-2525) Add configuration support in Storm-compatibility - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/02 10:53:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2801) Rework Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/02 10:56:26 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2642] [table] Scala Table API crashes w... - posted by twalthr <gi...@git.apache.org> on 2015/10/02 11:17:39 UTC, 5 replies.
- [jira] [Commented] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 11:18:26 UTC, 7 replies.
- [jira] [Created] (FLINK-2803) Add test case for Flink's memory allocation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 11:19:26 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/02 11:21:27 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Execute YARN integration tests only u... - posted by rmetzger <gi...@git.apache.org> on 2015/10/02 11:44:32 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2561] Adds gelly-scala examples - posted by vasia <gi...@git.apache.org> on 2015/10/02 11:50:12 UTC, 15 replies.
- [jira] [Created] (FLINK-2804) Support blocking job submission with Job Manager recovery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/02 11:56:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2354] Add job graph and checkpoint reco... - posted by uce <gi...@git.apache.org> on 2015/10/02 11:57:04 UTC, 131 replies.
- [jira] [Closed] (FLINK-2762) Job Runtime: -1 ms - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 11:57:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2354) Recover running jobs on JobManager failure - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 11:57:27 UTC, 131 replies.
- [jira] [Closed] (FLINK-2776) Print job id to standard out on CLI job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 11:59:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2748) Accumulator fetch failure leads to duplicate job result response - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 11:59:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-1599) TypeComperator with no keys and comparators matches some elements - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 12:00:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-2800) kryo serialization problem - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/10/02 12:06:26 UTC, 17 replies.
- [jira] [Created] (FLINK-2805) Make user jars available for all job managers to recover - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/02 12:09:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2550) Rework DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 12:11:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2550) Rework DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 12:11:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2806) No TypeInfo for Scala's Nothing type - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/02 12:22:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2806] [scala-api] Add a TypeInformation... - posted by ggevay <gi...@git.apache.org> on 2015/10/02 12:27:06 UTC, 8 replies.
- [jira] [Commented] (FLINK-2806) No TypeInfo for Scala's Nothing type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 12:27:26 UTC, 9 replies.
- [jira] [Created] (FLINK-2807) Add javadocs/comments to new windowing mechanics - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/02 13:05:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-2807) Add javadocs/comments to new windowing mechanics - posted by "Kostas Tzoumas (JIRA)" <ji...@apache.org> on 2015/10/02 13:12:26 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2807) Add javadocs/comments to new windowing mechanics - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/02 13:13:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/02 13:43:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 13:45:27 UTC, 2 replies.
- [jira] [Closed] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 13:51:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2576] Add Outer Join operator to Optimi... - posted by jkovacs <gi...@git.apache.org> on 2015/10/02 13:55:53 UTC, 7 replies.
- [jira] [Commented] (FLINK-2576) Add outer joins to API and Optimizer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 13:56:26 UTC, 8 replies.
- [jira] [Assigned] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/02 14:00:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 14:07:26 UTC, 80 replies.
- [GitHub] flink pull request: [FLINK-2167] [table] Add fromHCat() to TableEn... - posted by twalthr <gi...@git.apache.org> on 2015/10/02 14:16:44 UTC, 1 replies.
- [jira] [Commented] (FLINK-2167) Add fromHCat() to TableEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 14:17:26 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2790] [yarn] [ha] Adds high availabilit... - posted by tillrohrmann <gi...@git.apache.org> on 2015/10/02 14:39:08 UTC, 22 replies.
- [jira] [Commented] (FLINK-2790) Add high availability support for Yarn - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 14:39:26 UTC, 23 replies.
- [jira] [Created] (FLINK-2808) Rework / Extend the StatehandleProvider - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 14:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2809) DataSet[Unit] doesn't work - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/02 15:09:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2810) Warn user if bc not installed - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/02 15:19:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/02 15:33:27 UTC, 77 replies.
- [jira] [Commented] (FLINK-2810) Warn user if bc not installed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 15:34:26 UTC, 8 replies.
- [jira] [Updated] (FLINK-2810) Warn user if bc not installed - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 16:20:26 UTC, 2 replies.
- [jira] [Updated] (FLINK-2799) Yarn tests cannot be executed with DEBUG log level - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 16:21:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 16:53:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2727) Add a base class for MessageQueue-with-acknowledgement sources - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/02 16:53:27 UTC, 0 replies.
- [GitHub] flink pull request: Stream API Refactoring - posted by aljoscha <gi...@git.apache.org> on 2015/10/02 16:53:35 UTC, 8 replies.
- [jira] [Closed] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/02 17:36:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2811) Add page with configuration overview - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/02 17:37:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/02 17:41:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2813) Document off-heap configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/02 18:15:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2811) Add page with configuration overview - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/02 18:22:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2802] [streaming] Remove cyclic waterma... - posted by gyfora <gi...@git.apache.org> on 2015/10/02 18:31:05 UTC, 2 replies.
- [jira] [Commented] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 18:31:26 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2809] [scala-api] Added UnitTypeInfo an... - posted by ggevay <gi...@git.apache.org> on 2015/10/02 18:40:13 UTC, 18 replies.
- [jira] [Commented] (FLINK-2809) DataSet[Unit] doesn't work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 18:40:26 UTC, 17 replies.
- [jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/02 18:52:26 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2566] FlinkTopologyContext not populate... - posted by mjsax <gi...@git.apache.org> on 2015/10/02 18:55:21 UTC, 3 replies.
- [jira] [Commented] (FLINK-2566) FlinkTopologyContext not populated completely - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/02 18:55:26 UTC, 4 replies.
- [jira] [Created] (FLINK-2814) DeltaIteration: DualInputPlanNode cannot be cast to SingleInputPlanNode - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/02 22:08:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.1 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/02 23:18:26 UTC, 2 replies.
- [jira] [Created] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/03 05:44:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2815] [REFACTOR] Remove Pact from class... - posted by hsaputra <gi...@git.apache.org> on 2015/10/03 05:55:46 UTC, 13 replies.
- [jira] [Commented] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/03 05:56:26 UTC, 13 replies.
- [jira] [Created] (FLINK-2816) Memory allocation module as a separate maven artifact - posted by "Suminda Dharmasena (JIRA)" <ji...@apache.org> on 2015/10/03 10:20:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2283] [streaming] Make grouped reduce/f... - posted by mbalassi <gi...@git.apache.org> on 2015/10/03 11:27:27 UTC, 6 replies.
- [jira] [Commented] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/03 11:28:26 UTC, 6 replies.
- [jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/03 12:27:26 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-2811][web-dashboard]Add page with Confi... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/03 13:10:14 UTC, 24 replies.
- [jira] [Commented] (FLINK-2811) Add page with configuration overview - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/03 13:10:26 UTC, 24 replies.
- [jira] [Assigned] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/03 13:19:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2237) Add hash-based Aggregation - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/03 20:37:26 UTC, 0 replies.
- [GitHub] flink pull request: Flink 1745 - posted by danielblazevski <gi...@git.apache.org> on 2015/10/03 21:03:15 UTC, 11 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/10/03 21:03:26 UTC, 35 replies.
- [jira] [Updated] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/03 21:51:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/03 22:51:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/03 22:52:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2100) Add ITCases for all Table API examples - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/10/04 00:23:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-1940) StockPrice example cannot be visualized - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/10/04 00:32:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2741) Use single log statement in TestLogger - posted by "rerngvit yanggratoke (JIRA)" <ji...@apache.org> on 2015/10/04 00:36:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2741] - Use single log statement in Tes... - posted by rerngvit <gi...@git.apache.org> on 2015/10/04 00:58:21 UTC, 14 replies.
- [jira] [Commented] (FLINK-2741) Use single log statement in TestLogger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/04 00:58:26 UTC, 15 replies.
- [jira] [Created] (FLINK-2817) FileMonitoring function throws NPE when location is empty - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/04 07:12:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2798] Serve static files for the new we... - posted by rmetzger <gi...@git.apache.org> on 2015/10/04 08:36:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing in on YARN - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/04 08:37:26 UTC, 4 replies.
- [jira] [Closed] (FLINK-1940) StockPrice example cannot be visualized - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/04 09:31:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-1536) Graph partitioning operators for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/04 11:11:26 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2066][core] Add delay between execution... - posted by WangCHX <gi...@git.apache.org> on 2015/10/04 11:15:39 UTC, 15 replies.
- [jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/04 15:33:26 UTC, 29 replies.
- [jira] [Commented] (FLINK-2787) Prevent explicit use of RemoteEnvironment when running a job through the command line - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/04 16:15:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2666) Allow custom Timestamp extractors for Flink sources - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/04 17:13:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/04 20:37:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2818] [runtime] Corrected javadocs of *... - posted by ggevay <gi...@git.apache.org> on 2015/10/04 20:51:57 UTC, 4 replies.
- [jira] [Commented] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/04 20:52:26 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2740) Create data consumer for Apache NiFi - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/05 03:56:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/05 09:14:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2802) Watermark triggered operators cannot progress with cyclic flows - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:07:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:10:27 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2317) Stream Jobs with Windows Leave Lingering State - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:10:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:12:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:12:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-2770) KafkaITCase.testConcurrentProducerConsumerTopology fails - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:13:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:13:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:13:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:14:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-2670) Unstable CombineTaskTest - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:15:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:15:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:17:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-2348) IterateExampleITCase failing - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:17:28 UTC, 1 replies.
- [jira] [Updated] (FLINK-2156) Scala modules cannot create logging file - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:19:26 UTC, 3 replies.
- [jira] [Updated] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 12:30:26 UTC, 0 replies.
- [jira] [Resolved] (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/10/05 12:34:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2816) Memory allocation module as a separate maven artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/05 12:36:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2816) Memory allocation module as a separate maven artifact - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/05 12:36:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1675) Rework Accumulators - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 13:15:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by danielblazevski <gi...@git.apache.org> on 2015/10/05 14:11:17 UTC, 30 replies.
- [jira] [Commented] (FLINK-1675) Rework Accumulators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/05 14:27:26 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1610] fix building of java doc for Java... - posted by mxm <gi...@git.apache.org> on 2015/10/05 15:16:55 UTC, 3 replies.
- [jira] [Commented] (FLINK-1610) Java docs do not build - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/05 15:17:26 UTC, 3 replies.
- [jira] [Updated] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/05 15:21:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1610) Java docs do not build - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 15:35:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-1610) Java docs do not build - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 15:35:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 15:36:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2787) Prevent explicit use of RemoteEnvironment when running a job through the command line - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 15:43:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2482) Document sreaming processing guarantees - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 15:45:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/05 16:37:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2807) Add javadocs/comments to new windowing mechanics - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/05 16:45:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/05 17:13:27 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2813] document parameter for off-heap m... - posted by mxm <gi...@git.apache.org> on 2015/10/05 17:29:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-2813) Document off-heap configuration - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/05 17:30:28 UTC, 4 replies.
- [jira] [Closed] (FLINK-2489) Improve the streaming window join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/05 17:31:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2805] [blobmanager] Write JARs to file ... - posted by uce <gi...@git.apache.org> on 2015/10/05 17:34:57 UTC, 18 replies.
- [jira] [Commented] (FLINK-2805) Make user jars available for all job managers to recover - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/05 17:35:26 UTC, 18 replies.
- [jira] [Closed] (FLINK-2333) Stream Data Sink that periodically rolls files - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/05 17:42:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/05 17:44:28 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/05 17:46:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/05 18:38:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2810] Warn user if bc not installed - posted by greghogan <gi...@git.apache.org> on 2015/10/05 18:42:46 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/05 21:22:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2786] Remove Spargel from source code a... - posted by vasia <gi...@git.apache.org> on 2015/10/05 21:23:24 UTC, 3 replies.
- [jira] [Commented] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/05 21:23:27 UTC, 3 replies.
- [jira] [Created] (FLINK-2820) Configuration not passed to JobGraphGenerator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/05 21:46:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/06 02:19:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2552) Sporadic failure of PartialConsumePipelinedResultTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/06 05:56:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2804] [client, runtime] Add blocking jo... - posted by uce <gi...@git.apache.org> on 2015/10/06 10:30:33 UTC, 5 replies.
- [jira] [Commented] (FLINK-2804) Support blocking job submission with Job Manager recovery - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 10:31:26 UTC, 9 replies.
- [jira] [Closed] (FLINK-1610) Java docs do not build - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 10:54:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-2813) Document off-heap configuration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 10:55:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2810) Warn user if bc not installed - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 10:56:30 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2811) Add page with configuration overview - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/06 11:41:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2741) Use single log statement in TestLogger - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/06 11:43:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 11:58:27 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 11:59:26 UTC, 1 replies.
- [jira] [Updated] (FLINK-2820) Configuration not passed to JobGraphGenerator - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 12:12:26 UTC, 1 replies.
- [jira] [Reopened] (FLINK-1610) Java docs do not build - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 12:14:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] [ml] [WIP] Add exact k-nearest-ne... - posted by chiwanpark <gi...@git.apache.org> on 2015/10/06 12:15:12 UTC, 1 replies.
- [jira] [Updated] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/06 12:23:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2786) Remove Spargel from source code and update documentation in favor of Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/06 12:23:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2822) Windowing classes incorrectly import scala.Serializable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/06 12:40:26 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2210) Table API aggregate by ignoring null values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 12:42:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 12:44:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1731] [ml] Implementation of Feature K-... - posted by peedeeX21 <gi...@git.apache.org> on 2015/10/06 13:02:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 13:03:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2566) FlinkTopologyContext not populated completely - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/06 13:34:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2822) Windowing classes incorrectly import scala.Serializable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/06 14:31:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2642) Scala Table API crashes when executing word count example - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/06 14:33:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2822) Windowing classes incorrectly import scala.Serializable - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/06 14:37:26 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2800) kryo serialization problem - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/10/06 14:39:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2718) LeaserChangeCleanupTest sometimes fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/06 15:04:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2718) LeaserChangeCleanupTest sometimes fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/06 15:04:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/06 15:14:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1472] Fixed Web frontend config overvie... - posted by fhueske <gi...@git.apache.org> on 2015/10/06 15:21:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-1472) Web frontend config overview shows wrong value - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 15:21:26 UTC, 1 replies.
- [jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/06 15:23:26 UTC, 10 replies.
- [GitHub] flink pull request: Parameter Server: Distributed Key-Value store,... - posted by fhueske <gi...@git.apache.org> on 2015/10/06 15:23:48 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2125][streaming] Delimiter change from ... - posted by fhueske <gi...@git.apache.org> on 2015/10/06 15:24:49 UTC, 2 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 15:25:26 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2731) Add JobManager log file access - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/06 15:52:26 UTC, 0 replies.
- [GitHub] flink pull request: Create a deep-copy of the record when changing... - posted by kl0u <gi...@git.apache.org> on 2015/10/06 16:35:35 UTC, 2 replies.
- [jira] [Closed] (FLINK-2815) [REFACTOR] Remove Pact from class and file names since it is no longer valid reference - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/06 17:16:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2210) Table API aggregate by ignoring null values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 17:21:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2210) Table API aggregate by ignoring null values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 17:24:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2203) Add Support for Null-Values in RowSerializer - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 17:25:27 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2479] Refactor runtime.operators.* test... - posted by fhueske <gi...@git.apache.org> on 2015/10/06 17:27:17 UTC, 22 replies.
- [jira] [Commented] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 17:27:26 UTC, 22 replies.
- [jira] [Resolved] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/06 17:28:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2819] Add Windowed Join/CoGroup Operato... - posted by aljoscha <gi...@git.apache.org> on 2015/10/06 18:03:50 UTC, 2 replies.
- [jira] [Commented] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 18:04:26 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2731][web-dashboard] Adds access to Job... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/06 19:04:42 UTC, 32 replies.
- [jira] [Commented] (FLINK-2731) Add JobManager log file access - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 19:05:26 UTC, 35 replies.
- [jira] [Created] (FLINK-2824) Iteration feedback partitioning does not work as expected - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/06 20:03:27 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2731) Add JobManager log file access - posted by "Piotr Godek (JIRA)" <ji...@apache.org> on 2015/10/06 20:17:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2156] Scala modules cannot create loggi... - posted by dawidwys <gi...@git.apache.org> on 2015/10/06 20:28:59 UTC, 9 replies.
- [jira] [Commented] (FLINK-2156) Scala modules cannot create logging file - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/06 20:29:26 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-2156) Scala modules cannot create logging file - posted by "Dawid Wysakowicz (JIRA)" <ji...@apache.org> on 2015/10/06 20:35:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/06 21:52:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2812) KeySelectorUtil.getSelectorForKeys and TypeExtractor.getKeySelectorTypes are incompatible - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/06 23:04:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2283) Make grouped reduce/fold/aggregations stateful using Partitioned state - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/06 23:05:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 00:54:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2825) FlinkClient.killTopology fails due to missing leader session ID - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 00:54:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/07 01:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/07 01:29:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2801) Rework Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 11:15:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 11:17:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2817) FileMonitoring function throws NPE when location is empty - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/07 11:41:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2804) Support blocking job submission with Job Manager recovery - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/07 12:31:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/07 12:37:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ... - posted by mxm <gi...@git.apache.org> on 2015/10/07 12:43:16 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/07 13:54:54 UTC, 24 replies.
- [jira] [Created] (FLINK-2828) Add interfaces for Table API input formats - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/07 14:45:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ... - posted by twalthr <gi...@git.apache.org> on 2015/10/07 14:59:55 UTC, 9 replies.
- [jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/07 15:00:31 UTC, 9 replies.
- [GitHub] flink pull request: Combination of Additions to the new Windowing ... - posted by aljoscha <gi...@git.apache.org> on 2015/10/07 15:11:22 UTC, 2 replies.
- [jira] [Closed] (FLINK-2767) Add support Scala 2.11 to Scala shell - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/07 16:14:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2066) Make delay between execution retries configurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/07 16:15:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2829) Confusing error message when Flink cannot create enough task threads - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/07 16:21:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2830) Add Fold Window Operation for new Windowing API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/07 16:53:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2806) No TypeInfo for Scala's Nothing type - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/07 18:44:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2831) Failinf Test: WrapperSetupHelperTest - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 19:22:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 19:26:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 20:42:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 21:04:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2785) Implement Graph's fromCsvReader in Gelly-Scala - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/07 21:19:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 23:12:28 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/07 23:13:26 UTC, 1 replies.
- [jira] [Closed] (FLINK-2830) Add Fold Window Operation for new Windowing API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/07 23:25:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2819) Add Windowed Join/CoGroup Operator Based on Tagged Union - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/07 23:25:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/08 01:46:27 UTC, 17 replies.
- [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... - posted by HuangWHWHW <gi...@git.apache.org> on 2015/10/08 03:14:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/08 03:15:26 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2808] Rework state abstraction and clea... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/08 07:01:48 UTC, 18 replies.
- [jira] [Commented] (FLINK-2808) Rework / Extend the StatehandleProvider - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/08 07:02:27 UTC, 18 replies.
- [jira] [Assigned] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/10/08 08:08:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2611) YARN reports failed final state for successful jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/08 11:14:27 UTC, 7 replies.
- [jira] [Created] (FLINK-2833) Unstage Gelly and Module refactoring - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/08 11:21:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2611] YARN reports failed final state f... - posted by mxm <gi...@git.apache.org> on 2015/10/08 11:32:14 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2833] [gelly] unstage Gelly and move to... - posted by vasia <gi...@git.apache.org> on 2015/10/08 11:52:03 UTC, 3 replies.
- [jira] [Commented] (FLINK-2833) Unstage Gelly and Module refactoring - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/08 11:52:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/08 12:05:26 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod... - posted by chiwanpark <gi...@git.apache.org> on 2015/10/08 12:10:15 UTC, 11 replies.
- [jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/08 12:10:27 UTC, 11 replies.
- [jira] [Resolved] (FLINK-2790) Add high availability support for Yarn - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/08 14:25:26 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2611) YARN reports failed final state for successful jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/08 14:32:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2834) Global round-robin for temporary directories - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/08 15:15:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2835) Update Documenation for new Streaming API - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 15:53:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2836) Cyclic Topologies not supported - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 15:57:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2835) Update Documenation for new Streaming API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/08 15:58:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-1789) Allow adding of URLs to the usercode class loader - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/08 16:00:35 UTC, 0 replies.
- [jira] [Commented] (FLINK-2836) Cyclic Topologies not supported - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2015/10/08 16:06:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/08 16:10:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2780] Remove Old Windowing Logic and AP... - posted by aljoscha <gi...@git.apache.org> on 2015/10/08 17:30:29 UTC, 4 replies.
- [jira] [Commented] (FLINK-2780) Remove Old Windowing Logic and API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/08 17:31:26 UTC, 4 replies.
- [jira] [Closed] (FLINK-1129) The Plan Visualizer Cuts of the Lower Part of Certain Operators - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/08 17:39:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2834) Global round-robin for temporary directories - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/08 17:46:26 UTC, 7 replies.
- [jira] [Issue Comment Deleted] (FLINK-2714) Port the Flink DataSet Triangle Count example to the Gelly library - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/09 00:54:26 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/09 05:29:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2838) Inconsistent use of URL and Path classes for resources - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 10:33:28 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/09 11:14:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2780) Remove Old Windowing Logic and API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/09 12:18:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2550) Rework DataStream API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/09 12:27:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2779) Update documentation to reflect new Stream/Window API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/09 12:33:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2794) Document exactly-once support for sources and sinks - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/09 12:47:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/09 13:33:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2840) KMeans library for Flink ML - posted by "Devang Bacharwar (JIRA)" <ji...@apache.org> on 2015/10/09 14:00:28 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... - posted by HilmiYildirim <gi...@git.apache.org> on 2015/10/09 14:33:37 UTC, 16 replies.
- [jira] [Commented] (FLINK-2840) KMeans library for Flink ML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 14:53:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2840) KMeans library for Flink ML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 14:56:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 15:09:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2784) Remove deprecated config keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 15:36:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2842) S3FileSystem is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 15:57:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2842) S3FileSystem is broken - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/09 16:01:26 UTC, 14 replies.
- [jira] [Comment Edited] (FLINK-2842) S3FileSystem is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 16:05:28 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2784] Remove deprecated configuration k... - posted by fhueske <gi...@git.apache.org> on 2015/10/09 16:18:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-2784) Remove deprecated config keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/09 16:18:26 UTC, 3 replies.
- [jira] [Created] (FLINK-2843) Add documentation for DataSet outer joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 16:25:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2818) The *ReduceDriver classes have incorrect javadocs - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 16:31:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2613) Print usage information for Scala Shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 16:41:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2156) Scala modules cannot create logging file - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 16:48:26 UTC, 0 replies.
- [jira] [Created] (FLINK-2844) Remove old web interface and default to the new one - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 17:31:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2842] [documentation] Remove Flink S3Fi... - posted by fhueske <gi...@git.apache.org> on 2015/10/09 17:38:43 UTC, 8 replies.
- [jira] [Created] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/09 17:46:26 UTC, 0 replies.
- [jira] [Updated] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/09 17:47:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2844][jobmanager] remove old web interf... - posted by mxm <gi...@git.apache.org> on 2015/10/09 17:47:49 UTC, 9 replies.
- [jira] [Commented] (FLINK-2844) Remove old web interface and default to the new one - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/09 17:48:26 UTC, 9 replies.
- [jira] [Updated] (FLINK-2798) Prepare new web dashboard for executing it on YARN - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 17:57:26 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2833) Unstage Gelly and Module refactoring - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/09 18:08:28 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2784) Remove deprecated config keys - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/09 18:09:26 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2782) Remove deprecated features for 0.10 - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/09 18:10:26 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/09 18:31:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:48:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:49:26 UTC, 1 replies.
- [jira] [Reopened] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:50:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2576) Add outer joins to API and Optimizer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:50:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2107) Implement Hash Outer Join algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:51:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-687) Add support for outer-joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/09 18:53:26 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2774] [scala shell] Import some Java an... - posted by chiwanpark <gi...@git.apache.org> on 2015/10/09 19:01:57 UTC, 3 replies.
- [jira] [Closed] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/09 19:10:06 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/09 20:30:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2843] Add documentation for outer joins... - posted by fhueske <gi...@git.apache.org> on 2015/10/09 21:31:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-2843) Add documentation for DataSet outer joins - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/09 21:32:05 UTC, 3 replies.
- [jira] [Created] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/09 21:44:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2804] [runtime] Add blocking job submis... - posted by tillrohrmann <gi...@git.apache.org> on 2015/10/09 22:18:24 UTC, 3 replies.
- [jira] [Created] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/10 01:35:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/10 01:36:05 UTC, 2 replies.
- [jira] [Created] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/10/10 03:49:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/10/10 09:48:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2714] [Gelly] Copy triangle counting lo... - posted by ssaumitra <gi...@git.apache.org> on 2015/10/10 13:53:28 UTC, 25 replies.
- [jira] [Comment Edited] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/10 14:30:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/10 14:30:05 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-2411) Add basic graph summarization algorithm - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/10 17:45:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2411) Add basic graph summarization algorithm - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/10 17:45:05 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-2817] FileMonitoring function throws NP... - posted by ehnalis <gi...@git.apache.org> on 2015/10/10 18:00:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-2817) FileMonitoring function throws NPE when location is empty - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/10 18:01:05 UTC, 2 replies.
- [jira] [Closed] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/10 23:45:05 UTC, 0 replies.
- [GitHub] flink pull request: Fix Avro getter/setter recognition - posted by ukarlsson <gi...@git.apache.org> on 2015/10/11 00:06:52 UTC, 4 replies.
- [jira] [Updated] (FLINK-2714) Port the Flink DataSet Triangle Enumeration example to the Gelly library - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/11 12:48:05 UTC, 2 replies.
- [GitHub] flink pull request: types_serialization.md: fix typo in Scala func... - posted by viktortnk <gi...@git.apache.org> on 2015/10/11 12:52:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-2714) Port the Flink DataSet Triangle Enumeration example to the Gelly library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/11 14:00:07 UTC, 18 replies.
- [jira] [Closed] (FLINK-2817) FileMonitoring function throws NPE when location is empty - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/10/11 14:41:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/11 20:45:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2841] Correcting roadmap link to point ... - posted by ssaumitra <gi...@git.apache.org> on 2015/10/11 22:35:02 UTC, 6 replies.
- [jira] [Commented] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/11 22:35:05 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner. - posted by ChengXiangLi <gi...@git.apache.org> on 2015/10/12 09:56:41 UTC, 18 replies.
- [jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/12 09:57:05 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ... - posted by JonathanH5 <gi...@git.apache.org> on 2015/10/12 11:25:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/12 11:26:05 UTC, 1 replies.
- [jira] [Created] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:05:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:06:05 UTC, 1 replies.
- [jira] [Created] (FLINK-2850) Limit the types of jobs which can run in detached mode - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:38:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2850) Limit the types of jobs which can run in detached mode - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/13 15:57:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2574) Remove Spargel from master in next release - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:19:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1983) Remove dependencies on Record APIs for Spargel - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:21:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1884) Outdated Spargel docs - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:21:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-1983) Remove dependencies on Record APIs for Spargel - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:23:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2574) Remove Spargel from master in next release - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:24:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-1258) Merge iterative and non-iterative tasks - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/13 18:35:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/10/13 23:16:05 UTC, 0 replies.
- [GitHub] flink pull request: change "it's" contraction to possession "its" - posted by chrisatcodedmarkets <gi...@git.apache.org> on 2015/10/14 02:19:32 UTC, 3 replies.
- [jira] [Reopened] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/14 12:00:09 UTC, 0 replies.
- [jira] [Created] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/14 14:05:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/14 15:13:05 UTC, 7 replies.
- [jira] [Resolved] (FLINK-2697) Deadlock in StreamDiscretizer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/14 16:01:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2181) SessionWindowing example has a memleak - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/14 16:02:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2697) Deadlock in StreamDiscretizer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/14 16:02:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2234) CoStreamWindow is Dependent on Input Ordering - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/14 16:02:05 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/14 16:14:08 UTC, 0 replies.
- [jira] [Updated] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/14 16:14:08 UTC, 0 replies.
- [jira] [Closed] (FLINK-2607) Shade plugin copies signature files from original jar into fat jar - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/14 16:15:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2852) Fix flaky ScalaShellITSuite - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/14 16:47:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2266) Building Flink for a specific HDP version fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/14 16:51:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2266) Building Flink for a specific HDP version fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/14 16:51:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2851] Move PythonAPI to flink-libraries - posted by zentol <gi...@git.apache.org> on 2015/10/14 17:05:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/14 17:51:06 UTC, 5 replies.
- [jira] [Commented] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/14 18:02:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/14 23:06:05 UTC, 3 replies.
- [jira] [Updated] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/14 23:06:06 UTC, 0 replies.
- [jira] [Updated] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/14 23:06:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2853) Apply JMH on Flink benchmarks - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/15 05:04:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Stefano Bortoli (JIRA)" <ji...@apache.org> on 2015/10/15 10:01:05 UTC, 4 replies.
- [jira] [Updated] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/15 10:40:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2770) KafkaITCase.testConcurrentProducerConsumerTopology fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 11:02:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 11:03:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/15 12:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 12:50:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 13:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2856) Introduce flink.version property into quickstart archetype - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 13:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2857) Gelly API improvements - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 14:15:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2798) Prepare new web dashboard for executing it on YARN - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/15 14:18:05 UTC, 1 replies.
- [jira] [Updated] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 14:38:05 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/15 14:38:05 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2856) Introduce flink.version property into quickstart archetype - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 14:48:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2856) Introduce flink.version property into quickstart archetype - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/15 14:56:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2843) Add documentation for DataSet outer joins - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/15 15:12:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2479) Refactoring of org.apache.flink.runtime.operators.testutils.TestData class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/15 15:12:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2774) Import Java API classes automatically in Flink's Scala shell - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/15 15:13:06 UTC, 0 replies.
- [jira] [Created] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/15 15:15:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 15:26:05 UTC, 6 replies.
- [jira] [Updated] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 15:26:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 15:27:05 UTC, 5 replies.
- [jira] [Commented] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases - posted by "Wilmer DAZA (JIRA)" <ji...@apache.org> on 2015/10/15 15:37:05 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2856) Introduce flink.version property into quickstart archetype - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/10/15 16:33:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/10/15 16:56:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2855] [gelly] Add documentation for the... - posted by vasia <gi...@git.apache.org> on 2015/10/15 17:06:42 UTC, 6 replies.
- [jira] [Commented] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/15 17:07:05 UTC, 6 replies.
- [jira] [Commented] (FLINK-2107) Implement Hash Outer Join algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/15 17:25:05 UTC, 5 replies.
- [GitHub] flink pull request: Removed broken dependency to flink-spargel. - posted by aalexandrov <gi...@git.apache.org> on 2015/10/15 23:19:04 UTC, 4 replies.
- [GitHub] flink pull request: [docs] Fix documentation for building Flink wi... - posted by aalexandrov <gi...@git.apache.org> on 2015/10/16 00:24:13 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2848] [test] Apply JMH on MutableHashTa... - posted by gallenvara <gi...@git.apache.org> on 2015/10/16 10:54:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-2848) Refactor Flink benchmarks with JMH and move to flink-benchmark module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/16 10:55:05 UTC, 5 replies.
- [jira] [Commented] (FLINK-2857) Gelly API improvements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/16 10:58:05 UTC, 5 replies.
- [jira] [Assigned] (FLINK-2857) Gelly API improvements - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/16 11:18:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2859) Add links to docs and JIRA issues in FlinkML roadmap - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/16 11:27:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2107] Add hash-based strategies for lef... - posted by fhueske <gi...@git.apache.org> on 2015/10/16 11:32:35 UTC, 2 replies.
- [jira] [Created] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/16 12:45:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/16 12:46:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2861) Fields grouping on split streams fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 15:18:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2862) FlinkTopologyBuilder should use proper generic types - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 15:19:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 17:29:06 UTC, 1 replies.
- [jira] [Created] (FLINK-2863) Kafka producer does not fail in case of write failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 17:42:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2854) KafkaITCase.testOneSourceMultiplePartitions failed on Travis - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 17:44:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 18:10:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2808) Rework / Extend the StatehandleProvider - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 18:10:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2846) Emit checkpoint barriers earlier, before drawing the state snapshot - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 18:10:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2808) Rework / Extend the StatehandleProvider - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/16 18:11:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2857] [gelly] API improvements - posted by vasia <gi...@git.apache.org> on 2015/10/16 18:13:34 UTC, 4 replies.
- [jira] [Created] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/16 18:18:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2855) Add a documentation section for Gelly library methods - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/16 19:08:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2411] Add graph summarization algorithm - posted by s1ck <gi...@git.apache.org> on 2015/10/17 19:36:37 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:06:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2844) Remove old web interface and default to the new one - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:07:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:07:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2844) Remove old web interface and default to the new one - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:07:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2863) Kafka producer does not fail in case of write failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:07:06 UTC, 0 replies.
- [jira] [Closed] (FLINK-2863) Kafka producer does not fail in case of write failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/17 21:07:06 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2864] Make State of General-Purpose Win... - posted by aljoscha <gi...@git.apache.org> on 2015/10/17 21:53:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/17 21:54:05 UTC, 3 replies.
- [jira] [Commented] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/18 10:59:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2714) Port the Flink DataSet Triangle Enumeration example to the Gelly library - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/18 11:29:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/18 20:34:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat - posted by zentol <gi...@git.apache.org> on 2015/10/19 00:34:45 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2853] [tests] Apply JMH on MutableHashT... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/10/19 03:58:10 UTC, 20 replies.
- [jira] [Commented] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/19 03:59:05 UTC, 20 replies.
- [jira] [Created] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:06:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:29:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/19 06:49:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/19 08:43:05 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2310] Add an Adamic Adar Similarity exa... - posted by vasia <gi...@git.apache.org> on 2015/10/19 10:44:45 UTC, 0 replies.
- [jira] [Commented] (FLINK-2310) Add an Adamic-Adar Similarity example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/19 10:45:05 UTC, 0 replies.
- [GitHub] flink pull request: Hits - posted by vasia <gi...@git.apache.org> on 2015/10/19 10:48:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/19 11:24:05 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2611) YARN reports failed final state for successful jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/19 12:13:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2731) Add JobManager log file access - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/19 14:35:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/19 15:03:05 UTC, 11 replies.
- [jira] [Commented] (FLINK-2852) Fix flaky ScalaShellITSuite - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/19 15:04:05 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-2852) Fix flaky ScalaShellITSuite - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/19 15:05:05 UTC, 0 replies.
- [GitHub] flink pull request: - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/19 15:33:50 UTC, 1 replies.
- [jira] [Commented] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class. - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/19 15:36:05 UTC, 9 replies.
- [jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/19 15:51:05 UTC, 7 replies.
- [jira] [Assigned] (FLINK-1991) Return Table as DataSet - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/19 16:20:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-1991) Return Table as DataSet - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/19 16:21:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/19 16:57:05 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/10/19 17:41:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Rikhu Prasad (JIRA)" <ji...@apache.org> on 2015/10/19 18:04:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2809) DataSet[Unit] doesn't work - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:07:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2725) Max/Min/Sum Aggregation of mutable types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:08:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2842) S3FileSystem is broken - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:09:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2857) Gelly API improvements - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:09:05 UTC, 0 replies.
- [jira] [Updated] (FLINK-2107) Add OuterJoin strategy with HashTable on inner side - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:10:05 UTC, 0 replies.
- [jira] [Closed] (FLINK-2107) Add OuterJoin strategy with HashTable on inner side - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:12:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/19 18:17:05 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Rikhu Prasad (JIRA)" <ji...@apache.org> on 2015/10/19 18:19:05 UTC, 0 replies.
- [jira] [Created] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/19 19:13:05 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "Rikhu Prasad (JIRA)" <ji...@apache.org> on 2015/10/19 20:42:28 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2872] [Documentation] Update the docume... - posted by hsaputra <gi...@git.apache.org> on 2015/10/19 21:08:53 UTC, 6 replies.
- [jira] [Commented] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/19 21:09:27 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/19 23:19:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/19 23:20:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/20 00:02:27 UTC, 9 replies.
- [jira] [Comment Edited] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/20 00:03:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2411] [gelly] Add Summarization Algorit... - posted by s1ck <gi...@git.apache.org> on 2015/10/20 09:29:22 UTC, 4 replies.
- [jira] [Closed] (FLINK-2852) Fix flaky ScalaShellITSuite - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:02:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2652) Failing PartitionRequestClientFactoryTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:02:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2354) Recover running jobs on JobManager failure - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:03:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2792) Set log level of actor messages to TRACE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:03:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2804) Support blocking job submission with Job Manager recovery - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:04:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2805) Make user jars available for all job managers to recover - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:04:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2793) Redirect to leading JobManager web fronted in non-standalone mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/20 10:10:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 10:46:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2869] [tests] Apply JMH on IOManagerPer... - posted by gallenvara <gi...@git.apache.org> on 2015/10/20 10:47:52 UTC, 8 replies.
- [jira] [Updated] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 10:54:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/20 11:15:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/20 11:25:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 11:26:27 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/20 11:56:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2033) Add overloaded methods with explicit TypeInformation parameters to Gelly - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2015/10/20 12:11:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2874) Certain Avro generated getters/setters not recognized - posted by "Ulf Karlsson (JIRA)" <ji...@apache.org> on 2015/10/20 14:53:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2513) Extend state handle provider interface to list all state handles - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 14:55:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2287) Implement JobManager high availability - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 14:56:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2874) Certain Avro generated getters/setters not recognized - posted by "Ulf Karlsson (JIRA)" <ji...@apache.org> on 2015/10/20 14:57:27 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2874] Fix Avro getter/setter recognitio... - posted by ukarlsson <gi...@git.apache.org> on 2015/10/20 14:58:16 UTC, 4 replies.
- [jira] [Commented] (FLINK-2874) Certain Avro generated getters/setters not recognized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 14:58:27 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2651) Failing NettyServerLowAndHighWatermarkTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 15:05:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2875) Add createRemoveEnvironment variant for HA - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 15:10:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2738) StackOverflow in case of unbounded restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 15:16:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2862) FlinkTopologyBuilder should use proper generic types - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/20 16:01:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2876) Minutiae - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 16:08:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by mjsax <gi...@git.apache.org> on 2015/10/20 16:12:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 16:12:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2877) Move Streaming API out of Staging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/20 16:47:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2878) JobManager warns: Unexpected leader address pattern - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 17:04:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2877) Move Streaming API out of Staging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/20 17:08:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2877) Move Streaming API out of Staging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/20 17:11:27 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2873] detect & serve the job manager lo... - posted by mxm <gi...@git.apache.org> on 2015/10/20 17:15:41 UTC, 1 replies.
- [jira] [Commented] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 17:16:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2879) Links in documentation are broken - posted by "Nikolaas Steenbergen (JIRA)" <ji...@apache.org> on 2015/10/20 17:26:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2877) Move Streaming API out of Staging - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/20 17:50:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/20 18:23:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/20 18:23:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 18:40:28 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2834] Global round-robin for temporary ... - posted by greghogan <gi...@git.apache.org> on 2015/10/20 18:43:19 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-2873) WebRuntimeMonitor does not start when multiple log files are present - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/20 18:43:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2877] Move Streaming API out of Staging... - posted by aljoscha <gi...@git.apache.org> on 2015/10/20 19:02:30 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2862] [Storm Compatibility] FlinkTopolo... - posted by mjsax <gi...@git.apache.org> on 2015/10/20 19:19:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-2862) FlinkTopologyBuilder should use proper generic types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 19:19:27 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2880] [streaming] [API-Breaking] Allow ... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/20 19:21:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 19:22:27 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2827] Closing FileInputStream in finall... - posted by ssaumitra <gi...@git.apache.org> on 2015/10/20 19:32:27 UTC, 4 replies.
- [jira] [Created] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 20:07:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2876] Minutiae - posted by greghogan <gi...@git.apache.org> on 2015/10/20 20:19:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-2876) Minutiae - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 20:19:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2882) Improve performance of string conversions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/20 21:42:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2820] Configuration not passed to JobGr... - posted by greghogan <gi...@git.apache.org> on 2015/10/20 21:42:56 UTC, 3 replies.
- [jira] [Commented] (FLINK-2820) Configuration not passed to JobGraphGenerator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/20 21:43:28 UTC, 3 replies.
- [jira] [Commented] (FLINK-2882) Improve performance of string conversions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 21:53:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2685) TaskManager deadlock on NetworkBufferPool - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/20 21:54:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2872) Update the documentation for Scala part to add readFileOfPrimitives - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/20 23:00:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2883) Combinable reduce produces wrong result - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/21 01:13:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2883) Combinable reduce produces wrong result - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/21 01:16:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/21 04:52:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2798) Prepare new web dashboard for executing it on YARN - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 09:40:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 09:46:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 09:46:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2881) WebRuntimeMonitor overly restrictive file patterns - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 09:49:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2885) Path to Python resources is not constructed correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 10:41:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2885) Path to Python resources is not constructed correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 10:42:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2885) Path to Python resources is not constructed correctly - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 10:47:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2883) Combinable reduce produces wrong result - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/21 11:14:27 UTC, 2 replies.
- [jira] [Closed] (FLINK-2864) Make State of General-Purpose Window Operators Fault-Tolerant - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/21 11:46:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2877) Move Streaming API out of Staging - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/21 11:47:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2122) Make all internal streaming operators Checkpointable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/21 11:49:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/21 13:33:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2886) NettyClient parses wrong configuration key for number of client threads - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/21 13:43:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2820) Configuration not passed to JobGraphGenerator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/21 14:37:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2880) Allow DeserializationSchema to throw IOException in deserialization method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/21 14:38:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2876) Minutiae - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/21 14:38:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2743) Add new RNG based on XORShift algorithm - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/21 14:40:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2834) Global round-robin for temporary directories - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/21 14:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/21 15:15:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2668] Chained Projections are no longer... - posted by zentol <gi...@git.apache.org> on 2015/10/21 15:31:05 UTC, 8 replies.
- [jira] [Commented] (FLINK-2668) ProjectOperator method to close projection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/21 15:31:27 UTC, 8 replies.
- [jira] [Commented] (FLINK-1988) Port Record API based tests in the common.io - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/21 15:42:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-1982) Remove dependencies on Record for Flink runtime and core - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/21 15:42:27 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2878] [webmonitor] Fix unexpected leade... - posted by tillrohrmann <gi...@git.apache.org> on 2015/10/21 15:57:41 UTC, 3 replies.
- [jira] [Commented] (FLINK-2878) JobManager warns: Unexpected leader address pattern - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/21 15:58:27 UTC, 3 replies.
- [jira] [Closed] (FLINK-2886) NettyClient parses wrong configuration key for number of client threads - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/21 16:01:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2887] [gelly] sendMessageToAllNeighbors... - posted by vasia <gi...@git.apache.org> on 2015/10/21 16:41:13 UTC, 12 replies.
- [jira] [Commented] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/21 16:41:27 UTC, 12 replies.
- [jira] [Resolved] (FLINK-2878) JobManager warns: Unexpected leader address pattern - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/21 16:55:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2017] Add predefined required parameter... - posted by fhueske <gi...@git.apache.org> on 2015/10/21 18:38:59 UTC, 22 replies.
- [jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/21 18:39:27 UTC, 22 replies.
- [jira] [Commented] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:07:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:08:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2789) Vulnerability to XSS attack due to printing HTML output - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:09:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:28:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:35:27 UTC, 14 replies.
- [jira] [Commented] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/21 19:49:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2867) Access to pendingFilesPerCheckpoint should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/21 19:50:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:14:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2143) Add an overload to reduceWindow which takes the inverse of the reduceFunction as a second parameter - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:17:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2180) Streaming iterate test fails spuriously - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:18:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2154) ActiveTriggerPolicy collects elements to a closed buffer after job finishes - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:18:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2403) Rework partitioned state checkpointing logic - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:19:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2201) Inconsistent use of ClosureCleaner in streaming window helpers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:19:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-1617) GSoC project: Query optimisation layer for Flink Streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:20:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2481) Test at least once processing guarantee for streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:21:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2470) Stream Iteration can Hang after some Data - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:22:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-2494) Fix StreamGraph getJobGraph bug - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:22:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2630) Scala DataStream API does not have a project method - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:24:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2138) PartitionCustom for streaming - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:25:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2010) Add test that verifies that chained tasks are properly checkpointed - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:26:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:26:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-1503) GSoC project: Batch and Streaming integration through new operators and unified API - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:28:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2471) FileSinkFunction invoke performance optimize - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:29:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2589) Threads created in TimeTriggerPolicy don't end properly - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:29:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/21 23:30:28 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-2866 Potential resource leak due to uncl... - posted by tedyu <gi...@git.apache.org> on 2015/10/22 04:41:16 UTC, 2 replies.
- [jira] [Created] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 05:05:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2889] [tests] Apply JMH on LongSerializ... - posted by gallenvara <gi...@git.apache.org> on 2015/10/22 05:11:29 UTC, 6 replies.
- [jira] [Commented] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 05:12:27 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/10/22 07:44:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 08:02:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/22 08:10:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/22 08:13:27 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2890] [tests] Apply JMH on StringSerial... - posted by gallenvara <gi...@git.apache.org> on 2015/10/22 09:30:34 UTC, 3 replies.
- [jira] [Commented] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 09:31:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-2824) Iteration feedback partitioning does not work as expected - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/22 10:09:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/22 10:24:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/22 11:31:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2891] Set KV-State key upon Window Eval... - posted by aljoscha <gi...@git.apache.org> on 2015/10/22 11:31:35 UTC, 1 replies.
- [jira] [Reopened] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/22 11:55:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/22 11:55:27 UTC, 1 replies.
- [jira] [Reopened] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/22 12:44:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2841) Broken roadmap link in FlinkML contribution guide - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/22 12:44:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2893) Rename recovery configuration keys - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/22 12:49:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2893] Rename recovery configuration key... - posted by uce <gi...@git.apache.org> on 2015/10/22 13:05:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-2893) Rename recovery configuration keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 13:05:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 13:46:27 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2887) sendMessageToAllNeighbors ignores the EdgeDirection - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/22 13:57:28 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2206] Fix incorrect counts of finished,... - posted by fhueske <gi...@git.apache.org> on 2015/10/22 14:43:57 UTC, 3 replies.
- [jira] [Created] (FLINK-2894) Flink does not allow to specify default serializer for Kryo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/22 14:51:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2894) Flink does not allow to specify default serializer for Kryo - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/22 15:02:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2895) Duplicate immutable object creation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 15:18:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2896) Right-hand side menu items of website are missing in narrow browsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 15:24:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2895) Duplicate immutable object creation - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 15:30:27 UTC, 5 replies.
- [jira] [Created] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 16:41:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2898) Invert Travis CI build order - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 17:12:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2898) Invert Travis CI build order - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 17:15:27 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2895] Duplicate immutable object creati... - posted by greghogan <gi...@git.apache.org> on 2015/10/22 17:15:50 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2800) kryo serialization problem - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/22 18:24:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2866] [FLINK-2888] [FLINK-2891] Fixes f... - posted by StephanEwen <gi...@git.apache.org> on 2015/10/22 19:14:15 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in... - posted by greghogan <gi...@git.apache.org> on 2015/10/22 19:36:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 19:37:27 UTC, 4 replies.
- [jira] [Commented] (FLINK-2559) Fix Javadoc Code Examples - posted by "Hubert Czerpak (JIRA)" <ji...@apache.org> on 2015/10/22 19:41:27 UTC, 22 replies.
- [GitHub] flink pull request: [FLINK-2634] [gelly] [WIP] Vertex Centric Tria... - posted by andralungu <gi...@git.apache.org> on 2015/10/22 21:43:23 UTC, 0 replies.
- [jira] [Commented] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 21:43:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2898] [build] Invert Travis CI build or... - posted by greghogan <gi...@git.apache.org> on 2015/10/22 21:49:04 UTC, 3 replies.
- [jira] [Created] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/10/22 22:00:30 UTC, 0 replies.
- [jira] [Closed] (FLINK-1988) Port Record API based tests in the common.io - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 22:55:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 22:59:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 22:59:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 23:07:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1982) Remove dependencies on Record for Flink runtime and core - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 23:07:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2902) Web interface sort tasks newest first - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:17:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/22 23:18:27 UTC, 3 replies.
- [jira] [Created] (FLINK-2903) Web interface numeric localization - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:18:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2900] [hadoop-compat] Remove Record API... - posted by fhueske <gi...@git.apache.org> on 2015/10/22 23:18:28 UTC, 3 replies.
- [jira] [Created] (FLINK-2904) Web interface truncated task counts - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/22 23:19:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1982] [record-api] Remove dependencies ... - posted by fhueske <gi...@git.apache.org> on 2015/10/22 23:19:48 UTC, 7 replies.
- [jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/22 23:23:28 UTC, 6 replies.
- [jira] [Assigned] (FLINK-2902) Web interface sort tasks newest first - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/23 08:00:33 UTC, 0 replies.
- [GitHub] flink pull request: Mesos - posted by cfmcgrady <gi...@git.apache.org> on 2015/10/23 08:26:26 UTC, 1 replies.
- [jira] [Closed] (FLINK-2668) ProjectOperator method to close projection - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 10:18:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2206) JobManager webinterface shows 5 finished jobs at most - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 10:20:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/23 10:35:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2906) Remove Record-API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 10:42:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2874) Certain Avro generated getters/setters not recognized - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 10:54:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2902) Web interface sort tasks newest first - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/23 11:12:27 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-2902][web-dashboard] Sort completed job... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/23 11:14:18 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/23 12:14:27 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Fix Mutable Object window aggregator/... - posted by aljoscha <gi...@git.apache.org> on 2015/10/23 14:06:21 UTC, 2 replies.
- [jira] [Closed] (FLINK-2898) Invert Travis CI build order - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 15:41:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-1982) Remove dependencies on Record for Flink runtime and core - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 16:08:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2895) Duplicate immutable object creation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 16:09:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2893) Rename recovery configuration keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 16:10:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2254) Add Bipartite Graph Support for Gelly - posted by "Saumitra Shahapure (JIRA)" <ji...@apache.org> on 2015/10/23 16:32:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2712) Add some description about tests to "How to Contribute" documentation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/23 18:14:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2907) Bloom filter for Join - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 18:29:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2908) Web interface redraw web plan when browser resized - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 19:30:27 UTC, 0 replies.
- [GitHub] flink pull request: Flink 2559 - posted by hczerpak <gi...@git.apache.org> on 2015/10/23 19:42:58 UTC, 0 replies.
- [jira] [Updated] (FLINK-2559) Fix Javadoc Code Examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/23 19:51:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2559) Fix Javadoc Code Examples - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/23 19:51:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2909) Gelly Graph Generators - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/10/23 20:54:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2827] Closing FileInputStream through t... - posted by ssaumitra <gi...@git.apache.org> on 2015/10/23 21:07:46 UTC, 3 replies.
- [jira] [Commented] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/24 11:29:27 UTC, 9 replies.
- [jira] [Created] (FLINK-2910) Combine tests for binary graph operators - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/24 11:49:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2910) Combine tests for binary graph operators - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/24 11:51:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2911) AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/24 14:32:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 16:18:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2862) FlinkTopologyBuilder should use proper generic types - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/24 16:28:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 18:06:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/24 18:11:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/25 11:02:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2916) Add more context information for the StateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/25 11:59:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/25 15:34:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/25 16:40:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/25 16:50:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/25 23:11:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/25 23:13:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/25 23:13:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2866) Potential resource leak due to unclosed ObjectInputStream in FileSerializableStateHandle - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/25 23:13:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2888) Default state not copied for AbstractHeapKvState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/10/25 23:14:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2918] Add method to read a file of type... - posted by smarthi <gi...@git.apache.org> on 2015/10/25 23:17:35 UTC, 16 replies.
- [jira] [Commented] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/25 23:18:27 UTC, 16 replies.
- [jira] [Created] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/26 06:33:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2919] [tests] Apply JMH on FieldAccessM... - posted by gallenvara <gi...@git.apache.org> on 2015/10/26 08:17:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/26 08:18:27 UTC, 4 replies.
- [jira] [Created] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/26 08:47:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2891) Key for Keyed State is not set upon Window Evaluation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/26 08:57:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/26 08:57:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2909) Gelly Graph Generators - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/26 10:39:27 UTC, 2 replies.
- [jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/26 11:06:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2921) Add online documentation of sample methods - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/10/26 11:16:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2411) Add basic graph summarization algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/26 11:46:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2850) Limit the types of jobs which can run in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/26 13:55:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2922) Add Queryable Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/26 15:57:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2922) Add Queryable Window Operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/26 16:55:27 UTC, 3 replies.
- [GitHub] flink pull request: Add org.apache.httpcomponents:(httpcore, httpc... - posted by uce <gi...@git.apache.org> on 2015/10/26 18:52:28 UTC, 3 replies.
- [jira] [Created] (FLINK-2923) Make it possible to mix-and-match StateBackends with KvState implementations - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/26 19:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2924) Create database state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/26 19:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2925) Client does not show root cause of Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/26 19:43:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2925) Client shows incomplete cause of Exception - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/26 19:43:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2853) Apply JMH on MutableHashTablePerformanceBenchmark class. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/26 22:55:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2919) Apply JMH on FieldAccessMinibenchmark class. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/26 22:56:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2827) Potential resource leak in TwitterSource#loadAuthenticationProperties() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/26 22:56:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2889) Apply JMH on LongSerializationSpeedBenchmark class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/26 22:57:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2890) Apply JMH on StringSerializationSpeedBenchmark class. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/26 22:57:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-1827) Move test classes in test folders and fix scope of test dependencies - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/10/26 23:32:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-1611) [REFACTOR] Rename classes and packages in test that contains Nephele - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/10/27 02:07:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2920] [tests] Apply JMH on KryoVersusAv... - posted by gallenvara <gi...@git.apache.org> on 2015/10/27 04:48:35 UTC, 3 replies.
- [jira] [Commented] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/27 04:49:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-2883) Add documentation to forbid key-modifying ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/27 09:26:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2922) Add Queryable Window Operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/27 09:45:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-2476) Remove unwanted check null of input1 in ConnectedDataStream - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/27 10:04:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2907) Bloom filter for Join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/27 11:02:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2907) Bloom filter for Join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/27 11:02:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2922) Add Queryable Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/27 11:13:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/27 11:58:27 UTC, 4 replies.
- [jira] [Created] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/10/27 14:19:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/10/27 16:06:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2927) Provide default required configuration keys in flink-conf of binary distribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:39:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2927] [runtime] Provide default require... - posted by uce <gi...@git.apache.org> on 2015/10/27 17:40:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-2927) Provide default required configuration keys in flink-conf of binary distribution - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/27 17:41:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:44:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2929) Recovery of jobs on cluster restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:50:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2929) Recovery of jobs on cluster restarts - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/27 17:53:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/10/27 17:56:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2559] Fix Javadoc Code Examples - posted by fhueske <gi...@git.apache.org> on 2015/10/27 17:57:53 UTC, 21 replies.
- [jira] [Created] (FLINK-2931) Add global recovery timestamp to state restore - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/10/27 18:11:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2930] Respect ExecutionConfig execution... - posted by uce <gi...@git.apache.org> on 2015/10/27 18:17:51 UTC, 0 replies.
- [jira] [Commented] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/27 18:18:27 UTC, 0 replies.
- [GitHub] flink pull request: Out-of-core state backend for JDBC databases - posted by gyfora <gi...@git.apache.org> on 2015/10/27 18:33:25 UTC, 2 replies.
- [jira] [Created] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http - posted by "Frederick F. Kautz IV (JIRA)" <ji...@apache.org> on 2015/10/27 22:45:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Frederick F. Kautz IV (JIRA)" <ji...@apache.org> on 2015/10/28 00:39:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/28 01:03:28 UTC, 2 replies.
- [jira] [Commented] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/28 03:23:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2892) Apply JMH on MemorySegmentSpeedBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/28 03:25:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/10/28 08:04:27 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-2901] Remove Record API dependencies fr... - posted by zentol <gi...@git.apache.org> on 2015/10/28 11:45:09 UTC, 1 replies.
- [jira] [Created] (FLINK-2934) Remove placehoder pages in Web dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/28 13:21:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2934] Remove placeholder pages for job.... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/10/28 13:52:19 UTC, 3 replies.
- [jira] [Commented] (FLINK-2934) Remove placehoder pages in Web dashboard - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/28 13:52:27 UTC, 6 replies.
- [jira] [Created] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/10/28 16:12:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/28 17:11:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2868) Missing null check for operatorChain in StreamTask#invoke() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/10/28 17:50:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2800] [kryo] Fix Kryo serialization to ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/10/28 18:53:44 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2932] Examples in docs now download she... - posted by fkautz <gi...@git.apache.org> on 2015/10/28 22:06:52 UTC, 3 replies.
- [jira] [Created] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/28 23:40:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/10/29 09:19:27 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/10/29 09:29:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 09:53:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2860] The mlr object from the FlinkML G... - posted by chiwanpark <gi...@git.apache.org> on 2015/10/29 09:59:04 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/29 09:59:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/29 09:59:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2015/10/29 10:20:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2938) Streaming docs not in sink with latest state changes - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:29:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/29 11:48:27 UTC, 3 replies.
- [jira] [Created] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 11:54:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/10/29 12:09:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 12:14:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 12:26:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/29 12:29:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/29 12:30:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 13:26:27 UTC, 1 replies.
- [jira] [Updated] (FLINK-2559) Fix Javadoc (e.g. Code Examples) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 13:34:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/29 13:36:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2900) Remove Record-API dependencies from Hadoop Compat module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 13:36:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2884) Apply JMH on HashVsSortMiniBenchmark class. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/10/29 13:36:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2869) Apply JMH on IOManagerPerformanceBenchmark class. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 13:43:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2920) Apply JMH on KryoVersusAvroMinibenchmark class. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 13:44:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2559) Fix Javadoc (e.g. Code Examples) - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 13:47:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2559) Fix Javadoc (e.g. Code Examples) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 13:59:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2902) Web interface sort tasks newest first - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 14:00:30 UTC, 0 replies.
- [jira] [Closed] (FLINK-2934) Remove placehoder pages in Web dashboard - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 14:01:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2932) Flink quickstart docs should ask users to download from https, not http - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 14:02:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2800) kryo serialization problem - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 14:05:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/29 14:12:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/29 14:22:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/10/29 14:26:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-2925) Client shows incomplete cause of Exception - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 15:32:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2925) Client shows incomplete cause of Exception - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 15:47:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2925) Client shows incomplete cause of Exception - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/29 15:47:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2942) Dangling operators in web UI's program visualization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 17:34:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 17:45:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2942) Dangling operators in web UI's program visualization - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 17:46:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 18:36:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/29 20:43:27 UTC, 3 replies.
- [jira] [Created] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 10:22:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2571) Add task hooks support in Storm-compatibility - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/10/30 10:44:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2910) Combine tests for binary graph operators - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/10/30 11:22:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 13:48:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2945) Shutting down a local Flink instance on Windows doesn't clean up blob cache - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 14:34:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/30 16:47:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/10/30 16:49:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2946) Add orderBy() to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/10/30 18:55:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2947) Coloured Scala Shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/30 19:49:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2947) Coloured Scala Shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/30 19:50:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2948) Cannot compile example code in SVM quickstart guide - posted by "Do Le Quoc (JIRA)" <ji...@apache.org> on 2015/10/30 20:20:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2946) Add orderBy() to Table API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/10/30 21:47:27 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2918) Add a method to be able to read SequenceFileInputFormat - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/31 00:27:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2949) Add method 'writeSequencefile' to DataSet - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/10/31 00:55:27 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2949 [WIP]: Add method 'writeSequencefil... - posted by smarthi <gi...@git.apache.org> on 2015/10/31 02:26:31 UTC, 0 replies.
- [jira] [Commented] (FLINK-2949) Add method 'writeSequencefile' to DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/10/31 02:27:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2948) Cannot compile example code in SVM quickstart guide - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/31 05:18:27 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2948) Cannot compile example code in SVM quickstart guide - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/31 05:20:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2950) Markdown presentation problem in SVM documentation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/31 05:21:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2948) Cannot compile example code in SVM quickstart guide - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/10/31 05:23:27 UTC, 0 replies.