You are viewing a plain text version of this content. The canonical link for it is here.
- RE: The null in Flink - posted by "Li, Chengxiang" <ch...@intel.com> on 2015/12/01 04:09:52 UTC, 4 replies.
- FOSDEM 2016 - take action by 4th of December 2015 - posted by Roman Shaposhnik <rv...@apache.org> on 2015/12/01 07:30:21 UTC, 0 replies.
- [jira] [Created] (FLINK-3092) Scala API quick start word count example is broken - posted by "madhukara phatak (JIRA)" <ji...@apache.org> on 2015/12/01 07:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3093) Introduce annotations for interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 12:30:10 UTC, 0 replies.
- Re: Tagging Flink classes with InterfaceAudience and InterfaceStability - posted by Maximilian Michels <mx...@apache.org> on 2015/12/01 14:13:59 UTC, 3 replies.
- [jira] [Created] (FLINK-3094) FileStateBackend does not clean up job-id checkpoint directory - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/01 14:18:11 UTC, 0 replies.
- Re: Task Parallelism in a Cluster - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/12/01 15:26:39 UTC, 13 replies.
- [jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/01 19:26:11 UTC, 0 replies.
- Re: could you please add me Contributor list? - posted by jun aoki <ja...@apache.org> on 2015/12/01 20:48:47 UTC, 0 replies.
- [jira] [Created] (FLINK-3097) Add support for custom functions in Table API - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/01 23:32:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3098) Cast from Date to Long throw compile error. - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/02 06:56:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3099) Create Script for Starting WebClient on Windows - posted by "Welly Tambunan (JIRA)" <ji...@apache.org> on 2015/12/02 12:16:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3100) Signal handler prints error on normal shutdown of cluster - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/02 17:25:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record - posted by "Sanjar Akhmedov (JIRA)" <ji...@apache.org> on 2015/12/02 17:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/02 19:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3103) Accessing closed in FsStateBackend#FsCheckpointStateOutputStream#flush() should be synchronized - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/02 23:09:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3104) Potential null dereference of outStream in FsStateBackend#CheckpointStateOutputStream#closeAndGetHandle() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/02 23:12:11 UTC, 0 replies.
- Distributed DataFrame - ddf.io - posted by Nam-Luc Tran <na...@euranova.eu> on 2015/12/03 11:23:59 UTC, 2 replies.
- [jira] [Created] (FLINK-3105) Submission in per job YARN cluster mode reuses properties file of long-lived session - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 12:00:14 UTC, 0 replies.
- [jira] [Created] (FLINK-3106) ChaosMonkeyITCase failure - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/03 13:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3107) ZooKeeperCheckpointIDCounter.start() can block JobManager actor - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/03 13:56:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3108) JoinOperator's with() calls the wrong TypeExtractor method - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/03 17:28:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3109) Join two streams with two different cache time - posted by "Wang Yangjun (JIRA)" <ji...@apache.org> on 2015/12/03 22:27:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3110) Add support for the partition-centric iterations - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/04 10:52:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/04 11:26:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/04 13:03:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/04 13:07:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 13:14:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 15:18:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3116) Remove RecordOperator - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/04 15:29:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/04 16:15:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/04 16:18:11 UTC, 0 replies.
- Fwd: DATA TRANSFORMATION PROBLEM - posted by JOHN MILLER <jm...@gmail.com> on 2015/12/04 16:39:06 UTC, 0 replies.
- [jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/04 18:35:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/04 18:55:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/04 22:21:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3122) Generalize value type in LabelPropagation - posted by "Martin Junghanns (JIRA)" <ji...@apache.org> on 2015/12/05 10:29:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/05 10:52:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3124) Introduce a TaskInfo object to better represent task name, index, attempt number etc. - posted by "Sachin Goel (JIRA)" <ji...@apache.org> on 2015/12/05 16:11:10 UTC, 0 replies.
- Lack of review on PRs - posted by Sachin Goel <sa...@gmail.com> on 2015/12/05 17:00:36 UTC, 3 replies.
- [jira] [Created] (FLINK-3125) Web dashboard does not start when log files are not found - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/06 18:18:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3126) Remove accumulator type from "value" in web frontend - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/06 18:23:11 UTC, 0 replies.
- Monitoring backpressure - posted by Gyula Fóra <gy...@apache.org> on 2015/12/07 09:45:42 UTC, 2 replies.
- [jira] [Created] (FLINK-3127) Measure backpressure in Flink jobs - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 11:11:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3128) Add Isotonic Regression To ML Library - posted by "Fridtjof Sander (JIRA)" <ji...@apache.org> on 2015/12/07 13:44:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3129) Add tooling to ensure interface stability - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/07 14:35:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3130) Visualize throughput of tasks - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3131) Expose checkpoint metrics - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:46:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3132) Restructure streaming guide - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/07 14:53:11 UTC, 1 replies.
- [jira] [Created] (FLINK-3133) Introduce collect()/coun()/print() methods in DataStream API - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 16:47:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3134) Make YarnJobManager's allocate call asynchronous - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/07 17:06:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3135) Add chainable driver for UNARY_NO_OP strategy - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/07 17:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3136) Scala Closure Cleaner uses wrong ASM import - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 20:24:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3137) Missing break in OutputEmitter ctor - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/07 21:50:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3138) Method References are not supported as lambda expressions - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/07 23:10:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3139) NULL values handling in Table API - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3140) NULL value data layout in Row Serializer/Comparator - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:23:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3141) Design of NULL values handling in operation - posted by "Chengxiang Li (JIRA)" <ji...@apache.org> on 2015/12/08 07:28:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3142) CheckpointCoordinatorTest fails - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/08 08:22:11 UTC, 0 replies.
- JobManagerCheckpointRecoveryITCase - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/12/08 08:29:00 UTC, 0 replies.
- [jira] [Created] (FLINK-3143) Update Clojure Cleaner's ASM references to ASM5 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 13:32:10 UTC, 0 replies.
- Migrating Spark to Flink - posted by Humberto Moura <hu...@humbertomoura.com.br> on 2015/12/08 14:25:12 UTC, 1 replies.
- [jira] [Created] (FLINK-3144) [storm] LocalCluster prints nothing without a configured logger - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 15:05:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3145) Storm examples can't be run without flink-java as dependency - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/08 17:28:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/08 18:46:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3147) HadoopOutputFormatBase should expose CLOSE_MUTEX for subuclasses - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:02:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3148) Support configured serializers for shipping UDFs - posted by "Nick Dimiduk (JIRA)" <ji...@apache.org> on 2015/12/08 19:37:11 UTC, 0 replies.
- flink-dist packaging including unshaded classes - posted by Nick Dimiduk <nd...@apache.org> on 2015/12/08 21:25:18 UTC, 10 replies.
- [jira] [Created] (FLINK-3149) mvn test fails on flink-runtime because curator classes not found - posted by "jun aoki (JIRA)" <ji...@apache.org> on 2015/12/09 01:07:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3150) Make YARN container invocation configurable - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 09:53:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap) - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/09 10:17:10 UTC, 0 replies.
- Community choice for Hadoop Summit Europe 2016 - posted by Kostas Tzoumas <kt...@apache.org> on 2015/12/09 10:52:37 UTC, 0 replies.
- [jira] [Created] (FLINK-3152) Support all comparisons for Date type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/09 11:22:11 UTC, 0 replies.
- New Blog Post Draft - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/12/09 11:32:12 UTC, 11 replies.
- [jira] [Created] (FLINK-3153) Support all comparisons for String type - posted by "Timo Walther (JIRA)" <ji...@apache.org> on 2015/12/09 11:33:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3154) Update Kryo version from 2.24.0 to 3.0.3 - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 12:03:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3155) Update Flink docker version to latest stable Flink version - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/09 12:38:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3156) FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/09 18:15:11 UTC, 0 replies.
- Re: Apache Tinkerpop & Geode Integration? - posted by Vasiliki Kalavri <va...@gmail.com> on 2015/12/09 20:40:52 UTC, 8 replies.
- [jira] [Created] (FLINK-3157) Web frontend json files contain author attribution - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/09 23:43:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 10:16:11 UTC, 0 replies.
- Externalizing the Flink connectors - posted by Maximilian Michels <mx...@apache.org> on 2015/12/10 15:31:51 UTC, 11 replies.
- [jira] [Created] (FLINK-3159) YARN AM should shutdown itself after a the job for which the AM was started has finished - posted by "Robert Metzger (JIRA)" <ji...@apache.org> on 2015/12/10 16:41:10 UTC, 0 replies.
- [DISCUSS] Improving State/Timers/Windows - posted by Aljoscha Krettek <al...@apache.org> on 2015/12/10 16:47:24 UTC, 10 replies.
- Flink and Clojure - posted by "Matthias J. Sax" <mj...@apache.org> on 2015/12/10 17:05:01 UTC, 11 replies.
- [jira] [Created] (FLINK-3160) Aggregate operator statistics by TaskManager - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 17:50:10 UTC, 0 replies.
- [jira] [Created] (FLINK-3161) Externalize cluster start-up and tear-down when available - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 18:08:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3162) Configure number of TaskManager slots as ratio of available processors - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 18:30:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3163) Configure Flink for NUMA systems - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 19:46:11 UTC, 0 replies.
- [jira] [Created] (FLINK-3164) Spread out scheduling strategy - posted by "Greg Hogan (JIRA)" <ji...@apache.org> on 2015/12/11 21:17:46 UTC, 0 replies.
- Re: Diagnosing TaskManager disappearance - posted by Greg Hogan <co...@greghogan.com> on 2015/12/12 12:53:22 UTC, 1 replies.
- [jira] [Created] (FLINK-3165) [py] Add support for Windows OS - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/13 14:11:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3166) The first program in ObjectReuseITCase has the wrong expected result, and it succeeds - posted by "Gabor Gevay (JIRA)" <ji...@apache.org> on 2015/12/13 18:12:46 UTC, 0 replies.
- Object reuse documentation should be improved - posted by Gábor Gévay <gg...@gmail.com> on 2015/12/13 19:24:09 UTC, 4 replies.
- [jira] [Created] (FLINK-3167) Stopping start-local.bat doesn't shutdown JM on W10 - posted by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2015/12/13 20:56:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/12/14 15:29:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3169) Drop {{Key}} type from Record Data Model - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 17:46:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3170) Expose task manager metrics via JMX - posted by "Maximilian Michels (JIRA)" <ji...@apache.org> on 2015/12/14 18:31:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3171) Consolidate zoo of wrapper classes for input/output-stream to data-input/output-view - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/14 20:55:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3172) Specify jobmanager port in HA mode - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/15 00:01:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3173) Bump org.apache.httpcomponents.httpclient version to 4.2.6 - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/15 13:57:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3174) Add merging WindowAssigner - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/15 16:04:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3175) KafkaITCase.testOffsetAutocommitTest - posted by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2015/12/15 16:14:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3176) Window Apply Website Example - posted by "radu (JIRA)" <ji...@apache.org> on 2015/12/16 04:03:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3177) Add Stream Operator that Discards Late Elements - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/16 11:34:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3178) Make Closing Behavior of Window Operators Configurable - posted by "Aljoscha Krettek (JIRA)" <ji...@apache.org> on 2015/12/16 11:47:46 UTC, 0 replies.
- [DISCUSS] Flink roadmap for 2016 - posted by Kostas Tzoumas <kt...@apache.org> on 2015/12/16 15:12:21 UTC, 0 replies.
- [DISCUSS] Time Behavior in Streaming Jobs (Event-time/processing-time) - posted by Aljoscha Krettek <al...@apache.org> on 2015/12/16 15:26:40 UTC, 7 replies.
- Flink shell in Jupyter - posted by Gyula Fóra <gy...@apache.org> on 2015/12/16 16:22:39 UTC, 4 replies.
- No job recovery after job manager failure - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/12/16 17:26:45 UTC, 4 replies.
- [jira] [Created] (FLINK-3179) Combiner is not injected if Reduce or GroupReduce input is explicitly partitioned - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/16 21:02:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3180) MemoryLogger does not log direct memory - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 12:48:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3181) The vertex-centric SSSP example and library method send unnecessary messages during the first superstep - posted by "Vasia Kalavri (JIRA)" <ji...@apache.org> on 2015/12/17 15:27:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3182) TaskManagersHandler can block web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 16:51:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3183) Display direct memory stats in web frontend - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/17 17:34:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3184) Decrease Akka timeouts on cluster side to make system more responsive - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/17 19:51:46 UTC, 0 replies.
- Flink Benchmarks have been included in BigDataBench - posted by Xinhui Tian <ti...@ict.ac.cn> on 2015/12/18 03:07:35 UTC, 1 replies.
- [jira] [Created] (FLINK-3185) Silent failure during job graph recovery - posted by "Ufuk Celebi (JIRA)" <ji...@apache.org> on 2015/12/18 12:32:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3186) Deprecate DataSink.sortLocalOutput() methods - posted by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2015/12/18 16:51:46 UTC, 0 replies.
- Re: ClassNotFoundException : org.apache.flink.api.common.operators.util.UserCodeObjectWrapper, while trying to run locally - posted by peterpanne <er...@peukert.org> on 2015/12/18 17:15:14 UTC, 2 replies.
- [jira] [Created] (FLINK-3187) Decouple restart strategy from ExecutionGraph - posted by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2015/12/18 18:31:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2015/12/18 18:52:47 UTC, 0 replies.
- Incremental checkpoints for Flink - posted by Marius Melzer <ma...@rasumi.net> on 2015/12/19 17:04:53 UTC, 1 replies.
- [jira] [Created] (FLINK-3189) Error while parsing job arguments passed by CLI - posted by "Filip Leczycki (JIRA)" <ji...@apache.org> on 2015/12/21 14:26:46 UTC, 0 replies.
- Error due to Hadoop version mismatch - posted by "Kashmar, Ali" <Al...@emc.com> on 2015/12/22 16:10:51 UTC, 5 replies.
- [jira] [Created] (FLINK-3190) Retry rate limits for DataStream API - posted by "Sebastian Klemke (JIRA)" <ji...@apache.org> on 2015/12/23 15:03:46 UTC, 0 replies.
- [jira] [Created] (FLINK-3191) WordCount without fileOutput - execute is missing - posted by "Simone Robutti (JIRA)" <ji...@apache.org> on 2015/12/24 15:35:49 UTC, 0 replies.
- [jira] [Created] (FLINK-3192) Add explain support to print ast and sql physical execution. - posted by "GaoLun (JIRA)" <ji...@apache.org> on 2015/12/25 09:28:49 UTC, 0 replies.
- Why does Flink copy code from Spark? - posted by Edward Lee <ed...@gmail.com> on 2015/12/27 08:51:45 UTC, 2 replies.
- [jira] [Created] (FLINK-3193) Add optional bloomfilter to sql state backend - posted by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/12/30 17:50:49 UTC, 0 replies.
- [jira] [Created] (FLINK-3194) Remove web client - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 00:51:49 UTC, 0 replies.
- 2015: A Year in Review for Apache Flink - posted by Henry Saputra <he...@gmail.com> on 2015/12/31 03:22:13 UTC, 2 replies.
- [jira] [Created] (FLINK-3195) Restructure examples projects and package streaming examples - posted by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/12/31 18:07:49 UTC, 0 replies.
- [jira] [Created] (FLINK-3196) InputStream should be closed in EnvironmentInformation#getRevisionInformation() - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/31 20:15:39 UTC, 0 replies.
- [jira] [Created] (FLINK-3197) InputStream not closed in BinaryInputFormat#createStatistics - posted by "Ted Yu (JIRA)" <ji...@apache.org> on 2015/12/31 21:09:39 UTC, 0 replies.