You are viewing a plain text version of this content. The canonical link for it is here.
- [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.
- Checkpointing to S3 - posted by Gyula Fóra <gy...@apache.org> on 2016/01/02 11:57:32 UTC, 3 replies.
- Streaming Iterations, no headOperator ? - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/01/02 21:07:30 UTC, 1 replies.
- Re: 2015: A Year in Review for Apache Flink - posted by Till Rohrmann <tr...@apache.org> on 2016/01/04 10:22:59 UTC, 0 replies.
- Re: Error due to Hadoop version mismatch - posted by "Kashmar, Ali" <Al...@emc.com> on 2016/01/04 15:03:29 UTC, 4 replies.
- Re: [gelly] Spargel model rework - posted by Vasiliki Kalavri <va...@gmail.com> on 2016/01/04 19:48:11 UTC, 3 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.
- LabeledVector with label vector - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/01/05 11:36:58 UTC, 5 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.
- Serialization Bug ? - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/01/05 16:09:12 UTC, 1 replies.
- Empty test-jar - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/01/05 22:01:27 UTC, 1 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.
- Re: Tagging Flink classes with InterfaceAudience and InterfaceStability - posted by Robert Metzger <rm...@apache.org> on 2016/01/06 16:00:06 UTC, 1 replies.
- Re: Pulling Streaming out of staging and project restructure - posted by Robert Metzger <rm...@apache.org> on 2016/01/06 16:21:06 UTC, 4 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] [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.
- JavaScript Bindings - posted by Adam Dutko <ad...@runbymany.com> on 2016/01/06 18:01:14 UTC, 1 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] [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.
- [gelly] partition-centric iterations - posted by Vasiliki Kalavri <va...@gmail.com> on 2016/01/06 23:29:49 UTC, 3 replies.
- New to Apache Flink - posted by Arjun Rao <sp...@gmail.com> on 2016/01/07 05:40:10 UTC, 5 replies.
- [DISCUSS] Refactor StateBackend into Partitioned State and Non-Partitioned State Backends - posted by Aljoscha Krettek <al...@apache.org> on 2016/01/07 11:02:28 UTC, 1 replies.
- Effort to add SQL / StreamSQL to Flink - posted by Fabian Hueske <fh...@gmail.com> on 2016/01/07 15:05:24 UTC, 11 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.
- Weird test-source issue - posted by Gyula Fóra <gy...@apache.org> on 2016/01/08 11:49:08 UTC, 4 replies.
- Naive question - posted by "Vasudevan, Ramkrishna S" <ra...@intel.com> on 2016/01/08 12:06:16 UTC, 12 replies.
- Add CEP library to Flink - posted by Till Rohrmann <tr...@apache.org> on 2016/01/08 15:54:04 UTC, 7 replies.
- Dripping the Flink-on-Tez code for Flink 1.0 - posted by Stephan Ewen <se...@apache.org> on 2016/01/08 16:43:31 UTC, 8 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.
- Release tag for 0.10.1 - posted by Nick Dimiduk <nd...@apache.org> on 2016/01/08 18:45:27 UTC, 6 replies.
- Flink kicks off Calcite integration - posted by Julian Hyde <jh...@apache.org> on 2016/01/08 20:06:47 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.
- Machine Learning on Apache Fink - posted by Ashutosh Kumar <as...@gmail.com> on 2016/01/09 11:02:43 UTC, 1 replies.
- Need thoughts on Kinesis Streaming Connector - posted by tzulitai <tz...@gmail.com> on 2016/01/09 15:00:44 UTC, 0 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] [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.
- 答复: Effort to add SQL / StreamSQL to Flink - posted by "Jiangsong (Hi)" <hi...@huawei.com> on 2016/01/11 04:03:55 UTC, 4 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.
- [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] [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] [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.
- [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] [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] [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.
- akka.pattern.AskTimeoutException - posted by Frederick Ayala <fr...@gmail.com> on 2016/01/13 02:13:18 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:39 UTC, 0 replies.
- [DISCUSS] Git force pushing and deletion of branchs - posted by Fabian Hueske <fh...@gmail.com> on 2016/01/13 11:07:05 UTC, 14 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] [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.
- [DISCUSS] Remove Combinable Annotation from DataSet API - posted by Fabian Hueske <fh...@gmail.com> on 2016/01/13 13:53:32 UTC, 6 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.
- UpdateTaskExecutionState during JobManager failover - posted by wangzhijiang999 <wa...@aliyun.com> on 2016/01/14 03:49:26 UTC, 1 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] [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] [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] [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.
- flink-shaded-hadoop modules disconnected from parent pom - posted by Nick Dimiduk <nd...@gmail.com> on 2016/01/15 00:48:47 UTC, 1 replies.
- FileNotFoundException thrown by BlobCache when running "mvn test" against flink-runtime 0.10 for Scala 2.11 - posted by Prez Cannady <re...@opencorrelate.org> on 2016/01/15 01:16:18 UTC, 6 replies.
- 答复：UpdateTaskExecutionState during JobManager failover - posted by wangzhijiang999 <wa...@aliyun.com> on 2016/01/15 03:09:40 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] [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, 1 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.
- Old Flink Graph Repository - posted by Stephan Ewen <se...@apache.org> on 2016/01/15 14:59:26 UTC, 5 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] [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.
- web-dashboard Bower dependencies - posted by Greg Hogan <co...@greghogan.com> on 2016/01/15 20:31:19 UTC, 1 replies.
- Dependency on non-existent org.scalamacros:quasiquotes_2.11: - posted by Prez Cannady <re...@opencorrelate.org> on 2016/01/16 21:09:16 UTC, 6 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] [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.
- Scala no-parenthesis methods on DataStream - posted by Stephan Ewen <se...@apache.org> on 2016/01/17 21:23:30 UTC, 1 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.
- [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] [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.
- Flink ML Vector and DenseVector - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/01/18 13:19:38 UTC, 7 replies.
- Flink ML - Vector and DenseVector - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/01/18 13:24:09 UTC, 4 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] [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.
- [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] [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] [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.
- [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.
- [ANNOUNCE] Chengxiang Li added as committer - posted by Fabian Hueske <fh...@gmail.com> on 2016/01/19 11:02:44 UTC, 9 replies.
- What is the topic & offset used for in KeyedDeserializationSchema.deserialize()? - posted by "Tzu-Li (Gordon) Tai" <tz...@gmail.com> on 2016/01/19 11:27:56 UTC, 9 replies.
- Questions for a better understanding of the internals of data exchange between tasks - posted by Camelia Elena Ciolac <ca...@chalmers.se> on 2016/01/19 11:37:41 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] [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] [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.
- Emitting to non-declared output stream - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/01/19 15:25:45 UTC, 1 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.
- Fwd: integration with a scheduler - posted by Serkan Taş <se...@likyateknoloji.com> on 2016/01/19 19:27:10 UTC, 0 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.
- [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.
- Suggestions on contributions - posted by Stefano Baghino <st...@radicalbit.io> on 2016/01/20 11:55:35 UTC, 8 replies.
- maven dependency problem when building stream job - posted by Martin Neumann <mn...@sics.se> on 2016/01/20 13:48:08 UTC, 5 replies.
- Flink distributed cache in scalding - posted by Milosz Tanski <mi...@adfin.com> on 2016/01/20 14:52:55 UTC, 2 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.
- [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] [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] [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] [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.
- Stackoverflow in Serialization - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/01/21 10:47:51 UTC, 3 replies.
- Deep Learning on Flink - posted by Trevor Grant <tr...@gmail.com> on 2016/01/21 15:40:37 UTC, 2 replies.
- Re: Scala 2.10/2.11 Maven dependencies - posted by Maximilian Michels <mx...@apache.org> on 2016/01/21 17:51:44 UTC, 6 replies.
- Feedback welcome: reworking the examples with ParameterTools - posted by Stefano Baghino <st...@radicalbit.io> on 2016/01/21 18:04:56 UTC, 6 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] [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.
- Flink Yarn Stack Size - posted by Hilmi Yildirim <Hi...@dfki.de> on 2016/01/22 11:44:51 UTC, 9 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] [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] [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.
- [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.
- Kafka As Sink in Flink Streaming - posted by Deepak Jha <dk...@gmail.com> on 2016/01/22 20:13:41 UTC, 2 replies.
- Features only compatible with hadoop 2.x - posted by Gyula Fóra <gy...@apache.org> on 2016/01/22 22:23:31 UTC, 3 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] [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.
- Re: Release Flink 1.0.0 - posted by "Matthias J. Sax" <mj...@apache.org> on 2016/01/25 09:02:29 UTC, 4 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] [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] [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.
- [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.
- [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] [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] [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.
- [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] [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] [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] [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.
- [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.
- [NOTICE] Maven artifacts names now suffixed with Scala version - posted by Maximilian Michels <mx...@apache.org> on 2016/01/27 12:20:30 UTC, 1 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.
- Python start scripts broken - posted by Chesnay Schepler <ch...@apache.org> on 2016/01/27 18:05:47 UTC, 6 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] [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-3298) Streaming connector for ActiveMQ - posted by "Mohit Sethi (JIRA)" <ji...@apache.org> on 2016/01/28 12:51: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.
- Case style anonymous functions not supported by Scala API - posted by Stefano Baghino <st...@radicalbit.io> on 2016/01/28 14:05:19 UTC, 2 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] [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.
- How it is used internally Akka framework in Flink? - posted by Lorena Reis <lo...@gmail.com> on 2016/01/29 09:25:14 UTC, 1 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.
- [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] [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] [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] [Created] (FLINK-3307) RMQSourceTest failure - posted by "Márton Balassi (JIRA)" <ji...@apache.org> on 2016/01/30 08:08:39 UTC, 0 replies.
- Memory manager behavior in iterative jobs - posted by Gábor Gévay <gg...@gmail.com> on 2016/01/30 14:04:07 UTC, 1 replies.