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

---

- [GitHub] flink pull request: [FLINK-3087] [Table-API] support multi count i... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/12/01 02:51:53 UTC, 6 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/12/01 02:52:11 UTC, 6 replies.
- [jira] [Created] (FLINK-3092) Scala API quick start word count example is broken - posted by "madhukara phatak (JIRA)" <ji...@apache.org> on 2015/12/01 07:33:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3092) Scala API quick start word count example is broken - posted by "madhukara phatak (JIRA)" <ji...@apache.org> on 2015/12/01 07:35:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3092) Scala API quick start word count example is broken - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/12/01 07:36:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3092) Fix Scala API quick start word count example - posted by "madhukara phatak (JIRA)" <ji...@apache.org> on 2015/12/01 07:47:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3092][Documentation]Fix Scala API quick... - posted by phatak-dev <gi...@git.apache.org> on 2015/12/01 07:47:29 UTC, 4 replies.
- [jira] [Commented] (FLINK-3092) Fix Scala API quick start word count example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 07:48:11 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3084] FsStateBackend backs up very smal... - posted by asfgit <gi...@git.apache.org> on 2015/12/01 09:45:26 UTC, 0 replies.
- [jira] [Closed] (FLINK-3084) File State Backend should not write very small state into files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/01 09:46:11 UTC, 0 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/12/01 09:46:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3084) File State Backend should not write very small state into files - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/01 09:46:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2928][web-dashboard] Fix confusing job ... - posted by StephanEwen <gi...@git.apache.org> on 2015/12/01 10:33:37 UTC, 7 replies.
- [jira] [Commented] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 10:34:11 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3077][cli] Add version option to Cli. - posted by StephanEwen <gi...@git.apache.org> on 2015/12/01 10:34:45 UTC, 7 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/12/01 10:35:11 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by rmetzger <gi...@git.apache.org> on 2015/12/01 11:03:16 UTC, 56 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 11:04:10 UTC, 56 replies.
- [jira] [Assigned] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/01 11:40:11 UTC, 0 replies.
- [GitHub] flink pull request: Out-of-core state backend for JDBC databases - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/01 11:49:21 UTC, 2 replies.
- [jira] [Commented] (FLINK-3073) Activate streaming mode by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/01 12:16:10 UTC, 27 replies.
- [jira] [Created] (FLINK-3093) Introduce annotations for interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 12:30:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3092) Fix Scala API quick start word count example - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/12/01 12:54:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3080] Relax restrictions of DataStream.... - posted by aljoscha <gi...@git.apache.org> on 2015/12/01 13:50:17 UTC, 5 replies.
- [jira] [Commented] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 13:51:10 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa... - posted by rmetzger <gi...@git.apache.org> on 2015/12/01 14:03:24 UTC, 21 replies.
- [jira] [Commented] (FLINK-3093) Introduce annotations for interface stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 14:04:10 UTC, 21 replies.
- [jira] [Commented] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 14:07:11 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 14:08:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 14:09:10 UTC, 1 replies.
- [jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/01 14:18:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2837][storm] various improvements for S... - posted by mxm <gi...@git.apache.org> on 2015/12/01 14:27:39 UTC, 12 replies.
- [jira] [Commented] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 14:28:11 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-2624]: RabbitMQSource now extends Messa... - posted by asfgit <gi...@git.apache.org> on 2015/12/01 15:46:23 UTC, 1 replies.
- [jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 15:47:11 UTC, 1 replies.
- [jira] [Updated] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/01 15:49:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:26:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3093) Introduce annotations for interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:38:10 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2949 [WIP]: Add method 'writeSequencefil... - posted by rmetzger <gi...@git.apache.org> on 2015/12/01 19:42:29 UTC, 4 replies.
- [jira] [Commented] (FLINK-2949) Add method 'writeSequencefile' to DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/01 19:43:10 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:52:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:52:11 UTC, 0 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/12/01 19:55:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3097) Add support for custom functions in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/01 23:32:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3097] [table] Add support for custom fu... - posted by twalthr <gi...@git.apache.org> on 2015/12/02 00:24:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-3097) Add support for custom functions in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 00:24:11 UTC, 1 replies.
- [GitHub] flink pull request: JobManager Data Structure doc fix - posted by jaoki <gi...@git.apache.org> on 2015/12/02 00:49:38 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by danielblazevski <gi...@git.apache.org> on 2015/12/02 03:35:18 UTC, 45 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/12/02 03:36:11 UTC, 45 replies.
- [jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/02 06:56:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3098] [Table API] Cast Date to Long thr... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/12/02 07:01:54 UTC, 4 replies.
- [jira] [Commented] (FLINK-3098) Cast from Date to Long throw compile error. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 07:02:10 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2115] [Table API] support no aggregatio... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/12/02 07:10:24 UTC, 3 replies.
- [jira] [Commented] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 07:11:10 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3087) Table API do not support multi count in aggregation. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/02 10:34:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-7] [Runtime] Enable Range Partitioner. - posted by twalthr <gi...@git.apache.org> on 2015/12/02 11:31:49 UTC, 24 replies.
- [jira] [Commented] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 11:32:11 UTC, 25 replies.
- [jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows - posted by "Welly Tambunan (JIRA)" <ji...@apache.org> on 2015/12/02 12:16:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/02 12:21:10 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3080) Cannot union a data stream with a product of itself - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/02 12:22:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2115) TableAPI throws ExpressionException for "Dangling GroupBy operation" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/02 12:23:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2440][py] Expand Environment feature co... - posted by zentol <gi...@git.apache.org> on 2015/12/02 13:13:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-2440) [py] Expand Environment feature coverage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 13:14:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2488] Expose Attempt Number in RuntimeC... - posted by StephanEwen <gi...@git.apache.org> on 2015/12/02 14:09:53 UTC, 21 replies.
- [jira] [Commented] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 14:10:10 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-3071] Add asynchronous state materializ... - posted by asfgit <gi...@git.apache.org> on 2015/12/02 14:26:44 UTC, 0 replies.
- [jira] [Commented] (FLINK-3071) Add asynchronous materialization thread - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 14:27:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3071) Add asynchronous materialization thread - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/02 14:28:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3069) Make state materialization asynchronous - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/02 14:29:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-2440) [py] Expand Environment feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/02 14:42:11 UTC, 0 replies.
- [GitHub] flink pull request: 3057 py con - posted by zentol <gi...@git.apache.org> on 2015/12/02 14:49:00 UTC, 0 replies.
- [jira] [Commented] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 14:49:11 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by mxm <gi...@git.apache.org> on 2015/12/02 15:40:16 UTC, 9 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 15:41:10 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an... - posted by mxm <gi...@git.apache.org> on 2015/12/02 15:43:18 UTC, 11 replies.
- [jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/02 15:44:11 UTC, 11 replies.
- [GitHub] flink pull request: [hotfix] Register signal handler for JobManage... - posted by mxm <gi...@git.apache.org> on 2015/12/02 17:18:16 UTC, 0 replies.
- [jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/02 17:25:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record - posted by "Sanjar Akhmedov (JIRA)" <ji...@apache.org> on 2015/12/02 17:43:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3100) Signal handler prints error on normal shutdown of cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/02 17:46:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/02 18:58:10 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/02 18:58:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/02 19:02:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/02 19:27:11 UTC, 5 replies.
- [jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/02 23:09:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/02 23:12:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3072) DbStateBackendTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/03 00:08:11 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3072) DbStateBackendTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/03 00:08:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/03 00:10:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2549] add topK operator to DataSet. - posted by ChengXiangLi <gi...@git.apache.org> on 2015/12/03 03:56:32 UTC, 1 replies.
- [jira] [Commented] (FLINK-2549) Add topK operator for DataSet - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/03 03:57:11 UTC, 1 replies.
- [jira] [Commented] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/03 11:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 12:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/03 13:35:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3106) ChaosMonkeyITCase failure - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 13:49:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 13:50:11 UTC, 6 replies.
- [jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 13:56:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/03 14:00:14 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 14:13:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2099) Add a SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/03 14:53:10 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-3073] Replace Streaming Mode by Memory ... - posted by aljoscha <gi...@git.apache.org> on 2015/12/03 15:22:05 UTC, 23 replies.
- [jira] [Resolved] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/03 15:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/03 17:28:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/03 17:29:10 UTC, 6 replies.
- [jira] [Resolved] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 18:09:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/03 18:26:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3098) Cast from Date to Long throw compile error. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/03 18:44:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3098) Cast from Date to Long throw compile error. - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/03 18:44:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 18:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3109) Join two streams with two different cache time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/03 22:27:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3109) Join two streams with two different cache time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/03 22:31:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2583) Add Stream Sink For Rolling HDFS Files - posted by "Roshan Naik (JIRA)" <ji...@apache.org> on 2015/12/03 23:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3110) Add support for the partition-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/04 10:52:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3110) Add support for partition-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/04 10:53:10 UTC, 1 replies.
- [jira] [Updated] (FLINK-3111) Short lived client interaction logs warning in job manager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/04 11:26:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/04 11:26:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/04 13:03:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu... - posted by uce <gi...@git.apache.org> on 2015/12/04 13:04:18 UTC, 42 replies.
- [jira] [Commented] (FLINK-2976) Save and load checkpoints manually - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/04 13:05:11 UTC, 42 replies.
- [jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/04 13:07:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 13:14:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3114) Read cluster's default parallelism upon remote job submission - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 13:15:10 UTC, 0 replies.
- [jira] [Updated] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 13:15:10 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2622][streaming]add WriteMode for write... - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/04 14:36:10 UTC, 2 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/12/04 14:36:11 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3113] Remove unused and unsupported glo... - posted by fhueske <gi...@git.apache.org> on 2015/12/04 14:57:17 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3112] Remove unused RecordModelPostPass - posted by fhueske <gi...@git.apache.org> on 2015/12/04 14:58:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/04 14:58:10 UTC, 6 replies.
- [jira] [Commented] (FLINK-3112) Remove unused RecordModelPostPass class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/04 14:58:11 UTC, 5 replies.
- [jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 15:18:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/04 15:22:10 UTC, 4 replies.
- [jira] [Created] (FLINK-3116) Remove RecordOperator - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/04 15:29:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 16:15:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/04 16:18:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/04 16:26:10 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-3102] Allow reading from multiple topic... - posted by rmetzger <gi...@git.apache.org> on 2015/12/04 17:35:38 UTC, 32 replies.
- [jira] [Commented] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/04 17:36:11 UTC, 32 replies.
- [jira] [Comment Edited] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/04 17:47:11 UTC, 2 replies.
- [jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/04 18:35:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/04 18:55:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/04 19:43:11 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3055] remove getSubTaskIndex() - posted by jaoki <gi...@git.apache.org> on 2015/12/04 20:59:34 UTC, 2 replies.
- [jira] [Commented] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/04 21:00:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/04 22:21:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3089) OperatorState timeout - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2015/12/04 23:35:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3109) Join two streams with two different cache time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/05 02:14:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3109) Join two streams with two different buffer time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/05 02:17:10 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3109) Join two streams with two different buffer time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/05 02:28:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3116) Remove RecordOperator - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/12/05 03:17:10 UTC, 9 replies.
- [jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/05 10:29:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/05 10:52:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2344) Deprecate/Remove the old Pact Pair type - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/05 11:10:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/05 11:20:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2954] Add config parameter for passing ... - posted by rmetzger <gi...@git.apache.org> on 2015/12/05 12:15:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/05 12:16:11 UTC, 1 replies.
- [jira] [Resolved] (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/12/05 15:28:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2978][web-dashboard][webclient] Integra... - posted by sachingoel0101 <gi...@git.apache.org> on 2015/12/05 16:05:33 UTC, 11 replies.
- [jira] [Commented] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/05 16:06:10 UTC, 11 replies.
- [jira] [Created] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/12/05 16:11:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3116) Remove RecordOperator - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/12/05 21:17:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-1518) Laggy task cancelling on task managers - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 18:14:10 UTC, 1 replies.
- [jira] [Closed] (FLINK-3008) Failing/restarting streaming jobs are buggy in the webfrontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/06 18:15:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3125) Web dashboard does not start when log files are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 18:18:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/06 18:23:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 18:26:10 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/12/06 18:35:10 UTC, 2 replies.
- [jira] [Assigned] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/12/06 20:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Ovidiu Marcu (JIRA)" <ji...@apache.org> on 2015/12/06 21:58:11 UTC, 1 replies.
- [jira] [Closed] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 22:35:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 22:35:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3125) Web dashboard does not start when log files are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 22:36:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3125) Web dashboard does not start when log files are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 22:36:10 UTC, 0 replies.
- [GitHub] flink pull request: Bumped the docker container to the latest vers... - posted by rmetzger <gi...@git.apache.org> on 2015/12/07 10:59:34 UTC, 2 replies.
- [jira] [Created] (FLINK-3127) Measure backpressure in Flink jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 11:11:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2379][ml]Add column wise statistics for... - posted by chiwanpark <gi...@git.apache.org> on 2015/12/07 13:07:25 UTC, 4 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/12/07 13:08:11 UTC, 4 replies.
- [jira] [Created] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "Fridtjof Sander (JIRA)" <ji...@apache.org> on 2015/12/07 13:44:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "Fridtjof Sander (JIRA)" <ji...@apache.org> on 2015/12/07 14:08:10 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3074] Add config option to start YARN A... - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/07 14:16:21 UTC, 14 replies.
- [jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/07 14:17:11 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-2828] [table] Add interfaces for Table ... - posted by twalthr <gi...@git.apache.org> on 2015/12/07 14:18:19 UTC, 3 replies.
- [jira] [Commented] (FLINK-2828) Add interfaces for Table API input formats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/07 14:19:10 UTC, 3 replies.
- [jira] [Created] (FLINK-3129) Add tooling to ensure interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 14:35:11 UTC, 0 replies.
- [GitHub] flink pull request: [contrib, connector-wikiedits] Add WikipediaEd... - posted by uce <gi...@git.apache.org> on 2015/12/07 14:36:30 UTC, 6 replies.
- [jira] [Created] (FLINK-3130) Visualize throughput of tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3131) Expose checkpoint metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:46:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/07 14:51:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3132) Restructure streaming guide - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:53:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:58:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc. - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:58:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:59:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:59:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2488) Expose attemptNumber in RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:59:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2524) Add "getTaskNameWithSubtasks()" to RuntimeContext - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 14:59:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2897] [runtime] Use distinct initial in... - posted by greghogan <gi...@git.apache.org> on 2015/12/07 15:51:05 UTC, 2 replies.
- [jira] [Updated] (FLINK-3066) Kafka source fails on leader change - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 15:59:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 16:47:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 16:47:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 16:54:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 16:54:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3134) Make YarnJobManager's allocate call asynchronous - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 17:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/07 17:08:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 17:15:11 UTC, 5 replies.
- [jira] [Commented] (FLINK-3132) Restructure streaming guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/07 18:02:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 18:25:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 18:25:12 UTC, 0 replies.
- [jira] [Closed] (FLINK-1278) Remove the Record special code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 18:26:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1278) Remove the Record special code paths - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 18:26:10 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2099) Add a SQL API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/07 20:09:11 UTC, 3 replies.
- [jira] [Created] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 20:24:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3108] [java] JoinOperator's with() call... - posted by twalthr <gi...@git.apache.org> on 2015/12/07 20:33:00 UTC, 4 replies.
- [jira] [Created] (FLINK-3137) Missing break in OutputEmitter ctor - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/07 21:50:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3137) Missing break in OutputEmitter ctor - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/07 22:14:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3137) Missing break in OutputEmitter ctor - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/07 22:21:10 UTC, 2 replies.
- [jira] [Created] (FLINK-3138) Method References are not supported as lambda expressions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 23:10:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3139) NULL values handling in Table API - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3141) Design of NULL values handling in operation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:28:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3142) CheckpointCoordinatorTest fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/08 08:22:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3112) Remove unused RecordModelPostPass class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/08 09:34:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/08 09:35:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/08 09:36:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/08 09:58:11 UTC, 32 replies.
- [jira] [Assigned] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/08 09:58:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3134) Make YarnJobManager's allocate call asynchronous - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/08 10:50:10 UTC, 19 replies.
- [jira] [Commented] (FLINK-3057) [py] Provide a way to pass information back to the plan process - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/08 12:00:13 UTC, 0 replies.
- [jira] [Created] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 13:32:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3138) Method References are not supported as lambda expressions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/08 13:57:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3144) [storm] LocalCluster prints nothing without a configured logger - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 15:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3145) Storm examples can't be run without flink-java as dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 17:28:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3145) Storm examples can't be run without flink-java as dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 17:51:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/08 18:26:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/08 18:26:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/08 18:46:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3145][storm] pin Kryo version of transi... - posted by mxm <gi...@git.apache.org> on 2015/12/08 18:54:44 UTC, 6 replies.
- [jira] [Commented] (FLINK-3145) Storm examples can't be run without flink-java as dependency - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/08 18:55:10 UTC, 6 replies.
- [jira] [Created] (FLINK-3147) HadoopOutputFormatBase should expose CLOSE_MUTEX for subuclasses - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:02:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose CLOSE_MUTEX for subuclasses - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:18:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose mutexes for subclasses - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/08 19:22:10 UTC, 2 replies.
- [jira] [Updated] (FLINK-3147) HadoopOutputFormatBase should expose mutexes for subclasses - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:22:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3147] HadoopOutputFormatBase should exp... - posted by ndimiduk <gi...@git.apache.org> on 2015/12/08 19:23:39 UTC, 9 replies.
- [jira] [Created] (FLINK-3148) Support configured serializers for shipping UDFs - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:37:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 20:20:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/08 20:23:10 UTC, 9 replies.
- [jira] [Resolved] (FLINK-3148) Support configured serializers for shipping UDFs - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 20:28:11 UTC, 0 replies.
- [GitHub] flink pull request: updated to Flink v0.10.1 - posted by romeokienzler <gi...@git.apache.org> on 2015/12/08 21:27:33 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3116] Remove RecordOperator - posted by jaoki <gi...@git.apache.org> on 2015/12/08 23:50:53 UTC, 6 replies.
- [jira] [Created] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/12/09 01:07:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/12/09 02:21:10 UTC, 3 replies.
- [jira] [Created] (FLINK-3150) Make YARN container invocation configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 09:53:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 10:17:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 10:22:11 UTC, 0 replies.
- [jira] [Updated] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 10:22:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2976) Save and load checkpoints manually - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 10:27:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 10:28:11 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 10:29:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 10:38:11 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/09 11:08:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/09 11:17:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3152) Support all comparisons for Date type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/09 11:22:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/09 11:24:10 UTC, 5 replies.
- [jira] [Created] (FLINK-3153) Support all comparisons for String type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/09 11:33:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3143] update Closure Cleaner's ASM refe... - posted by mxm <gi...@git.apache.org> on 2015/12/09 11:44:13 UTC, 1 replies.
- [jira] [Created] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 12:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3155) Update Flink docker version to latest stable Flink version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 12:38:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3155) Update Flink docker version to latest stable Flink version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 12:39:10 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2823][yarn] throw exception on file as ... - posted by mxm <gi...@git.apache.org> on 2015/12/09 13:53:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 13:54:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 13:55:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3150] Make the YARN container start inv... - posted by rmetzger <gi...@git.apache.org> on 2015/12/09 14:04:17 UTC, 0 replies.
- [jira] [Commented] (FLINK-3150) Make YARN container invocation configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 14:05:10 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/09 15:11:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3121] Emit Final Watermark in Kafka Sou... - posted by aljoscha <gi...@git.apache.org> on 2015/12/09 15:13:12 UTC, 2 replies.
- [jira] [Commented] (FLINK-3121) Watermark forwarding does not work for sources not producing any data - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 15:14:11 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3121) Watermark forwarding does not work for sources not producing any data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/09 15:15:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3073) Activate streaming mode by default - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/09 15:35:11 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 15:42:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2936] Fix ClassCastException for Event-... - posted by aljoscha <gi...@git.apache.org> on 2015/12/09 16:01:56 UTC, 3 replies.
- [jira] [Commented] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 16:02:11 UTC, 3 replies.
- [jira] [Closed] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 16:17:10 UTC, 1 replies.
- [jira] [Reopened] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 16:18:10 UTC, 0 replies.
- [jira] [Closed] (FLINK-3145) Storm examples can't be run without flink-java as dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 16:19:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-2796) CLI -q flag to supress the output does not work - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/09 16:51:10 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2796] [runtime-web] Add configurable jo... - posted by uce <gi...@git.apache.org> on 2015/12/09 16:51:10 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 17:45:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3156) FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/09 18:15:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3157) Web frontend json files contain author attribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 23:43:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3157) Web frontend json files contain author attribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 23:55:10 UTC, 2 replies.
- [jira] [Updated] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/12/10 00:28:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 10:16:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 12:20:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/10 13:19:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2769] [runtime-web] Add configurable jo... - posted by uce <gi...@git.apache.org> on 2015/12/10 13:21:11 UTC, 6 replies.
- [jira] [Commented] (FLINK-2769) Web dashboard port not configurable on client side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/10 13:21:11 UTC, 6 replies.
- [jira] [Created] (FLINK-3159) YARN AM should shutdown itself after a the job for which the AM was started has finished - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 16:41:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3156) FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 18:15:11 UTC, 0 replies.
- [jira] [Closed] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/11 11:13:11 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3134][yarn] asynchronous YarnJobManager... - posted by mxm <gi...@git.apache.org> on 2015/12/11 16:08:26 UTC, 18 replies.
- [jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 17:50:10 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3121) Watermark forwarding does not work for sources not producing any data - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/11 18:06:11 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2936) ClassCastException when using EventTimeSourceFunction in non-EventTime program - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/11 18:06:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 18:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 18:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3163) Configure Flink for NUMA systems - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 19:46:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3164) Spread out scheduling strategy - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 21:17:46 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/12 18:18:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3067] Use curator for committing offset... - posted by rmetzger <gi...@git.apache.org> on 2015/12/12 19:57:32 UTC, 14 replies.
- [jira] [Commented] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/12 19:57:46 UTC, 15 replies.
- [jira] [Resolved] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/12 20:23:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/12 20:35:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/12 21:36:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3165) [py] Add support for Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/13 14:11:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/12/13 18:12:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/12/13 18:13:46 UTC, 1 replies.
- [jira] [Created] (FLINK-3167) Stopping start-local.bat doesn't shutdown JM on W10 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/13 20:56:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-3167) Stopping start-local.bat doesn't shutdown JM on W10 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/14 01:46:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3003) Add container allocation timeout to YARN CLI - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/14 11:11:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/14 11:46:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/12/14 15:29:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/14 17:12:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2769) Web dashboard port not configurable on client side - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/14 17:37:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 17:46:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 17:59:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/14 18:11:47 UTC, 0 replies.
- [jira] [Created] (FLINK-3170) Expose task manager metrics via JMX - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/14 18:31:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3170) Expose task manager metrics via JMX - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/14 18:33:46 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3170] expose task manager metrics via J... - posted by mxm <gi...@git.apache.org> on 2015/12/14 18:40:14 UTC, 0 replies.
- [jira] [Commented] (FLINK-3163) Configure Flink for NUMA systems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:01:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:02:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:11:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:29:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:55:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-3172) Specify jobmanager port in HA mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/15 00:01:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3172) Specify jobmanager port in HA mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/15 00:01:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-766) Web interface progress monitoring for DataSources and DataSinks with splits - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/15 00:16:46 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3131] Expose checkpoint metrics - posted by uce <gi...@git.apache.org> on 2015/12/15 01:08:06 UTC, 5 replies.
- [jira] [Commented] (FLINK-3131) Expose checkpoint metrics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/15 01:08:46 UTC, 5 replies.
- [jira] [Comment Edited] (FLINK-3073) Activate streaming mode by default - posted by "Henry Saputra (JIRA)" <ji...@apache.org> on 2015/12/15 08:01:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/15 10:25:46 UTC, 2 replies.
- [jira] [Closed] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/15 11:54:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/15 11:54:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3165] [py] Windows OS support - posted by zentol <gi...@git.apache.org> on 2015/12/15 11:59:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-3165) [py] Add support for Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/15 12:00:48 UTC, 2 replies.
- [jira] [Updated] (FLINK-3130) Visualize throughput of tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/15 12:06:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2882] [core] Improve performance of str... - posted by greghogan <gi...@git.apache.org> on 2015/12/15 13:11:52 UTC, 6 replies.
- [jira] [Commented] (FLINK-2882) Improve performance of string conversions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/15 13:12:46 UTC, 6 replies.
- [jira] [Created] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/15 13:57:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/15 13:58:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3173] Bump httpclient and httpcore to v... - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/15 14:02:06 UTC, 2 replies.
- [jira] [Commented] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/15 14:02:46 UTC, 2 replies.
- [GitHub] flink pull request: Set current class loader to user-class loader ... - posted by mjsax <gi...@git.apache.org> on 2015/12/15 14:58:56 UTC, 6 replies.
- [jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/15 16:04:46 UTC, 1 replies.
- [jira] [Created] (FLINK-3174) Add merging WindowAssigner - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/15 16:04:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/15 16:14:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-2882) Improve performance of string conversions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/15 21:40:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/15 21:42:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3172] Specify JobManager port in HA mod... - posted by uce <gi...@git.apache.org> on 2015/12/15 22:50:22 UTC, 0 replies.
- [jira] [Created] (FLINK-3176) Window Apply Website Example - posted by "radu (JIRA)" <ji...@apache.org> on 2015/12/16 04:03:46 UTC, 0 replies.
- [GitHub] flink pull request: Release 0.10 - posted by guochuanzhi <gi...@git.apache.org> on 2015/12/16 05:54:34 UTC, 3 replies.
- [jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/16 11:34:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/16 11:47:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/16 14:03:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3174] Add merging WindowAssigner - posted by aljoscha <gi...@git.apache.org> on 2015/12/16 14:13:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-3174) Add merging WindowAssigner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/16 14:14:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3050] [runtime] Add UnrecoverableExcept... - posted by uce <gi...@git.apache.org> on 2015/12/16 14:16:22 UTC, 4 replies.
- [jira] [Commented] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/16 14:16:46 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-2716] [gelly java scala] New checksum m... - posted by greghogan <gi...@git.apache.org> on 2015/12/16 18:54:13 UTC, 7 replies.
- [jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/16 18:54:46 UTC, 7 replies.
- [jira] [Created] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/16 21:02:46 UTC, 0 replies.
- [GitHub] flink pull request: Trivial typo in docker-flink/README.md - posted by petervandenabeele <gi...@git.apache.org> on 2015/12/16 21:15:09 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3166] [runtime] The first program in Ob... - posted by greghogan <gi...@git.apache.org> on 2015/12/16 23:09:41 UTC, 9 replies.
- [jira] [Commented] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/16 23:09:46 UTC, 9 replies.
- [jira] [Commented] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/17 03:04:46 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/17 03:05:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser... - posted by twalthr <gi...@git.apache.org> on 2015/12/17 11:19:21 UTC, 28 replies.
- [jira] [Created] (FLINK-3180) MemoryLogger does not log direct memory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 12:48:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3180] [runtime] Log direct memory usage... - posted by uce <gi...@git.apache.org> on 2015/12/17 14:31:09 UTC, 6 replies.
- [jira] [Commented] (FLINK-3180) MemoryLogger does not log direct memory - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/17 14:31:46 UTC, 6 replies.
- [jira] [Closed] (FLINK-3134) Make YarnJobManager's allocate call asynchronous - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/17 15:21:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/17 15:27:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/17 15:27:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/17 16:20:46 UTC, 2 replies.
- [jira] [Created] (FLINK-3182) TaskManagersHandler can block web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 16:51:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3183) Display direct memory stats in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 17:34:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3181] [gelly] avoid unnecessary message... - posted by vasia <gi...@git.apache.org> on 2015/12/17 19:09:49 UTC, 3 replies.
- [jira] [Commented] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/17 19:10:46 UTC, 3 replies.
- [jira] [Created] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/17 19:51:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/17 19:55:14 UTC, 8 replies.
- [jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/17 19:55:46 UTC, 8 replies.
- [jira] [Assigned] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/17 23:18:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2971] support outer join for hash join ... - posted by ChengXiangLi <gi...@git.apache.org> on 2015/12/18 06:14:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-2971) Add outer joins to the Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/18 06:14:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/18 09:26:46 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2871] support outer join for hash join ... - posted by fhueske <gi...@git.apache.org> on 2015/12/18 11:23:10 UTC, 0 replies.
- [jira] [Commented] (FLINK-3182) TaskManagersHandler can block web frontend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/18 12:07:46 UTC, 0 replies.
- [jira] [Updated] (FLINK-3182) TaskManagersHandler can block web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/18 12:14:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3185) Silent failure during job graph recovery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/18 12:32:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/18 16:51:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3187) Decouple restart strategy from ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/18 18:31:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2015/12/18 18:52:47 UTC, 0 replies.
- [jira] [Updated] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2015/12/18 18:55:46 UTC, 0 replies.
- [GitHub] flink pull request: Introduce RestartStrategy to decouple restarti... - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/18 19:01:59 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3118] [Gelly] Consider ResultTypeQuerya... - posted by s1ck <gi...@git.apache.org> on 2015/12/18 22:08:08 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati... - posted by rawkintrevo <gi...@git.apache.org> on 2015/12/19 04:40:49 UTC, 1 replies.
- [jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/19 04:41:46 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3185] [runtime, tests] Log error on fai... - posted by uce <gi...@git.apache.org> on 2015/12/19 19:15:32 UTC, 4 replies.
- [jira] [Commented] (FLINK-3185) Silent failure during job graph recovery - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/19 19:15:46 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/21 10:46:46 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2622] [streaming] Align Scala streaming... - posted by tillrohrmann <gi...@git.apache.org> on 2015/12/21 12:10:30 UTC, 4 replies.
- [jira] [Created] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Filip Leczycki (JIRA)" <ji...@apache.org> on 2015/12/21 14:26:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/21 16:26:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/21 16:26:46 UTC, 2 replies.
- [jira] [Updated] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/21 18:29:46 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/21 18:29:46 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3103 Remove synchronization in FsStateBa... - posted by tedyu <gi...@git.apache.org> on 2015/12/21 18:30:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/21 18:31:46 UTC, 3 replies.
- [jira] [Closed] (FLINK-2622) Scala DataStream API does not have writeAsText method which supports WriteMode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:46:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-3180) MemoryLogger does not log direct memory - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:47:46 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3116) Remove RecordOperator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:47:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-7) [GitHub] Enable Range Partitioner - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:48:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-8) [GitHub] Implement automatic sample histogram building for Range Partitioning - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:50:46 UTC, 0 replies.
- [jira] [Closed] (FLINK-146) Sorted output not working - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:54:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-598) Add support for globalOrdering in DataSet API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/21 18:56:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3190) Retry rate limits for DataStream API - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2015/12/23 15:03:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/23 15:43:47 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3103] Remove synchronization in FsState... - posted by StephanEwen <gi...@git.apache.org> on 2015/12/23 17:16:11 UTC, 2 replies.
- [GitHub] flink pull request: FLINK-1737: Kronecker product - posted by daniel-pape <gi...@git.apache.org> on 2015/12/23 22:20:34 UTC, 0 replies.
- [jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/23 22:20:46 UTC, 0 replies.
- [GitHub] flink pull request: Trivial WriteMode comment fix - posted by jaoki <gi...@git.apache.org> on 2015/12/24 04:21:57 UTC, 1 replies.
- [jira] [Created] (FLINK-3191) WordCount without fileOutput - execute is missing - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2015/12/24 15:35:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-3191) WordCount without fileOutput - execute is missing - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2015/12/24 15:44:49 UTC, 2 replies.
- [GitHub] flink pull request: - posted by hash-X <gi...@git.apache.org> on 2015/12/24 17:14:45 UTC, 0 replies.
- [GitHub] flink pull request: Update PoissonSampler.java - posted by hash-X <gi...@git.apache.org> on 2015/12/24 17:20:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3191) WordCount without fileOutput - execute is missing - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2015/12/24 18:25:49 UTC, 0 replies.
- [jira] [Created] (FLINK-3192) Add explain support to print ast and sql physical execution. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/12/25 09:28:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3192] Add explain support to print ast ... - posted by gallenvara <gi...@git.apache.org> on 2015/12/25 09:31:28 UTC, 0 replies.
- [jira] [Commented] (FLINK-3192) Add explain support to print ast and sql physical execution. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/25 09:31:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-3192) Add explain support to print ast and sql physical execution plan. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/12/25 09:33:49 UTC, 1 replies.
- [jira] [Closed] (FLINK-2949) Add method 'writeSequencefile' to DataSet - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/12/27 00:55:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/27 01:00:51 UTC, 0 replies.
- [jira] [Closed] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:14:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:14:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:15:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:15:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:28:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3103) Remove synchronization in FsStateBackend#FsCheckpointStateOutputStream#close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 13:28:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3185) Silent failure during job graph recovery - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 16:34:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3185) Silent failure during job graph recovery - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/27 16:35:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/12/27 23:33:49 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3186: Deprecate DataSink.sortLocalOutput... - posted by smarthi <gi...@git.apache.org> on 2015/12/28 03:21:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/28 03:22:49 UTC, 3 replies.
- [jira] [Closed] (FLINK-2837) FlinkTopologyBuilder cannot handle multiple input streams - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/28 11:56:49 UTC, 0 replies.
- [jira] [Updated] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/28 14:37:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/28 14:37:49 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/12/28 18:32:49 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2015/12/28 20:20:49 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3115: Update ElasticSearch connector to ... - posted by smarthi <gi...@git.apache.org> on 2015/12/30 10:36:38 UTC, 2 replies.
- [GitHub] flink pull request: [streaming] [scala] Exposed environment from D... - posted by mbalassi <gi...@git.apache.org> on 2015/12/30 17:33:48 UTC, 4 replies.
- [jira] [Created] (FLINK-3193) Add optional bloomfilter to sql state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/12/30 17:50:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2974] Add periodic offset committer for... - posted by filipefigcorreia <gi...@git.apache.org> on 2015/12/30 18:13:59 UTC, 1 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/12/30 18:14:49 UTC, 1 replies.
- [jira] [Created] (FLINK-3194) Remove web client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 00:51:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 01:07:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3131) Expose checkpoint metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:34:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3131) Expose checkpoint metrics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:35:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:36:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2978) Integrate web submission interface into the new dashboard - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:36:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-734) Integrate web job client into JobManager web interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:37:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-734) Integrate web job client into JobManager web interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 15:37:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3186] Deprecate DataSink.sortLocalOutpu... - posted by StephanEwen <gi...@git.apache.org> on 2015/12/31 15:58:27 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3015) Bring Features Web Page up to speed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:10:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3015) Bring Features Web Page up to speed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:11:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-1228) Add REST Interface to JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:15:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1228) Add REST Interface to JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:15:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-3009) Cannot build docs with Jekyll 3.0.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:17:49 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3009) Cannot build docs with Jekyll 3.0.0 - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 16:17:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3194] Remove standalone web client - posted by StephanEwen <gi...@git.apache.org> on 2015/12/31 17:57:58 UTC, 1 replies.
- [jira] [Commented] (FLINK-3194) Remove web client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2015/12/31 17:58:49 UTC, 0 replies.
- [jira] [Closed] (FLINK-1331) Running examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 18:03:49 UTC, 0 replies.
- [jira] [Created] (FLINK-3195) Restructure examples projects and package streaming examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 18:07:49 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3195] [examples] Consolidate Java/Scala... - posted by StephanEwen <gi...@git.apache.org> on 2015/12/31 18:56:17 UTC, 0 replies.
- [jira] [Created] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/31 20:15:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/31 21:09:39 UTC, 0 replies.