issues@flink.apache.org, 2016-02

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

- [GitHub] flink pull request: [FLINK-2678]DataSet API does not support multi... - posted by sbcd90 <gi...@git.apache.org> on 2016/02/01 03:25:43 UTC, 21 replies.
- [jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 03:26:39 UTC, 22 replies.
- [GitHub] flink pull request: [Flink-3226] Translate logical plan into physi... - posted by ChengXiangLi <gi...@git.apache.org> on 2016/02/01 08:34:34 UTC, 20 replies.
- [GitHub] flink pull request: Enhance Partitioned State and use it in Window... - posted by aljoscha <gi...@git.apache.org> on 2016/02/01 09:26:53 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table... - posted by fhueske <gi...@git.apache.org> on 2016/02/01 09:45:41 UTC, 0 replies.
- [jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 09:46:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3033) Redis Source Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/01 09:46:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/01 09:47:39 UTC, 31 replies.
- [jira] [Created] (FLINK-3308) [py] Remove debug mode - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/01 10:02:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan... - posted by asfgit <gi...@git.apache.org> on 2016/02/01 10:11:55 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3300) Concurrency Bug in Yarn JobManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 10:12:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 10:12:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/01 10:13:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2016/02/01 10:45:39 UTC, 5 replies.
- [jira] [Issue Comment Deleted] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:29:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:45:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3177) Add Stream Operator that Discards Late Elements - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:56:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:56:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/02/01 11:56:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3309) [py] Resolve maven warnings - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/01 12:05:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3033) Redis Source Connector - posted by "subhankar biswas (JIRA)" <ji...@apache.org> on 2016/02/01 12:31:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3034) Redis SInk Connector - posted by "subhankar biswas (JIRA)" <ji...@apache.org> on 2016/02/01 12:31:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3307) RMQSourceTest failure - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 12:36:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 12:37:39 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 12:38:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3301 Ineffective synchronization in Mess... - posted by mxm <gi...@git.apache.org> on 2016/02/01 12:39:32 UTC, 2 replies.
- [jira] [Commented] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 12:39:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT... - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/01 13:36:50 UTC, 37 replies.
- [jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 13:37:39 UTC, 37 replies.
- [GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/02/01 13:52:34 UTC, 33 replies.
- [jira] [Commented] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 13:52:40 UTC, 35 replies.
- [jira] [Assigned] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 14:08:40 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2055) Implement Streaming HBaseSink - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2016/02/01 15:11:39 UTC, 1 replies.
- [GitHub] flink pull request: FLINK-3254: Adding functionality to support th... - posted by kl0u <gi...@git.apache.org> on 2016/02/01 15:38:55 UTC, 13 replies.
- [jira] [Commented] (FLINK-3254) CombineFunction interface not respected - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 15:39:40 UTC, 13 replies.
- [jira] [Closed] (FLINK-3306) Auto type registration at Kryo is buggy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 16:00:45 UTC, 0 replies.
- [jira] [Closed] (FLINK-3305) Remove JavaKaffee serializer util - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 16:00:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3306) Auto type registration at Kryo is buggy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 16:00:45 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3305) Remove JavaKaffee serializer util - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 16:00:45 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3296] Remove 'flushing' behavior of the... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/01 16:04:48 UTC, 7 replies.
- [jira] [Commented] (FLINK-3296) DataStream.write*() methods are not flushing properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 16:05:39 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3265][tests] adapt RabbitMQ checkpointi... - posted by mxm <gi...@git.apache.org> on 2016/02/01 16:35:45 UTC, 3 replies.
- [jira] [Commented] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 16:36:40 UTC, 3 replies.
- [GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar - posted by abhishekagarwal87 <gi...@git.apache.org> on 2016/02/01 16:52:25 UTC, 14 replies.
- [jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 16:52:39 UTC, 14 replies.
- [jira] [Closed] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 16:58:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2348) IterateExampleITCase failing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 17:12:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/02/01 17:42:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3303] Move all non-batch specific class... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/01 18:55:06 UTC, 3 replies.
- [jira] [Commented] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 18:55:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/01 18:56:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato... - posted by greghogan <gi...@git.apache.org> on 2016/02/01 19:48:51 UTC, 7 replies.
- [jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 19:49:39 UTC, 7 replies.
- [jira] [Created] (FLINK-3310) Add back pressure statistics to web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/01 20:12:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/01 20:56:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3312) Add convenience accessor methods for extended state interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/01 21:58:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3312] State enhancements convenience me... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/01 22:15:22 UTC, 2 replies.
- [jira] [Commented] (FLINK-3312) Add convenience accessor methods for extended state interface - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/01 22:15:39 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/02 07:04:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3208] [gelly] rename vertex-centric ite... - posted by vasia <gi...@git.apache.org> on 2016/02/02 09:53:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 09:53:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3049] move Either type to org.apache.fl... - posted by vasia <gi...@git.apache.org> on 2016/02/02 10:54:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 10:54:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 10:59:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3128] [flink-ml] Add Isotonic Regressio... - posted by f-sander <gi...@git.apache.org> on 2016/02/02 11:00:51 UTC, 9 replies.
- [jira] [Commented] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 11:01:39 UTC, 9 replies.
- [jira] [Resolved] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/02 11:11:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2736) Failing KafkaConsumerTestBase.runCancelingOnEmptyInputTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 11:34:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3035) Redis as State Backend - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/02 11:53:39 UTC, 29 replies.
- [GitHub] flink pull request: FLINK-2380: allow to specify the default files... - posted by kl0u <gi...@git.apache.org> on 2016/02/02 11:56:18 UTC, 12 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 11:56:39 UTC, 12 replies.
- [jira] [Created] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 11:56:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 12:06:39 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3216] [FLINK-3217] [cep] Initial versio... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/02 12:12:47 UTC, 2 replies.
- [jira] [Commented] (FLINK-3216) Define pattern specification - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 12:13:39 UTC, 2 replies.
- [jira] [Created] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 12:17:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3287] [FLINK-3247] Fix curator shading ... - posted by rmetzger <gi...@git.apache.org> on 2016/02/02 12:18:48 UTC, 3 replies.
- [jira] [Created] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/02 12:23:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3187] Introduce RestartStrategy to deco... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/02 12:29:12 UTC, 11 replies.
- [jira] [Commented] (FLINK-3187) Decouple restart strategy from ExecutionGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 12:29:39 UTC, 11 replies.
- [jira] [Commented] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/02/02 12:43:39 UTC, 48 replies.
- [jira] [Created] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/02 13:41:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 13:53:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2915) JobManagerProcessFailureBatchRecoveryITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 14:04:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/02 14:10:39 UTC, 11 replies.
- [jira] [Comment Edited] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 14:14:39 UTC, 3 replies.
- [GitHub] flink pull request: Scala DataStream&DataStreamUtils accessors fix - posted by mbalassi <gi...@git.apache.org> on 2016/02/02 14:29:02 UTC, 7 replies.
- [jira] [Created] (FLINK-3317) Add timeout handler to CEP operator - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:34:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3318) Add support for quantifiers to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:42:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3319) Add or operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:50:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 14:53:39 UTC, 12 replies.
- [jira] [Created] (FLINK-3320) Add not operator to CEP's pattern API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 14:53:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3216) Define pattern specification - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 15:10:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3216) Define pattern specification - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 15:10:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3217) Implement NFA for pattern detection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 15:10:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3217) Implement NFA for pattern detection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 15:11:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3215) Add CEP library to Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 15:11:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 15:21:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 15:25:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 15:40:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/02 15:40:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3035) Redis as State Backend - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/02/02 15:58:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 16:09:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 16:21:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 16:22:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 16:26:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/02 16:31:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3207] [gelly] adds the vertex-centric i... - posted by vasia <gi...@git.apache.org> on 2016/02/02 17:13:47 UTC, 0 replies.
- [jira] [Commented] (FLINK-3207) Add a Pregel iteration abstraction to Gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 17:14:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/02 17:23:39 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix][yarn] Shutdown JVM when Flink-on-yarn... - posted by rmetzger <gi...@git.apache.org> on 2016/02/02 17:30:08 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3313] [kafka] Fix concurrent TypeInform... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/02 17:42:02 UTC, 10 replies.
- [jira] [Commented] (FLINK-3310) Add back pressure statistics to web frontend - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/02 18:01:40 UTC, 13 replies.
- [jira] [Commented] (FLINK-2803) Add test case for Flink's memory allocation - posted by "Lokesh Ravindranathan (JIRA)" <ji...@apache.org> on 2016/02/02 18:10:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3310] [runtime, runtime-web] Add back p... - posted by uce <gi...@git.apache.org> on 2016/02/02 18:21:32 UTC, 10 replies.
- [jira] [Resolved] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:24:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3049) Move "Either" type to package "org.apache.flink.types" - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:24:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:25:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:25:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2348) IterateExampleITCase failing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:25:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-2348) IterateExampleITCase failing - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:25:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:26:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3314) Early cancel calls can cause Tasks to not cancel properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/02 18:26:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Add DataSet scan and conversion t... - posted by fhueske <gi...@git.apache.org> on 2016/02/02 22:15:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 22:15:39 UTC, 100 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by mjsax <gi...@git.apache.org> on 2016/02/02 22:36:21 UTC, 36 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/02 22:36:40 UTC, 36 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/03 03:26:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3034][Streaming Connectors] Redis Sink ... - posted by subhankarb <gi...@git.apache.org> on 2016/02/03 04:28:57 UTC, 29 replies.
- [jira] [Closed] (FLINK-3127) Measure backpressure in Flink jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/03 10:10:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2935] [scala-shell] Allow Scala shell t... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/03 11:45:05 UTC, 4 replies.
- [jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/03 11:45:39 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3313) Kafka08ITCase.testOneSourceMultiplePartitions fails with EOFException - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/03 14:34:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3323) Nifi connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:33:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3324) Flume connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:33:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3323) Nifi connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:35:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3324) Flume connector not documented - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/03 15:38:39 UTC, 3 replies.
- [jira] [Created] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/03 15:42:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/03 15:46:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3325) Unclosed InputStream in CEPPatternOperator#restoreState() - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/03 15:54:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic - posted by "Farouk Salem (JIRA)" <ji...@apache.org> on 2016/02/03 16:36:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/03 16:42:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3161][dist] Externalize cluster start-u... - posted by fhueske <gi...@git.apache.org> on 2016/02/03 16:56:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/03 16:56:40 UTC, 2 replies.
- [jira] [Closed] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic - posted by "Farouk Salem (JIRA)" <ji...@apache.org> on 2016/02/03 17:09:39 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix, yarn] Exit JVM after YARN actor syste... - posted by uce <gi...@git.apache.org> on 2016/02/03 17:25:38 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/02/03 17:41:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3324) Flume connector not documented - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/03 18:20:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/02/03 18:53:39 UTC, 0 replies.
- [GitHub] flink pull request: ExecutionConfig to JobGraph. - posted by kl0u <gi...@git.apache.org> on 2016/02/03 19:39:02 UTC, 2 replies.
- [jira] [Created] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/03 21:06:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3293] Respect custom cli yarn name in j... - posted by rmetzger <gi...@git.apache.org> on 2016/02/03 21:10:41 UTC, 2 replies.
- [jira] [Commented] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/03 21:11:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/03 21:29:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-2719) ProcessFailureStreamingRecoveryITCase>AbstractProcessFailureRecoveryTest.testTaskManagerProcessFailure failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/03 21:30:39 UTC, 3 replies.
- [jira] [Closed] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/04 00:30:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/04 00:30:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3254) CombineFunction interface not respected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/04 00:31:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/04 00:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/04 05:05:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/04 05:19:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3330) Add SparseVector support to BLAS library in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/04 06:07:39 UTC, 6 replies.
- [jira] [Created] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 09:09:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3234) SortPartition does not support KeySelectorFunctions - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/04 09:56:39 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 10:57:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2213) Configure number of vcores - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/02/04 11:16:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3311) Add a connector for streaming data into Cassandra - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 11:16:40 UTC, 1 replies.
- [jira] [Created] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 11:21:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 11:27:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3332) Provide an exactly-once Cassandra connector - posted by "Andrea Sella (JIRA)" <ji...@apache.org> on 2016/02/04 11:32:40 UTC, 74 replies.
- [jira] [Created] (FLINK-3333) Documentation about object reuse should be improved - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/04 11:37:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2523: making the task cancellation inter... - posted by kl0u <gi...@git.apache.org> on 2016/02/04 11:40:26 UTC, 0 replies.
- [jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 11:40:39 UTC, 19 replies.
- [jira] [Commented] (FLINK-3221) Move Table API on top of Apache Calcite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 11:41:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 11:52:39 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3328] Incorrectly shaded dependencies i... - posted by rmetzger <gi...@git.apache.org> on 2016/02/04 12:20:57 UTC, 4 replies.
- [jira] [Commented] (FLINK-3201) Enhance Partitioned State Interface with State Types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 13:11:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3234] [dataSet] Add KeySelector support... - posted by chiwanpark <gi...@git.apache.org> on 2016/02/04 13:18:39 UTC, 33 replies.
- [jira] [Commented] (FLINK-3234) SortPartition does not support KeySelectorFunctions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 13:18:39 UTC, 33 replies.
- [GitHub] flink pull request: [FLINK-3329] Auto-Close BackupEngine in Abstra... - posted by aljoscha <gi...@git.apache.org> on 2016/02/04 13:27:36 UTC, 1 replies.
- [jira] [Commented] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 13:27:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 13:27:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/04 13:31:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3335) DataSourceTask object reuse when disabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 14:45:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3328) Incorrectly shaded dependencies in flink-runtime - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/04 15:25:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/04 15:53:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/04 15:53:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3330] [ml] Fix SparseVector support in ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/04 16:17:45 UTC, 7 replies.
- [GitHub] flink pull request: - posted by uce <gi...@git.apache.org> on 2016/02/04 16:20:35 UTC, 15 replies.
- [jira] [Commented] (FLINK-3335) DataSourceTask object reuse when disabled - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/04 16:38:39 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 16:53:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa... - posted by rmetzger <gi...@git.apache.org> on 2016/02/04 17:20:21 UTC, 1 replies.
- [jira] [Commented] (FLINK-3093) Introduce annotations for interface stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 17:20:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 18:28:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 18:39:39 UTC, 18 replies.
- [jira] [Created] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 18:39:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 19:14:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2213 Makes the number of vcores per YARN... - posted by kl0u <gi...@git.apache.org> on 2016/02/04 19:15:36 UTC, 15 replies.
- [jira] [Commented] (FLINK-2213) Configure number of vcores - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/04 19:15:39 UTC, 15 replies.
- [jira] [Commented] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 19:28:40 UTC, 5 replies.
- [jira] [Updated] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 19:32:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/04 19:41:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3329) Unclosed BackupEngine in AbstractRocksDBState#snapshot() - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 19:50:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3339) Checkpointing NPE when using filterWithState - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/04 20:11:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3336] Add Semi-Rebalance Data Shipping ... - posted by aljoscha <gi...@git.apache.org> on 2016/02/04 20:21:17 UTC, 7 replies.
- [jira] [Commented] (FLINK-3339) Checkpointing NPE when using filterWithState - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/04 20:33:39 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/04 21:19:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3338] [kafka] Use proper classloader wh... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/04 21:20:46 UTC, 3 replies.
- [jira] [Created] (FLINK-3340) Fix object juggling in reduce drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/04 23:17:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2721] [Storm Compatibility] Add Tuple m... - posted by mjsax <gi...@git.apache.org> on 2016/02/05 00:17:13 UTC, 10 replies.
- [jira] [Commented] (FLINK-2721) Add Tuple meta information - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/05 00:17:39 UTC, 11 replies.
- [jira] [Updated] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/05 01:53:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/05 01:54:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/05 01:54:39 UTC, 5 replies.
- [jira] [Commented] (FLINK-1733) Add PCA to machine learning library - posted by "Thang Nguyen (JIRA)" <ji...@apache.org> on 2016/02/05 02:07:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-1873) Distributed matrix implementation - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/02/05 02:42:40 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1733) Add PCA to machine learning library - posted by "Thang Nguyen (JIRA)" <ji...@apache.org> on 2016/02/05 03:15:40 UTC, 1 replies.
- [jira] [Created] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/05 07:08:39 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] [docs] Fixed typo in process model il... - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/05 09:27:06 UTC, 1 replies.
- [jira] [Commented] (FLINK-3327) Attach the ExecutionConfig to the JobGraph and make it accessible to the AbstractInvocable. - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/02/05 11:14:39 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-3336] Add Rescale Data Shipping for Dat... - posted by aljoscha <gi...@git.apache.org> on 2016/02/05 11:20:01 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3120] [runtime] Manually configure Nett... - posted by uce <gi...@git.apache.org> on 2016/02/05 11:21:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/05 11:21:39 UTC, 4 replies.
- [jira] [Created] (FLINK-3342) Operator checkpoint statistics state size overflow - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/05 11:49:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3342) Operator checkpoint statistics state size overflow - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/05 11:53:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3330) Add SparseVector support to GradientDescent in FlinkML - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 11:55:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/02/05 11:56:39 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-1731) Add kMeans clustering algorithm to machine learning library - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2016/02/05 11:56:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-3333) Documentation about object reuse should be improved - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/05 11:57:40 UTC, 4 replies.
- [jira] [Created] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Farouk Salem (JIRA)" <ji...@apache.org> on 2016/02/05 13:28:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3343) Exception while using Kafka 0.9 connector - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/05 13:39:39 UTC, 10 replies.
- [jira] [Created] (FLINK-3344) EventTimeWindowCheckpointingITCase.testPreAggregatedTumblingTimeWindow - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/05 13:49:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 14:09:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3338) Kafka deserialization issue - ClassNotFoundException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 14:10:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3339) Checkpointing NPE when using filterWithState - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/05 14:18:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3093) Introduce annotations for interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/05 14:45:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3339] Make ValueState.update(null) act ... - posted by aljoscha <gi...@git.apache.org> on 2016/02/05 14:47:40 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2131][ml]: Initialization schemes for k... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/05 14:49:38 UTC, 13 replies.
- [jira] [Commented] (FLINK-2131) Add Initialization schemes for K-means clustering - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/05 14:49:40 UTC, 13 replies.
- [jira] [Created] (FLINK-3345) Restart TaskManager in case of a Akka quarantine event - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 15:47:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3346) Replace Akka death watch with own heartbeats - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 15:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 16:03:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 16:04:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 16:06:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 16:06:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3345) Restart TaskManager in case of a Akka quarantine event - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 16:07:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 16:09:39 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3347) TaskManager ActorSystems need to restart themselves in case they notice quarantine - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/05 16:09:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/05 16:34:39 UTC, 9 replies.
- [jira] [Commented] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/05 17:14:39 UTC, 2 replies.
- [jira] [Issue Comment Deleted] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/05 17:19:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/05 17:19:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3253) deserializeObject exception on WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/05 17:21:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3227) Translate physical Table API plan into DataSet program - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/05 17:21:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3227) Translate physical Table API plan into DataSet program - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/05 17:22:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/05 17:37:39 UTC, 6 replies.
- [jira] [Created] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation - posted by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/02/05 17:52:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Implement a CodeGenerator for an ... - posted by twalthr <gi...@git.apache.org> on 2016/02/05 17:53:32 UTC, 13 replies.
- [jira] [Created] (FLINK-3349) planVisualizer doesn't work! - posted by "Riccardo Diomedi (JIRA)" <ji...@apache.org> on 2016/02/05 18:14:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3349) planVisualizer doesn't work! - posted by "Riccardo Diomedi (JIRA)" <ji...@apache.org> on 2016/02/05 18:18:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3349) PlanVisualizer doesn't work - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/05 19:00:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-3349) PlanVisualizer doesn't work - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/05 19:32:39 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/05 20:41:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3337] [runtime] mvn test fails on flink... - posted by greghogan <gi...@git.apache.org> on 2016/02/05 22:53:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/02/06 12:21:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3349) PlanVisualizer doesn't work - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/06 13:10:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/06 13:15:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/06 13:21:39 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3341] Make 'auto.offset.reset' compatib... - posted by rmetzger <gi...@git.apache.org> on 2016/02/06 13:29:29 UTC, 5 replies.
- [jira] [Resolved] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/06 14:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/06 15:47:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3351) RocksDB Backend cannot determine correct local db path - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 21:12:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2021) Rework examples to use ParameterTool - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/06 22:09:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 22:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3353) CSV-related tests may fail depending on locale - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/06 22:56:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3353] CSV-related tests may fail depend... - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/06 23:00:16 UTC, 2 replies.
- [jira] [Commented] (FLINK-3353) CSV-related tests may fail depending on locale - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/06 23:00:40 UTC, 2 replies.
- [jira] [Created] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/06 23:30:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/07 00:05:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Dongwon Kim (JIRA)" <ji...@apache.org> on 2016/02/07 15:02:39 UTC, 21 replies.
- [jira] [Commented] (FLINK-3351) RocksDB Backend cannot determine correct local db path - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 19:10:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/07 19:38:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2504) ExternalSortLargeRecordsITCase.testSortWithLongAndShortRecordsMixed failed spuriously - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/07 19:39:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2721) Add Tuple meta information - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/07 19:43:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3357) Drop JobId.toShortString() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:48:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:54:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3359) Make RocksDB file copies asynchronous - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:56:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3312) Add convenience accessor methods for extended state interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:57:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3312) Add convenience accessor methods for extended state interface - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 20:57:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3358) Create constructors for FsStateBackend in RocksDBBackens - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/07 21:00:40 UTC, 2 replies.
- [jira] [Created] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/07 21:04:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3357) Drop JobId.toShortString() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/07 21:10:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3357) Drop JobId.toShortString() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/07 21:11:39 UTC, 3 replies.
- [jira] [Created] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/07 21:17:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1870] Reintroduce indexed reader functi... - posted by mjsax <gi...@git.apache.org> on 2016/02/07 23:36:49 UTC, 0 replies.
- [jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/07 23:37:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/07 23:38:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/08 00:29:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/08 09:37:39 UTC, 11 replies.
- [jira] [Closed] (FLINK-3362) Potential overflow in NettyBufferPool#getNumberOfAllocatedBytes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 09:45:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 09:48:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 09:48:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 09:54:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/08 11:28:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 11:36:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3360) Clear up StateBackend, AbstractStateBackend abstractions - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 11:45:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3354) RocksDB should compute checkpoint size based on backup file size - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 11:50:39 UTC, 9 replies.
- [jira] [Created] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 11:52:39 UTC, 0 replies.
- [jira] [Updated] (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 2016/02/08 12:00:42 UTC, 0 replies.
- [jira] [Closed] (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 2016/02/08 12:01:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/08 12:07:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/08 12:22:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/08 12:23:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 12:26:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3339) Checkpointing NPE when using filterWithState - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 13:04:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 13:10:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3336) Add Semi-Rebalance Data Shipping for DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 13:14:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 13:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/08 13:39:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/08 13:43:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3035) Redis as State Backend - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/08 13:53:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3366] Rename @Experimental annotation t... - posted by fhueske <gi...@git.apache.org> on 2016/02/08 14:16:21 UTC, 5 replies.
- [jira] [Commented] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 14:16:39 UTC, 5 replies.
- [jira] [Closed] (FLINK-3353) CSV-related tests may fail depending on locale - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/08 15:01:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3348) taskmanager.memory.off-heap missing bc documentation - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/08 15:03:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Translate logical aggregations to... - posted by vasia <gi...@git.apache.org> on 2016/02/08 15:05:46 UTC, 27 replies.
- [jira] [Closed] (FLINK-3310) Add back pressure statistics to web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 15:06:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3367] [core] Drop AbstractID#toShortStr... - posted by uce <gi...@git.apache.org> on 2016/02/08 16:08:52 UTC, 0 replies.
- [jira] [Commented] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 16:09:39 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3278) Add Partitioned State Backend Based on RocksDB - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 16:20:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3201) Enhance Partitioned State Interface with State Types - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/08 16:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/08 16:26:39 UTC, 4 replies.
- [jira] [Created] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/08 16:38:39 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] typo IllegalArgumentException - posted by alkagin <gi...@git.apache.org> on 2016/02/08 16:39:29 UTC, 3 replies.
- [jira] [Created] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 16:40:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3243] Fix Interplay of TimeCharacterist... - posted by rmetzger <gi...@git.apache.org> on 2016/02/08 16:48:24 UTC, 13 replies.
- [jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 16:48:39 UTC, 13 replies.
- [GitHub] flink pull request: [FLINK-3357] [core] Drop AbstractID#toShortStr... - posted by aljoscha <gi...@git.apache.org> on 2016/02/08 16:50:49 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2237] [runtime] Add hash-based combiner... - posted by ggevay <gi...@git.apache.org> on 2016/02/08 16:54:50 UTC, 70 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 16:55:40 UTC, 70 replies.
- [jira] [Commented] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:04:39 UTC, 5 replies.
- [jira] [Updated] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:05:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:05:39 UTC, 24 replies.
- [GitHub] flink pull request: [FLINK-1966][ml]Add support for Predictive Mod... - posted by chobeat <gi...@git.apache.org> on 2016/02/08 17:08:21 UTC, 10 replies.
- [jira] [Commented] (FLINK-1966) Add support for predictive model markup language (PMML) - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 17:08:39 UTC, 10 replies.
- [jira] [Commented] (FLINK-2696) ZookeeperOffsetHandlerTest.runOffsetManipulationinZooKeeperTest failed on Travis - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/08 17:13:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3370) Add an aligned version of the window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:16:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3370) Add an aligned version of the window operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:16:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:18:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3371] [api breaking] Move TriggerResult... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/08 17:19:46 UTC, 3 replies.
- [jira] [Commented] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 17:20:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:34:39 UTC, 7 replies.
- [jira] [Comment Edited] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:35:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 17:39:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3334] [conf] Include year-month-day in ... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/08 17:44:52 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-2991] Add Folding State and use in Wind... - posted by aljoscha <gi...@git.apache.org> on 2016/02/08 17:48:42 UTC, 16 replies.
- [jira] [Commented] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/08 17:49:39 UTC, 16 replies.
- [jira] [Created] (FLINK-3372) Setting custom YARN application name is ignored - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/02/08 18:39:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3372) Setting custom YARN application name is ignored - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/08 18:46:39 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-3367] Add PublicEvolving and Internal a... - posted by fhueske <gi...@git.apache.org> on 2016/02/08 18:54:44 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3372] Setting custom YARN application n... - posted by ndimiduk <gi...@git.apache.org> on 2016/02/08 19:30:44 UTC, 7 replies.
- [jira] [Assigned] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/08 20:03:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3355] [rocksdb backend] Allow passing o... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/08 20:14:33 UTC, 3 replies.
- [jira] [Updated] (FLINK-3066) Kafka producer fails on leader change - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/08 21:15:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3066) Kafka producer fails on leader change - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/08 21:18:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/08 22:20:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3340) Fix object juggling in drivers - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/08 23:09:40 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3357) Drop JobId.toShortString() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:07:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:08:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3357) Drop JobId.toShortString() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:08:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3334) Change default log4j.properties Conversion pattern to include year-month-day in the timestamp - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:08:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:09:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:09:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3363) JobManager does not shut down dedicated executor properly - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:09:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3365) BlobLibraryCacheManager does not shutdown Timer thread - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:09:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:10:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3361) Wrong error messages for execution retry delay and akka ask pause config values - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:10:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:10:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:10:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:11:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3337) mvn test fails on flink-runtime because curator classes not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 00:11:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1502) Expose metrics to graphite, ganglia and JMX. - posted by "Dongwon Kim (JIRA)" <ji...@apache.org> on 2016/02/09 08:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Jakob Sultan Ericsson (JIRA)" <ji...@apache.org> on 2016/02/09 09:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/09 10:02:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/09 10:12:18 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3359) Make RocksDB file copies asynchronous - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/09 10:15:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/09 10:32:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2832) Failing test: RandomSamplerTest.testReservoirSamplerWithReplacement - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/09 11:01:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:45:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docsq - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:56:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:56:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3376) Add an illustration of Event Time and Watermarks to the docs - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 11:57:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 12:01:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/09 12:11:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3375) Allow Watermark Generation in the Kafka Source - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/09 15:42:18 UTC, 10 replies.
- [jira] [Created] (FLINK-3377) Remove final flag from ResultPatitionWriter class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/09 15:49:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3377) Remove final flag from ResultPartitionWriter class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/09 15:50:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3377] Remove final flag from ResultPart... - posted by zentol <gi...@git.apache.org> on 2016/02/09 15:51:53 UTC, 4 replies.
- [jira] [Commented] (FLINK-3377) Remove final flag from ResultPartitionWriter class - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 15:52:18 UTC, 4 replies.
- [jira] [Commented] (FLINK-3333) Documentation about object reuse should be improved - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/09 15:54:18 UTC, 14 replies.
- [jira] [Created] (FLINK-3378) Consolidate TestingCluster and FokableFlinkMiniCluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/09 16:13:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3107] [runtime] Start checkpoint ID cou... - posted by uce <gi...@git.apache.org> on 2016/02/09 16:14:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 16:15:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3109]Join two streams with two differen... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/09 16:50:46 UTC, 0 replies.
- [jira] [Commented] (FLINK-3109) Join two streams with two different buffer time - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 16:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3379) Refactor TimestampExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/09 16:53:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:07:18 UTC, 1 replies.
- [GitHub] flink pull request: Increase test timeouts - posted by uce <gi...@git.apache.org> on 2016/02/09 17:09:53 UTC, 4 replies.
- [jira] [Commented] (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 2016/02/09 17:15:18 UTC, 0 replies.
- [jira] [Updated] (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 2016/02/09 17:15:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3356) JobClientActorRecoveryITCase.testJobClientRecovery - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:15:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:48:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/09 17:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 17:52:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3381) Unstable Test: JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:52:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3380) Unstable Test: JobSubmissionFailsITCase - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/09 17:53:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3383) Separate Maven deployment from CI testing - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/09 18:30:18 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2523: Makes the task cancellation interv... - posted by kl0u <gi...@git.apache.org> on 2016/02/09 18:44:45 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-3260] [runtime] Enforce terminal state ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/09 18:54:07 UTC, 8 replies.
- [jira] [Commented] (FLINK-3260) ExecutionGraph gets stuck in state FAILING - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 18:54:18 UTC, 9 replies.
- [jira] [Updated] (FLINK-3335) Fix DataSourceTask object reuse when disabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 19:21:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 19:32:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3382] Improve clarity of object reuse i... - posted by greghogan <gi...@git.apache.org> on 2016/02/09 20:13:17 UTC, 3 replies.
- [jira] [Commented] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 20:13:18 UTC, 3 replies.
- [jira] [Closed] (FLINK-3382) Improve clarity of object reuse in ReusingMutableToRegularIteratorWrapper - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 21:02:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3333) Documentation about object reuse should be improved - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/09 21:08:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3373] [build] Shade away Hadoop's HTTP ... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/09 21:21:54 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3335] [runtime] Fix DataSourceTask obje... - posted by greghogan <gi...@git.apache.org> on 2016/02/09 22:02:15 UTC, 3 replies.
- [jira] [Commented] (FLINK-3335) Fix DataSourceTask object reuse when disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/09 22:02:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3035] Redis as State Backend - posted by sbcd90 <gi...@git.apache.org> on 2016/02/10 03:03:57 UTC, 23 replies.
- [jira] [Closed] (FLINK-3256) Invalid execution graph cleanup for jobs with colocation groups - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/02/10 11:00:27 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1723] [ml] [WIP] Add cross validation f... - posted by chobeat <gi...@git.apache.org> on 2016/02/10 12:04:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-1723) Add cross validation for model evaluation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/10 12:04:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3234) SortPartition does not support KeySelectorFunctions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/10 12:07:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3366) Rename @Experimental annotation to @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/10 12:07:18 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Fixed typo in Storm Compatibility page - posted by geoand <gi...@git.apache.org> on 2016/02/10 13:35:08 UTC, 3 replies.
- [jira] [Closed] (FLINK-3372) Setting custom YARN application name is ignored - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:23:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3372) Setting custom YARN application name is ignored - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:23:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:51:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3373) Using a newer library of Apache HttpClient than 4.2.6 will get class loading problems - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3384) Create atomic closable queue for communication between Kafka Threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 15:59:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3383] remove Maven deployment from Trav... - posted by mxm <gi...@git.apache.org> on 2016/02/10 15:59:28 UTC, 4 replies.
- [jira] [Commented] (FLINK-3383) Separate Maven deployment from CI testing - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/10 16:00:25 UTC, 4 replies.
- [GitHub] flink pull request: FLINK-3327: ExecutionConfig to JobGraph. - posted by kl0u <gi...@git.apache.org> on 2016/02/10 16:08:00 UTC, 17 replies.
- [GitHub] flink pull request: [FLINK-3332] Cassandra connector - posted by zentol <gi...@git.apache.org> on 2016/02/10 16:19:38 UTC, 24 replies.
- [jira] [Closed] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:56:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3260) ExecutionGraph gets stuck in state FAILING - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:56:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3260) ExecutionGraph gets stuck in state FAILING - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:56:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3350) Increase timeouts on Travis Builds - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:56:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:57:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3341) Kafka connector's 'auto.offset.reset' inconsistent with Kafka - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 17:57:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3228) Cannot submit multiple streaming involving JDBC drivers - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/02/10 18:23:18 UTC, 2 replies.
- [jira] [Closed] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/10 19:53:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/10 20:07:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/10 20:26:18 UTC, 11 replies.
- [jira] [Updated] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/10 20:54:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/10 22:17:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 22:44:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3371) Move TriggerCotext and TriggerResult to their own classes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 22:44:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3384) Create atomic closable queue for communication between Kafka Threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 22:44:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3384) Create atomic closable queue for communication between Kafka Threads - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/10 22:44:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode - posted by "Klou (JIRA)" <ji...@apache.org> on 2016/02/11 00:32:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3270] Add Kafka example - posted by fhueske <gi...@git.apache.org> on 2016/02/11 10:26:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-3270) Add example for reading and writing to Kafka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/11 10:27:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3369] [runtime] Make RemoteTransportExc... - posted by uce <gi...@git.apache.org> on 2016/02/11 11:48:04 UTC, 3 replies.
- [jira] [Commented] (FLINK-2824) Iteration feedback partitioning does not work as expected - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 12:01:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-2824) Iteration feedback partitioning does not work as expected - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/11 12:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/11 12:28:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/11 12:28:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/11 12:28:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/11 12:31:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/11 12:33:18 UTC, 2 replies.
- [jira] [Closed] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/11 12:34:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3299) Remove ApplicationID from Environment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 12:47:18 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-2428] Clean up unused properties in Str... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/11 12:50:27 UTC, 0 replies.
- [jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/11 12:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 14:07:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3170) Expose task manager metrics via JMX - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/11 14:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3388) Expose task accumulators via JMX - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/11 14:30:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3369) RemoteTransportException should be instance of CancelTaskException - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 14:41:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3283) Failed Kafka 0.9 test on duplicate message - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 14:43:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3364] [runtime, yarn] Move SavepointSto... - posted by uce <gi...@git.apache.org> on 2016/02/11 15:02:43 UTC, 2 replies.
- [jira] [Commented] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/11 15:03:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 15:33:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3390) Savepoint resume is not retried - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/02/11 15:40:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 15:41:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3355) Allow passing RocksDB Option to RocksDBStateBackend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 15:41:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3390) Savepoint resume is not retried - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/02/11 15:41:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3391) Typo in SavepointITCase - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/02/11 15:48:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3391) Typo in SavepointITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 16:14:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats - posted by mliesenberg <gi...@git.apache.org> on 2016/02/11 16:44:11 UTC, 3 replies.
- [jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/11 16:44:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3368][Kafka 0.8] Handle leader changes ... - posted by rmetzger <gi...@git.apache.org> on 2016/02/11 18:47:26 UTC, 17 replies.
- [jira] [Commented] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/02/11 18:52:18 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Vijay Srinivasaraghavan (JIRA)" <ji...@apache.org> on 2016/02/11 18:53:18 UTC, 2 replies.
- [jira] [Updated] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/11 18:59:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/11 19:03:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Translation from and to POJOs for... - posted by twalthr <gi...@git.apache.org> on 2016/02/11 20:11:36 UTC, 16 replies.
- [jira] [Closed] (FLINK-3364) Don't initialize SavepointStore in JobManager constructor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/11 20:51:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 21:50:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3374) CEPITCase testSimplePatternEventTime fails - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 21:50:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 22:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 22:03:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 22:04:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3351) RocksDB Backend cannot determine correct local db path - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 22:06:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3351) RocksDB Backend cannot determine correct local db path - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/11 22:07:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3340] [runtime] Fix object juggling in ... - posted by greghogan <gi...@git.apache.org> on 2016/02/11 22:50:36 UTC, 10 replies.
- [jira] [Commented] (FLINK-3340) Fix object juggling in drivers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/11 22:51:18 UTC, 13 replies.
- [jira] [Created] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/11 23:21:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 00:53:18 UTC, 3 replies.
- [GitHub] flink pull request: [WIP] [streaming] OutOfCoreKvState added + maj... - posted by gyfora <gi...@git.apache.org> on 2016/02/12 10:02:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2444] add tests for HadoopInputFormats - posted by mliesenberg <gi...@git.apache.org> on 2016/02/12 10:29:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-2444) Add tests for HadoopInputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/12 10:30:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/12 12:06:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2032) Migrate integration tests from temp output files to collect() - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/02/12 12:14:18 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3359] Make RocksDB File Copies Asynchro... - posted by aljoscha <gi...@git.apache.org> on 2016/02/12 14:16:59 UTC, 2 replies.
- [jira] [Commented] (FLINK-3359) Make RocksDB file copies asynchronous - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/12 14:17:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/02/12 14:33:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/12 14:36:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/12 14:38:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2259) Support training Estimators using a (train, validation, test) split of the available data - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/02/12 14:49:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3270) Add example for reading and writing to Kafka - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/12 15:05:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3393] [core] ExternalProcessRunner wait... - posted by greghogan <gi...@git.apache.org> on 2016/02/12 17:10:25 UTC, 4 replies.
- [jira] [Commented] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/12 17:11:18 UTC, 4 replies.
- [jira] [Created] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse) - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/12 17:30:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse) - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/12 17:30:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3352] Use HDFS Config in RocksDB Copy U... - posted by aljoscha <gi...@git.apache.org> on 2016/02/12 17:55:41 UTC, 6 replies.
- [jira] [Commented] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/12 17:56:18 UTC, 6 replies.
- [jira] [Resolved] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 18:57:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 18:58:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 19:01:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 19:34:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3392) Unprotected access to elements in ClosableBlockingQueue#size() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/12 19:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/12 20:37:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3396) Job submission Savepoint restore logic flawed - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/12 21:11:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Translate logical joins to physic... - posted by vasia <gi...@git.apache.org> on 2016/02/12 21:22:40 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3396] [runtime] Fail job submission aft... - posted by uce <gi...@git.apache.org> on 2016/02/12 22:16:22 UTC, 16 replies.
- [jira] [Commented] (FLINK-3396) Job submission Savepoint restore logic flawed - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/12 22:17:18 UTC, 19 replies.
- [jira] [Resolved] (FLINK-3352) RocksDB Backend cannot determine correct hdfs path - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/12 23:01:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3359) Make RocksDB file copies asynchronous - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/12 23:02:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3393) ExternalProcessRunner wait to finish copying error stream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/12 23:07:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Casting support for arithmetic op... - posted by twalthr <gi...@git.apache.org> on 2016/02/13 12:42:04 UTC, 7 replies.
- [GitHub] flink pull request: FLINK-3304: Making the Avro Schema serializabl... - posted by kl0u <gi...@git.apache.org> on 2016/02/14 12:07:45 UTC, 5 replies.
- [jira] [Created] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/14 21:48:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3367) Annotate all user-facing API classes with @Public or @PublicEvolving - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/14 22:58:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/15 04:15:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/15 04:16:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3399) Count with timeout trigger - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/15 05:26:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3399] CountWithTimeoutTrigger - posted by shikhar <gi...@git.apache.org> on 2016/02/15 05:45:14 UTC, 4 replies.
- [jira] [Commented] (FLINK-3399) Count with timeout trigger - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/15 05:45:18 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3390] [runtime, tests] Reset Execution ... - posted by uce <gi...@git.apache.org> on 2016/02/15 11:48:35 UTC, 2 replies.
- [jira] [Commented] (FLINK-3390) Savepoint resume is not retried - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/15 11:49:18 UTC, 7 replies.
- [jira] [Created] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 12:08:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by nikste <gi...@git.apache.org> on 2016/02/15 12:45:00 UTC, 1 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/15 12:45:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3395) Polishing the web UI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/15 12:53:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3354] Determine correct size for RocksD... - posted by gyfora <gi...@git.apache.org> on 2016/02/15 13:36:35 UTC, 7 replies.
- [jira] [Closed] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/15 13:58:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 14:03:18 UTC, 3 replies.
- [jira] [Closed] (FLINK-3187) Decouple restart strategy from ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/15 16:00:24 UTC, 0 replies.
- [jira] [Commented] (FLINK-2922) Add Queryable Window Operator - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/15 16:25:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/15 16:27:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Translation of explicit casting - posted by twalthr <gi...@git.apache.org> on 2016/02/15 17:11:55 UTC, 4 replies.
- [jira] [Closed] (FLINK-3377) Remove final flag from ResultPartitionWriter class - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/15 17:16:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3332] Add Exactly-Once Cassandra connec... - posted by zentol <gi...@git.apache.org> on 2016/02/15 17:26:14 UTC, 42 replies.
- [jira] [Commented] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/02/15 18:12:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/15 18:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3402) Refactor Common Parts of Stream/Batch Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 19:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3403) Create Section "Working with Time" in Streaming Guide - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/15 19:05:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/15 19:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3404) Extend Kafka consumers with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3405) Extend NiFiSource with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3406) Extend RabbitMQ source with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3407) Extend TwitterSource with interface StoppableFunction - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3408) Make STOP signal reliable - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:39:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3409) Integrate STOP with Savepoints - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/02/15 20:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs. - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/15 21:26:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/16 01:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3411) Failed recovery can lead to removal of HA state - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/16 10:44:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/16 10:46:18 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3321) TupleSerializerBase.getLength should know the length when all fields know it - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/16 10:52:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 11:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3413) Remove implicit Seq to DataStream conversion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 11:17:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3413) Remove implicit Seq to DataStream conversion - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/16 11:33:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/16 11:33:18 UTC, 6 replies.
- [jira] [Created] (FLINK-3414) Add Scala API for CEP's pattern definition - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/16 11:54:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3315] Fix Slot Sharing in Streaming API - posted by aljoscha <gi...@git.apache.org> on 2016/02/16 14:02:43 UTC, 15 replies.
- [jira] [Commented] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/16 14:03:18 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-3299] Remove ApplicationID from Environ... - posted by uce <gi...@git.apache.org> on 2016/02/16 14:09:01 UTC, 8 replies.
- [jira] [Resolved] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 14:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3415) TimestampExctractor accepts negative watermarks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 14:57:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 15:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3416) [py] .bat files fail when path contains spaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/16 15:04:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3410] [restart] Choose NoRestart strate... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/16 15:34:35 UTC, 4 replies.
- [jira] [Commented] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/16 15:35:18 UTC, 4 replies.
- [jira] [Resolved] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 15:39:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3296) DataStream.write*() methods are not flushing properly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 15:54:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3400] Move RocksDB Copy Utils to flink-... - posted by aljoscha <gi...@git.apache.org> on 2016/02/16 16:50:43 UTC, 2 replies.
- [jira] [Created] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/16 17:26:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 17:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 17:42:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/16 17:42:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/16 17:42:18 UTC, 13 replies.
- [GitHub] flink pull request: Refactor Common Parts of Stream/Batch Document... - posted by aljoscha <gi...@git.apache.org> on 2016/02/16 17:52:55 UTC, 7 replies.
- [jira] [Created] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:10:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3413) Remove implicit Seq to DataStream conversion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:30:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3413) Remove implicit Seq to DataStream conversion - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3421) Remove all unused ClassTag context bounds in the Streaming Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 19:59:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3379] [FLINK-3415] [streaming] Refactor... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/16 20:01:22 UTC, 3 replies.
- [jira] [Commented] (FLINK-3379) Refactor TimestampExtractor - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/16 20:02:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by danielblazevski <gi...@git.apache.org> on 2016/02/16 20:39:59 UTC, 1 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 2016/02/16 20:40:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 21:40:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3401] [api breaking] AscendingTimestamp... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/16 21:54:45 UTC, 2 replies.
- [jira] [Commented] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/16 21:55:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 22:16:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/16 22:27:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/16 22:43:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3395) Polishing the web UI - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/16 22:57:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3420] [api-breaking] Remove utility fun... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/16 22:59:14 UTC, 3 replies.
- [jira] [Commented] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/16 22:59:18 UTC, 3 replies.
- [jira] [Commented] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 08:49:18 UTC, 6 replies.
- [jira] [Closed] (FLINK-3308) [py] Remove debug mode - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 09:32:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3309] [py] Resolve Maven warnings - posted by zentol <gi...@git.apache.org> on 2016/02/17 09:50:25 UTC, 3 replies.
- [jira] [Commented] (FLINK-3309) [py] Resolve maven warnings - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 09:51:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 09:58:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/17 10:28:18 UTC, 27 replies.
- [jira] [Closed] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 10:36:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 10:36:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3420) Remove "ReadTextFileWithValue" from StreamExecutionEnvironment - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 10:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:43:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:45:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:47:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:47:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-1159) Case style anonymous functions not supported by Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 10:47:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:47:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 10:49:18 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3423] Fixed ExternalProcessRunnerTest o... - posted by zentol <gi...@git.apache.org> on 2016/02/17 10:51:43 UTC, 3 replies.
- [jira] [Updated] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 10:52:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 10:52:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3426] Fixed JobManagerLeader[Re]Electio... - posted by zentol <gi...@git.apache.org> on 2016/02/17 10:54:53 UTC, 7 replies.
- [jira] [Resolved] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 11:02:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3402) Refactor Common Parts of Stream/Batch Documentation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 11:03:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3200) Use Partitioned State Abstraction in WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 11:04:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 11:13:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3425] FileOutputFormat closes outStream... - posted by zentol <gi...@git.apache.org> on 2016/02/17 11:23:54 UTC, 6 replies.
- [jira] [Commented] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 11:24:18 UTC, 6 replies.
- [jira] [Reopened] (FLINK-3386) Kafka consumers should not necessarily fail on expiring data - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 11:44:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3386) Kafka consumers are not properly respecting the "auto.offset.reset" behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 11:45:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3424] Close InputStream in FileStateBac... - posted by zentol <gi...@git.apache.org> on 2016/02/17 11:46:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 11:47:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3332] TupleSerializer.getLength() can r... - posted by zentol <gi...@git.apache.org> on 2016/02/17 11:57:00 UTC, 3 replies.
- [jira] [Created] (FLINK-3427) Add watermark monitoring to JobManager web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 11:59:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3428) Add fixed time trailing timestamp/watermark extractor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 12:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3429) Add histogram-based timestamp/watermark extractor - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/17 12:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 12:12:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3430] Remove "no POJO" warning in TypeA... - posted by aljoscha <gi...@git.apache.org> on 2016/02/17 12:13:07 UTC, 3 replies.
- [jira] [Commented] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 12:13:18 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3415) TimestampExctractor accepts negative watermarks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3415) TimestampExctractor accepts negative watermarks - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:27:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3401) AscendingTimestampExtractor should not fail on order violation - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3379) Refactor TimestampExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:28:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3379) Refactor TimestampExtractor - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 12:28:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3396] [runtime] Fix JobGraph submission... - posted by uce <gi...@git.apache.org> on 2016/02/17 12:40:09 UTC, 1 replies.
- [jira] [Commented] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 13:11:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 13:12:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3431) Add retrying logic for RocksDB snapshots - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/17 13:22:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3431) Add retrying logic for RocksDB snapshots - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 13:25:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 13:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/17 14:31:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3396] [runtime] Suppress job restart if... - posted by uce <gi...@git.apache.org> on 2016/02/17 14:32:22 UTC, 0 replies.
- [jira] [Created] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/17 14:41:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/17 14:43:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2922) Add Queryable Window Operator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/17 14:43:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3299) Remove ApplicationID from Environment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/17 14:48:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3411) Failed recovery can lead to removal of HA state - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 14:52:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 14:59:18 UTC, 0 replies.
- [GitHub] flink pull request: Improve TaskManagerTest#testRemotePartitionNot... - posted by zentol <gi...@git.apache.org> on 2016/02/17 15:09:33 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:22:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2737) KeyedDataStream should not be a subclass of DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:23:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:24:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3412) Remove implicit conversions JavaStream / ScalaStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:24:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3421) Remove all unused ClassTag context bounds in the Streaming Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:24:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3421) Remove all unused ClassTag context bounds in the Streaming Scala API - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:25:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:27:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3419) Drop partitionByHash from DataStream - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:27:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:44:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3430) Remove "no POJO" warning in TypeAnalyzer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 15:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3435) Change interplay of Ingestion Time and Event Time - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 16:55:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3435) Change interplay of Ingestion Time and Event Time - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 16:56:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3435) Change interplay of Ingestion Time and Event Time - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/17 16:56:18 UTC, 16 replies.
- [jira] [Created] (FLINK-3436) Remove ComplexIntegrationITCase - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 17:40:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-1989) Sorting of POJO data set from TableEnv yields NotSerializableException - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 17:44:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3400) RocksDB Backend does not work when not in Flink lib folder - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/17 17:47:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3436] Remove ComplexIntegrationITCase - posted by aljoscha <gi...@git.apache.org> on 2016/02/17 17:47:52 UTC, 3 replies.
- [jira] [Commented] (FLINK-3436) Remove ComplexIntegrationITCase - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/17 17:48:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3437) Fix UI router state for job plan - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/17 17:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/17 18:00:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/17 18:01:18 UTC, 11 replies.
- [jira] [Updated] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/17 18:02:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3311] Add a connector for streaming dat... - posted by alkagin <gi...@git.apache.org> on 2016/02/17 18:11:06 UTC, 34 replies.
- [jira] [Updated] (FLINK-3437) Fix UI router state for job plan - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/17 18:15:18 UTC, 1 replies.
- [GitHub] flink pull request: 3437 fix UI router state for job plan - posted by greghogan <gi...@git.apache.org> on 2016/02/17 18:34:16 UTC, 0 replies.
- [jira] [Commented] (FLINK-3437) Fix UI router state for job plan - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/17 19:01:18 UTC, 3 replies.
- [GitHub] flink pull request: [docs] fix typos in quickstart and CEP docs - posted by vasia <gi...@git.apache.org> on 2016/02/17 22:20:27 UTC, 3 replies.
- [jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Josep Rubió (JIRA)" <ji...@apache.org> on 2016/02/17 22:27:18 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3432] Fixed ZookeeperOffsethandlerTest ... - posted by zentol <gi...@git.apache.org> on 2016/02/18 09:36:29 UTC, 2 replies.
- [jira] [Commented] (FLINK-3432) ZookeeperOffsetHandlerTest fails on windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 09:37:18 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3438] ExternalProcessRunner fails to de... - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/18 09:59:47 UTC, 7 replies.
- [GitHub] flink pull request: [FLINK-3433] AvroOutputFormat#readObject uses ... - posted by zentol <gi...@git.apache.org> on 2016/02/18 10:38:47 UTC, 3 replies.
- [jira] [Commented] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 10:39:18 UTC, 3 replies.
- [jira] [Commented] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/18 11:10:18 UTC, 5 replies.
- [jira] [Created] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/18 11:12:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3436) Remove ComplexIntegrationITCase - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/18 11:14:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 11:25:18 UTC, 12 replies.
- [jira] [Commented] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/18 12:11:18 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/02/18 12:51:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3422) Scramble HashPartitioner hashes - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/02/18 13:14:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/18 13:33:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:45:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3423) ExternalProcessRunnerTest fails on Windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:45:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:46:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3424) FileStateBackendtest.testStateOutputStream fails on windows - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:46:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:50:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3417) Add RocksDB StateBackendFactory and integrate with Flink Config - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 13:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:00:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3441) Revisit quickstarts exclusion policy - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/18 14:11:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3441) Revisit quickstarts exclusion policy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:18:18 UTC, 2 replies.
- [jira] [Updated] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:20:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:40:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:41:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-2917) Make non-copying behaviour default for stream operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/18 14:42:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3169] Remove Key class - posted by zentol <gi...@git.apache.org> on 2016/02/18 14:42:26 UTC, 8 replies.
- [jira] [Commented] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 14:43:18 UTC, 8 replies.
- [jira] [Assigned] (FLINK-3277) Use Value types in Gelly API - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/18 15:16:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/18 15:39:18 UTC, 2 replies.
- [jira] [Commented] (FLINK-3277) Use Value types in Gelly API - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/18 15:54:18 UTC, 6 replies.
- [jira] [Updated] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal) - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/18 16:18:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3442) Expose savepoint button on web ui - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/02/18 18:03:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3257] Add Exactly-Once Processing Guara... - posted by senorcarbone <gi...@git.apache.org> on 2016/02/18 18:35:04 UTC, 6 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 18:35:18 UTC, 6 replies.
- [jira] [Created] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/18 19:02:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3443] [runtime] Prevent cancelled jobs ... - posted by uce <gi...@git.apache.org> on 2016/02/18 19:05:16 UTC, 14 replies.
- [jira] [Commented] (FLINK-3443) JobManager cancel and clear everything fails jobs instead of cancelling - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 19:05:18 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-3248] add constructor params and generi... - posted by mxm <gi...@git.apache.org> on 2016/02/18 19:38:29 UTC, 1 replies.
- [jira] [Commented] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 19:39:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3277] Use Value types in Gelly API - posted by greghogan <gi...@git.apache.org> on 2016/02/18 19:59:54 UTC, 1 replies.
- [jira] [Commented] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/02/18 20:19:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3224) The Streaming API does not call setInputType if a format implements InputTypeConfigurable - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/02/18 20:20:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3444) env.fromElements relies on the first input element for determining the DataSet/DataStream type - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/18 20:49:18 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/18 21:02:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3147) HadoopOutputFormatBase should expose fields as protected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/18 21:03:18 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3224) The Streaming API does not call setInputType if a format implements InputTypeConfigurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/18 21:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3224) The Streaming API does not call setInputType if a format implements InputTypeConfigurable - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/18 21:03:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3368][Kafka 0.8] Improvements to the Ka... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/18 21:32:21 UTC, 1 replies.
- [jira] [Created] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/18 22:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3446) Back pressure tracker throws NPE for archived jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/18 22:12:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/18 22:29:18 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3446] [runtime-web] Don't trigger back ... - posted by uce <gi...@git.apache.org> on 2016/02/18 22:30:53 UTC, 2 replies.
- [jira] [Commented] (FLINK-3446) Back pressure tracker throws NPE for archived jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/18 22:31:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3447) Package Gelly algorithms by framework - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/18 23:29:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3416) [py] .bat files fail when path contains spaces - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/19 11:10:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3416] [py] Support for spaces in flink ... - posted by zentol <gi...@git.apache.org> on 2016/02/19 11:12:21 UTC, 7 replies.
- [jira] [Commented] (FLINK-3416) [py] .bat files fail when path contains spaces - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/19 11:13:18 UTC, 7 replies.
- [jira] [Updated] (FLINK-3448) WebRuntimeMonitor: Move initialization of handlers to start() method - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/19 12:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3448) Move initialization of handlers to start() method - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/19 12:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3449) createInput swallows exception if TypeExtractor fails - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/19 12:29:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3449] createInput() no longer swallows ... - posted by zentol <gi...@git.apache.org> on 2016/02/19 13:40:35 UTC, 3 replies.
- [jira] [Commented] (FLINK-3449) createInput swallows exception if TypeExtractor fails - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/19 13:41:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3450) RocksDB Backed Window Fails with KryoSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/19 14:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3451) NettyServer port is determined via NetUtils.getAvailablePort() - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/19 15:11:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3452) Procuring more Travis CI build capacity for Flink - posted by "Wes McKinney (JIRA)" <ji...@apache.org> on 2016/02/19 15:18:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3452) Procuring more Travis CI build capacity for Flink - posted by "Wes McKinney (JIRA)" <ji...@apache.org> on 2016/02/19 15:27:18 UTC, 6 replies.
- [jira] [Commented] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/19 15:39:18 UTC, 0 replies.
- [GitHub] flink pull request: Various test stability fixes - posted by uce <gi...@git.apache.org> on 2016/02/19 15:53:35 UTC, 3 replies.
- [jira] [Created] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/19 15:56:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/19 17:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3454) Add test dependencies on packaged jars - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/19 18:58:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3368) Kafka 0.8 consumer fails to recover from broker shutdowns - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 19:50:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3386) Kafka consumers are not properly respecting the "auto.offset.reset" behavior - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 19:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 19:53:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 19:53:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3439] Remove final Long.MAX_VALUE Water... - posted by aljoscha <gi...@git.apache.org> on 2016/02/19 20:03:40 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/19 20:31:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/19 21:10:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3456) Backpressure Monitoring does not work for Kafka Sources - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/19 22:17:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/02/19 22:41:18 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3453] [runtime, runtime-web] Report par... - posted by uce <gi...@git.apache.org> on 2016/02/19 23:48:26 UTC, 2 replies.
- [jira] [Commented] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/19 23:49:18 UTC, 2 replies.
- [jira] [Closed] (FLINK-3381) Unstable Test: JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/20 00:14:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3446) Back pressure tracker throws NPE for archived jobs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/20 00:17:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3453) Fix TaskManager logs exception when sampling backpressure while task completes - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/20 19:05:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/20 20:15:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Translation of scalar function su... - posted by twalthr <gi...@git.apache.org> on 2016/02/20 21:53:51 UTC, 13 replies.
- [GitHub] flink pull request: 3385 fix outer join skipping unprobed partitio... - posted by greghogan <gi...@git.apache.org> on 2016/02/21 05:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2016/02/21 14:00:20 UTC, 0 replies.
- [jira] [Created] (FLINK-3458) Shading broken in flink-shaded-hadoop - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:28:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3458] [build] Disable shade-flink execu... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/21 14:28:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-3458) Shading broken in flink-shaded-hadoop - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/21 14:29:18 UTC, 4 replies.
- [jira] [Created] (FLINK-3459) Make build SBT compatible - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:31:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3459] [build] Fix conflicting dependenc... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/21 14:32:21 UTC, 4 replies.
- [jira] [Commented] (FLINK-3459) Make build SBT compatible - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/21 14:33:18 UTC, 4 replies.
- [jira] [Created] (FLINK-3460) Make flink-streaming-connectors' flink dependencies provided - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/21 14:33:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3460] [build] Set Flink dependencies in... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/21 14:34:32 UTC, 6 replies.
- [jira] [Commented] (FLINK-3460) Make flink-streaming-connectors' flink dependencies provided - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/21 14:35:18 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3455] Bump Kafka to 0.9.0.1 and 0.8.2.2 - posted by rmetzger <gi...@git.apache.org> on 2016/02/21 15:59:16 UTC, 3 replies.
- [jira] [Commented] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/21 15:59:18 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/21 16:02:18 UTC, 0 replies.
- [GitHub] flink pull request: [WIP][FLINK-3422][streaming][api-breaking] Scr... - posted by Xazax-hun <gi...@git.apache.org> on 2016/02/21 23:23:35 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3450] Duplicate TypeSerializer in State... - posted by aljoscha <gi...@git.apache.org> on 2016/02/22 10:48:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-3450) RocksDB Backed Window Fails with KryoSerializer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/22 10:49:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/22 12:03:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3462) Add position and magic number checks to record (de)serializers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/22 14:26:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3439) Remove final Long.MAX_VALUE Watermark in StreamSource - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/22 14:59:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3450) RocksDB Backed Window Fails with KryoSerializer - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/22 15:01:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3418] Don't run RocksDB copy utils in e... - posted by aljoscha <gi...@git.apache.org> on 2016/02/22 15:03:00 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-3174] Add merging WindowAssigner - posted by aljoscha <gi...@git.apache.org> on 2016/02/22 15:03:31 UTC, 1 replies.
- [jira] [Commented] (FLINK-3174) Add merging WindowAssigner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/22 15:04:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3463) Implement Calc Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/22 15:13:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3464) Add SBT build tool description to quickstart documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/22 15:41:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3465) Add SBT template script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/22 15:43:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3466) Job might get stuck in restoreState() from HDFS due to interrupt - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/22 15:43:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3464] [docs] Add SBT template documenta... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/22 15:55:27 UTC, 5 replies.
- [jira] [Commented] (FLINK-3464) Add SBT build tool description to quickstart documentation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/22 15:56:18 UTC, 5 replies.
- [jira] [Closed] (FLINK-3335) Fix DataSourceTask object reuse when disabled - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 16:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 17:02:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 17:03:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3385] [runtime] Fix outer join skipping... - posted by hsaputra <gi...@git.apache.org> on 2016/02/22 17:27:40 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3331] TupleSerializer.getLength() can r... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/22 17:53:22 UTC, 0 replies.
- [jira] [Commented] (FLINK-3331) Test instability: LocalFlinkMiniClusterITCase.testLocalFlinkMiniClusterWithMultipleTaskManagers - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/22 17:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/22 18:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3469) Fix documentation for grouping keys - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/22 18:52:18 UTC, 0 replies.
- [GitHub] flink pull request: Make DataStream property methods properly Scal... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/22 18:59:24 UTC, 5 replies.
- [GitHub] flink pull request: FLINK-3398: Allow for opting-out from Kafka of... - posted by shikhar <gi...@git.apache.org> on 2016/02/22 19:11:21 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3467] Remove superfluous objects from D... - posted by greghogan <gi...@git.apache.org> on 2016/02/22 19:24:38 UTC, 0 replies.
- [jira] [Commented] (FLINK-3467) Remove superfluous objects from DataSourceTask.invoke - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/22 19:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/22 19:30:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3340][Kafka 0.8] Commit also offsets re... - posted by rmetzger <gi...@git.apache.org> on 2016/02/22 21:18:48 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3455) Bump Kafka 0.9 connector dependency to Kafka 0.9.0.1 - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/22 21:21:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/22 22:18:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Ken Geis (JIRA)" <ji...@apache.org> on 2016/02/22 22:22:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2118) Table API fails on composite filter conditions - posted by "sahitya pavurala (JIRA)" <ji...@apache.org> on 2016/02/23 02:59:18 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3253) deserializeObject exception on WindowOperator - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/02/23 07:19:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3473) Add partial aggregate support in Flink - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 08:39:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3474) Partial aggregate interface design and sort-based implementation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 08:47:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3385) Fix outer join skipping unprobed partitions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 09:23:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3475) DISTINCT aggregate function support - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:38:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3474) Partial aggregate interface design and sort-based implementation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:39:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:40:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3476) Support hash-based partial aggregate - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/23 09:49:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3478) Flink serves arbitary files through the web interface - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/23 10:17:19 UTC, 0 replies.
- [jira] [Updated] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/23 10:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3465) Add SBT template script - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 10:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3479) Add hash-based strategy for CombineFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:35:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3480) Add hash-based strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:40:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3476) Support hash-based partial aggregate - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:45:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3479) Add hash-based strategy for CombineFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 10:49:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3457) Link to Apache Flink meetups from the 'Community' section of the website - posted by "Gabor Horvath (JIRA)" <ji...@apache.org> on 2016/02/23 11:11:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/23 11:18:18 UTC, 0 replies.
- [GitHub] flink pull request: redundant check in getting leadership status - posted by sahitya-pavurala <gi...@git.apache.org> on 2016/02/23 12:24:16 UTC, 5 replies.
- [jira] [Created] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 12:25:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/23 12:31:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3472) JDBCInputFormat.nextRecord(..) has misleading message on NPE - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/23 12:31:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3471) JDBCInputFormat cannot handle null fields of certain types - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/23 12:34:18 UTC, 2 replies.
- [GitHub] flink pull request: added support for Main-Class separated by / in... - posted by fs111 <gi...@git.apache.org> on 2016/02/23 12:34:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3478) Flink serves arbitary files through the web interface - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 12:37:18 UTC, 9 replies.
- [jira] [Resolved] (FLINK-2213) Configure number of vcores - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/23 14:00:21 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3481) KafkaShortRetention08ITCase.testAutoOffsetReset failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/23 14:09:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3477] [runtime] Add hash-based combine ... - posted by ggevay <gi...@git.apache.org> on 2016/02/23 14:25:08 UTC, 1 replies.
- [jira] [Commented] (FLINK-3477) Add hash-based combine strategy for ReduceFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/23 14:25:18 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3440][Kafka 0.8] Commit also offsets re... - posted by asfgit <gi...@git.apache.org> on 2016/02/23 14:48:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/23 14:48:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3440) Kafka should also checkpoint partitions where no initial offset was retrieved - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/23 14:48:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3478) Flink serves arbitary files through the web interface - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/23 14:59:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3425) DataSinkTaskTest.Failing[Sorting]DataSinkTask fails on Windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:23:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3464) Add SBT build tool description to quickstart documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:23:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3410) setting setNumberOfExecutionRetries to 0 still leads to RESTARTs. - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:24:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3433) Return value from ObjectInputStream#read() should be checked in AvroOutputFormat#readObject - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:25:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3438) ExternalProcessRunner fails to detect ClassNotFound exception because of locale settings - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3460) Make flink-streaming-connectors' flink dependencies provided - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3459) Make build SBT compatible - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3458) Shading broken in flink-shaded-hadoop - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:27:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3416) [py] .bat files fail when path contains spaces - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 15:28:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClieFrotend#getCli... - posted by zentol <gi...@git.apache.org> on 2016/02/23 16:10:07 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3463] implement calc translation - posted by vasia <gi...@git.apache.org> on 2016/02/23 16:23:37 UTC, 16 replies.
- [jira] [Commented] (FLINK-3463) Implement Calc Support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/23 16:24:18 UTC, 16 replies.
- [GitHub] flink pull request: [FLINK-3434] Prevent NPE in ClientFrontend#get... - posted by rmetzger <gi...@git.apache.org> on 2016/02/23 16:35:06 UTC, 2 replies.
- [jira] [Created] (FLINK-3482) Implement Union Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/23 16:38:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3483) Job graph visualization not working properly in OS X Chrome - posted by "Zach Cox (JIRA)" <ji...@apache.org> on 2016/02/23 16:40:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3483) Job graph visualization not working properly in OS X Chrome - posted by "Zach Cox (JIRA)" <ji...@apache.org> on 2016/02/23 16:42:18 UTC, 5 replies.
- [jira] [Commented] (FLINK-3483) Job graph visualization not working properly in OS X Chrome - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/23 17:14:18 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3426) JobManagerLeader[Re]ElectionTest.testleaderElection fails on Windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 17:52:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3418) RocksDB HDFSCopyFromLocal util doesn't respect our Hadoop security configuration - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 17:53:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3484) Add setSlotSharingGroup documentation - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 18:32:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3315) Fix Slot Sharing in Streaming API - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/23 18:39:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3478] [runtime-web] Don't serve files o... - posted by uce <gi...@git.apache.org> on 2016/02/23 19:03:47 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3454] Add test dependencies on packaged... - posted by greghogan <gi...@git.apache.org> on 2016/02/23 19:04:48 UTC, 0 replies.
- [jira] [Commented] (FLINK-3454) Add test dependencies on packaged jars - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/23 19:05:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2021) Rework examples to use ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/23 19:37:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3435] Proparly separate IngestionTime a... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/23 20:07:32 UTC, 15 replies.
- [jira] [Updated] (FLINK-3469) Improve documentation for grouping keys - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/23 20:21:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/24 03:15:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3485) The accumulator value doest seem to be right - posted by "sahitya pavurala (JIRA)" <ji...@apache.org> on 2016/02/24 03:26:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3485) The accumulator value doest seem to be right - posted by "sahitya pavurala (JIRA)" <ji...@apache.org> on 2016/02/24 03:27:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-3485) The SerializedListAccumulator value doest seem to be right - posted by "sahitya pavurala (JIRA)" <ji...@apache.org> on 2016/02/24 03:50:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/24 07:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/24 07:51:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3485) The SerializedListAccumulator value doest seem to be right - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/24 09:35:18 UTC, 5 replies.
- [jira] [Created] (FLINK-3488) Kafka08ITCase.testBigRecordJob fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/24 09:41:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3489) Refactor Table API before merging into master - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 10:00:26 UTC, 3 replies.
- [jira] [Created] (FLINK-3489) Refactor Table API before merging into master - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 10:00:26 UTC, 0 replies.
- [jira] [Created] (FLINK-3490) Bump Chill version to 0.7.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/24 10:27:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3490) Bump Chill version to 0.7.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/24 10:29:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3490] Bump Chill version to 0.7.4 - posted by fhueske <gi...@git.apache.org> on 2016/02/24 10:30:26 UTC, 6 replies.
- [jira] [Commented] (FLINK-3490) Bump Chill version to 0.7.4 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/24 10:31:18 UTC, 6 replies.
- [jira] [Created] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 10:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/24 11:05:18 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Add logging for RocksDB backup durati... - posted by aljoscha <gi...@git.apache.org> on 2016/02/24 11:27:27 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3491] Prevent failure of HDFSCopyUtilit... - posted by zentol <gi...@git.apache.org> on 2016/02/24 11:28:44 UTC, 3 replies.
- [jira] [Commented] (FLINK-3491) HDFSCopyUtilitiesTest fails on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/24 11:29:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3493) Update plan visualizer to web frontend version - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 11:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3494) Integrate plan visualizer with web page - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 11:31:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3478) Flink serves arbitary files through the web interface - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/24 11:48:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3492) Allow users to define a min pause between checkpoints - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/24 11:50:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3483) Job graph visualization not working properly in OS X Chrome - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 12:06:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 12:20:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3490) Bump Chill version to 0.7.4 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/24 12:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3496) Flink-ml tests fail on Windows - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/02/24 12:47:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-1159] Case style anonymous functions no... - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/24 13:08:25 UTC, 24 replies.
- [jira] [Created] (FLINK-3497) Add SQL scalar functions to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 13:48:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3497) Add SQL scalar functions to Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 13:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3498) Implement TRIM, SUBSTRING as reference design for Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/02/24 14:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3316) Links to Gelly and FlinkML libraries on main site broken - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:23:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2860) The mlr object from the FlinkML Getting Started code example uses an undefined argument - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:24:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2297) Add threshold setting for SVM binary predictions - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:25:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2272) Move vision and roadmap for FlinkML from docs to the wiki - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:25:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:25:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2056) Add guide to create a chainable predictor in docs - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2072) Add a quickstart guide for FlinkML - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-1995) The Flink project is categorized under "Incubator" in the Apache JIRA tracker - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2047) Rename CoCoA to SVM - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:27:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-2035) Update 0.9 roadmap with ML issues - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:27:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-2396) Review the datasets of dynamic path and static path in iteration. - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/24 14:29:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3496) Flink-ml tests fail on Windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/24 14:59:18 UTC, 10 replies.
- [jira] [Comment Edited] (FLINK-3496) Flink-ml tests fail on Windows - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/24 15:20:18 UTC, 3 replies.
- [jira] [Commented] (FLINK-3489) Refactor Table API before merging into master - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/24 15:34:18 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Move state and windows guide to separat... - posted by uce <gi...@git.apache.org> on 2016/02/24 15:51:08 UTC, 4 replies.
- [jira] [Created] (FLINK-3499) Possible ghost references in ZooKeeper completed checkpoint store - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 17:25:18 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] Expose current watermark to Triggers - posted by aljoscha <gi...@git.apache.org> on 2016/02/24 17:43:44 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3499] [runtime] Clear ZooKeeper referen... - posted by uce <gi...@git.apache.org> on 2016/02/24 18:03:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-3499) Possible ghost references in ZooKeeper completed checkpoint store - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/24 18:04:18 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3468) Change Timestamp Extractors to not support negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/24 18:07:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3470) EventTime WindowAssigners should error on negative timestamps - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/24 18:08:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3500) ExecutionGraphRestartTest testFailingExecutionAfterRestart fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 18:38:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3500) ExecutionGraphRestartTest testFailingExecutionAfterRestart fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 18:39:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3500] [test] Fix possible instability i... - posted by uce <gi...@git.apache.org> on 2016/02/24 20:43:36 UTC, 2 replies.
- [jira] [Closed] (FLINK-3499) Possible ghost references in ZooKeeper completed checkpoint store - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/24 20:58:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3435) Change interplay of Ingestion Time and Event Time - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/24 22:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3500) ExecutionGraphRestartTest testFailingExecutionAfterRestart fails - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 00:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem - posted by "Paul Harris (JIRA)" <ji...@apache.org> on 2016/02/25 02:34:19 UTC, 0 replies.
- [jira] [Created] (FLINK-3502) [SQL] AggregateProjectPullUpConstantsRule fails on certain group keys order. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 03:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3503) [SQL] ProjectJoinTransposeRule fails to push down project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:00:22 UTC, 0 replies.
- [jira] [Updated] (FLINK-3487) [SQL] FilterAggregateTransposeRule does not transform logical plan as desired. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:01:18 UTC, 1 replies.
- [jira] [Created] (FLINK-3504) [SQL] Join fails while have expression inside join condition. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:12:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3504) Join fails while have expression inside join condition. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:34:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3503) [SQL] ProjectJoinTransposeRule fails to push down project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:34:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3505) JoinUnionTransposeRule fails to push Join past Union. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:34:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3503) ProjectJoinTransposeRule fails to push down project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3487) FilterAggregateTransposeRule does not transform logical plan as desired. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3502) AggregateProjectPullUpConstantsRule fails on certain group keys order. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3486) [SQL] Use Project to rename all record fields would fail following Project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:35:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3486) Use Project to rename all record fields would fail following Project. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 04:36:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 07:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3507) PruneEmptyRules does not prune empty node as expected. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 07:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 09:07:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3226] Improvements for expected types - posted by twalthr <gi...@git.apache.org> on 2016/02/25 09:40:24 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2695) KafkaITCase.testConcurrentProducerConsumerTopology failed on Travis - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/25 10:13:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/25 10:14:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/25 13:55:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3510) Pattern class class-level comment misses type argument - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 15:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3511) Flink library examples not runnable withput adding dependencies - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/02/25 15:43:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3496] Fix ML test discovery on Windows - posted by zentol <gi...@git.apache.org> on 2016/02/25 16:13:10 UTC, 1 replies.
- [jira] [Commented] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 16:14:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 16:14:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3508) Add more test cases to verify the rules of logical plan optimization - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/02/25 16:14:18 UTC, 0 replies.
- [GitHub] flink pull request: git push -f[FLINK-3496] Disable RocksDB tests ... - posted by zentol <gi...@git.apache.org> on 2016/02/25 16:31:24 UTC, 0 replies.
- [jira] [Created] (FLINK-3512) Savepoint backend should not revert to "jobmanager" - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/25 16:48:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/25 16:50:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/25 16:51:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3513] [FLINK-3512] Fix savepoint issues - posted by uce <gi...@git.apache.org> on 2016/02/25 17:01:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/25 17:02:18 UTC, 4 replies.
- [jira] [Commented] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/25 17:03:18 UTC, 3 replies.
- [jira] [Commented] (FLINK-3322) MemoryManager creates too much GC pressure with iterative jobs - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/25 17:16:18 UTC, 4 replies.
- [jira] [Commented] (FLINK-3511) Flink library examples not runnable withput adding dependencies - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/02/25 17:42:18 UTC, 4 replies.
- [jira] [Comment Edited] (FLINK-3511) Flink library examples not runnable withput adding dependencies - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/02/25 18:04:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3509] Update Hadoop minor versions to l... - posted by rmetzger <gi...@git.apache.org> on 2016/02/25 18:23:40 UTC, 2 replies.
- [jira] [Commented] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/25 18:24:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3514) Add support for slowly changing streaming broadcast variables - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/25 18:59:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3515) Make the "file monitoring source" exactly-once - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/25 19:19:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3442) Expose savepoint button on web ui - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/25 19:22:18 UTC, 1 replies.
- [GitHub] flink pull request: [hotfix] fix PageRank example to run with no a... - posted by vasia <gi...@git.apache.org> on 2016/02/25 19:34:43 UTC, 3 replies.
- [jira] [Created] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram still fails :( - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 19:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 20:03:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3512) Savepoint backend should not revert to "jobmanager" - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 20:05:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3513) Fix interplay of automatic Operator UID and Changing name of WindowOperator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/25 20:05:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3482] implement union translation - posted by vasia <gi...@git.apache.org> on 2016/02/25 20:54:34 UTC, 5 replies.
- [jira] [Commented] (FLINK-3482) Implement Union Support - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/25 20:55:18 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3517] [dist] Only count active PIDs in ... - posted by uce <gi...@git.apache.org> on 2016/02/26 00:26:05 UTC, 4 replies.
- [jira] [Commented] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/26 00:26:18 UTC, 4 replies.
- [jira] [Closed] (FLINK-3510) Pattern class class-level comment misses type argument - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/26 00:29:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3485] implement toString for Serialized... - posted by mxm <gi...@git.apache.org> on 2016/02/26 00:52:33 UTC, 2 replies.
- [jira] [Comment Edited] (FLINK-3501) flink-runtime-0.10.2-hadoop-1 jar problem - posted by "Paul Harris (JIRA)" <ji...@apache.org> on 2016/02/26 01:58:18 UTC, 1 replies.
- [jira] [Updated] (FLINK-3511) Flink library examples not runnable without adding dependencies - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/02/26 09:29:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3518) Stale docs for quickstart setup - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/02/26 09:30:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3518) Stale docs for quickstart setup - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 09:34:18 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3518] Stale docs for quickstart setup - posted by stefanobaghino <gi...@git.apache.org> on 2016/02/26 09:55:51 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3485) The SerializedListAccumulator value doest seem to be right - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/26 10:26:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3437] [web-dashboard] Fix UI router sta... - posted by rmetzger <gi...@git.apache.org> on 2016/02/26 11:21:12 UTC, 2 replies.
- [jira] [Created] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/26 11:23:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/02/26 11:26:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3519) Subclasses of Tuples don't work if the declared type of a DataSet is not the descendant - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 11:28:18 UTC, 9 replies.
- [jira] [Resolved] (FLINK-3463) Implement Calc Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/26 11:35:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3520) Periodic watermark operator should emit current watermark in close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 11:59:18 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] [build] Disable exclusion rules when ... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/26 11:59:25 UTC, 10 replies.
- [jira] [Assigned] (FLINK-3511) Flink library examples not runnable without adding dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/26 12:04:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3511) Flink library examples not runnable without adding dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/26 12:09:18 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3495] Disable RocksDB tests on Windows - posted by StephanEwen <gi...@git.apache.org> on 2016/02/26 12:23:54 UTC, 0 replies.
- [jira] [Commented] (FLINK-3495) RocksDB Tests can't run on Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/26 12:24:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3482) Implement Union Support - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/26 12:32:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3390] [runtime, tests] Restore savepoin... - posted by uce <gi...@git.apache.org> on 2016/02/26 12:50:40 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3340) Fix object juggling in drivers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 13:32:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3437) Fix UI router state for job plan - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 13:33:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3509) Update Hadoop versions in release script and on travis to the latest minor version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 13:33:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3520) Periodic watermark operator should emit current watermark in close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 13:34:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3449) createInput swallows exception if TypeExtractor fails - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 13:34:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3434) Return value from flinkYarnClient#deploy() should be checked against null - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 13:34:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3520) Periodic watermark operator should emit current watermark in close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 13:34:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3518) Stale docs for quickstart setup - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/26 14:24:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3521) Make Iterable part of method signature for WindowFunction - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 14:33:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3333] [Documentation][DataSet] Improve ... - posted by fhueske <gi...@git.apache.org> on 2016/02/26 14:38:56 UTC, 6 replies.
- [jira] [Created] (FLINK-3522) Storm examples "PrintSampleStream" throws an error if called without arguments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 15:09:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3523) Storm SpoutSplitExample fails with a ClassCastException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 15:17:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 15:22:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3524) Provide a JSONSerialisationSchema in the kafka connector package - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 15:22:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3511] Create example modules for librar... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/26 15:44:41 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3502) AggregateProjectPullUpConstantsRule fails on certain group keys order. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/26 15:47:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3521] Make Iterable part of method sign... - posted by aljoscha <gi...@git.apache.org> on 2016/02/26 15:56:25 UTC, 12 replies.
- [jira] [Commented] (FLINK-3521) Make Iterable part of method signature for WindowFunction - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/26 15:57:18 UTC, 12 replies.
- [jira] [Assigned] (FLINK-3504) Join fails while have expression inside join condition. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/26 15:58:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3519] [core] Add warning about subclass... - posted by ggevay <gi...@git.apache.org> on 2016/02/26 16:31:24 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3511] Create example module for Gelly's... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/26 17:14:48 UTC, 3 replies.
- [jira] [Created] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/02/26 18:10:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3390) Savepoint resume is not retried - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/26 18:45:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 19:01:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3522) Storm examples "PrintSampleStream" throws an error if called without arguments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 19:02:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3522) Storm examples "PrintSampleStream" throws an error if called without arguments - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 19:02:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 19:02:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3525) Missing call to super#close() in TimestampsAndPeriodicWatermarksOperator#close() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 19:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 20:06:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3526] [streaming] Fix Processing Time W... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/26 20:10:00 UTC, 7 replies.
- [jira] [Commented] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/26 20:10:18 UTC, 7 replies.
- [jira] [Resolved] (FLINK-3511) Flink library examples not runnable without adding dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/26 20:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3527) Scala DataStream has no transform method - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 20:56:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3527] Add Scala DataStream.transform() - posted by aljoscha <gi...@git.apache.org> on 2016/02/26 20:57:43 UTC, 1 replies.
- [jira] [Commented] (FLINK-3527) Scala DataStream has no transform method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/26 20:58:18 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 21:22:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/26 21:22:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3526) ProcessingTime Window Assigner and Trigger are broken - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/26 21:22:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3521) Make Iterable part of method signature for WindowFunction - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/27 00:13:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3528) Add Incremental Fold for Non-Keyed Window Operator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/27 00:33:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3527) Scala DataStream has no transform method - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/27 00:41:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-2941) Implement a neo4j - Flink/Gelly connector - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/02/27 16:44:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3529) Add pull request template - posted by "Martin Liesenberg (JIRA)" <ji...@apache.org> on 2016/02/27 20:49:18 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3529 Add template for pull requests - posted by mliesenberg <gi...@git.apache.org> on 2016/02/27 20:56:37 UTC, 3 replies.
- [jira] [Commented] (FLINK-3529) Add pull request template - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/27 20:57:18 UTC, 3 replies.
- [GitHub] flink pull request: [docs] fix typos in Basic Concepts documentati... - posted by wuchong <gi...@git.apache.org> on 2016/02/28 04:11:07 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3422][streaming][api-breaking] Scramble... - posted by Xazax-hun <gi...@git.apache.org> on 2016/02/28 21:56:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-3461) Remove duplicate condition check in ZooKeeperLeaderElectionService - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 10:20:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3517) Number of job and task managers not checked in scripts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 10:41:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3502) AggregateProjectPullUpConstantsRule fails on certain group keys order. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/29 10:54:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:31:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3531) KafkaShortRetention09ITCase.testAutoOffsetReset fails on Travis - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:32:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3532) Flink-gelly-examples jar contains an underscore instead of an hyphen - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 11:58:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3532] [gelly] Fix artifact ID of flink-... - posted by tillrohrmann <gi...@git.apache.org> on 2016/02/29 12:02:53 UTC, 3 replies.
- [jira] [Commented] (FLINK-3532) Flink-gelly-examples jar contains an underscore instead of an hyphen - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 12:03:18 UTC, 3 replies.
- [jira] [Closed] (FLINK-3532) Flink-gelly-examples jar contains an underscore instead of an hyphen - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 12:17:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3533) Update the Gelly docs wrt examples and cluster execution - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 12:25:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3534) Cancelling a running job can lead to restart instead of stopping - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/29 12:28:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3535) Decrease logging verbosity of StackTraceSampleCoordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 13:57:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3535] [runtime-web] Decrease log verbos... - posted by uce <gi...@git.apache.org> on 2016/02/29 14:18:55 UTC, 2 replies.
- [jira] [Commented] (FLINK-3535) Decrease logging verbosity of StackTraceSampleCoordinator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 14:19:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-3506) ReduceExpressionsRule does not remove duplicate expression in Filter - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 14:20:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3536) Make clearer distinction between event time and processing time - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 14:42:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3536) Make clearer distinction between event time and processing time - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 14:46:18 UTC, 4 replies.
- [jira] [Created] (FLINK-3537) Faulty code generation for disjunctions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/29 14:58:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3537] Fix code gen for disjunctions. - posted by fhueske <gi...@git.apache.org> on 2016/02/29 15:11:10 UTC, 2 replies.
- [jira] [Commented] (FLINK-3537) Faulty code generation for disjunctions - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 15:11:18 UTC, 2 replies.
- [jira] [Created] (FLINK-3538) DataStream join API does not enforce consistent usage - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 15:13:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3504) Join fails while have expression inside join condition. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 15:29:18 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3504] Fix join translation. Equality pr... - posted by fhueske <gi...@git.apache.org> on 2016/02/29 15:29:18 UTC, 5 replies.
- [jira] [Created] (FLINK-3539) Sync running Execution and Task instances via heartbeats - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 15:45:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3540) Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/29 15:57:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3534] [runtime] Prevent canceling Execu... - posted by uce <gi...@git.apache.org> on 2016/02/29 16:04:56 UTC, 5 replies.
- [jira] [Commented] (FLINK-3534) Cancelling a running job can lead to restart instead of stopping - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 16:05:18 UTC, 5 replies.
- [jira] [Created] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:14:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3541) Clean up workaround in FlinkKafkaConsumer09 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:17:18 UTC, 0 replies.
- [GitHub] flink pull request: [docs] Update readme with current feature list... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/29 16:28:16 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3540] Shade org.htrace in flink-shaded-... - posted by rmetzger <gi...@git.apache.org> on 2016/02/29 16:31:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-3540) Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 16:32:18 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3486) Use Project to rename all record fields would fail following Project. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/29 16:32:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3486] [tableAPI] Fix broken renaming of... - posted by fhueske <gi...@git.apache.org> on 2016/02/29 16:36:31 UTC, 3 replies.
- [jira] [Commented] (FLINK-3486) Use Project to rename all record fields would fail following Project. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 16:37:18 UTC, 3 replies.
- [jira] [Created] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:47:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3062) Kafka Producer is not failing if broker is not available/no partitions available - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/02/29 16:48:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3536) Make clearer distinction between event time and processing time - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 17:39:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3538) DataStream join API does not enforce consistent usage - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 17:39:18 UTC, 0 replies.
- [jira] [Commented] (FLINK-3505) JoinUnionTransposeRule fails to push Join past Union. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/02/29 17:42:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3536] Make clearer distinction between ... - posted by aljoscha <gi...@git.apache.org> on 2016/02/29 17:43:18 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3538] Streamline Scala DataStream.join/... - posted by aljoscha <gi...@git.apache.org> on 2016/02/29 17:44:45 UTC, 5 replies.
- [jira] [Commented] (FLINK-3538) DataStream join API does not enforce consistent usage - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 17:45:18 UTC, 5 replies.
- [jira] [Created] (FLINK-3543) Introduce ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 17:50:18 UTC, 0 replies.
- [jira] [Updated] (FLINK-3543) Introduce ResourceManager component - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 17:51:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3544) ResourceManager runtime components - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 18:06:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3545) ResourceManager: YARN integration - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/02/29 18:07:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3544] Introduce ResourceManager compone... - posted by mxm <gi...@git.apache.org> on 2016/02/29 18:47:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-3544) ResourceManager runtime components - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 18:47:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3546) Streaming Table API - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 19:02:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3547) Add support for streaming projection, selection, and union - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/02/29 19:10:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 19:21:18 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 19:26:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3534) Cancelling a running job can lead to restart instead of stopping - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 20:08:18 UTC, 0 replies.
- [jira] [Closed] (FLINK-3535) Decrease logging verbosity of StackTraceSampleCoordinator - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/02/29 20:11:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3548] [api-breaking] Remove unnecessary... - posted by aljoscha <gi...@git.apache.org> on 2016/02/29 20:25:19 UTC, 2 replies.
- [jira] [Commented] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 20:26:18 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3538) DataStream join API does not enforce consistent usage - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 20:39:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3536) Make clearer distinction between event time and processing time - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 20:54:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3540) Hadoop 2.6.3 build contains /com/google/common (guava) classes in flink-dist.jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/02/29 21:13:18 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3548) Remove unnecessary generic parameter from SingleOutputStreamOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/02/29 21:42:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3549) Make streaming examples more streaming - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:04:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3550) Rework stream join example - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:05:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3551) Sync Scala and Java Streaming Examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:07:18 UTC, 0 replies.
- [jira] [Created] (FLINK-3552) Change socket WordCount to be properly windowed - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/02/29 22:08:18 UTC, 0 replies.
- [GitHub] flink pull request: [docs] fix readme typos; use the same scala st... - posted by vasia <gi...@git.apache.org> on 2016/02/29 22:53:14 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2788] [apis] Add TypeHint class to allo... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/29 23:12:43 UTC, 0 replies.
- [jira] [Commented] (FLINK-2788) Add type hint with TypeExtactor call on Hint Type - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 23:13:18 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3550] [FLINK-3552] Rework WindowJoin an... - posted by StephanEwen <gi...@git.apache.org> on 2016/02/29 23:17:11 UTC, 0 replies.
- [jira] [Commented] (FLINK-3550) Rework stream join example - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/02/29 23:17:18 UTC, 0 replies.