You are viewing a plain text version of this content. The canonical link for it is here.
- Re: yarn kill container due to running beyond physical memory limits [ How can i debug memory issue ] - posted by Alexis Gendronneau <a....@gmail.com> on 2016/06/01 00:05:58 UTC, 4 replies.
- Re: Facing error while running Hands-in training example “writing to Apache Kafka” - posted by arpit srivastava <ar...@gmail.com> on 2016/06/01 05:01:35 UTC, 7 replies.
- Re: Type of TypeVariable 'OT' in 'class org.apache.flink.api.common.io.RichInputFormat' could not be determined. - posted by Maximilian Michels <mx...@apache.org> on 2016/06/01 08:51:10 UTC, 0 replies.
- Internal buffers - posted by le...@tutanota.com on 2016/06/01 09:54:33 UTC, 2 replies.
- Re: Context-specific step function in Iteration - posted by Maximilian Michels <mx...@apache.org> on 2016/06/01 12:46:26 UTC, 0 replies.
- Re: Maintaining watermarks per key, instead of per operator instance - posted by Aljoscha Krettek <al...@apache.org> on 2016/06/01 12:54:44 UTC, 3 replies.
- No key found restore States - posted by simon peyer <si...@soom-it.ch> on 2016/06/01 13:06:05 UTC, 6 replies.
- Re: Extracting Timestamp in MapFunction - posted by Biplob Biswas <re...@gmail.com> on 2016/06/01 14:33:09 UTC, 2 replies.
- Re: Weird Kryo exception (Unable to find class: java.ttil.HashSet) - posted by Flavio Pompermaier <po...@okkam.it> on 2016/06/01 15:44:26 UTC, 6 replies.
- Flink Kafka Unused Properties Log Warnings - posted by David Kim <da...@braintreepayments.com> on 2016/06/01 16:42:43 UTC, 2 replies.
- API request to submit job takes over 1hr - posted by Shannon Carey <sc...@expedia.com> on 2016/06/01 17:54:03 UTC, 5 replies.
- Scala case classes with a generic parameter - posted by James Bucher <jb...@expedia.com> on 2016/06/01 18:11:15 UTC, 1 replies.
- Submitting job via Flink web interface giving Null pointer exception - posted by Ritesh Kumar Singh <ri...@gmail.com> on 2016/06/01 18:11:26 UTC, 3 replies.
- Exception in thread main: No such exception errpr - posted by Debaditya Roy <ro...@gmail.com> on 2016/06/02 10:02:42 UTC, 15 replies.
- Re: Flink Kafka Consumer throwing Null Pointer Exception - posted by Aljoscha Krettek <al...@apache.org> on 2016/06/02 15:58:32 UTC, 0 replies.
- Adding Context To Logs - posted by "Hamilton, Paul" <pa...@sap.com> on 2016/06/02 16:53:00 UTC, 2 replies.
- Re: Result comparison from 2 DataStream Sources - posted by iñaki williams <ju...@gmail.com> on 2016/06/02 21:20:57 UTC, 2 replies.
- S3 as streaming source - posted by Soumya Simanta <so...@gmail.com> on 2016/06/03 05:22:51 UTC, 4 replies.
- Re: Writing test for Flink streaming jobs - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/06/03 06:58:28 UTC, 0 replies.
- Event processing time with lateness - posted by Igor Berman <ig...@gmail.com> on 2016/06/03 12:55:37 UTC, 6 replies.
- /newbie/ Share state between streams - posted by Andrey Utkin <ci...@gmail.com> on 2016/06/03 16:34:42 UTC, 2 replies.
- Kafka producer sink message loss? - posted by Elias Levy <fe...@gmail.com> on 2016/06/04 02:05:38 UTC, 4 replies.
- Why would slot sharing be undesirable? - posted by le...@tutanota.com on 2016/06/04 08:09:31 UTC, 1 replies.
- env.fromElements produces TypeInformation error - posted by Dan Drewes <dr...@campus.tu-berlin.de> on 2016/06/04 15:34:36 UTC, 3 replies.
- java.io.IOException: Couldn't access resultSet - posted by David Olsen <da...@gmail.com> on 2016/06/05 09:05:41 UTC, 8 replies.
- Custom keyBy(), look for similaties - posted by iñaki williams <ju...@gmail.com> on 2016/06/06 07:31:21 UTC, 3 replies.
- Data Source Generator emits 4 instances of the same tuple - posted by Biplob Biswas <re...@gmail.com> on 2016/06/06 08:30:37 UTC, 4 replies.
- HBase Input Format for streaming - posted by Christophe Salperwyck <ch...@gmail.com> on 2016/06/06 11:49:42 UTC, 2 replies.
- Logs show `Marking the coordinator 2147483637 dead` in Flink-Kafka conn - posted by Sendoh <un...@gmail.com> on 2016/06/06 12:10:03 UTC, 2 replies.
- Yarn batch not working with standalone yarn job manager once a persistent, HA job manager is launched ? - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2016/06/06 12:19:17 UTC, 13 replies.
- Re: Submit Flink Jobs to YARN running on AWS - posted by Josh <jo...@gmail.com> on 2016/06/06 18:55:41 UTC, 3 replies.
- Does Flink allows for encapsulation of transformations? - posted by Ser Kho <kh...@yahoo.com> on 2016/06/06 19:14:02 UTC, 7 replies.
- Periodically evicting internal states when using mapWithState() - posted by Jack Huang <ja...@mz.com> on 2016/06/07 01:04:24 UTC, 1 replies.
- Hourly top-k statistics of DataStream - posted by Yukun Guo <gy...@gmail.com> on 2016/06/07 02:26:25 UTC, 5 replies.
- Window start and end issue with TumblingProcessingTimeWindows - posted by Soumya Simanta <so...@gmail.com> on 2016/06/07 04:40:05 UTC, 4 replies.
- Multi-field "sum" function just like "keyBy" - posted by Al-Isawi Rami <Ra...@comptel.com> on 2016/06/07 12:41:52 UTC, 5 replies.
- Reading whole files (from S3) - posted by Andrea Cisternino <a....@gmail.com> on 2016/06/07 14:35:02 UTC, 5 replies.
- Event timestamps after data transformations - posted by Chris Wildman <cw...@newrelic.com> on 2016/06/07 18:43:48 UTC, 1 replies.
- Uploaded jar disappears when web monitor restarts - posted by Emanuele Cesena <em...@shopkick.com> on 2016/06/08 03:06:01 UTC, 1 replies.
- Dedicated ExecutionContext inside Flink - posted by Soumya Simanta <so...@gmail.com> on 2016/06/08 05:14:15 UTC, 1 replies.
- ClassCastException when redeploying Flink job on running cluster - posted by Josh <jo...@gmail.com> on 2016/06/08 08:38:32 UTC, 6 replies.
- Re: Uploaded jar disappears when web monitor restarts - posted by Till Rohrmann <tr...@apache.org> on 2016/06/08 08:57:22 UTC, 0 replies.
- Flink Dashboard - posted by le...@tutanota.com on 2016/06/08 09:01:02 UTC, 2 replies.
- com.esotericsoftware.kryo.KryoException and java.lang.IndexOutOfBoundsException - posted by Ahmed Nader <ah...@gmail.com> on 2016/06/08 13:40:14 UTC, 5 replies.
- How to maintain the state of a variable in a map transformation. - posted by Ravikumar Hawaldar <ra...@gmail.com> on 2016/06/08 15:08:06 UTC, 8 replies.
- Kafka exception "Unable to find a leader for partitions" - posted by Shannon Carey <sc...@expedia.com> on 2016/06/08 17:11:27 UTC, 1 replies.
- Using Flink watermarks and a large window state for scheduling - posted by Josh <jo...@gmail.com> on 2016/06/08 19:47:24 UTC, 2 replies.
- NotSerializableException - posted by Tarandeep Singh <ta...@gmail.com> on 2016/06/09 00:28:20 UTC, 8 replies.
- FlinkKafkaProducer API - posted by Elias Levy <fe...@gmail.com> on 2016/06/09 01:58:33 UTC, 3 replies.
- Flink 1.0 Critical memory issue/leak with a high throughput stream - posted by Soumya Simanta <so...@gmail.com> on 2016/06/09 08:29:27 UTC, 6 replies.
- Strange behavior of DataStream.countWindow - posted by Yukun Guo <gy...@gmail.com> on 2016/06/09 11:19:08 UTC, 3 replies.
- Maxby() and KeyBy() question - posted by iñaki williams <ju...@gmail.com> on 2016/06/09 12:36:22 UTC, 2 replies.
- HBase reads and back pressure - posted by Christophe Salperwyck <ch...@gmail.com> on 2016/06/09 12:53:08 UTC, 12 replies.
- Join two streams using a count-based window - posted by "Nikos R. Katsipoulakis" <ni...@gmail.com> on 2016/06/09 18:13:43 UTC, 2 replies.
- Application log on Yarn FlinkCluster - posted by Theofilos Kakantousis <tk...@kth.se> on 2016/06/10 14:00:26 UTC, 8 replies.
- Re: Leader not found - posted by Robert Metzger <rm...@apache.org> on 2016/06/10 14:35:22 UTC, 0 replies.
- Arrays values in keyBy - posted by Elias Levy <fe...@gmail.com> on 2016/06/10 22:03:57 UTC, 2 replies.
- Re: Accessing StateBackend snapshots outside of Flink - posted by Josh <jo...@gmail.com> on 2016/06/13 08:14:49 UTC, 3 replies.
- [jira] Akshay Shingote shared "FLINK-4059: Requirement of Streaming layer for Complex Event Processing" with you - posted by "Akshay Shingote (JIRA)" <ji...@apache.org> on 2016/06/13 12:36:20 UTC, 0 replies.
- Custom Barrier? - posted by Paul Wilson <pa...@gmail.com> on 2016/06/13 14:29:15 UTC, 4 replies.
- Gelly scatter/gather - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/06/13 16:06:13 UTC, 1 replies.
- Checkpoint takes long with FlinkKafkaConsumer - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/06/14 09:52:21 UTC, 9 replies.
- Gelly Scatter/Gather - Vertex update - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/06/14 10:21:47 UTC, 1 replies.
- what is flink hardware require？？ - posted by 笑傲风云 <sh...@qq.com> on 2016/06/14 10:33:55 UTC, 0 replies.
- Send to all in gelly scatter - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/06/14 15:30:43 UTC, 3 replies.
- Lazy Evaluation - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/06/14 17:52:01 UTC, 2 replies.
- Migrating from one state backend to another - posted by Josh <jo...@gmail.com> on 2016/06/14 22:04:22 UTC, 2 replies.
- LongMaxAggragator() - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/06/15 08:52:57 UTC, 1 replies.
- LongMaxAggregator in gelly scatter/gather - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/06/15 08:58:20 UTC, 1 replies.
- dataset dataframe join - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/06/15 21:43:05 UTC, 2 replies.
- How MapFunction gets executed? - posted by Yan Chou Chen <yc...@gmail.com> on 2016/06/16 15:07:30 UTC, 2 replies.
- Elasticsearch Connector - posted by Eamon Kavanagh <ka...@gmail.com> on 2016/06/16 15:14:04 UTC, 1 replies.
- Kinesis connector classpath issue when running Flink 1.1-SNAPSHOT on YARN - posted by Josh <jo...@gmail.com> on 2016/06/16 17:08:32 UTC, 8 replies.
- Documentation for translation of Job graph to Execution graph - posted by "Bajaj, Abhinav" <ab...@here.com> on 2016/06/16 17:31:09 UTC, 5 replies.
- Moving from single-node, Maven examples to cluster execution - posted by Prez Cannady <re...@opencorrelate.org> on 2016/06/16 21:51:18 UTC, 2 replies.
- Flink on YARN : Amazon S3 wrongly used instead of HDFS - posted by VALLEE Charles <ch...@edf.fr> on 2016/06/17 13:11:43 UTC, 1 replies.
- AW: Writing Intermediates to disk - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/06/19 14:57:01 UTC, 0 replies.
- Cassamdra Connector in Scala - posted by Eamon Kavanagh <ka...@gmail.com> on 2016/06/19 22:17:18 UTC, 4 replies.
- Caused by: java.lang.IllegalArgumentException: LoggerFactory is not a Logback LoggerContext - posted by Debaditya Roy <ro...@gmail.com> on 2016/06/20 08:54:17 UTC, 1 replies.
- Getting the NumberOfParallelSubtask - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/06/20 13:56:34 UTC, 2 replies.
- Keeping latest data point in a data stream variable - posted by Biplob Biswas <re...@gmail.com> on 2016/06/21 09:45:37 UTC, 1 replies.
- NPE in JDBCInputFormat - posted by Martin Scholl <ms...@funkpopes.org> on 2016/06/21 09:49:14 UTC, 3 replies.
- Start cluster in different modes - posted by Ravinder Kaur <ne...@gmail.com> on 2016/06/21 12:47:21 UTC, 1 replies.
- What is the best way of sharing a dataset between the nodes in Apache flink? - posted by ahmad Sa P <as...@gmail.com> on 2016/06/21 13:12:39 UTC, 0 replies.
- Caused by: java.lang.Exception: Serialized representation of java.lang.StackOverflowError: null - posted by Debaditya Roy <ro...@gmail.com> on 2016/06/21 15:22:02 UTC, 3 replies.
- TaskManager information during runtime - posted by omaralvarez <xx...@gmail.com> on 2016/06/21 17:10:13 UTC, 2 replies.
- Code related to spilling data to disk - posted by Tae-Geon Um <ta...@gmail.com> on 2016/06/22 04:48:28 UTC, 2 replies.
- Re: Code related to spilling data to disk - posted by Chiwan Park <ch...@apache.org> on 2016/06/22 10:22:12 UTC, 2 replies.
- Stoppable Job And Web UI Questions - posted by Yan Chou Chen <yc...@gmail.com> on 2016/06/22 14:39:13 UTC, 1 replies.
- State key serializer has not been configured in the config. - posted by Jacob Bay Larsen <ma...@jacobbay.dk> on 2016/06/22 19:17:35 UTC, 3 replies.
- Iterate several kafka topics using the kafka connector - posted by Sendoh <un...@gmail.com> on 2016/06/23 12:33:20 UTC, 2 replies.
- Initialization of static variables - posted by Flavio Pompermaier <po...@okkam.it> on 2016/06/23 13:12:36 UTC, 2 replies.
- Scala/ReactiveMongo: type classes, macros and java.util.Serializable - posted by Stefano Baghino <st...@radicalbit.io> on 2016/06/23 14:22:56 UTC, 1 replies.
- Localhost terminated - posted by Debaditya Roy <ro...@gmail.com> on 2016/06/23 14:46:10 UTC, 1 replies.
- Question regarding logging capabilities in flink - posted by "Sharma, Samiksha" <sa...@here.com> on 2016/06/23 17:44:03 UTC, 5 replies.
- Adding 3rd party moving average and other 'indicators' - posted by Anton <ku...@gmail.com> on 2016/06/24 20:05:01 UTC, 1 replies.
- Way to hold execution of one of the map operator in Co-FlatMaps - posted by Biplob Biswas <re...@gmail.com> on 2016/06/26 10:55:28 UTC, 5 replies.
- Cassandra Connector Problem (Possible Guava Conflict?) - posted by Eamon Kavanagh <ka...@gmail.com> on 2016/06/26 15:46:22 UTC, 4 replies.
- maximum size of window - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/06/27 18:22:56 UTC, 6 replies.
- Flink java.io.FileNotFoundException Exception with Peel Framework - posted by ANDREA SPINA <74...@studenti.unimore.it> on 2016/06/28 09:57:27 UTC, 4 replies.
- How to count number of records received per second in processing time while using event time characteristic - posted by Saiph Kappa <sa...@gmail.com> on 2016/06/28 15:33:21 UTC, 1 replies.
- Flink for historical time series processing - posted by Mindaugas Zickus <mi...@yahoo.com> on 2016/06/28 18:15:08 UTC, 0 replies.
- Optimizations not performed - please confirm - posted by Ovidiu-Cristian MARCU <ov...@inria.fr> on 2016/06/28 19:41:44 UTC, 3 replies.
- Best way to read property file in flink - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/06/29 10:08:24 UTC, 1 replies.
- Apache Flink 1.0.3 IllegalStateException Partiction State on chaining - posted by ANDREA SPINA <74...@studenti.unimore.it> on 2016/06/29 10:19:25 UTC, 4 replies.
- How to avoid breaking states when upgrading Flink job? - posted by Josh <jo...@gmail.com> on 2016/06/29 19:00:13 UTC, 4 replies.
- Flink on YARN - how to resize a running cluster? - posted by Josh <jo...@gmail.com> on 2016/06/29 20:13:30 UTC, 4 replies.
- Switch to skip the stream alignment during a checkpoint? - posted by Daniel Li <da...@gmail.com> on 2016/06/29 20:58:29 UTC, 1 replies.
- Checkpointing very large state in RocksDB? - posted by Daniel Li <da...@gmail.com> on 2016/06/29 21:04:41 UTC, 1 replies.
- Parameters to Control Intra-node Parallelism - posted by Saliya Ekanayake <es...@gmail.com> on 2016/06/29 23:44:30 UTC, 2 replies.
- RollingSink - question on a failure scenario - posted by "vprabhu@gmail.com" <vp...@gmail.com> on 2016/06/30 01:35:38 UTC, 1 replies.
- Flink streaming connect and split streams - posted by Martin Neumann <mn...@sics.se> on 2016/06/30 14:50:19 UTC, 0 replies.
- Error submitting stand-alone Flink job to EMR YARN cluster - posted by "Hanson, Bruce" <br...@here.com> on 2016/06/30 18:28:41 UTC, 0 replies.