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

---

- [jira] [Updated] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/01 13:08:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/01 13:09:39 UTC, 7 replies.
- [jira] [Created] (FLINK-3198) Rename Grouping.getDataSet() method and add JavaDocs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/02 10:18:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3118] [Gelly] Consider ResultTypeQuerya... - posted by vasia <gi...@git.apache.org> on 2016/01/02 13:32:29 UTC, 3 replies.
- [jira] [Commented] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/02 13:32:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1870] Reintroduce indexed reader functi... - posted by mjsax <gi...@git.apache.org> on 2016/01/02 22:19:59 UTC, 16 replies.
- [jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/02 22:20:39 UTC, 16 replies.
- [jira] [Updated] (FLINK-2099) Add a SQL API - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/03 10:08:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/01/04 10:27:39 UTC, 4 replies.
- [GitHub] flink pull request: [FLINK-3194] Remove standalone web client - posted by rmetzger <gi...@git.apache.org> on 2016/01/04 10:29:08 UTC, 2 replies.
- [jira] [Commented] (FLINK-3194) Remove web client - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 10:29:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/01/04 11:15:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2928][web-dashboard] Fix confusing job ... - posted by sachingoel0101 <gi...@git.apache.org> on 2016/01/04 11:24:01 UTC, 1 replies.
- [jira] [Commented] (FLINK-2928) Confusing job status visualisation in web frontend - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 11:24:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3186] Deprecate DataSink.sortLocalOutpu... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/04 11:57:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 11:57:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3157) Web frontend json files contain author attribution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 12:00:42 UTC, 0 replies.
- [jira] [Closed] (FLINK-3157) Web frontend json files contain author attribution - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 12:00:42 UTC, 0 replies.
- [jira] [Updated] (FLINK-2980) Add CUBE/ROLLUP/GROUPING SETS operator in Table API. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/04 12:07:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/04 12:10:39 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3172] Specify JobManager port in HA mod... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/04 12:16:57 UTC, 7 replies.
- [jira] [Commented] (FLINK-3172) Specify jobmanager port in HA mode - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 12:17:39 UTC, 7 replies.
- [jira] [Resolved] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 14:05:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 14:05:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3194) Remove web client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 14:06:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3194) Remove web client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/04 14:06:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2111] Add "stop" signal to cleanly shut... - posted by tillrohrmann <gi...@git.apache.org> on 2016/01/04 14:07:33 UTC, 21 replies.
- [jira] [Commented] (FLINK-2111) Add "stop" signal to cleanly shutdown streaming jobs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 14:07:39 UTC, 21 replies.
- [GitHub] flink pull request: [FLINK-3188] Pass deletes to KeyedDeserializat... - posted by rmetzger <gi...@git.apache.org> on 2016/01/04 14:54:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3192] Add explain support to print ast ... - posted by fhueske <gi...@git.apache.org> on 2016/01/04 17:49:38 UTC, 27 replies.
- [jira] [Commented] (FLINK-3192) Add explain support to print ast and sql physical execution plan. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 17:49:39 UTC, 27 replies.
- [jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/04 19:52:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/04 20:17:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3199) KafkaITCase.testOneToOneSources - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/04 20:40:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2976] Allow to trigger checkpoints manu... - posted by gyfora <gi...@git.apache.org> on 2016/01/04 21:48:11 UTC, 4 replies.
- [jira] [Commented] (FLINK-2976) Save and load checkpoints manually - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/04 21:48:39 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/05 10:03:40 UTC, 0 replies.
- [GitHub] flink pull request: Stale Synchronous Parallel Iterations - posted by nltran <gi...@git.apache.org> on 2016/01/05 11:25:52 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3195] [examples] Consolidate Java/Scala... - posted by fhueske <gi...@git.apache.org> on 2016/01/05 11:27:00 UTC, 6 replies.
- [jira] [Commented] (FLINK-3195) Restructure examples projects and package streaming examples - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/05 11:27:39 UTC, 6 replies.
- [jira] [Closed] (FLINK-2643) Change Travis Build Profile to Exclude Hadoop 2.0.0-alpha, Include 2.7.0 - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 11:49:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 12:06:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2991) Extend Window Operators to Allow Efficient Fold Operation - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 12:06:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3200) Use Partitioned State Abstraction in WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 12:18:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3201) Enhance Partitioned State Interface with State Types - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 12:27:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3202) Make Timer/Trigger Service Scoped to Key/Namespace - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/05 13:16:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3203) Python API crashing when run in OGS - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/01/05 13:32:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3203) Python API crashing when run in OGS - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/01/05 13:33:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3203) Python API crashing when run in OGS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/05 15:08:39 UTC, 3 replies.
- [jira] [Comment Edited] (FLINK-3203) Python API crashing when run in OGS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/05 18:22:39 UTC, 2 replies.
- [GitHub] flink pull request: [streaming] [scala] Exposed environment from D... - posted by mbalassi <gi...@git.apache.org> on 2016/01/05 21:13:08 UTC, 6 replies.
- [GitHub] flink pull request: [Refactor] [Cleanup] Change bunch of if-else c... - posted by hsaputra <gi...@git.apache.org> on 2016/01/05 22:50:31 UTC, 4 replies.
- [jira] [Updated] (FLINK-3203) DistributedCache crashing when run in OGS - posted by "Omar Alvarez (JIRA)" <ji...@apache.org> on 2016/01/06 10:02:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3140] NULL value data layout in Row Ser... - posted by twalthr <gi...@git.apache.org> on 2016/01/06 10:29:56 UTC, 40 replies.
- [jira] [Commented] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 10:30:39 UTC, 41 replies.
- [GitHub] flink pull request: [FLINK-2445] Add tests for HadoopOutputFormats - posted by ajaybhat <gi...@git.apache.org> on 2016/01/06 10:34:11 UTC, 10 replies.
- [jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 10:34:39 UTC, 10 replies.
- [jira] [Created] (FLINK-3204) TaskManagers are not shutting down properly on YARN - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/06 11:19:39 UTC, 0 replies.
- [GitHub] flink pull request: Added, to the DataStream API guide guide, an e... - posted by filipefigcorreia <gi...@git.apache.org> on 2016/01/06 13:25:31 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3167] Improve documentation for window ... - posted by rtudoran <gi...@git.apache.org> on 2016/01/06 14:45:13 UTC, 8 replies.
- [jira] [Commented] (FLINK-3167) Stopping start-local.bat doesn't shutdown JM on W10 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 14:45:40 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3058] Add support for Kafka 0.9.0.0 - posted by rmetzger <gi...@git.apache.org> on 2016/01/06 14:46:35 UTC, 12 replies.
- [jira] [Commented] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 14:46:40 UTC, 12 replies.
- [GitHub] flink pull request: [FLINK-3057][py] Bidirectional Connection - posted by rmetzger <gi...@git.apache.org> on 2016/01/06 15:00:26 UTC, 3 replies.
- [jira] [Commented] (FLINK-3057) [py] Provide a way to pass information back to the plan process - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 15:00:44 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-3093] Introduce annotations for interfa... - posted by rmetzger <gi...@git.apache.org> on 2016/01/06 15:24:27 UTC, 4 replies.
- [jira] [Commented] (FLINK-3093) Introduce annotations for interface stability - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 15:24:39 UTC, 5 replies.
- [jira] [Created] (FLINK-3205) Remove the flink-staging module - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/06 16:21:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2833) Unstage Gelly and Module refactoring - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/06 16:23:40 UTC, 1 replies.
- [jira] [Updated] (FLINK-2877) Move Streaming API out of Staging - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/06 16:23:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3205) Remove the flink-staging module - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/06 16:27:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3206) Heap size for non-pre-allocated off-heap memory - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/06 17:27:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3206) Heap size for non-pre-allocated off-heap memory - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/06 17:39:40 UTC, 5 replies.
- [GitHub] flink pull request: corrections in the javadoc examples of tumblin... - posted by vasia <gi...@git.apache.org> on 2016/01/06 19:44:26 UTC, 3 replies.
- [jira] [Created] (FLINK-3207) Add a Pregel iteration abstraction to Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/06 19:53:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3207) Add a Pregel iteration abstraction to Gelly - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/06 19:53:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/06 19:56:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/06 19:56:40 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3115:[WIP] Update ElasticSearch connecto... - posted by smarthi <gi...@git.apache.org> on 2016/01/06 21:23:24 UTC, 1 replies.
- [jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/06 21:23:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/07 01:05:39 UTC, 1 replies.
- [jira] [Updated] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/07 01:05:40 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2125][streaming] Delimiter change from ... - posted by ajaybhat <gi...@git.apache.org> on 2016/01/07 10:07:03 UTC, 5 replies.
- [jira] [Commented] (FLINK-2125) String delimiter for SocketTextStream - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/07 10:07:39 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1712] Remove "flink-staging" module - posted by rmetzger <gi...@git.apache.org> on 2016/01/07 10:32:10 UTC, 9 replies.
- [jira] [Commented] (FLINK-1712) Restructure Maven Projects - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/07 10:32:39 UTC, 9 replies.
- [GitHub] flink pull request: Added, to the DataStream API guide, an example... - posted by rmetzger <gi...@git.apache.org> on 2016/01/07 14:04:57 UTC, 4 replies.
- [jira] [Assigned] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/07 14:22:39 UTC, 0 replies.
- [GitHub] flink pull request: Update PoissonSampler.java - posted by rmetzger <gi...@git.apache.org> on 2016/01/07 14:30:15 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-3187] Introduce RestartStrategy to deco... - posted by rmetzger <gi...@git.apache.org> on 2016/01/07 14:46:21 UTC, 8 replies.
- [jira] [Commented] (FLINK-3187) Decouple restart strategy from ExecutionGraph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/07 14:46:39 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3174] Add merging WindowAssigner - posted by rmetzger <gi...@git.apache.org> on 2016/01/07 14:59:14 UTC, 2 replies.
- [jira] [Commented] (FLINK-3174) Add merging WindowAssigner - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/07 14:59:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3189] Error while parsing job arguments... - posted by mjsax <gi...@git.apache.org> on 2016/01/07 15:48:21 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-1994] [ml] Add different gain calculati... - posted by rawkintrevo <gi...@git.apache.org> on 2016/01/07 16:12:14 UTC, 30 replies.
- [jira] [Commented] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/07 16:12:39 UTC, 30 replies.
- [jira] [Created] (FLINK-3209) Remove Unused ProcessingTime, EventTime and AbstractTime - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/07 18:18:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3176) Window Apply Website Example - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/07 19:03:40 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3197: InputStream not closed in BinaryIn... - posted by ajaybhat <gi...@git.apache.org> on 2016/01/08 08:27:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/08 08:28:39 UTC, 4 replies.
- [GitHub] flink pull request: FLINK-1737: Kronecker product - posted by tillrohrmann <gi...@git.apache.org> on 2016/01/08 17:42:42 UTC, 1 replies.
- [jira] [Commented] (FLINK-1737) Add statistical whitening transformation to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/08 17:43:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/08 18:09:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/08 18:29:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-2765) Upgrade hbase version for hadoop-2 to 1.1 release - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/08 21:43:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/09 08:23:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/09 09:06:39 UTC, 11 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/10 07:36:39 UTC, 8 replies.
- [jira] [Comment Edited] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/10 07:41:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-3211) Add AWS Kinesis streaming connector with deep integration with Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/10 10:54:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector with deep integration with Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/10 11:41:39 UTC, 1 replies.
- [jira] [Comment Edited] (FLINK-3211) Add AWS Kinesis streaming connector with deep integration with Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/10 11:42:40 UTC, 5 replies.
- [jira] [Created] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/10 16:48:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3109) Join two streams with two different buffer time - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/10 20:01:39 UTC, 12 replies.
- [jira] [Created] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/10 20:07:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/01/10 20:13:40 UTC, 0 replies.
- [GitHub] flink pull request: [Storm-Compatibility] Forward Storm Kryo regis... - posted by mjsax <gi...@git.apache.org> on 2016/01/10 21:55:37 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3211) Add AWS Kinesis streaming connector - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/11 05:10:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/11 07:46:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3214) WindowCheckpointingITCase - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/11 07:49:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3050] [runtime] Add UnrecoverableExcept... - posted by uce <gi...@git.apache.org> on 2016/01/11 10:06:02 UTC, 1 replies.
- [jira] [Commented] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/11 10:06:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3050) Add custom Exception type to suppress job restarts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/11 16:33:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2976) Save and load checkpoints manually - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/11 16:33:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3215) Add CEP library to Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/11 17:08:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3216) Define pattern specification - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/11 17:15:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3217) Implement NFA for pattern detection - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/11 17:21:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3218) Merging Hadoop configurations overrides user parameters - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/11 18:49:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar - posted by "Christophe S (JIRA)" <ji...@apache.org> on 2016/01/11 18:56:39 UTC, 3 replies.
- [jira] [Created] (FLINK-3219) Implement DataSet.count using a single operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/11 19:18:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2551) Fix Several Bugs in Input/Output Formats - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/01/11 22:28:40 UTC, 8 replies.
- [GitHub] flink pull request: [FLINK-3218] Merging Hadoop configurations ove... - posted by greghogan <gi...@git.apache.org> on 2016/01/11 22:37:38 UTC, 3 replies.
- [jira] [Commented] (FLINK-3218) Merging Hadoop configurations overrides user parameters - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/11 22:37:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2716] [gelly java scala] New checksum m... - posted by greghogan <gi...@git.apache.org> on 2016/01/11 22:48:01 UTC, 9 replies.
- [jira] [Commented] (FLINK-2716) Checksum method for DataSet and Graph - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/11 22:48:39 UTC, 9 replies.
- [GitHub] flink pull request: FLINK-2551 Fix Several Bugs in Input/Output Fo... - posted by ndimiduk <gi...@git.apache.org> on 2016/01/11 23:05:59 UTC, 5 replies.
- [jira] [Closed] (FLINK-430) Provide a simple way of parsing text - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/11 23:35:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/11 23:44:39 UTC, 2 replies.
- [jira] [Closed] (FLINK-1241) Record processing counter for Dashboard - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:09:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:10:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-1500) exampleScalaPrograms.EnumTriangleOptITCase does not finish on Travis - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1581) Configure DeathWatch parameters properly - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:23:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-1644) WebClient dies when no ExecutionEnvironment in main method - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 00:42:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1712) Restructure Maven Projects - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/12 09:40:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1712) Restructure Maven Projects - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/12 09:40:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/12 10:26:39 UTC, 0 replies.
- [GitHub] flink pull request: [Docs] Fixed code example in streaming docs - posted by mjsax <gi...@git.apache.org> on 2016/01/12 10:34:43 UTC, 4 replies.
- [jira] [Closed] (FLINK-1581) Configure DeathWatch parameters properly - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/12 11:23:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/12 11:32:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-1745] Add exact k-nearest-neighbours al... - posted by chiwanpark <gi...@git.apache.org> on 2016/01/12 11:58:30 UTC, 7 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/01/12 11:58:39 UTC, 7 replies.
- [GitHub] flink pull request: [Flink-1999] basic TfidfTransformer - posted by chiwanpark <gi...@git.apache.org> on 2016/01/12 12:08:02 UTC, 11 replies.
- [jira] [Resolved] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically - posted by "Suneel Marthi (JIRA)" <ji...@apache.org> on 2016/01/12 13:19:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1274) Make Flink Streaming's FileSourceFunction type generic - posted by "Péter Szabó (JIRA)" <ji...@apache.org> on 2016/01/12 14:01:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3220) Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/12 14:33:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3132] [docs] Initial docs restructure - posted by uce <gi...@git.apache.org> on 2016/01/12 14:55:13 UTC, 19 replies.
- [jira] [Commented] (FLINK-3132) Restructure streaming guide - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/12 14:55:39 UTC, 19 replies.
- [GitHub] flink pull request: [FLINK-2935] [scala-shell] Allow Scala shell t... - posted by chiwanpark <gi...@git.apache.org> on 2016/01/12 15:18:16 UTC, 22 replies.
- [jira] [Commented] (FLINK-2935) Allow scala shell to read yarn properties - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/12 15:18:39 UTC, 22 replies.
- [jira] [Updated] (FLINK-3219) Implement DataSet.count using a single operator - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/12 17:45:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3221) Move Table API on top of Apache Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:01:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/12 18:01:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3221) Move Table API on top of Apache Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:04:40 UTC, 1 replies.
- [jira] [Commented] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/12 18:07:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3223) Translate Table API query into logical relational plans for Apache Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3224) The Streaming API does not call setInputType if a format implements InputTypeConfigurable - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/01/12 18:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3225) Optimize logical Table API plans in Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:27:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:36:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3227) Translate physical Table API plan into DataSet program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:40:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3223) Translate Table API query into logical relational plans for Apache Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/12 18:44:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3219] [java scala] Implement DataSet.co... - posted by greghogan <gi...@git.apache.org> on 2016/01/12 21:35:00 UTC, 4 replies.
- [jira] [Commented] (FLINK-3219) Implement DataSet.count using a single operator - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/12 21:35:40 UTC, 4 replies.
- [jira] [Created] (FLINK-3228) Cannot submit multiple streaming involving JDBC drivers - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2016/01/12 23:33:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3192) Add explain support to print ast and sql physical execution plan. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/13 00:28:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3218) Merging Hadoop configurations overrides user parameters - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/13 00:29:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/13 00:30:39 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/01/13 00:30:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/13 03:13:39 UTC, 14 replies.
- [GitHub] flink pull request: [FLINK-2342] [ml] Add new fit operation and mo... - posted by chiwanpark <gi...@git.apache.org> on 2016/01/13 03:51:50 UTC, 3 replies.
- [jira] [Commented] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/13 03:52:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-3228) Cannot submit multiple streaming involving JDBC drivers - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/01/13 08:02:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/01/13 08:06:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3229) Kinesis consumer with integration of Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/13 09:06:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/13 09:43:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/13 09:43:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/13 10:34:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2865) OutOfMemory error (Direct buffer memory) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/13 11:21:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-2773) OutOfMemoryError on YARN Session - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/13 11:25:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/13 11:27:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/13 11:29:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2847) Fix flaky test in StormTestBase.testJob - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/13 11:32:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3230) Kinesis streaming producer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/13 11:38:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/13 11:40:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/13 12:16:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3227) Translate physical Table API plan into DataSet program - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/01/13 13:22:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Tzu-Li (Gordon) Tai (JIRA)" <ji...@apache.org> on 2016/01/13 14:18:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3232) Add option to eagerly deploy channels - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/13 17:08:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/13 17:29:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2720][storm-compatibility]Add Storm-Cou... - posted by mjsax <gi...@git.apache.org> on 2016/01/13 17:30:20 UTC, 0 replies.
- [jira] [Commented] (FLINK-2720) Add Storm-CountMetric in flink-stormcompatibility - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/13 17:30:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2586] Unstable Storm Compatibility Test... - posted by mjsax <gi...@git.apache.org> on 2016/01/13 18:13:43 UTC, 5 replies.
- [jira] [Commented] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/13 18:14:39 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3232] Add option to eagerly deploy chan... - posted by uce <gi...@git.apache.org> on 2016/01/13 19:31:46 UTC, 2 replies.
- [jira] [Commented] (FLINK-3232) Add option to eagerly deploy channels - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/13 19:32:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2871] support outer join for hash join ... - posted by fhueske <gi...@git.apache.org> on 2016/01/13 22:40:09 UTC, 46 replies.
- [jira] [Commented] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/13 22:40:40 UTC, 46 replies.
- [GitHub] flink pull request: [FLINK-2984] [ml] Extend libSVM file format su... - posted by chiwanpark <gi...@git.apache.org> on 2016/01/14 10:13:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/14 10:13:40 UTC, 3 replies.
- [jira] [Closed] (FLINK-2342) Add new fit operation and more tests for StandardScaler - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/01/14 10:18:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3233) PartitionOperator does not support expression keys on atomic types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 11:30:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3234) SortPartition does not support KeySelectorFunctions - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 11:35:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2606) Extend StormFileSpout to handle HDFS - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/14 14:58:39 UTC, 0 replies.
- [GitHub] flink pull request: Enerscore spring classloading fix - posted by revprez <gi...@git.apache.org> on 2016/01/14 15:32:29 UTC, 1 replies.
- [GitHub] flink pull request: Fix to class loader to ensure tasks receive th... - posted by revprez <gi...@git.apache.org> on 2016/01/14 16:10:29 UTC, 8 replies.
- [jira] [Resolved] (FLINK-1712) Restructure Maven Projects - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/14 17:17:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3195) Restructure examples projects and package streaming examples - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/14 17:17:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/14 18:30:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-1125) JobManager exception shown incompletely in TaskManager logs - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1936) Normalize keys and default values in ConfigConstants.java - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:24:39 UTC, 2 replies.
- [jira] [Closed] (FLINK-1518) Laggy task cancelling on task managers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:25:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-1810) UpdateTask message contains unused information - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:28:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1861) Rename doc deployment directories - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:30:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-1860) Release script out of sync with build artifacts - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:31:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1864) Investigate Travis build success when locally not building - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:31:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3235) Drop Flink-on-Tez code - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:34:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2064) Set Tez version to 0.6.1 - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:35:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-1877) Stalled Flink on Tez build - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:35:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-1895) Add task chaining to Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:36:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1893) Add Scala support for Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:37:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1898) Add support for self-joins to Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:37:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1894) Add Tez execution mode to Flink command-line tools - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:37:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1897) Add accummulators and counters feature to Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:37:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-1896) Add broadcast variables feature to Flink on Tez - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:38:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2927) Provide default required configuration keys in flink-conf of binary distribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:40:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3183) Display direct memory stats in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:44:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2962) Cluster startup script refers to unused variable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:51:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1861) Rename doc deployment directories - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/14 19:52:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2099) Add a SQL API - posted by "chenliang613 (JIRA)" <ji...@apache.org> on 2016/01/14 20:23:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-2099) Add a SQL API - posted by "chenliang613 (JIRA)" <ji...@apache.org> on 2016/01/14 20:24:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3236) Flink user code classloader should have Flink classloader as parent classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/14 20:29:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3236) Flink user code classloader should have Flink classloader as parent classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/14 20:29:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1666) Clean-up Field Expression Code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:22:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1272) Add a "reduceWithKey" function - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:22:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1269) Easy way to "group count" dataset - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:23:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1140) Add a flatmap that returns an Iterable instead of aggregation to a collector - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:24:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2250) Backtracking of intermediate results - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:24:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2020) Table API JoinITCase fails non-deterministically - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:26:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2907) Bloom filter for Join - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:26:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-605) Compiler hints for new java api - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:27:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-87) Extend collectors to specify target sink - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:27:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1456) Projection to fieldnames, keyselectors - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:27:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-553) Add getGroupKey() method to group-at-time operators - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:27:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2435) Add support for custom CSV field parsers - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:28:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-1733) Add PCA to machine learning library - posted by "Thang Nguyen (JIRA)" <ji...@apache.org> on 2016/01/14 21:28:40 UTC, 4 replies.
- [jira] [Updated] (FLINK-3164) Spread out scheduling strategy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:29:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2315) Hadoop Writables cannot exploit implementing NormalizableKey - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:29:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:30:40 UTC, 2 replies.
- [jira] [Updated] (FLINK-2678) Java/Scala API does not support multi-dimensional arrays as keys - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:30:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1293) Add support for out-of-place aggregations - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:31:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1127) Utility library - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:31:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1267) Add crossGroup operator - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:31:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1890) Add note to docs that ReadFields annotations are currently not evaluated - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:32:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1919) Add HCatOutputFormat for Tuple data types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:32:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2274) Add a histogram method for DataSet[Double] - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:32:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1045) Remove Combinable Annotation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:32:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-2693) Refactor InvalidTypesException to be checked - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:33:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-992) Create CollectionDataSets by reading (client) local files. - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:33:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2549) Add topK operator for DataSet - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:33:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1267) Add crossGroup operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/14 21:34:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-1388) POJO support for writeAsCsv - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:34:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2716) Checksum method for DataSet and Graph - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/14 21:34:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3184] [timeouts] Decrease timeouts - posted by StephanEwen <gi...@git.apache.org> on 2016/01/14 22:34:58 UTC, 6 replies.
- [jira] [Commented] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/14 22:35:40 UTC, 6 replies.
- [GitHub] flink pull request: [FLINK-3165] [py] Windows OS support - posted by StephanEwen <gi...@git.apache.org> on 2016/01/14 22:41:45 UTC, 1 replies.
- [jira] [Commented] (FLINK-3165) [py] Add support for Windows OS - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/14 22:42:39 UTC, 2 replies.
- [jira] [Created] (FLINK-3237) Create AsynchronousKvStateSnapshot similar to AsynchronousStateHandle - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/01/14 22:51:39 UTC, 0 replies.
- [GitHub] flink pull request: [Refactor] [DataSet] Refactor key selector tra... - posted by fhueske <gi...@git.apache.org> on 2016/01/14 23:28:58 UTC, 3 replies.
- [GitHub] flink pull request: [hotfix] moved files to correct folder to matc... - posted by mjsax <gi...@git.apache.org> on 2016/01/15 00:17:28 UTC, 3 replies.
- [GitHub] flink pull request: Using AccumulatorSnapshot's class loader deser... - posted by revprez <gi...@git.apache.org> on 2016/01/15 01:39:05 UTC, 1 replies.
- [jira] [Closed] (FLINK-2984) Support lenient parsing of SVMLight input files - posted by "Chiwan Park (JIRA)" <ji...@apache.org> on 2016/01/15 02:22:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2586) Unstable Storm Compatibility Tests - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/15 09:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/15 10:05:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3239) Support for Kerberos enabled Kafka 0.9.0.0 - posted by "Niels Basjes (JIRA)" <ji...@apache.org> on 2016/01/15 10:12:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3240) Remove or document DataStream(.global|.forward) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/15 10:15:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1733) Add PCA to machine learning library - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/15 10:31:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/15 11:06:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1045) Remove Combinable Annotation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/15 11:24:39 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:54:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:54:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3232) Add option to eagerly deploy channels - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:55:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3219) Implement DataSet.count using a single operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:55:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3219) Implement DataSet.count using a single operator - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:55:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3235) Drop Flink-on-Tez code - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:56:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3235) Drop Flink-on-Tez code - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:56:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3232) Add option to eagerly deploy channels - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:56:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3236) Flink user code classloader should have Flink classloader as parent classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:57:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3236) Flink user code classloader should have Flink classloader as parent classloader - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 11:57:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/15 12:19:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3010) Add link to powered-by wiki page to project website - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/15 15:39:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-3010) Add link to powered-by wiki page to project website - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/15 15:45:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/15 16:06:39 UTC, 22 replies.
- [jira] [Comment Edited] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/15 16:07:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3209] Remove Unused ProcessingTime, Eve... - posted by aljoscha <gi...@git.apache.org> on 2016/01/15 16:08:58 UTC, 5 replies.
- [jira] [Commented] (FLINK-3209) Remove Unused ProcessingTime, EventTime and AbstractTime - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/15 16:09:39 UTC, 5 replies.
- [jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 16:10:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 16:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/15 16:30:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2380) Allow to configure default FS for file inputs - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/01/15 16:40:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/15 16:43:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3073) Activate streaming mode by default - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/15 16:44:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3172) Specify jobmanager port in HA mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/15 16:45:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 16:49:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3132) Restructure streaming guide - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/15 16:51:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3244) Add log messages to savepoint coordinator restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/15 17:12:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1947) Make Avro and Tachyon test logging less verbose - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/15 17:21:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-1947) Make Avro and Tachyon test logging less verbose - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 17:34:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1947) Make Avro and Tachyon test logging less verbose - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 17:34:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-992) Create CollectionDataSets by reading (client) local files. - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/15 17:53:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3243] Fix Interplay of TimeCharacterist... - posted by aljoscha <gi...@git.apache.org> on 2016/01/15 18:40:11 UTC, 3 replies.
- [jira] [Commented] (FLINK-3243) Fix Interplay of TimeCharacteristic and Time Windows - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/15 18:40:39 UTC, 3 replies.
- [jira] [Resolved] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 19:03:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2671) Instable Test StreamCheckpointNotifierITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 19:03:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2716) Checksum method for DataSet and Graph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 19:04:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2716) Checksum method for DataSet and Graph - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/15 19:04:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/15 22:08:39 UTC, 9 replies.
- [GitHub] flink pull request: [FLINK-3208] [gelly] rename vertex-centric ite... - posted by vasia <gi...@git.apache.org> on 2016/01/16 12:41:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-3208) Rename Gelly vertex-centric model to scatter-gather - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/16 12:41:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-1885] [gelly] Added bulk execution mode... - posted by vasia <gi...@git.apache.org> on 2016/01/16 13:01:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-1885) Bulk mode for gelly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/16 13:02:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2634] [gelly] [WIP] Vertex Centric Tria... - posted by vasia <gi...@git.apache.org> on 2016/01/16 13:03:42 UTC, 4 replies.
- [jira] [Commented] (FLINK-2634) Add a Vertex-centric Version of the Tringle Count Library Method - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/16 13:04:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-2366) HA Without ZooKeeper - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/01/16 21:37:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-2287) Implement JobManager high availability - posted by "Eron Wright (JIRA)" <ji...@apache.org> on 2016/01/16 21:45:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset - posted by "Kay (JIRA)" <ji...@apache.org> on 2016/01/17 17:19:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/17 17:48:39 UTC, 2 replies.
- [jira] [Created] (FLINK-3246) Consolidate maven project names with *-parent suffix - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/17 19:49:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3246] Remove unnecessary '-parent' suff... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/17 19:53:44 UTC, 5 replies.
- [jira] [Commented] (FLINK-3246) Consolidate maven project names with *-parent suffix - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/17 19:54:39 UTC, 5 replies.
- [jira] [Created] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/17 22:09:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3097] [table] Add support for custom fu... - posted by twalthr <gi...@git.apache.org> on 2016/01/18 09:22:23 UTC, 4 replies.
- [jira] [Commented] (FLINK-3097) Add support for custom functions in Table API - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 09:22:39 UTC, 4 replies.
- [jira] [Assigned] (FLINK-1903) Joins where one side uses a field more than once don't work - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/18 10:08:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3233) PartitionOperator does not support expression keys on atomic types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/18 10:08:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1666) Clean-up Field Expression Code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/18 10:08:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/18 11:23:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3220) Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/18 11:24:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/18 11:26:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/18 11:31:39 UTC, 3 replies.
- [jira] [Created] (FLINK-3249) Wrong "unknown partition state/input gate" error messages - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 11:33:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/18 11:34:39 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2522] Streaming support for Flink-Scala... - posted by mxm <gi...@git.apache.org> on 2016/01/18 11:39:36 UTC, 2 replies.
- [jira] [Commented] (FLINK-2522) Integrate Streaming Api into Flink-scala-shell - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 11:39:39 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/18 11:51:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3242] Also Set User-specified StateBack... - posted by aljoscha <gi...@git.apache.org> on 2016/01/18 11:55:12 UTC, 3 replies.
- [jira] [Commented] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 11:55:39 UTC, 3 replies.
- [jira] [Assigned] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/18 12:03:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/18 12:03:39 UTC, 9 replies.
- [jira] [Assigned] (FLINK-1045) Remove Combinable Annotation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/18 12:21:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/18 13:12:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3250) Savepoint coordinator requires too strict parallelism match - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 13:55:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/01/18 14:00:42 UTC, 0 replies.
- [jira] [Created] (FLINK-3251) Checkpoint stats show ghost numbers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 14:01:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3170] expose task manager metrics via J... - posted by mxm <gi...@git.apache.org> on 2016/01/18 14:13:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3170) Expose task manager metrics via JMX - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 14:13:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3252) Checkpoint stats only displayed after click on graph - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 14:34:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2911) AccumulatingAlignedProcessingTimeWindowOperatorTest.checkpointRestoreWithPendingWindowTumbling - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/18 14:54:39 UTC, 0 replies.
- [jira] [Reopened] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/18 14:57:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/18 14:58:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/18 15:00:41 UTC, 0 replies.
- [jira] [Created] (FLINK-3253) deserializeObject exception on WindowOperator - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/01/18 15:18:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3254) CombineFunction interface not respected - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/18 16:04:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3253) deserializeObject exception on WindowOperator - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/18 16:19:39 UTC, 3 replies.
- [jira] [Closed] (FLINK-3251) Checkpoint stats show ghost numbers - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:01:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3252) Checkpoint stats only displayed after click on graph - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:04:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3252) Checkpoint stats only displayed after click on graph - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:04:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2845) TimestampITCase.testWatermarkPropagation - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:05:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3250) Savepoint coordinator requires too strict parallelism match - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:50:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3244) Add log messages to savepoint coordinator restore - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/18 17:50:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2237] [runtime] Add hash-based combiner... - posted by ggevay <gi...@git.apache.org> on 2016/01/18 17:53:50 UTC, 11 replies.
- [jira] [Commented] (FLINK-2237) Add hash-based Aggregation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 17:54:39 UTC, 11 replies.
- [jira] [Created] (FLINK-3255) Chaining behavior should not depend on parallelism - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/18 18:38:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3256) Invalid execution graph cleanup for jobs with colocation groups - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/01/18 19:52:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3255] [streaming] Disable parallelism-d... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/18 20:05:06 UTC, 4 replies.
- [jira] [Commented] (FLINK-3255) Chaining behavior should not depend on parallelism - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 20:05:39 UTC, 4 replies.
- [jira] [Created] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/01/18 20:11:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3238) EventTimeAllWindowCheckpointingITCase.testSlidingTimeWindow() - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/18 21:47:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2831] [Storm Compatibility Tests] Fixed... - posted by mjsax <gi...@git.apache.org> on 2016/01/18 21:48:13 UTC, 3 replies.
- [jira] [Commented] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/18 21:48:39 UTC, 4 replies.
- [jira] [Commented] (FLINK-3257) Add Exactly-Once Processing Guarantees in Iterative DataStream Jobs - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/01/18 22:01:39 UTC, 2 replies.
- [jira] [Created] (FLINK-3258) Merge AbstractInvokable's registerInputOutput and invoke - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/19 12:32:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3259) Redirect programming guides to new layout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/19 12:37:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3256) Invalid execution graph cleanup for jobs with colocation groups - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/01/19 12:44:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/19 12:47:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3260) ExecutionGraph gets stuck in state FAILING - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/19 14:46:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3260) ExecutionGraph gets stuck in state FAILING - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/19 14:48:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3220) Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/19 15:03:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/19 15:08:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2831) Failing Test: WrapperSetupHelperTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2016/01/19 15:21:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3261) Tasks should eagerly report back when they cannot start a checkpoint - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/19 15:22:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3262) Remove fuzzy versioning from Bower dependencies - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/19 16:19:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/19 17:24:39 UTC, 0 replies.
- [GitHub] flink pull request: - posted by rmetzger <gi...@git.apache.org> on 2016/01/19 17:47:21 UTC, 10 replies.
- [GitHub] flink pull request: [FLINK-1666] [FLINK-1903] [FLINK-3233] Refacto... - posted by fhueske <gi...@git.apache.org> on 2016/01/19 18:01:43 UTC, 3 replies.
- [jira] [Commented] (FLINK-1666) Clean-up Field Expression Code - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/19 18:02:40 UTC, 3 replies.
- [jira] [Closed] (FLINK-3165) [py] Add support for Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/19 18:11:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2321) The seed for the SVM classifier is currently static - posted by "Theodore Vasiloudis (JIRA)" <ji...@apache.org> on 2016/01/19 19:09:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3122] [Gelly] Generic vertex value in l... - posted by s1ck <gi...@git.apache.org> on 2016/01/19 21:05:23 UTC, 3 replies.
- [jira] [Commented] (FLINK-3122) Generalize value type in LabelPropagation - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/19 21:05:39 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-1045] Remove Combinable annotation. - posted by fhueske <gi...@git.apache.org> on 2016/01/19 21:13:38 UTC, 3 replies.
- [jira] [Created] (FLINK-3263) Log task statistics on TaskManager - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/19 21:58:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3161][dist] Externalize cluster start-u... - posted by greghogan <gi...@git.apache.org> on 2016/01/19 22:26:04 UTC, 8 replies.
- [GitHub] flink pull request: FLINK-2380: allow to specify the default files... - posted by kl0u <gi...@git.apache.org> on 2016/01/19 22:36:27 UTC, 18 replies.
- [GitHub] flink pull request: [FLINK-3262][web-dashboard] Remove fuzzy versi... - posted by greghogan <gi...@git.apache.org> on 2016/01/20 03:15:01 UTC, 4 replies.
- [jira] [Commented] (FLINK-3262) Remove fuzzy versioning from Bower dependencies - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/20 03:15:39 UTC, 4 replies.
- [jira] [Closed] (FLINK-3057) [py] Provide a way to pass information back to the plan process - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 07:26:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3014) Return code from InputStream#read() should be checked in PythonStreamer#sendBroadCastVariables - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 07:27:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3263) Log task statistics on TaskManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 10:16:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3063) [py] Remove combiner - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 10:21:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3063) [py] Remove combiner - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 10:21:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/20 10:23:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3261) Tasks should eagerly report back when they cannot start a checkpoint - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/20 11:14:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3264) Add load shedding policy into Kafka Consumers - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 11:49:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2021) Rework examples to use ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 12:12:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2021) Rework examples to use ParameterTool - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 12:21:40 UTC, 35 replies.
- [jira] [Reopened] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/20 12:42:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3256] Fix colocation group re-instantia... - posted by senorcarbone <gi...@git.apache.org> on 2016/01/20 14:34:52 UTC, 6 replies.
- [jira] [Commented] (FLINK-3256) Invalid execution graph cleanup for jobs with colocation groups - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/20 14:35:39 UTC, 6 replies.
- [jira] [Closed] (FLINK-2562) [py] Implement KeySelectors - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 14:52:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2501) [py] Remove the need to specify types for transformations - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 14:52:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3265) Unstable RabbitMQ test: MessageAcknowledgingSourceBase.notifyCheckpointComplete: ConcurrentModificationException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 15:14:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3109]Join two streams with two differen... - posted by wangyangjun <gi...@git.apache.org> on 2016/01/20 15:59:08 UTC, 10 replies.
- [jira] [Created] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/01/20 16:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3267) Disable reference tracking in Kryo fallback serializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 16:27:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3267) Disable reference tracking in Kryo fallback serializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 16:28:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3267] Disable reference tracking in Kry... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/20 16:28:52 UTC, 4 replies.
- [jira] [Commented] (FLINK-3267) Disable reference tracking in Kryo fallback serializer - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/20 16:29:39 UTC, 4 replies.
- [jira] [Assigned] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/20 16:54:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/20 16:55:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-2933] Flink scala libraries exposed wit... - posted by mxm <gi...@git.apache.org> on 2016/01/20 17:06:10 UTC, 12 replies.
- [jira] [Commented] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/20 17:06:39 UTC, 12 replies.
- [jira] [Created] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 17:21:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 17:27:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 17:32:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3266) LocalFlinkMiniCluster leaks resources when multiple jobs are submitted - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 17:33:39 UTC, 3 replies.
- [jira] [Updated] (FLINK-3265) RabbitMQ not threadsafe: ConcurrentModificationException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 17:34:39 UTC, 2 replies.
- [jira] [Updated] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/20 17:34:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-2439) [py] Expand DataSet feature coverage - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 17:43:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3247) Kafka Connector unusable with quickstarts - shading issue - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 17:58:40 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3268) Unstable test JobManagerSubmittedJobGraphsRecoveryITCase - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/20 18:13:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/20 18:17:39 UTC, 6 replies.
- [GitHub] flink pull request: FLINK-3135 Add chainable driver for UNARY_NO_O... - posted by ramkrish86 <gi...@git.apache.org> on 2016/01/20 18:43:43 UTC, 2 replies.
- [jira] [Commented] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/20 18:44:39 UTC, 11 replies.
- [jira] [Created] (FLINK-3269) Return value from DataInputStream#read() should be checked in PythonPlanReceiver - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/20 20:21:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/20 20:33:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3269) Return value from DataInputStream#read() should be checked in PythonPlanReceiver - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 21:03:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3269) Return value from DataInputStream#read() should be checked in PythonPlanReceiver - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/20 21:04:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3122) Generalize value type in LabelPropagation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/20 22:55:40 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3122) Generalize value type in LabelPropagation - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2016/01/20 22:55:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3222) Incorrect shift amount in OperatorCheckpointStats#hashCode() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/20 23:54:39 UTC, 1 replies.
- [GitHub] flink pull request: Tidied up some docs. Fixed some non-idiomatic ... - posted by sksamuel <gi...@git.apache.org> on 2016/01/21 01:02:33 UTC, 6 replies.
- [jira] [Closed] (FLINK-3269) Return value from DataInputStream#read() should be checked in PythonPlanReceiver - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/21 07:50:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3270) Add example for reading and writing to Kafka - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/21 10:40:39 UTC, 0 replies.
- [GitHub] flink pull request: [refactor] Rename OperatorState to ValueState,... - posted by aljoscha <gi...@git.apache.org> on 2016/01/21 11:25:33 UTC, 1 replies.
- [GitHub] flink pull request: [hotfix] Fix interaction of Async calls/checkp... - posted by aljoscha <gi...@git.apache.org> on 2016/01/21 11:26:29 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-3270] Add Kafka example - posted by rmetzger <gi...@git.apache.org> on 2016/01/21 11:43:51 UTC, 2 replies.
- [jira] [Commented] (FLINK-3270) Add example for reading and writing to Kafka - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/21 11:44:39 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/21 11:47:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3265] Make RabbitMQ source threadsafe - posted by rmetzger <gi...@git.apache.org> on 2016/01/21 12:22:58 UTC, 3 replies.
- [jira] [Commented] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/21 12:23:39 UTC, 3 replies.
- [jira] [Commented] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/21 12:25:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3065) Can't cancel failing jobs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/21 12:26:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-2972] remove Chill dependency from the ... - posted by mxm <gi...@git.apache.org> on 2016/01/21 12:33:34 UTC, 2 replies.
- [GitHub] flink pull request: [FLINK-2021] Rework examples to use ParameterT... - posted by stefanobaghino <gi...@git.apache.org> on 2016/01/21 12:47:45 UTC, 33 replies.
- [jira] [Commented] (FLINK-2168) Add fromHBase() to TableEnvironment - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/01/21 13:35:39 UTC, 2 replies.
- [jira] [Resolved] (FLINK-2972) Remove Twitter Chill dependency from flink-java module - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/21 16:28:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3206) Heap size for non-pre-allocated off-heap memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/21 17:39:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3261] Allow Task to decline checkpoint ... - posted by aljoscha <gi...@git.apache.org> on 2016/01/21 18:15:01 UTC, 15 replies.
- [jira] [Commented] (FLINK-3261) Tasks should eagerly report back when they cannot start a checkpoint - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/21 18:15:39 UTC, 15 replies.
- [GitHub] flink pull request: [FLINK-3258] [runtime, streaming-java, tests] ... - posted by uce <gi...@git.apache.org> on 2016/01/21 18:21:30 UTC, 3 replies.
- [jira] [Commented] (FLINK-3258) Merge AbstractInvokable's registerInputOutput and invoke - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/21 18:21:39 UTC, 3 replies.
- [jira] [Resolved] (FLINK-3206) Heap size for non-pre-allocated off-heap memory - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/21 18:23:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3262) Remove fuzzy versioning from Bower dependencies - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/21 18:43:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2016/01/21 19:52:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2016/01/21 19:53:40 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2016/01/21 19:54:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2016/01/21 19:54:39 UTC, 6 replies.
- [jira] [Assigned] (FLINK-3271) Using webhdfs in a flink topology throws classnotfound exception - posted by "Abhishek Agarwal (JIRA)" <ji...@apache.org> on 2016/01/21 20:07:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3253) deserializeObject exception on WindowOperator - posted by "godfrey he (JIRA)" <ji...@apache.org> on 2016/01/22 02:34:39 UTC, 4 replies.
- [GitHub] flink pull request: [hotfix]: remove references to deprecated juni... - posted by smarthi <gi...@git.apache.org> on 2016/01/22 03:55:54 UTC, 2 replies.
- [GitHub] flink pull request: Enable range partition with custom data distri... - posted by gallenvara <gi...@git.apache.org> on 2016/01/22 06:50:38 UTC, 5 replies.
- [jira] [Created] (FLINK-3272) Generalize vertex value type in ConnectedComponents - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2016/01/22 10:34:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3273) Remove Scala dependency from flink-streaming-java - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/22 10:47:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3274) Prefix Kafka connector accumulators with unique id - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:05:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3065) Can't cancel failing jobs - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:15:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3274] Make accumulator names of Kafka c... - posted by rmetzger <gi...@git.apache.org> on 2016/01/22 11:33:12 UTC, 4 replies.
- [jira] [Commented] (FLINK-3274) Prefix Kafka connector accumulators with unique id - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/22 11:33:40 UTC, 4 replies.
- [jira] [Updated] (FLINK-2609) Automatic type registration is only called from the batch execution environment - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:37:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-2581) Add warning to the YARN client when using an older Hadoop version - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:37:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3275) [py] Add support for Dataset.setParallelism() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/22 11:55:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2973) Remove OpenJDK JMH dependency from flink-benchmark - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:55:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2973) Add flink-benchmark with compliant licenses again - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:56:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2973) Add flink-benchmark with compliant licenses again - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 11:56:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/22 12:02:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3276) Move runtime parts of flink-streaming-java to flink-runtime - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/22 12:03:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-1994) Add different gain calculation schemes to SGD - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/22 16:06:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3278) Add Partitioned State Backend Based on RocksDB - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/22 16:19:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3277) Use Value types in Gelly API - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/22 16:19:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3178] Don't Emit In-Flight Windows When... - posted by aljoscha <gi...@git.apache.org> on 2016/01/22 16:22:58 UTC, 7 replies.
- [jira] [Created] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/22 18:51:40 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2246) Add chained combine driver strategy for ReduceFunction - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/01/22 19:58:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-1733) Add PCA to machine learning library - posted by "Thang Nguyen (JIRA)" <ji...@apache.org> on 2016/01/22 22:26:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3280) Wrong usage of Boolean.getBoolean() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/22 22:28:40 UTC, 0 replies.
- [jira] [Commented] (FLINK-3280) Wrong usage of Boolean.getBoolean() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/22 22:32:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2030) Implement discrete and continuous histograms - posted by "Trevor Grant (JIRA)" <ji...@apache.org> on 2016/01/22 23:05:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3223) Translate Table API query into logical relational plans for Apache Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/23 10:59:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2016/01/23 12:10:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure - posted by "Andra Lungu (JIRA)" <ji...@apache.org> on 2016/01/23 13:04:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3271: Include jetty-util in the dist jar - posted by abhishekagarwal87 <gi...@git.apache.org> on 2016/01/24 15:53:52 UTC, 4 replies.
- [jira] [Created] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet - posted by "Fridtjof Sander (JIRA)" <ji...@apache.org> on 2016/01/24 17:06:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/25 03:28:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3279) Optionally disable DistinctOperator combiner - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 10:27:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3259) Redirect programming guides to new layout - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/25 10:42:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3282) Add FlinkRelNode interface. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/25 10:58:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3198) Rename Grouping.getDataSet() method and add JavaDocs - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/01/25 11:30:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1904) Add cross() to Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/25 11:33:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3261) Tasks should eagerly report back when they cannot start a checkpoint - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/25 11:40:39 UTC, 0 replies.
- [GitHub] flink pull request: Add FlinkRelNode interface. - posted by ChengXiangLi <gi...@git.apache.org> on 2016/01/25 11:49:51 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3282] Add FlinkRelNode interface. - posted by fhueske <gi...@git.apache.org> on 2016/01/25 12:01:49 UTC, 19 replies.
- [jira] [Commented] (FLINK-3282) Add FlinkRelNode interface. - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/25 12:02:39 UTC, 19 replies.
- [jira] [Assigned] (FLINK-3225) Optimize logical Table API plans in Calcite - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 12:21:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3283) Failed Kafka 0.9 test on duplicate message - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/25 12:29:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3281) IndexOutOfBoundsException when range-partitioning empty DataSet - posted by "Fridtjof Sander (JIRA)" <ji...@apache.org> on 2016/01/25 12:32:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3284) Broken web link: Hadoop compatibility in Flink - posted by "Slim Baltagi (JIRA)" <ji...@apache.org> on 2016/01/25 13:08:39 UTC, 0 replies.
- [GitHub] flink pull request: [hotfix] [docs] Add missing licenses to progra... - posted by ggevay <gi...@git.apache.org> on 2016/01/25 13:56:57 UTC, 4 replies.
- [jira] [Commented] (FLINK-2246) Add chained combine driver strategy for ReduceFunction - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/01/25 14:15:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3285) Skip Maven deployment of flink-java8 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/25 14:23:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-2523: making the task cancellation inter... - posted by kl0u <gi...@git.apache.org> on 2016/01/25 14:40:19 UTC, 8 replies.
- [jira] [Commented] (FLINK-2523) Make task canceling interrupt interval configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/25 14:40:40 UTC, 8 replies.
- [jira] [Created] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:18:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/25 15:21:39 UTC, 1 replies.
- [jira] [Resolved] (FLINK-3255) Chaining behavior should not depend on parallelism - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:24:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3255) Chaining behavior should not depend on parallelism - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:24:40 UTC, 1 replies.
- [jira] [Closed] (FLINK-3255) Chaining behavior should not depend on parallelism - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:24:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3246) Consolidate maven project names with *-parent suffix - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:25:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3286) Remove JDEB Debian Package code from flink-dist - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/01/25 15:25:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3267) Disable reference tracking in Kryo fallback serializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:25:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3246) Consolidate maven project names with *-parent suffix - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:25:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3267) Disable reference tracking in Kryo fallback serializer - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 15:25:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3285][maven] skip deployment of flink-j... - posted by mxm <gi...@git.apache.org> on 2016/01/25 15:26:01 UTC, 3 replies.
- [jira] [Commented] (FLINK-3285) Skip Maven deployment of flink-java8 - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/25 15:26:39 UTC, 3 replies.
- [jira] [Created] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/25 15:43:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/25 15:48:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3287) Flink Kafka Consumer fails due to Curator version conflict - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/25 16:05:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3288) KafkaConsumer (0.8) fails with UnknownException - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/25 16:20:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3198: Renames and documents the getDataS... - posted by kl0u <gi...@git.apache.org> on 2016/01/25 16:28:34 UTC, 4 replies.
- [jira] [Commented] (FLINK-3198) Rename Grouping.getDataSet() method and add JavaDocs - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/25 16:28:40 UTC, 4 replies.
- [jira] [Resolved] (FLINK-3256) Invalid execution graph cleanup for jobs with colocation groups - posted by "Paris Carbone (JIRA)" <ji...@apache.org> on 2016/01/25 16:51:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-1904) Add cross() to Table API - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2016/01/25 17:05:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3284) Broken web link: Hadoop compatibility in Flink - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/25 17:48:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3274) Prefix Kafka connector accumulators with unique id - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 18:39:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3209) Remove Unused ProcessingTime, EventTime and AbstractTime - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 18:39:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 18:40:39 UTC, 1 replies.
- [jira] [Closed] (FLINK-3285) Skip Maven deployment of flink-java8 - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 18:40:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3280) Wrong usage of Boolean.getBoolean() - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/25 18:41:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3289) Double reference to flink-contrib - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/25 18:44:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3289) Double reference to flink-contrib - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/25 18:44:39 UTC, 5 replies.
- [jira] [Assigned] (FLINK-3280) Wrong usage of Boolean.getBoolean() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/25 19:23:39 UTC, 0 replies.
- [GitHub] flink pull request: Removed spark repl detection code from closure... - posted by sksamuel <gi...@git.apache.org> on 2016/01/25 20:16:18 UTC, 2 replies.
- [jira] [Assigned] (FLINK-3289) Double reference to flink-contrib - posted by "Stefano Baghino (JIRA)" <ji...@apache.org> on 2016/01/26 09:29:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3289] References to flink-contrib merge... - posted by stefanobaghino <gi...@git.apache.org> on 2016/01/26 09:34:05 UTC, 3 replies.
- [jira] [Commented] (FLINK-3227) Translate physical Table API plan into DataSet program - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 09:58:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3254) CombineFunction interface not respected - posted by "Kostas (JIRA)" <ji...@apache.org> on 2016/01/26 10:38:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3226) Translate optimized logical Table API plans into physical plans representing DataSet programs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 10:42:40 UTC, 0 replies.
- [jira] [Updated] (FLINK-3273) Remove Scala dependency from flink-streaming-java - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/26 11:24:39 UTC, 2 replies.
- [jira] [Commented] (FLINK-3273) Remove Scala dependency from flink-streaming-java - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/26 11:26:39 UTC, 0 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/01/26 11:28:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3290) [py] Generalize OperationInfo transfer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/26 12:41:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3290) [py] Generalize OperationInfo transfer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/26 12:50:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3289) Double reference to flink-contrib - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:29:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1045) Remove Combinable Annotation - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:29:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3198) Rename Grouping.getDataSet() method and add JavaDocs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:30:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-3198) Rename Grouping.getDataSet() method and add JavaDocs - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:30:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-1666) Clean-up Field Expression Code - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:31:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-1903) Joins where one side uses a field more than once don't work - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:31:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3233) PartitionOperator does not support expression keys on atomic types - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/26 13:32:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3215) Add CEP library to Flink - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/26 17:01:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/01/26 18:06:35 UTC, 0 replies.
- [jira] [Updated] (FLINK-3291) Object reuse bug in MergeIterator.HeadStream.nextHead - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2016/01/26 18:06:35 UTC, 0 replies.
- [jira] [Created] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/01/26 20:59:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3292]Fix for Bug in flink-jdbc. Not all... - posted by sbcd90 <gi...@git.apache.org> on 2016/01/26 21:21:16 UTC, 13 replies.
- [jira] [Commented] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/26 21:21:39 UTC, 13 replies.
- [jira] [Created] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/01/27 00:45:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/27 04:47:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/01/27 05:24:39 UTC, 0 replies.
- [jira] [Reopened] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy - posted by "ramkrishna.s.vasudevan (JIRA)" <ji...@apache.org> on 2016/01/27 05:25:39 UTC, 0 replies.
- [GitHub] flink pull request: Flink-3196: InputStream should be closed in En... - posted by smarthi <gi...@git.apache.org> on 2016/01/27 05:43:30 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3196] InputStream should be closed in E... - posted by StephanEwen <gi...@git.apache.org> on 2016/01/27 10:31:13 UTC, 2 replies.
- [jira] [Closed] (FLINK-2871) Add OuterJoin strategy with HashTable on outer side - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/27 10:56:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3282) Add FlinkRelNode interface. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/27 11:29:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3282) Add FlinkRelNode interface. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2016/01/27 11:29:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-2933) Flink scala libraries exposed with maven should carry scala version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/27 11:49:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-2940) Deploy multiple Scala versions for Maven artifacts - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/27 11:51:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3258) Merge AbstractInvokable's registerInputOutput and invoke - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/27 14:47:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3290) [py] Generalize OperationInfo transfer - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/27 15:08:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/27 16:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/27 16:23:39 UTC, 0 replies.
- [GitHub] flink pull request: FLINK-3179 Combiner is not injected if Reduce ... - posted by ramkrish86 <gi...@git.apache.org> on 2016/01/27 17:33:46 UTC, 6 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/01/27 17:34:39 UTC, 6 replies.
- [jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink - posted by "PJ Van Aeken (JIRA)" <ji...@apache.org> on 2016/01/27 17:40:40 UTC, 3 replies.
- [GitHub] flink pull request: [FLINK-2428] Clean up unused properties in Str... - posted by hczerpak <gi...@git.apache.org> on 2016/01/27 17:52:53 UTC, 1 replies.
- [jira] [Commented] (FLINK-2428) Clean up unused properties in StreamConfig - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/27 17:53:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/27 18:39:39 UTC, 0 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/01/27 18:44:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2985) Allow different field names for unionAll() in Table API - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/01/28 01:41:40 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3295][Kafka 0.8] Improve ZK error behav... - posted by rmetzger <gi...@git.apache.org> on 2016/01/28 11:22:30 UTC, 2 replies.
- [jira] [Commented] (FLINK-3295) Flink Kafka consumer fails with NoNodeException if zkConnect string contains chroot-path - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/28 11:22:39 UTC, 2 replies.
- [jira] [Resolved] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2016/01/28 11:49:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3275) [py] Add support for Dataset.setParallelism() - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/28 11:52:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/28 12:11:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3296) DataStream.write*() methods are not flushing properly - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/28 12:23:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3297) Streaming connector for ZeroMQ - posted by "Mohit Sethi (JIRA)" <ji...@apache.org> on 2016/01/28 12:51:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3298) Streaming connector for ActiveMQ - posted by "Mohit Sethi (JIRA)" <ji...@apache.org> on 2016/01/28 12:51:39 UTC, 0 replies.
- [GitHub] flink pull request: [Flink-3226] Implement project and filter tran... - posted by ChengXiangLi <gi...@git.apache.org> on 2016/01/28 12:53:05 UTC, 6 replies.
- [jira] [Commented] (FLINK-2678) DataSet API does not support multi-dimensional arrays as keys - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/01/28 13:46:39 UTC, 5 replies.
- [GitHub] flink pull request: [FLINK-1719] [ml] Add Multinomial Naive Bayes ... - posted by JonathanH5 <gi...@git.apache.org> on 2016/01/28 13:55:33 UTC, 0 replies.
- [jira] [Commented] (FLINK-1719) Add naive Bayes classification algorithm to machine learning library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/28 13:55:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3262) Remove fuzzy versioning from Bower dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 14:58:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3262) Remove fuzzy versioning from Bower dependencies - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 14:58:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3299) Remove ApplicationID from Environment - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2016/01/28 15:39:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets() - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/01/28 16:24:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:44:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3265) RabbitMQ Source not threadsafe: ConcurrentModificationException - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:44:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:45:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3299) Remove ApplicationID from Environment - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2016/01/28 16:45:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3292) Bug in flink-jdbc. Not all JDBC drivers supported - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:45:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:46:39 UTC, 0 replies.
- [jira] [Closed] (FLINK-3242) User-specified StateBackend is not Respected if Checkpointing is Disabled - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:46:40 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:47:39 UTC, 0 replies.
- [jira] [Resolved] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:47:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:47:40 UTC, 0 replies.
- [jira] [Closed] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation() - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 16:47:40 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3216] [FLINK-3217] [cep] Initial versio... - posted by tillrohrmann <gi...@git.apache.org> on 2016/01/28 20:19:37 UTC, 1 replies.
- [jira] [Commented] (FLINK-3216) Define pattern specification - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/28 20:19:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3300) Concurrency Bug in Yarn JobManager - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/28 21:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2016/01/28 23:13:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3034) Redis SInk Connector - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/01/29 00:53:39 UTC, 1 replies.
- [jira] [Commented] (FLINK-3033) Redis Source Connector - posted by "Subhobrata Dey (JIRA)" <ji...@apache.org> on 2016/01/29 00:54:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3293] Respect custom cli yarn name in j... - posted by jkirsch <gi...@git.apache.org> on 2016/01/29 01:01:04 UTC, 0 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/01/29 01:01:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3293) Custom Application Name on YARN is ignored in deploy jobmanager mode - posted by "Johannes (JIRA)" <ji...@apache.org> on 2016/01/29 01:02:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3225] Implemented optimization of Table... - posted by fhueske <gi...@git.apache.org> on 2016/01/29 01:49:36 UTC, 14 replies.
- [jira] [Commented] (FLINK-3225) Optimize logical Table API plans in Calcite - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 01:49:39 UTC, 14 replies.
- [GitHub] flink pull request: FLINK-3301 Ineffective synchronization in Mess... - posted by tedyu <gi...@git.apache.org> on 2016/01/29 05:49:59 UTC, 1 replies.
- [jira] [Commented] (FLINK-3301) Ineffective synchronization in MessageAcknowledgingSourceBase#restoreState - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 05:50:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-3300) Concurrency Bug in Yarn JobManager - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2016/01/29 10:25:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3300) Concurrency Bug in Yarn JobManager - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2016/01/29 10:46:39 UTC, 6 replies.
- [jira] [Created] (FLINK-3302) Save Taskmanager Metrics per Job - posted by "Pieter Hameete (JIRA)" <ji...@apache.org> on 2016/01/29 11:01:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3300] fix concurrency bug in YarnJobMan... - posted by mxm <gi...@git.apache.org> on 2016/01/29 11:49:07 UTC, 3 replies.
- [jira] [Commented] (FLINK-3089) OperatorState timeout - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 13:00:44 UTC, 0 replies.
- [jira] [Issue Comment Deleted] (FLINK-3089) OperatorState timeout - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 14:05:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 14:27:39 UTC, 1 replies.
- [jira] [Assigned] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/29 14:33:39 UTC, 0 replies.
- [jira] [Updated] (FLINK-2184) Cannot get last element with maxBy/minBy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2016/01/29 14:34:39 UTC, 1 replies.
- [GitHub] flink pull request: Enhance Partitioned State and use it in Window... - posted by aljoscha <gi...@git.apache.org> on 2016/01/29 16:07:38 UTC, 2 replies.
- [jira] [Commented] (FLINK-3201) Enhance Partitioned State Interface with State Types - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 16:07:40 UTC, 0 replies.
- [jira] [Created] (FLINK-3303) Move all non-batch specific classes in flink-java to flink-core - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/29 16:12:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 16:20:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-1509) Streaming Group Reduce Combiner - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 16:20:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2016/01/29 16:21:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3302) Save Taskmanager Metrics per Job - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2016/01/29 16:26:39 UTC, 1 replies.
- [jira] [Created] (FLINK-3305) Remove JavaKaffee serializer util - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/29 16:48:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3306) Auto type registration at Kryo is buggy - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2016/01/29 16:49:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-3177) Add Stream Operator that Discards Late Elements - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 16:55:39 UTC, 0 replies.
- [jira] [Assigned] (FLINK-2390) Replace iteration timeout with algorithm for detecting termination - posted by "Jeyhun Karimov (JIRA)" <ji...@apache.org> on 2016/01/29 16:58:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3150] Make the YARN container start inv... - posted by aljoscha <gi...@git.apache.org> on 2016/01/29 17:24:07 UTC, 0 replies.
- [jira] [Commented] (FLINK-3150) Make YARN container invocation configurable - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 17:24:39 UTC, 0 replies.
- [jira] [Comment Edited] (FLINK-3302) Save Taskmanager Metrics per Job - posted by "Pieter Hameete (JIRA)" <ji...@apache.org> on 2016/01/29 18:44:39 UTC, 0 replies.
- [GitHub] flink pull request: [FLINK-3296] Remove 'flushing' behavior of the... - posted by rmetzger <gi...@git.apache.org> on 2016/01/29 21:55:18 UTC, 1 replies.
- [jira] [Commented] (FLINK-3296) DataStream.write*() methods are not flushing properly - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 21:55:39 UTC, 1 replies.
- [GitHub] flink pull request: [FLINK-3160] [web-dashboard] Aggregate operato... - posted by greghogan <gi...@git.apache.org> on 2016/01/29 22:45:46 UTC, 1 replies.
- [jira] [Commented] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/29 22:46:39 UTC, 2 replies.
- [jira] [Created] (FLINK-3307) RMQSourceTest failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/01/30 08:08:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-3307) RMQSourceTest failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2016/01/30 08:48:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2870) Add support for accumulating/discarding for Event-Time Windows - posted by "Shikhar Bhushan (JIRA)" <ji...@apache.org> on 2016/01/31 05:04: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/01/31 16:42:29 UTC, 0 replies.
- [jira] [Commented] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/01/31 16:42:39 UTC, 0 replies.
- [jira] [Commented] (FLINK-2803) Add test case for Flink's memory allocation - posted by "Lokesh Ravindranathan (JIRA)" <ji...@apache.org> on 2016/01/31 17:28:39 UTC, 1 replies.