issues@flink.apache.org, 2015-11

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

- [GitHub] flink pull request: [FLINK-2950] [ml] [docs] Fix markdown renderin... - posted by chiwanpark <gi...@git.apache.org> on 2015/11/01 03:19:13 UTC, 2 replies.
- [jira] [Commented] (FLINK-2950) Markdown presentation problem in SVM documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/01 03:19:27 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2939][web-dashboard] Add support to can... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/01 13:33:42 UTC, 16 replies.
- [jira] [Commented] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/01 13:34:27 UTC, 16 replies.
- [jira] [Updated] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/01 18:16:27 UTC, 3 replies.
- [jira] [Updated] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/01 18:17:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/01 18:17:27 UTC, 1 replies.
- [GitHub] flink pull request: move the #!bash to first line, otherwise it do... - posted by frett27 <gi...@git.apache.org> on 2015/11/01 22:37:10 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/02 00:57:53 UTC, 22 replies.
- [jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 00:58:27 UTC, 22 replies.
- [jira] [Commented] (FLINK-2929) Recovery of jobs on cluster restarts - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/02 01:12:27 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2797][cli] Add support for running jobs... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/02 07:55:40 UTC, 46 replies.
- [jira] [Commented] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 07:56:27 UTC, 46 replies.
- [jira] [Created] (FLINK-2951) Add Union operator to Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/02 08:32:28 UTC, 0 replies.
- [GitHub] flink pull request: Out-of-core state backend for JDBC databases - posted by StephanEwen <gi...@git.apache.org> on 2015/11/02 08:42:31 UTC, 43 replies.
- [GitHub] flink pull request: [FLINK-2930] Respect ExecutionConfig execution... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/02 08:49:06 UTC, 6 replies.
- [jira] [Commented] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 08:49:27 UTC, 6 replies.
- [jira] [Commented] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/02 09:01:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2951] [Table API] add union operator to... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/11/02 09:07:20 UTC, 14 replies.
- [jira] [Commented] (FLINK-2951) Add Union operator to Table API. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 09:07:27 UTC, 15 replies.
- [jira] [Closed] (FLINK-2912) Potential resource leak due to unclosed RandomAccessFile in StaticFileServerHandler - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/02 09:13:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-1610) Java docs do not build - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/02 10:14:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/02 11:10:28 UTC, 0 replies.
- [jira] [Updated] (FLINK-2938) Streaming docs not in sync with latest state changes - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/02 11:14:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend - posted by "Sebastian Kruse (JIRA)" <ji...@apache.org> on 2015/11/02 11:21:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/02 12:01:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2953) Chained sortPartition() calls produce incorrect results in Scala DataSet API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/02 14:17:27 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Fix LICENSE/NOTICE, Add list_deps.py ... - posted by aljoscha <gi...@git.apache.org> on 2015/11/02 14:55:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2692] Untangle CsvInputFormat - posted by aljoscha <gi...@git.apache.org> on 2015/11/02 15:03:46 UTC, 13 replies.
- [jira] [Commented] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 15:04:27 UTC, 14 replies.
- [jira] [Updated] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2015/11/02 15:13:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2015/11/02 15:20:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Daniel Blazevski (JIRA)" <ji...@apache.org> on 2015/11/02 15:21:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1934) Add approximative k-nearest-neighbours (kNN) algorithm to machine learning library - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/02 16:20:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/02 16:49:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/02 16:51:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by danielblazevski <gi...@git.apache.org> on 2015/11/02 17:06:42 UTC, 138 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/11/02 17:07:27 UTC, 138 replies.
- [GitHub] flink pull request: [FLINK-2953] Fix chaining of sortPartition() c... - posted by fhueske <gi...@git.apache.org> on 2015/11/02 17:10:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-2953) Chained sortPartition() calls produce incorrect results in Scala DataSet API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/02 17:11:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 18:58:27 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 18:59:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2612) ZooKeeperLeaderElectionITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 19:00:30 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2615) Multiple restarts of Local Cluster for a single program - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 19:02:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2618) ExternalSortITCase failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 19:03:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/02 19:04:27 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/02 22:06:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2849) AggregatingAlignedProcessingTimeWindowOperatorTest failure - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/02 22:06:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2183) TaskManagerFailsWithSlotSharingITCase fails. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/02 22:13:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "Jian Jiang (JIRA)" <ji...@apache.org> on 2015/11/02 23:35:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "Jian Jiang (JIRA)" <ji...@apache.org> on 2015/11/02 23:36:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/03 00:57:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-2944) Collect, expose and display operator-specific stats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/03 01:03:27 UTC, 1 replies.
- [jira] [Commented] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/03 02:45:27 UTC, 13 replies.
- [jira] [Created] (FLINK-2955) Add operations introduction in Table API page. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/03 03:30:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2955] Add operators description in Tabl... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/11/03 08:08:24 UTC, 15 replies.
- [jira] [Commented] (FLINK-2955) Add operations introduction in Table API page. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/03 08:08:27 UTC, 15 replies.
- [jira] [Created] (FLINK-2956) Migrate integration tests for Table API - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/03 08:16:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/03 08:17:27 UTC, 14 replies.
- [jira] [Commented] (FLINK-2945) Shutting down a local Flink instance on Windows doesn't clean up blob cache - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/03 08:20:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2939) Add button to cancel jobs in new web frontend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 10:57:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2953) Chained sortPartition() calls produce incorrect results in Scala DataSet API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 10:58:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2957) Make cancel button look less like a label - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 11:09:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2957) Make cancel button look less like a label - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 11:14:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2958) StreamingJobGraphGenerator sets hard coded number execution retry - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 11:42:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 11:46:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2957][web-dashboard] Improve the appear... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/03 12:15:40 UTC, 17 replies.
- [jira] [Commented] (FLINK-2957) Make cancel button look less like a label - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/03 12:16:27 UTC, 17 replies.
- [jira] [Created] (FLINK-2960) Communicate with JobManager through YARN proxy - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 13:03:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2961) Add support for basic type Date in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/03 13:42:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2752] [Documentation] Documentation is ... - posted by mjsax <gi...@git.apache.org> on 2015/11/03 13:58:10 UTC, 32 replies.
- [jira] [Commented] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/03 13:58:27 UTC, 33 replies.
- [jira] [Assigned] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/03 13:59:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1472] Fixed Web frontend config overvie... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/03 14:12:31 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/11/03 14:13:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 14:17:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 14:18:27 UTC, 1 replies.
- [jira] [Closed] (FLINK-2413) Provide real vertex data - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 14:21:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2416) Expose vertex using with the new URL scheme - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 14:23:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/03 14:24:27 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2904][web-dashboard] Fix truncation of ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/03 14:40:50 UTC, 9 replies.
- [jira] [Commented] (FLINK-2904) Web interface truncated task counts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/03 14:41:27 UTC, 9 replies.
- [jira] [Created] (FLINK-2962) Cluster startup script refers to unused variable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/03 14:56:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/03 15:27:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2961] [table] Add support for basic typ... - posted by twalthr <gi...@git.apache.org> on 2015/11/03 15:32:36 UTC, 11 replies.
- [jira] [Commented] (FLINK-2961) Add support for basic type Date in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/03 15:33:27 UTC, 11 replies.
- [jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:00:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-2947) Coloured Scala Shell - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:01:27 UTC, 8 replies.
- [jira] [Commented] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:16:27 UTC, 11 replies.
- [jira] [Resolved] (FLINK-2958) StreamingJobGraphGenerator sets hard coded number execution retry - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:28:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2930) ExecutionConfig execution retry delay not respected - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:29:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2958) StreamingJobGraphGenerator sets hard coded number execution retry - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:29:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2943][web-dashboard] Confusing Bytes/Re... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/03 16:32:02 UTC, 11 replies.
- [jira] [Resolved] (FLINK-1614) JM Webfrontend doesn't always show the correct state of Tasks - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/03 16:39:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/03 22:25:27 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-2918] Add method to read a file of type... - posted by fhueske <gi...@git.apache.org> on 2015/11/03 23:01:22 UTC, 1 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/11/03 23:01:27 UTC, 2 replies.
- [jira] [Commented] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/03 23:06:27 UTC, 1 replies.
- [jira] [Created] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/04 01:15:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 02:12:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2964] [runtime] Fix broken spilling of ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/04 02:20:28 UTC, 5 replies.
- [jira] [Commented] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 02:21:27 UTC, 7 replies.
- [GitHub] flink pull request: minor document fix. - posted by jaoki <gi...@git.apache.org> on 2015/11/04 02:36:58 UTC, 7 replies.
- [jira] [Commented] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/04 08:10:27 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-2905) Add intersect method to Graph class - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/04 08:12:27 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2015/11/04 09:02:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/04 10:55:27 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 10:58:27 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2959) Remove number of execution retries configuration from Environment - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/04 11:21:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2964) MutableHashTable fails when spilling partitions without overflow segments - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/04 11:34:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2763) Bug in Hybrid Hash Join: Request to spill a partition with less than two buffers. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 11:41:27 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 "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 11:43:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2965) KafkaITCase failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/04 12:00:31 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2903] Format numeric values in web fron... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/04 12:05:36 UTC, 4 replies.
- [jira] [Commented] (FLINK-2903) Web interface numeric localization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 12:06:27 UTC, 4 replies.
- [jira] [Updated] (FLINK-2965) KafkaITCase failure - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 12:36:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2903) Web interface numeric localization - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/04 12:59:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2943) Confusing Bytes/Records "read" and "write" labels in WebUI job view - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/04 13:00:33 UTC, 0 replies.
- [GitHub] flink pull request: - posted by alexeyegorov <gi...@git.apache.org> on 2015/11/04 13:22:07 UTC, 25 replies.
- [jira] [Created] (FLINK-2966) Improve the way job duration is reported on web frontend. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/04 13:23:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2965) KafkaITCase failure - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/04 13:33:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 14:21:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2898] [build] Invert Travis CI build or... - posted by rmetzger <gi...@git.apache.org> on 2015/11/04 16:01:06 UTC, 0 replies.
- [jira] [Commented] (FLINK-2898) Invert Travis CI build order - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 16:01:27 UTC, 1 replies.
- [jira] [Commented] (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/11/04 16:05:27 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2898) Invert Travis CI build order - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 16:13:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2966][web-dashboard] Improve the way jo... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/04 16:17:54 UTC, 10 replies.
- [jira] [Commented] (FLINK-2966) Improve the way job duration is reported on web frontend. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 16:18:27 UTC, 11 replies.
- [jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/04 16:27:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2898) Invert Travis CI build order - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/04 16:33:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2968) Windowed fold operation fails because the initial value was not serialized - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/04 16:39:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2969) FlinkYarnSessionCli with recovery enabled fails when killing TaskManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/04 16:44:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2968] [streaming] Let AbstractUdfStream... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/04 16:45:20 UTC, 4 replies.
- [jira] [Commented] (FLINK-2968) Windowed fold operation fails because the initial value was not serialized - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 16:45:28 UTC, 4 replies.
- [jira] [Created] (FLINK-2970) Yarn client cannot connect to new job manager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/04 16:48:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2971) Add outer joins to the Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/04 17:27:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/04 17:38:27 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2905] [gelly] Add Graph Intersection me... - posted by s1ck <gi...@git.apache.org> on 2015/11/04 17:58:56 UTC, 10 replies.
- [jira] [Commented] (FLINK-2124) FromElementsFunction is not really Serializable - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/11/04 18:43:28 UTC, 12 replies.
- [jira] [Closed] (FLINK-2968) Windowed fold operation fails because the initial value was not serialized - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/04 19:51:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/04 21:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/04 21:36:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2940] [JavaAPI] Remove Chill dependency... - posted by fhueske <gi...@git.apache.org> on 2015/11/04 21:54:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 21:55:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2972] [JavaAPI] Remove Chill dependency... - posted by fhueske <gi...@git.apache.org> on 2015/11/04 22:06:29 UTC, 18 replies.
- [jira] [Commented] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 22:07:27 UTC, 18 replies.
- [jira] [Created] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/04 22:19:27 UTC, 0 replies.
- [GitHub] flink pull request: documentation fix, ~ as ` - posted by pkallos <gi...@git.apache.org> on 2015/11/04 22:47:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/04 23:08:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/04 23:20:27 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner. - posted by fhueske <gi...@git.apache.org> on 2015/11/04 23:33:41 UTC, 63 replies.
- [jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/04 23:34:27 UTC, 63 replies.
- [jira] [Comment Edited] (FLINK-2236) RowSerializer and CaseClassComparator are not in sync regarding Null-Values - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/05 10:16:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2955) Add operations introduction in Table API page. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/05 10:47:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 11:47:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar. - posted by "Jan Thomä (JIRA)" <ji...@apache.org> on 2015/11/05 12:00:30 UTC, 0 replies.
- [jira] [Updated] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 12:06:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 12:06:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2976) Save and load checkpoints manually - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/05 12:25:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2976) Save and load checkpoints manually - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/05 12:50:27 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2975) Exclude logging dependencies from shaded Hadoop jar. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 13:07:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/05 13:37:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/05 13:39:27 UTC, 35 replies.
- [GitHub] flink pull request: [doc] fix spelling mistakes in the transformat... - posted by vasia <gi...@git.apache.org> on 2015/11/05 13:45:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/05 13:45:27 UTC, 11 replies.
- [jira] [Assigned] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/05 14:04:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/05 14:36:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/05 15:07:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/05 15:28:27 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/05 15:29:27 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/05 15:42:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2045) JobManager webinterface is unresponsive with many TaskManagers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 15:58:28 UTC, 0 replies.
- [jira] [Closed] (FLINK-2598) NPE when arguments are missing for a "-m yarn-cluster" job - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/05 15:59:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/05 16:50:27 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2938) Streaming docs not in sync with latest state changes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/05 18:04:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2938) Streaming docs not in sync with latest state changes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/05 18:13:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2957) Make cancel button look less like a label - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/05 18:31:27 UTC, 0 replies.
- [jira] [Closed] (FLINK-2938) Streaming docs not in sync with latest state changes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/05 19:52:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2938) Streaming docs not in sync with latest state changes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/05 19:52:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-1728) Add random forest ensemble method to machine learning library - posted by "Devang Bacharwar (JIRA)" <ji...@apache.org> on 2015/11/05 20:21:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/06 04:34:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/06 04:35:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2981) Update README for building docs - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/06 08:25:28 UTC, 0 replies.
- [jira] [Created] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/06 08:31:27 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2951) Add Union operator to Table API. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/06 08:40:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2982][cli] Fix to show streaming plans ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/06 08:41:40 UTC, 4 replies.
- [jira] [Commented] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/06 08:42:27 UTC, 4 replies.
- [jira] [Commented] (FLINK-2981) Update README for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/06 10:36:27 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/06 11:08:27 UTC, 0 replies.
- [jira] [Updated] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/06 11:09:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2981] [docs] update requirements in doc... - posted by s1ck <gi...@git.apache.org> on 2015/11/06 11:34:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-2981) Update README for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/06 12:23:28 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2981) Update README for building docs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/06 12:24:27 UTC, 0 replies.
- [jira] [Created] (FLINK-2983) Add StateLoader as an alternative to default KvState - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/06 13:43:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2983) Add StateLoader as an alternative to default KvState - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/06 14:03:27 UTC, 2 replies.
- [jira] [Created] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/11/06 14:48:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2979] Fix RollingSink truncate for Hado... - posted by aljoscha <gi...@git.apache.org> on 2015/11/06 16:26:13 UTC, 4 replies.
- [jira] [Created] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/06 19:29:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/06 19:47:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2979) RollingSink does not work with Hadoop 2.7.1 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/06 19:49:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2213) Configure number of vcores - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/11/06 22:33:11 UTC, 5 replies.
- [jira] [Updated] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/07 00:01:11 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/11/07 00:02:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2947] [scala shell] Add color support t... - posted by chiwanpark <gi...@git.apache.org> on 2015/11/07 08:25:03 UTC, 7 replies.
- [jira] [Commented] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/07 08:28:11 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/08 14:36:21 UTC, 74 replies.
- [jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/08 14:37:10 UTC, 74 replies.
- [jira] [Commented] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/08 16:33:10 UTC, 3 replies.
- [GitHub] flink pull request: FLINK-2826 transformed is modified in Broadcas... - posted by tedyu <gi...@git.apache.org> on 2015/11/08 16:43:29 UTC, 2 replies.
- [jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/08 19:32:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2986) Typo in KvState interface snapshot method name - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/09 10:40:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2986) Typo in KvState interface snapshot method name - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/09 10:43:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2986) Typo in KvState interface snapshot method name - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/09 11:07:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-2752) Documentation is not easily differentiable from the Flink homepage - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/09 11:22:11 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-2213) Configure number of vcores - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/09 13:14:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-1144) Jobmanager Webfrontend task-totals are incorrect - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/09 13:53:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2987) Flink 0.10 fails to start on YARN 2.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 14:17:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2228) Web frontend uses two different timezones when reporting the time for job - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/09 14:21:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-2905) Add intersect method to Graph class - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/09 14:27:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2905) Add intersect method to Graph class - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/09 14:28:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2730][web-dashboard] Adds cpu and memor... - posted by mxm <gi...@git.apache.org> on 2015/11/09 14:36:20 UTC, 5 replies.
- [jira] [Commented] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/09 14:37:11 UTC, 6 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/11/09 14:51:11 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2987] Remove jersey-core and jersey-cli... - posted by rmetzger <gi...@git.apache.org> on 2015/11/09 15:32:41 UTC, 6 replies.
- [jira] [Commented] (FLINK-2987) Flink 0.10 fails to start on YARN 2.6.0 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/09 15:33:11 UTC, 7 replies.
- [jira] [Created] (FLINK-2988) Cannot load DataSet[Row] from CSV file - posted by "Johann Kovacs (JIRA)" <ji...@apache.org> on 2015/11/09 16:06:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/09 16:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2989) Job Cancel button doesn't work on Yarn - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/09 16:45:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2974] Add periodic offset committer for... - posted by rmetzger <gi...@git.apache.org> on 2015/11/09 17:17:39 UTC, 28 replies.
- [jira] [Commented] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/09 17:18:11 UTC, 28 replies.
- [jira] [Updated] (FLINK-2213) Configure number of vcores - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/09 17:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2990) Scala 2.11 build fails to start on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 17:50:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/09 18:15:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2982) CLI info option throws ClassCastException for streaming jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/09 18:19:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2990) Scala 2.11 build fails to start on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 18:34:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2987) Flink 0.10 fails to start on YARN 2.6.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/09 19:14:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2901] Remove Record API dependencies fr... - posted by fhueske <gi...@git.apache.org> on 2015/11/10 10:38:51 UTC, 11 replies.
- [jira] [Commented] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/10 10:39:10 UTC, 11 replies.
- [jira] [Created] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/10 10:39:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2977] Added support for accessing a Ker... - posted by nielsbasjes <gi...@git.apache.org> on 2015/11/10 11:05:38 UTC, 30 replies.
- [jira] [Created] (FLINK-2992) New Windowing code is using SerializationUtils with wrong classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/10 12:14:10 UTC, 0 replies.
- [GitHub] flink pull request: Remove and forbid use of SerializationUtils. F... - posted by rmetzger <gi...@git.apache.org> on 2015/11/10 12:31:41 UTC, 7 replies.
- [jira] [Commented] (FLINK-2992) New Windowing code is using SerializationUtils with wrong classloader - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/10 12:32:11 UTC, 7 replies.
- [jira] [Commented] (FLINK-2989) Job Cancel button doesn't work on Yarn - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/10 13:18:10 UTC, 11 replies.
- [jira] [Created] (FLINK-2993) Set default elayBetweenExecutionRetries to 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 13:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2993) Set default elayBetweenExecutionRetries to 0 - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/10 14:35:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2992) New Windowing code is using SerializationUtils with wrong classloader - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/10 14:36:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2989] job cancel button doesn't work on... - posted by mxm <gi...@git.apache.org> on 2015/11/10 15:03:01 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2851] Move PythonAPI to flink-libraries - posted by fhueske <gi...@git.apache.org> on 2015/11/10 15:16:51 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2966) Improve the way job duration is reported on web frontend. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/10 15:17:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/10 15:17:12 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2017] Add predefined required parameter... - posted by fhueske <gi...@git.apache.org> on 2015/11/10 15:42:04 UTC, 33 replies.
- [jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/10 15:42:11 UTC, 33 replies.
- [jira] [Commented] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/10 15:46:11 UTC, 2 replies.
- [jira] [Created] (FLINK-2994) Client sysout logging does not report exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:22:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2993) Set default elayBetweenExecutionRetries to 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2995) Set default number of retries to larger than 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:33:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-2993) Set default DelayBetweenExecutionRetries to 0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 17:36:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/10 17:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2996) Add config entry to define BlobServer port - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/10 21:16:11 UTC, 0 replies.
- [jira] [Created] (FLINK-2997) Support range partition with user customized data distribution. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/11 07:58:10 UTC, 0 replies.
- [jira] [Created] (FLINK-2998) Support range partition comparison for multi input nodes. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/11 08:04:11 UTC, 0 replies.
- [GitHub] flink pull request: fix pos assignment of instance - posted by fangmu <gi...@git.apache.org> on 2015/11/11 08:41:31 UTC, 5 replies.
- [jira] [Commented] (FLINK-2993) Set default DelayBetweenExecutionRetries to 0 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/11 10:07:10 UTC, 1 replies.
- [jira] [Created] (FLINK-2999) Support connected keyed streams - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/11 10:21:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 10:56:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/11 10:58:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3001) Add Support for Java 8 Optional type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:02:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3002) Add an EitherType to the Java API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:05:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2999) Support connected keyed streams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3003) Add container allocation timeout to YARN CLI - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/11 11:06:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2999) Support connected keyed streams - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 11:08:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3001) Add Support for Java 8 Optional type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/11 11:13:10 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3002) Add an EitherType to the Java API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/11 11:58:11 UTC, 0 replies.
- [GitHub] flink pull request: Fixed FLINK-2942 - posted by iampeter <gi...@git.apache.org> on 2015/11/11 13:34:20 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/11 14:16:38 UTC, 10 replies.
- [jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/11 14:17:11 UTC, 10 replies.
- [jira] [Updated] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/11 14:46:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2996) Add config entry to define BlobServer port - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/11 15:06:10 UTC, 12 replies.
- [jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/11 15:32:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 16:38:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2826) transformed is modified in BroadcastVariableMaterialization#decrementReferenceInternal without proper locking - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 16:38:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2994) Client sysout logging does not report exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 16:43:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2994) Client sysout logging does not report exceptions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/11 16:43:11 UTC, 0 replies.
- [GitHub] flink pull request: [refactor] Rename OperatorState to ValueState,... - posted by aljoscha <gi...@git.apache.org> on 2015/11/11 17:01:00 UTC, 7 replies.
- [jira] [Updated] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/11 17:16:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2879) Links in documentation are broken - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2015/11/11 20:58:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2879] [docs] Fixed broken links on the ... - posted by andralungu <gi...@git.apache.org> on 2015/11/11 21:02:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-2879) Links in documentation are broken - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/11 21:03:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2488][FLINK-2496] Expose Task Manager c... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/11 22:52:57 UTC, 5 replies.
- [jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/11 22:53:11 UTC, 12 replies.
- [jira] [Created] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/11/11 23:33:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/12 02:43:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/12 04:02:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2956] [tests] Migrate integration tests... - posted by gallenvara <gi...@git.apache.org> on 2015/11/12 07:47:21 UTC, 19 replies.
- [jira] [Commented] (FLINK-2956) Migrate integration tests for Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/12 07:48:11 UTC, 19 replies.
- [jira] [Commented] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/12 11:42:11 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/12 12:09:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2757) DataSinkTaskTest fails on Windows - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/11/12 14:56:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3006) TypeExtractor fails on custom type - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/12 15:37:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3006) TypeExtractor fails on custom type - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/12 15:49:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3007) Implement a parallel version of the Hidden Markov Model - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/11/12 16:19:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3007) Implement a parallel version of the Hidden Markov Model - posted by "Hilmi Yildirim (JIRA)" <ji...@apache.org> on 2015/11/12 16:19:10 UTC, 0 replies.
- [GitHub] flink pull request: Implemented a parallel version of Hidden Marko... - posted by HilmiYildirim <gi...@git.apache.org> on 2015/11/12 16:22:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3003) Add container allocation timeout to YARN CLI - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/12 16:42:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3007) Implement a parallel version of the Hidden Markov Model - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/12 16:47:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2379][ml]Add column wise statistics for... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/12 16:59:05 UTC, 0 replies.
- [jira] [Commented] (FLINK-2379) Add methods to evaluate field wise statistics over DataSet of vectors. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/12 16:59:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/12 16:59:59 UTC, 0 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/12 17:00:13 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3007] Implemented a parallel version of... - posted by chiwanpark <gi...@git.apache.org> on 2015/11/12 17:28:36 UTC, 45 replies.
- [jira] [Resolved] (FLINK-3004) ForkableMiniCluster does not call RichFunction#open - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/11/12 19:46:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2851) Merge Language-Binding into Python API and move to flink-libraries - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/12 21:12:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3008) Failing/restarting streaming jobs are buggy in the webfrontend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/13 10:59:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3008) Failing/restarting streaming jobs are buggy in the webfrontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/13 11:10:10 UTC, 3 replies.
- [jira] [Created] (FLINK-3009) Cannot build docs with Jekyll 3.0.0 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/13 11:49:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3002) Add an EitherType to the Java API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/13 11:52:10 UTC, 46 replies.
- [jira] [Created] (FLINK-3010) Add link to powered-by wiki page to project website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/13 12:28:10 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Wrong base url for docs - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/13 14:26:41 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2432] Custom serializer support - posted by zentol <gi...@git.apache.org> on 2015/11/13 14:39:55 UTC, 1 replies.
- [jira] [Commented] (FLINK-2432) [py] Provide support for custom serialization - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/13 14:40:10 UTC, 2 replies.
- [jira] [Updated] (FLINK-3008) Failing/restarting streaming jobs are buggy in the webfrontend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/13 15:03:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/13 15:09:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2432) [py] Provide support for custom serialization - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/13 15:56:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2850) Limit the types of jobs which can run in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/13 16:55:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/13 16:55:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2797) CLI: Missing option to submit jobs in detached mode - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/13 16:55:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3009) Cannot build docs with Jekyll 3.0.0 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/13 17:09:11 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-2441] Introduce Python OperationInfo - posted by zentol <gi...@git.apache.org> on 2015/11/13 18:50:30 UTC, 4 replies.
- [jira] [Commented] (FLINK-2441) [py] Introduce an OpInfo object on the python side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/13 18:51:11 UTC, 5 replies.
- [jira] [Updated] (FLINK-1814) Revisit the documentation to add new operator - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/13 23:07:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2913] Close of ObjectOutputStream shoul... - posted by tedyu <gi...@git.apache.org> on 2015/11/14 01:44:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/14 01:45:11 UTC, 2 replies.
- [GitHub] flink pull request: Hits - posted by mfahimazizi <gi...@git.apache.org> on 2015/11/14 07:04:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/14 12:05:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-2044) Implementation of Gelly HITS Algorithm - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/14 13:25:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3000]Adds shutdown hook to clean up lin... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/15 02:37:10 UTC, 7 replies.
- [jira] [Commented] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/15 02:37:10 UTC, 7 replies.
- [jira] [Created] (FLINK-3012) Refactor boilerplate code of while and if statements in DataSourceTask - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/15 19:44:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3012] Refactor boilerplate code in Data... - posted by jaoki <gi...@git.apache.org> on 2015/11/15 19:44:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-3012) Refactor boilerplate code of while and if statements in DataSourceTask - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/15 19:45:10 UTC, 5 replies.
- [jira] [Created] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/15 20:01:10 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3013: Incorrect package declaration in G... - posted by smarthi <gi...@git.apache.org> on 2015/11/15 20:45:13 UTC, 5 replies.
- [jira] [Commented] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/15 20:46:10 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/15 21:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/15 21:30:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3015) Bring Features Web Page up to speed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/15 23:06:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/15 23:54:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3016) Update Flink roadmap - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2015/11/16 05:34:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3017) Broken link 'Slots' on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 05:49:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 05:50:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 06:00:13 UTC, 0 replies.
- [GitHub] flink pull request: Flink-3017: Fix broken 'Slots' link on Streami... - posted by smarthi <gi...@git.apache.org> on 2015/11/16 06:06:13 UTC, 0 replies.
- [jira] [Commented] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 06:10:10 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/16 06:10:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3012) Refactor boilerplate code of while and if statements in DataSourceTask - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/16 08:33:10 UTC, 0 replies.
- [GitHub] flink pull request: minor jvadoc fix in JobManager - posted by jaoki <gi...@git.apache.org> on 2015/11/16 09:58:37 UTC, 0 replies.
- [jira] [Created] (FLINK-3018) Job state discarded from web interface for restarting jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/16 10:34:11 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3017: Fix broken 'Slots' link on Streami... - posted by mjsax <gi...@git.apache.org> on 2015/11/16 10:50:09 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2914] Add missing break Statement in ZK... - posted by zentol <gi...@git.apache.org> on 2015/11/16 11:37:17 UTC, 3 replies.
- [jira] [Commented] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/16 11:38:11 UTC, 3 replies.
- [jira] [Assigned] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/16 11:38:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3017) Broken 'Slots' link on Streaming Programming Guide - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/16 12:47:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/16 14:20:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2838) Inconsistent use of URL and Path classes for resources - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2803) Add test case for Flink's memory allocation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2799) Yarn tests cannot be executed with DEBUG log level - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:12 UTC, 0 replies.
- [jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2676) Add abstraction for keyed window state - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2667) Rework configuration parameters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2680) Create a dedicated aligned-event time window operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2608) Arrays.asList(..) does not work with CollectionInputFormat - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2758) TaskManagerRegistrationTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2674) Rework windowing logic - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2662) CompilerException: "Bug: Plan generation for Unions picked a ship strategy between binary plan operators." - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2759) TaskManagerProcessReapingTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2757) DataSinkTaskTest fails on Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2670) Unstable CombineTaskTest - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2728) Add missing features to new web dashboard - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2795) Print JobExecutionResult for interactively invoked jobs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2730) Add CPU/Network utilization graphs to new web dashboard - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2739) Release script depends on the order of parent module information - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:13 UTC, 0 replies.
- [jira] [Updated] (FLINK-2573) Add Kerberos test case - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2443) [CompactingHashTable] GSA Connected Components fails with NPE - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2491) Operators are not participating in state checkpointing in some cases - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2348) IterateExampleITCase failing - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2263) ExecutionGraph uses Thread.sleep to delay execution retries - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 1 replies.
- [jira] [Updated] (FLINK-2518) Avoid predetermination of ports for network services - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2455) Misleading I/O manager error log messages - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2399) Fail when actor versions don't match - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 1 replies.
- [jira] [Updated] (FLINK-2480) Improving tests coverage for org.apache.flink.streaming.api - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-2344) Deprecate/Remove the old Pact Pair type - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:14 UTC, 0 replies.
- [jira] [Updated] (FLINK-1513) Remove GlobalConfiguration Singleton - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-2157) Create evaluation framework for ML library - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1278) Remove the Record special code paths - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1240) We cannot use sortGroup on a global reduce - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1702) Authenticate via Kerberos from the client only - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1723) Add cross validation for model evaluation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-2185) Rework semantics for .setSeed function of SVM - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-2239) print() on DataSet: stream results and print incrementally - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-1778) Improve normalized keys in composite key case - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-2075) Shade akka and protobuf dependencies away - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/16 14:44:15 UTC, 0 replies.
- [jira] [Updated] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/16 17:30:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/16 17:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3019) CLI does not list running/restarting jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/16 17:42:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/16 18:39:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3020) Local streaming execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/16 18:57:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3020) Local execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/16 18:57:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3020][streaming] set local default para... - posted by mxm <gi...@git.apache.org> on 2015/11/16 19:17:36 UTC, 0 replies.
- [jira] [Commented] (FLINK-3020) Local streaming execution: set number of task manager slots to the maximum parallelism - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/16 19:18:11 UTC, 14 replies.
- [GitHub] flink pull request: minor javadoc fix in JobManager - posted by mxm <gi...@git.apache.org> on 2015/11/16 19:21:30 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2967] Enhance TaskManager network detec... - posted by rmetzger <gi...@git.apache.org> on 2015/11/16 21:30:21 UTC, 7 replies.
- [GitHub] flink pull request: Change the parameter 'numSample' in DataSetUti... - posted by smarthi <gi...@git.apache.org> on 2015/11/16 23:02:26 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3009] Add dockerized jekyll environment - posted by jaoki <gi...@git.apache.org> on 2015/11/17 09:07:35 UTC, 7 replies.
- [jira] [Created] (FLINK-3021) Job submission times out due to classloading issue on JobManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 09:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/17 09:33:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/17 09:35:11 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3022: Broken link 'Working With State' i... - posted by smarthi <gi...@git.apache.org> on 2015/11/17 09:36:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/17 09:37:10 UTC, 2 replies.
- [jira] [Reopened] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 10:08:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2977) Cannot access HBase in a Kerberos secured Yarn cluster - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 10:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 10:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/17 10:47:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3021) Job submission times out due to classloading issue on JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/17 11:05:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3021) Job submission times out due to classloading issue on JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/17 11:08:11 UTC, 5 replies.
- [jira] [Resolved] (FLINK-3022) Broken link 'Working With State' in Fault Tolerance Section of Stream Programming Guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/17 11:13:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/17 11:25:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/17 11:48:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3025] [kafka consumer] Bump transitive ... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/17 12:05:10 UTC, 3 replies.
- [jira] [Commented] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/17 12:05:11 UTC, 5 replies.
- [GitHub] flink pull request: Bumped the docker container to the latest vers... - posted by thedrow <gi...@git.apache.org> on 2015/11/17 13:35:51 UTC, 5 replies.
- [jira] [Created] (FLINK-3026) Publish the flink docker container to the docker registry - posted by "Omer Katz (JIRA)" <ji...@apache.org> on 2015/11/17 13:36:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 13:46:11 UTC, 5 replies.
- [GitHub] flink pull request: Fix JavaDoc of ElasticsearchSink - posted by mliesenberg <gi...@git.apache.org> on 2015/11/17 13:50:02 UTC, 4 replies.
- [jira] [Created] (FLINK-3027) Cancel button in Flink job dashboard does not work - posted by "Krzysztof Zarzycki (JIRA)" <ji...@apache.org> on 2015/11/17 13:56:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3027) Cancel button in Flink job dashboard does not work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 14:00:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:22:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2676) Add abstraction for keyed window state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:23:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2676) Add abstraction for keyed window state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2676) Add abstraction for keyed window state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:24:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2680) Create a dedicated aligned-event time window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:25:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2680) Create a dedicated aligned-event time window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:25:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3021] Fix class loading issue for strea... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/17 14:30:59 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2670) Unstable CombineTaskTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:31:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2670) Unstable CombineTaskTest - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:31:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:34:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2508) Confusing sharing of StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:34:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3028) Cannot cancel restarting job via web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/17 14:35:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:36:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2750) FileStateHandleTest fails when building for Hadoop 2.6.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 14:36:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3024) TimestampExtractor Does not Work When returning Long.MIN_VALUE - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/17 14:37:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-297) Redesign GUI client-server model - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/17 14:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/17 15:01:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 15:10:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3030) Enhance Dashboard to show Execution Attempts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 15:21:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3011, 3019, 3028] Cancel jobs in RESTAR... - posted by uce <gi...@git.apache.org> on 2015/11/17 15:21:31 UTC, 6 replies.
- [jira] [Commented] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/17 15:22:11 UTC, 6 replies.
- [jira] [Commented] (FLINK-3018) Job state discarded from web interface for restarting jobs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 15:26:11 UTC, 2 replies.
- [jira] [Updated] (FLINK-3018) Job state discarded from web interface for restarting jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/17 16:00:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-2771) IterateTest.testSimpleIteration fails on Travis - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/17 16:00:16 UTC, 0 replies.
- [jira] [Closed] (FLINK-2879) Links in documentation are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:16:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2879) Links in documentation are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:16:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:17:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2967) TM address detection might not always detect the right interface on slow networks / overloaded JMs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:17:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:18:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:18:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:19:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:19:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2914) Missing break in ZooKeeperSubmittedJobGraphStore#SubmittedJobGraphsPathCacheListener#childEvent() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:19:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3029) JobGraph is not connected correctly in webfrontend for streaming job - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/17 16:19:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/17 16:30:11 UTC, 3 replies.
- [jira] [Created] (FLINK-3031) Consistent Shutdown of Streaming Jobs - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:46:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 17:48:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 17:48:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3033) Redis Source Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3034) Redis SInk Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:50:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3033) Redis Source Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 17:51:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3035) Redis as State Backend - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/17 18:06:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by mjsax <gi...@git.apache.org> on 2015/11/17 18:20:02 UTC, 50 replies.
- [jira] [Created] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/17 18:20:11 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/11/17 18:20:11 UTC, 50 replies.
- [jira] [Assigned] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/17 18:22:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3036] [gelly] Fix Graph.fromCsvReader m... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/17 18:28:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/17 18:29:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 18:43:10 UTC, 11 replies.
- [GitHub] flink pull request: [FLINK-3002] Add Either type to the Java API - posted by vasia <gi...@git.apache.org> on 2015/11/17 20:41:01 UTC, 32 replies.
- [GitHub] flink pull request: [FLINK-3032] Fix jackson-core dependency confl... - posted by rmetzger <gi...@git.apache.org> on 2015/11/17 22:39:57 UTC, 8 replies.
- [jira] [Updated] (FLINK-2989) Job Cancel button doesn't work on Yarn - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 23:01:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3027) Cancel button in Flink job dashboard does not work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 23:02:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2924) Create database state backend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 23:13:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2925) Client shows incomplete cause of Exception - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 23:21:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/17 23:29:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/18 10:32:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 10:46:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2937] Fix Typo in Scala Quickstart Guid... - posted by zentol <gi...@git.apache.org> on 2015/11/18 11:22:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 11:23:11 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2233] Update InputFormat nextRecord jav... - posted by zentol <gi...@git.apache.org> on 2015/11/18 11:34:42 UTC, 3 replies.
- [jira] [Commented] (FLINK-2233) InputFormat nextRecord Javadocs out of sync - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 11:35:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 11:35:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2233) InputFormat nextRecord Javadocs out of sync - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 11:35:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 11:44:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation" - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/18 11:53:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2249] Ignore calls to execute without s... - posted by zentol <gi...@git.apache.org> on 2015/11/18 12:14:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 12:14:10 UTC, 6 replies.
- [jira] [Closed] (FLINK-2441) [py] Introduce an OpInfo object on the python side - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 12:29:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1945][py] Python Tests less verbose - posted by zentol <gi...@git.apache.org> on 2015/11/18 13:51:20 UTC, 11 replies.
- [jira] [Commented] (FLINK-1945) Make python tests less verbose - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 13:52:10 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-2115] [Table API] support no aggregatio... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/11/18 14:35:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 14:36:11 UTC, 5 replies.
- [jira] [Created] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 14:49:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 14:58:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 14:58:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2686) Extend JSON plan dump to contain channel info - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 15:02:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2686] Show exchange mode in JSON plan - posted by zentol <gi...@git.apache.org> on 2015/11/18 15:03:55 UTC, 7 replies.
- [jira] [Commented] (FLINK-2686) Extend JSON plan dump to contain channel info - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 15:04:11 UTC, 8 replies.
- [jira] [Created] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 15:28:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3013) Incorrect package declaration in GellyScalaAPICompletenessTest.scala - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/18 16:07:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3036) Gelly's Graph.fromCsvReader method returns wrongly parameterized Graph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/18 16:10:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 16:14:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 16:44:11 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2860] [ml] [docs] The mlr object from t... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/18 16:52:16 UTC, 2 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/11/18 16:53:11 UTC, 2 replies.
- [jira] [Closed] (FLINK-2233) InputFormat nextRecord Javadocs out of sync - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 17:18:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2937) Typo in Quickstart->Scala API->Alternative Build Tools: SBT - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 17:19:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3020][streaming] set number of task slo... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/18 17:23:02 UTC, 13 replies.
- [jira] [Created] (FLINK-3039) Trigger KeyValueState cannot be Scala Int - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/18 17:40:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/18 18:34:15 UTC, 2 replies.
- [jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 18:35:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3040) Add docs describing how to configure State Backends - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 18:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/11/18 18:47:11 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3041: Twitter Streaming Description sect... - posted by smarthi <gi...@git.apache.org> on 2015/11/18 18:49:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/18 18:50:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3042) Define a way to let types create their own TypeInformation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 18:56:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2989) Job Cancel button doesn't work on Yarn - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/18 18:58:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 19:16:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2942) Dangling operators in web UI's program visualization (non-deterministic) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 19:16:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 20:33:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3043] [docs] Fix description of Kafka C... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/18 20:35:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/18 20:36:11 UTC, 5 replies.
- [jira] [Closed] (FLINK-2692) Untangle CsvInputFormat into PojoTypeCsvInputFormat and TupleTypeCsvInputFormat - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/18 21:44:11 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3005 Commons-collections object deserial... - posted by tedyu <gi...@git.apache.org> on 2015/11/18 22:57:01 UTC, 0 replies.
- [jira] [Created] (FLINK-3044) In YARN mode, configure FsStateBackend by default. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/18 23:54:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/19 00:37:10 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2429] [streaming] Deprecate the "enable... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/19 00:37:31 UTC, 2 replies.
- [jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2015/11/19 02:03:10 UTC, 12 replies.
- [jira] [Created] (FLINK-3045) Properly expose the key of a kafka message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/19 10:15:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2955) Add operations introduction in Table API page. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/19 10:25:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3040) Add docs describing how to configure State Backends - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 10:30:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3040) Add docs describing how to configure State Backends - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 10:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3046) Integrate the Either Java type with the TypeExtractor - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/19 10:50:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3044) In YARN mode, configure FsStateBackend by default. - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/19 10:55:10 UTC, 3 replies.
- [jira] [Reopened] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 11:05:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2249) ExecutionEnvironment: Ignore calls to execute() if no data sinks defined - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 11:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3047) Local batch execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 12:18:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3047) Local batch execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 12:46:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3047) Local batch execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/19 12:47:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/19 13:22:11 UTC, 6 replies.
- [jira] [Closed] (FLINK-1945) Make python tests less verbose - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/19 13:27:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3041]: Twitter Streaming Description se... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/19 13:32:07 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2440][py] Expand Environment feature co... - posted by zentol <gi...@git.apache.org> on 2015/11/19 13:33:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-2440) [py] Expand Environment feature coverage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/19 13:33:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3041) Twitter Streaming Description section of Streaming Programming guide refers to an incorrect example 'TwitterLocal' - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/19 13:42:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3046) Integrate the Either Java type with the TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/19 13:57:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/19 13:58:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3005] Commons-collections object deseri... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/19 14:02:23 UTC, 1 replies.
- [GitHub] flink pull request: Flink 1994- Add different gain calculation sch... - posted by rawkintrevo <gi...@git.apache.org> on 2015/11/19 14:12:38 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3001) Add Support for Java 8 Optional type - posted by "Hubert Czerpak (JIRA)" <ji...@apache.org> on 2015/11/19 14:16:10 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3002) Add an EitherType to the Java API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/19 14:26:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()" - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/19 14:26:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:45:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:51:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3005) Commons-collections object deserialization remote command execution vulnerability - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:51:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:52:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3043) Kafka Connector description in Streaming API guide is wrong/outdated - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 14:52:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 14:55:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/19 15:01:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 15:53:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 15:53:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3045] Properly expose the key of a Kafk... - posted by rmetzger <gi...@git.apache.org> on 2015/11/19 15:53:18 UTC, 8 replies.
- [jira] [Commented] (FLINK-3045) Properly expose the key of a kafka message - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/19 15:54:11 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 17:17:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3048) DataSinkTaskTest.testCancelDataSinkTask - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 17:17:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 17:18:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2913) Close of ObjectOutputStream should be enclosed in finally block in FsStateBackend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 17:18:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2488] Expose Attempt Number in RuntimeC... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/19 17:45:19 UTC, 6 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 17:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/19 18:01:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2861] Fields grouping on split streams ... - posted by mjsax <gi...@git.apache.org> on 2015/11/19 18:19:15 UTC, 12 replies.
- [jira] [Commented] (FLINK-2861) Fields grouping on split streams fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/19 18:20:11 UTC, 13 replies.
- [jira] [Assigned] (FLINK-2861) Fields grouping on split streams fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/19 18:23:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:25:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-3019) CLI does not list running/restarting jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:26:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-3028) Cannot cancel restarting job via web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:26:11 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... - posted by mjsax <gi...@git.apache.org> on 2015/11/19 18:26:21 UTC, 0 replies.
- [jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/19 18:27:10 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3028) Cannot cancel restarting job via web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:42:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3028) Cannot cancel restarting job via web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:43:11 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3019) CLI does not list running/restarting jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:44:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3019) CLI does not list running/restarting jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:44:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3011) Cannot cancel failing/restarting streaming job from the command line - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/19 18:46:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/19 22:01:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3021) Job submission times out due to classloading issue on JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/20 10:04:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/20 11:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3052) Optimizer does not push properties out of bulk iterations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/20 12:21:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3052] [optimizer] Fix instantiation of ... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/20 12:32:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-3052) Optimizer does not push properties out of bulk iterations - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/20 12:33:11 UTC, 3 replies.
- [jira] [Created] (FLINK-3053) SuccessAfterNetworkBuffersFailureITCase.testSuccessfulProgramAfterFailure - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/20 14:17:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3052) Optimizer does not push properties out of bulk iterations - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/20 15:01:10 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Fix Documentation formatting for recent... - posted by smarthi <gi...@git.apache.org> on 2015/11/20 15:37:02 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/20 15:37:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3054) Remove R (return) type variable from SerializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/20 16:14:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3054) Remove R (return) type variable from SerializationSchema - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/20 16:57:10 UTC, 7 replies.
- [jira] [Commented] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/20 16:59:11 UTC, 11 replies.
- [jira] [Created] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/20 17:14:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/20 18:14:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 12:12:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/11/21 13:25:11 UTC, 5 replies.
- [jira] [Updated] (FLINK-1258) Merge iterative and non-iterative tasks - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/21 15:07:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 15:23:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 15:24:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 15:25:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/21 16:09:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2318] Union can be used as BroadcastVar... - posted by zentol <gi...@git.apache.org> on 2015/11/21 16:10:11 UTC, 3 replies.
- [jira] [Commented] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/21 18:18:10 UTC, 1 replies.
- [GitHub] flink pull request: [streaming-scala] Code cleanup: unused imports... - posted by smarthi <gi...@git.apache.org> on 2015/11/21 23:15:57 UTC, 6 replies.
- [jira] [Created] (FLINK-3057) Provide a way to pass informaiton back to the plan - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/22 12:34:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3057) [py] Provide a way to pass informaiton back to the plan - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/22 12:35:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/22 15:23:11 UTC, 149 replies.
- [jira] [Commented] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/22 16:57:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/22 18:17:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/22 18:55:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3059) Javadoc fix for DataSet.writeAsText() - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/23 04:25:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3059] Javadoc fix for DataSet.writeAsTe... - posted by jaoki <gi...@git.apache.org> on 2015/11/23 04:25:48 UTC, 9 replies.
- [jira] [Commented] (FLINK-3059) Javadoc fix for DataSet.writeAsText() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/23 04:26:10 UTC, 9 replies.
- [jira] [Resolved] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/23 10:09:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2429) Remove the "enableCheckpointing()" without interval variant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/23 10:09:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2017) Add predefined required parameters to ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 15:05:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3046] Integrate the Either Java type wi... - posted by twalthr <gi...@git.apache.org> on 2015/11/23 15:20:48 UTC, 10 replies.
- [jira] [Commented] (FLINK-3046) Integrate the Either Java type with the TypeExtractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/23 15:21:11 UTC, 10 replies.
- [jira] [Assigned] (FLINK-2996) Add config entry to define BlobServer port - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 15:27:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3060) Add possibility to integrate custom types into the TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/23 15:33:10 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-1737: Kronecker product - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/23 16:24:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/23 16:25:11 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2996] Introduce configuration parameter... - posted by rmetzger <gi...@git.apache.org> on 2015/11/23 17:04:55 UTC, 11 replies.
- [jira] [Created] (FLINK-3061) Kafka Consumer is not failing if broker is not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 17:47:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3061] Properly fail Kafka Consumer if b... - posted by rmetzger <gi...@git.apache.org> on 2015/11/23 17:57:50 UTC, 8 replies.
- [jira] [Commented] (FLINK-3061) Kafka Consumer is not failing if broker is not available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/23 17:58:11 UTC, 8 replies.
- [jira] [Created] (FLINK-3062) Kafka Producer is not failing if broker is not available/no partitions available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/23 18:11:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3020) Local streaming execution: set number of task manager slots to the maximum parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/23 18:36:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2947) Coloured Scala Shell - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/23 18:36:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3063) [py] Remove combiner - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/23 18:51:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/11/23 20:03:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/11/23 20:27:11 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-3064] [core] Add size check in GroupRed... - posted by s1ck <gi...@git.apache.org> on 2015/11/23 22:32:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/23 22:32:11 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati... - posted by rawkintrevo <gi...@git.apache.org> on 2015/11/24 04:21:21 UTC, 7 replies.
- [jira] [Commented] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 09:18:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2988) Cannot load DataSet[Row] from CSV file - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/11/24 09:35:11 UTC, 4 replies.
- [jira] [Created] (FLINK-3065) Can't cancel failing jobs - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:53:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3066) Kafka source fails on leader change - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 09:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/24 10:00:18 UTC, 19 replies.
- [jira] [Commented] (FLINK-3065) Can't cancel failing jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/24 10:03:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-3066) Kafka source fails on leader change - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 10:05:11 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 10:13:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2916) Add more context information for the StateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 10:49:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2924) Create database state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 10:49:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2931) Add global recovery timestamp to state restore - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 10:49:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2837][storm] various improvements for S... - posted by mxm <gi...@git.apache.org> on 2015/11/24 11:09:04 UTC, 147 replies.
- [GitHub] flink pull request: [FLINK-3067] Enforce zkclient 0.7 for Kafka - posted by rmetzger <gi...@git.apache.org> on 2015/11/24 11:11:12 UTC, 7 replies.
- [jira] [Updated] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 11:12:11 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 11:13:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-2956) Migrate integration tests for Table API - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/24 11:18:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2956) Migrate integration tests for Table API - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/11/24 11:19:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3068) Add a Table API configuration to TableEnvironment - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/24 12:20:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2100) Add ITCases for all Table API examples - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/24 12:41:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3045) Properly expose the key of a kafka message - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 13:25:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2861) Fields grouping on split streams fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/24 13:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3069) Make state materialization asynchronous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3070) Create an asynchronous state handle interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:47:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3071) Add asynchronous materialization thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/24 13:49:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3070) Create an asynchronous state handle interface - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/24 13:55:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3064) Missing size check in GroupReduceOperatorBase leads to NPE - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/24 15:46:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3057) [py] Provide a way to pass informaiton back to the plan - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/24 15:53:10 UTC, 1 replies.
- [jira] [Created] (FLINK-3072) DbStateBackendTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/24 16:00:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3072) DbStateBackendTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/11/24 16:00:17 UTC, 8 replies.
- [jira] [Resolved] (FLINK-2996) Add config entry to define BlobServer port - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 16:00:17 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/24 16:30:54 UTC, 5 replies.
- [jira] [Commented] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/24 16:31:11 UTC, 5 replies.
- [jira] [Created] (FLINK-3073) Activate streaming mode by default - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 16:48:10 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Register signal handler for JobManage... - posted by rmetzger <gi...@git.apache.org> on 2015/11/24 16:51:29 UTC, 3 replies.
- [jira] [Created] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/24 16:53:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3072) DbStateBackendTest - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 17:10:12 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3072] [streaming] Ensure Derby server s... - posted by gyfora <gi...@git.apache.org> on 2015/11/24 17:32:30 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2901) Several flink-test ITCases depend on Record API features - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/24 18:23:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 19:07:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 19:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/24 19:07:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3075] Change Either creation method nam... - posted by gyfora <gi...@git.apache.org> on 2015/11/24 19:16:41 UTC, 7 replies.
- [jira] [Commented] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/24 19:17:11 UTC, 7 replies.
- [jira] [Assigned] (FLINK-2906) Remove Record-API - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 19:25:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2906] Remove Record API - posted by zentol <gi...@git.apache.org> on 2015/11/24 19:31:02 UTC, 5 replies.
- [jira] [Commented] (FLINK-2906) Remove Record-API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/24 19:31:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-2435) Add support for custom CSV field parsers - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 19:48:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3057) [py] Provide a way to pass information back to the plan process - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 19:56:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2686) Extend JSON plan dump to contain channel info - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 21:51:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3076) Display channel exchange mode in the plan visualizer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 21:53:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2318) BroadcastVariable of unioned data set fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/24 22:42:11 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2988) Cannot load DataSet[Row] from CSV file - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/11/25 02:45:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3057) [py] Provide a way to pass information back to the plan process - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/11/25 10:16:10 UTC, 0 replies.
- [GitHub] flink pull request: [github] change tab size to 4 spaces - posted by mxm <gi...@git.apache.org> on 2015/11/25 11:00:19 UTC, 6 replies.
- [jira] [Updated] (FLINK-3059) Javadoc fix for DataSet.writeAsText() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/25 11:40:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-788) Enable combiner for Reduce with Broadcast Variable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/25 11:44:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-2186) Rework CSV import to support very wide files - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/25 11:56:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 12:24:10 UTC, 0 replies.
- [GitHub] flink pull request: typo in DelimitedInputFormat - posted by fversaci <gi...@git.apache.org> on 2015/11/25 12:28:04 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3072) DbStateBackendTest - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/25 12:59:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 14:30:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/25 14:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 16:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/11/25 16:13:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/25 16:24:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 16:42:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 16:47:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3054] Remove R (return) type variable f... - posted by rmetzger <gi...@git.apache.org> on 2015/11/25 16:53:48 UTC, 3 replies.
- [GitHub] flink pull request: [docs][hotfix] Fix wrong window definitions in... - posted by rmetzger <gi...@git.apache.org> on 2015/11/25 17:49:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-2960) Communicate with JobManager through YARN proxy - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 19:02:11 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2960) Communicate with JobManager through YARN proxy - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 19:02:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 19:04:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/25 19:04:11 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3051] Control the maximum number of con... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/25 20:51:14 UTC, 10 replies.
- [jira] [Assigned] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/26 00:10:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/11/26 00:24:10 UTC, 2 replies.
- [jira] [Closed] (FLINK-1681) Remove the old Record API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/26 01:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2906) Remove Record-API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/26 01:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3059) Javadoc fix for DataSet.writeAsText() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/26 01:25:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 12:12:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2954] Add config parameter for passing ... - posted by rmetzger <gi...@git.apache.org> on 2015/11/26 12:29:46 UTC, 8 replies.
- [jira] [Assigned] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/26 14:04:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3081] Properly stop periodic Kafka comm... - posted by rmetzger <gi...@git.apache.org> on 2015/11/26 14:26:45 UTC, 4 replies.
- [jira] [Commented] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/26 14:27:11 UTC, 4 replies.
- [jira] [Created] (FLINK-3082) Confusing error about ManualTimestampSourceFunction - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/26 15:06:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3082] Fixed confusing error about an in... - posted by nielsbasjes <gi...@git.apache.org> on 2015/11/26 15:23:00 UTC, 2 replies.
- [jira] [Commented] (FLINK-3082) Confusing error about ManualTimestampSourceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/26 15:23:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3083) Add docs how to configure streaming fault tolerance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:05:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2522] Adds streaming support for Flink-... - posted by nikste <gi...@git.apache.org> on 2015/11/26 17:09:21 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3083] [docs] Add docs on how to configu... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/26 17:18:55 UTC, 2 replies.
- [jira] [Commented] (FLINK-3083) Add docs how to configure streaming fault tolerance - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/26 17:19:10 UTC, 2 replies.
- [jira] [Created] (FLINK-3084) File State Backend should not write very small state into files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/26 17:31:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3086) ExpressionParser does not support concatenation of suffix operations - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/26 20:24:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/11/27 06:21:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/11/27 06:23:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2926) Add a Strongly Connected Components Library Method - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/11/27 06:24:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2015/11/27 06:25:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3087) Table API do not support multi count in aggregation. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/11/27 07:40:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3087] [Table-API] support multi count i... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/11/27 08:03:07 UTC, 2 replies.
- [jira] [Commented] (FLINK-3087) Table API do not support multi count in aggregation. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/27 08:03:10 UTC, 2 replies.
- [jira] [Closed] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/27 11:38:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3051) Define a maximum number of concurrent inflight checkpoints - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/27 11:38:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3088) WritableSerializer cannot copy writable object - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/27 12:37:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3082) Confusing error about ManualTimestampSourceFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/27 12:38:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3082) Confusing error about ManualTimestampSourceFunction - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/27 12:38:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/27 12:38:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3073) Activate streaming mode by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/27 13:09:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3085) Move State Backend Initialization from "registerInputOutput()" to "invoke()" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/27 13:22:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3089) OperatorState timeout - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/11/27 14:03:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3046) Integrate the Either Java type with the TypeExtractor - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/27 15:02:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/27 15:13:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3003) Add container allocation timeout to YARN CLI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/27 15:13:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3088] [serialization] Fix copy method o... - posted by tillrohrmann <gi...@git.apache.org> on 2015/11/27 15:19:03 UTC, 12 replies.
- [jira] [Commented] (FLINK-3088) WritableSerializer cannot copy writable object - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/27 15:19:11 UTC, 12 replies.
- [jira] [Assigned] (FLINK-3071) Add asynchronous materialization thread - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/27 16:19:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3054) Remove R (return) type variable from SerializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/27 16:26:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/27 17:08:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A... - posted by rmetzger <gi...@git.apache.org> on 2015/11/27 17:31:53 UTC, 0 replies.
- [jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/27 17:32:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/27 17:42:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3071] Add asynchronous state materializ... - posted by aljoscha <gi...@git.apache.org> on 2015/11/27 17:57:52 UTC, 1 replies.
- [jira] [Commented] (FLINK-3071) Add asynchronous materialization thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/27 17:58:10 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3077][cli] Add version option to Cli. - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/28 10:29:47 UTC, 6 replies.
- [jira] [Commented] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/28 10:30:11 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-3056][web-dashboard] Represent bytes in... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/28 12:46:02 UTC, 3 replies.
- [jira] [Issue Comment Deleted] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/28 12:53:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/28 13:13:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-573) Clean-up MapOperators in optimizer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/11/28 13:56:10 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/28 16:09:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3077] Add functions to access Flink Ver... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/28 16:35:04 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-2351] Remove IOFormat ConfigBuilders - posted by zentol <gi...@git.apache.org> on 2015/11/28 16:38:14 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2928][web-dashboard] Fix confusing job ... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/28 18:51:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/28 18:52:10 UTC, 2 replies.
- [jira] [Created] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Johannes (JIRA)" <ji...@apache.org> on 2015/11/28 19:21:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/29 16:18:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/29 16:32:02 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2961) Add support for basic type Date in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/11/29 16:54:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2505) HDFSTest failure: VM crash - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/29 16:56:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2505) HDFSTest failure: VM crash - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/11/29 16:58:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2030][FLINK-2274][core][utils]Histogram... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/29 17:09:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/29 17:10:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2399] Version checks for Job Manager an... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/11/29 17:54:28 UTC, 1 replies.
- [jira] [Commented] (FLINK-2399) Fail when actor versions don't match - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/29 17:55:11 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3075) Rename Either creation methods to avoid name clash with projection methods - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/11/29 22:31:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3084] FsStateBackend backs up very smal... - posted by StephanEwen <gi...@git.apache.org> on 2015/11/30 09:44:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-3084) File State Backend should not write very small state into files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/11/30 09:45:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-2736) Failing KafkaConsumerTestBase.runCancelingOnEmptyInputTest - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/30 10:50:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3091) Provide ZooKeeper root path in startup scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/11/30 10:53:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3073) Activate streaming mode by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/11/30 15:14:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by rmetzger <gi...@git.apache.org> on 2015/11/30 15:35:39 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3061) Kafka Consumer is not failing if broker is not available - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/11/30 16:16:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3088) WritableSerializer cannot copy writable object - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/11/30 16:31:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/11/30 18:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:24:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:24:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2950) Markdown presentation problem in SVM documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2950) Markdown presentation problem in SVM documentation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:24:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:25:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2351) Deprecate config builders in InputFormats and Output formats - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:25:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2904) Web interface truncated task counts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:26:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2904) Web interface truncated task counts - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:26:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3083) Add docs how to configure streaming fault tolerance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:27:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3083) Add docs how to configure streaming fault tolerance - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/11/30 19:27:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-296) Integrate graph visualization tab for running jobs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/30 20:40:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-598) Add support for globalOrdering in DataSet API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/30 20:49:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-573) Clean-up MapOperators in optimizer - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/30 20:49:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/11/30 22:45:10 UTC, 0 replies.