You are viewing a plain text version of this content. The canonical link for it is here.
- Re: maximum size of window - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/07/01 00:53:06 UTC, 0 replies.
- Is it possible to restart only the function that fails instead of entire job? - posted by Chia-Hung Lin <ch...@bubbleye.com> on 2016/07/01 07:18:51 UTC, 1 replies.
- Re: How to avoid breaking states when upgrading Flink job? - posted by Josh <jo...@gmail.com> on 2016/07/01 09:21:06 UTC, 3 replies.
- Different results on local and on cluster - posted by Flavio Pompermaier <po...@okkam.it> on 2016/07/01 12:17:12 UTC, 9 replies.
- Using standalone single node without HA in production, crazy? - posted by Ryan Crumley <cr...@gmail.com> on 2016/07/01 13:41:58 UTC, 4 replies.
- Re: Flink streaming connect and split streams - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/01 15:56:25 UTC, 0 replies.
- Failed job restart - flink on yarn - posted by "vprabhu@gmail.com" <vp...@gmail.com> on 2016/07/01 20:34:31 UTC, 5 replies.
- Re: Flink for historical time series processing - posted by Jamie Grier <ja...@data-artisans.com> on 2016/07/01 22:54:16 UTC, 0 replies.
- Re: Error submitting stand-alone Flink job to EMR YARN cluster - posted by Jamie Grier <ja...@data-artisans.com> on 2016/07/01 23:21:46 UTC, 2 replies.
- Re: Parameters to Control Intra-node Parallelism - posted by Saliya Ekanayake <es...@gmail.com> on 2016/07/02 01:26:28 UTC, 19 replies.
- Data point goes missing within iteration - posted by Biplob Biswas <re...@gmail.com> on 2016/07/03 14:26:54 UTC, 15 replies.
- Tumbling time window cannot group events properly - posted by Yukun Guo <gy...@gmail.com> on 2016/07/04 04:00:50 UTC, 6 replies.
- Flink programm with for loop yields wrong results when run in parallel - posted by Adrian Bartnik <ba...@campus.tu-berlin.de> on 2016/07/04 09:56:06 UTC, 2 replies.
- Re: Documentation for translation of Job graph to Execution graph - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/04 10:13:31 UTC, 0 replies.
- Re: Flink 1.0 Critical memory issue/leak with a high throughput stream - posted by Stephan Ewen <se...@apache.org> on 2016/07/04 15:17:28 UTC, 1 replies.
- custom scheduler in Flink? - posted by #ZHANG SHUHAO# <SZ...@e.ntu.edu.sg> on 2016/07/05 03:12:36 UTC, 1 replies.
- Re: Checkpoint takes long with FlinkKafkaConsumer - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/07/05 07:24:09 UTC, 2 replies.
- Timewindow watermarks specific to keys of stream - posted by madhu phatak <ph...@gmail.com> on 2016/07/05 08:14:28 UTC, 2 replies.
- Re: JDBC sink in flink - posted by Harikrishnan S <hi...@gmail.com> on 2016/07/05 08:41:04 UTC, 9 replies.
- disable console output - posted by "Andres R. Masegosa " <an...@cs.aau.dk> on 2016/07/05 12:13:47 UTC, 1 replies.
- Flink stops deploying jobs on normal iteration - posted by Nguyen Xuan Truong <tr...@gmail.com> on 2016/07/05 15:11:51 UTC, 4 replies.
- Re: Switch to skip the stream alignment during a checkpoint? - posted by Daniel Li <da...@gmail.com> on 2016/07/05 15:57:53 UTC, 0 replies.
- Re: Checkpointing very large state in RocksDB? - posted by Daniel Li <da...@gmail.com> on 2016/07/05 16:01:03 UTC, 2 replies.
- Parameters inside an iteration? - posted by "Boden, Christoph" <ch...@tu-berlin.de> on 2016/07/05 16:16:22 UTC, 1 replies.
- Kafka Producer Partitioning issue - posted by Gyula Fóra <gy...@gmail.com> on 2016/07/05 22:01:00 UTC, 2 replies.
- Late arriving events - posted by Chen Qin <qi...@gmail.com> on 2016/07/05 23:06:01 UTC, 3 replies.
- Re: Graph with stream of updates - posted by agentmilindu <ag...@gmail.com> on 2016/07/06 06:07:44 UTC, 1 replies.
- Re: [DISCUSS] Allowed Lateness in Flink - posted by Aljoscha Krettek <al...@apache.org> on 2016/07/06 13:19:15 UTC, 0 replies.
- Streaming Exception error message Explanation - posted by subash basnet <ya...@gmail.com> on 2016/07/06 13:35:19 UTC, 1 replies.
- Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime', or did you forget to call 'DataStream.assignTimestampsAndWatermarks(...)'? - posted by David Olsen <da...@gmail.com> on 2016/07/06 13:43:20 UTC, 7 replies.
- Flink and Calcite - posted by Radu Tudoran <ra...@huawei.com> on 2016/07/06 13:49:29 UTC, 2 replies.
- Accessing external DB inside RichFlatMap Function - posted by simon peyer <si...@soom-it.ch> on 2016/07/07 08:38:54 UTC, 3 replies.
- Cep NFA formal declaration - posted by Bence Ágocsi Kiss <ak...@gmail.com> on 2016/07/07 11:00:55 UTC, 1 replies.
- Adding and removing operations after execute - posted by adamlehenbauer <ad...@gmail.com> on 2016/07/07 11:25:14 UTC, 3 replies.
- Flink is Unstable when TM > 1 - posted by Saliya Ekanayake <es...@gmail.com> on 2016/07/08 03:57:31 UTC, 1 replies.
- Extract type information from SortedMap - posted by Yukun Guo <gy...@gmail.com> on 2016/07/08 10:27:40 UTC, 3 replies.
- Modifying start-cluster scripts to efficiently spawn multiple TMs - posted by Saliya Ekanayake <es...@gmail.com> on 2016/07/09 07:44:24 UTC, 10 replies.
- Random access to small global state - posted by Sebastian <ss...@apache.org> on 2016/07/09 12:05:43 UTC, 2 replies.
- sampling function - posted by Le Quoc Do <le...@gmail.com> on 2016/07/09 14:47:54 UTC, 7 replies.
- The two inputs have different execution contexts. - posted by Alieh Saeedi <a1...@yahoo.com> on 2016/07/10 13:13:26 UTC, 3 replies.
- dynamic streams and patterns - posted by Claudia Wegmann <c....@kasasi.de> on 2016/07/11 07:39:25 UTC, 4 replies.
- Flink Completed Jobs only has 5 entries - posted by Saliya Ekanayake <es...@gmail.com> on 2016/07/11 14:45:03 UTC, 2 replies.
- Re: Dynamic partitioning for stream output - posted by Josh <jo...@gmail.com> on 2016/07/11 15:28:02 UTC, 0 replies.
- ContinuousProcessingTimeTrigger on empty - posted by Xiang Zhang <xz...@ncsu.edu> on 2016/07/11 16:28:44 UTC, 3 replies.
- Create window before the first event - posted by Xiang Zhang <xz...@ncsu.edu> on 2016/07/12 02:21:05 UTC, 1 replies.
- error for building flink-runtime from source - posted by Radu Tudoran <ra...@huawei.com> on 2016/07/12 10:02:46 UTC, 2 replies.
- Killing Yarn Session Leaves Lingering Flink Jobs - posted by Konstantin Gregor <ko...@tngtech.com> on 2016/07/12 11:28:38 UTC, 5 replies.
- HDFS to Kafka - posted by Dominique Rondé <do...@allsecur.de> on 2016/07/12 16:30:37 UTC, 2 replies.
- [Discuss] Ordering of Records - posted by vinay patil <vi...@gmail.com> on 2016/07/12 17:12:50 UTC, 2 replies.
- Issue with running Flink Python jobs on cluster - posted by Geoffrey Mon <ge...@gmail.com> on 2016/07/13 02:11:33 UTC, 13 replies.
- Re: Apache Flink 1.0.3 IllegalStateException Partiction State on chaining - posted by ANDREA SPINA <74...@studenti.unimore.it> on 2016/07/13 09:18:58 UTC, 0 replies.
- countWindow custom WindowFunction - posted by "Ciar, David B." <dc...@ceh.ac.uk> on 2016/07/13 11:07:12 UTC, 2 replies.
- Writing in flink clusters - posted by Debaditya Roy <ro...@gmail.com> on 2016/07/13 13:20:15 UTC, 4 replies.
- How large a Flink cluster can have? - posted by Yan Chou Chen <yc...@gmail.com> on 2016/07/13 13:54:12 UTC, 1 replies.
- how to get rid of null pointer exception in collection in DataStream - posted by subash basnet <ya...@gmail.com> on 2016/07/13 16:45:23 UTC, 2 replies.
- Ability to partition logs per pipeline - posted by "Chawla,Sumit " <su...@gmail.com> on 2016/07/13 19:49:07 UTC, 3 replies.
- Questions about slot sharing - posted by Vincent Wang <fv...@gmail.com> on 2016/07/14 08:37:37 UTC, 2 replies.
- Helping Spread the Word about Apachecon EU 2016 - posted by Sharan Foga <sh...@apache.org> on 2016/07/14 08:52:12 UTC, 0 replies.
- In AbstractRocksDBState, why write a byte 42 between key and namespace? - posted by 刘彪 <mm...@gmail.com> on 2016/07/15 09:05:32 UTC, 2 replies.
- Error using S3a State Backend: Window Operators sending directory instead of fully qualified file? - posted by Clifford Resnick <cr...@mediamath.com> on 2016/07/16 16:26:58 UTC, 8 replies.
- - posted by Chen Bekor <ch...@gmail.com> on 2016/07/17 16:22:01 UTC, 3 replies.
- Intermediate Data Caching - posted by Saliya Ekanayake <es...@gmail.com> on 2016/07/17 19:36:11 UTC, 3 replies.
- Elasticsearch connector and number of shards - posted by Flavio Pompermaier <po...@okkam.it> on 2016/07/18 09:23:17 UTC, 3 replies.
- Unable to get the value of datatype in datastream - posted by subash basnet <ya...@gmail.com> on 2016/07/18 10:59:43 UTC, 2 replies.
- 1.1 release - posted by aris kol <gi...@hotmail.com> on 2016/07/18 13:30:33 UTC, 2 replies.
- Parallelizing openCV libraries in Flink - posted by Debaditya Roy <ro...@gmail.com> on 2016/07/19 08:33:56 UTC, 2 replies.
- DataStreamUtils not working properly - posted by subash basnet <ya...@gmail.com> on 2016/07/19 08:48:02 UTC, 11 replies.
- Can't access Flink Dashboard at 8081, running Flink program using Eclipse - posted by Biplob Biswas <re...@gmail.com> on 2016/07/19 10:35:50 UTC, 7 replies.
- Aggregate events in time window - posted by Dominique Rondé <do...@allsecur.de> on 2016/07/19 16:31:58 UTC, 3 replies.
- Using Kafka and Flink for batch processing of a batch data source - posted by Leith Mudge <le...@palamir.com> on 2016/07/20 04:37:08 UTC, 5 replies.
- Logical plan optimization with Calcite - posted by gallenvara <ga...@gmail.com> on 2016/07/20 05:24:45 UTC, 3 replies.
- Understanding iteration error message - posted by subash basnet <ya...@gmail.com> on 2016/07/20 09:33:02 UTC, 1 replies.
- Class loading and job versioning - posted by Michal Budzyn <mi...@zalando.de> on 2016/07/20 11:02:55 UTC, 7 replies.
- Flink Dashboard stopped showing list of uploaded jars - posted by Gary Yao <ga...@zalando.de> on 2016/07/20 12:52:10 UTC, 3 replies.
- Re: Arrays values in keyBy - posted by Stephan Ewen <se...@apache.org> on 2016/07/20 14:32:29 UTC, 0 replies.
- taskmanager memory leak - posted by 김동일 <ki...@gmail.com> on 2016/07/20 15:52:44 UTC, 7 replies.
- env.readFile with enumeratenestedFields - posted by Flavio Pompermaier <po...@okkam.it> on 2016/07/20 15:55:07 UTC, 2 replies.
- Running multiple Flink Streaming Jobs, one by one - posted by Biplob Biswas <re...@gmail.com> on 2016/07/20 21:15:33 UTC, 1 replies.
- Processing windows in event time order - posted by David Desberg <da...@uber.com> on 2016/07/21 01:30:19 UTC, 9 replies.
- Guava immutable collection kryo serialization - posted by Shaosu Liu <sh...@uber.com> on 2016/07/21 03:28:08 UTC, 2 replies.
- DataStreamUtils conversion problem, showing varied results for same code - posted by subash basnet <ya...@gmail.com> on 2016/07/21 10:20:02 UTC, 0 replies.
- add FLINK_LIB_DIR to classpath on yarn - posted by "Dong iL, Kim" <ki...@gmail.com> on 2016/07/21 19:28:41 UTC, 0 replies.
- counting words (not frequency) - posted by Roshan Naik <ro...@hortonworks.com> on 2016/07/22 02:06:23 UTC, 3 replies.
- Re: add FLINK_LIB_DIR to classpath on yarn -> add properties file to class path on yarn - posted by 김동일 <ki...@gmail.com> on 2016/07/22 03:46:08 UTC, 2 replies.
- flink1.0 DataStream groupby - posted by ri...@sina.cn on 2016/07/22 05:27:45 UTC, 1 replies.
- Re: State in external db (dynamodb) - posted by Josh <jo...@gmail.com> on 2016/07/22 09:54:56 UTC, 4 replies.
- AW: Getting the NumberOfParallelSubtask - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/07/22 11:56:37 UTC, 0 replies.
- Variable not initialized in the open() method of RichMapFunction - posted by Yassin Marzouki <ya...@gmail.com> on 2016/07/22 14:49:18 UTC, 6 replies.
- FlinkShell with standalone HA cluster - posted by Scott Clasen <sc...@heroku.com> on 2016/07/22 16:44:51 UTC, 1 replies.
- flink batch data processing - posted by Paul Joireman <pa...@physiq.com> on 2016/07/22 17:21:29 UTC, 1 replies.
- extract fields from nested map - posted by "Pauline Yeung (yeungp)" <ye...@cisco.com> on 2016/07/23 06:14:09 UTC, 1 replies.
- Supporting Multi-tenancy in a Flink - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2016/07/25 03:38:05 UTC, 3 replies.
- customize class path using on yarn - posted by "Dong-iL, Kim" <ki...@gmail.com> on 2016/07/25 05:29:38 UTC, 1 replies.
- Performance issues with GroupBy? - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/07/25 12:06:01 UTC, 4 replies.
- No output when using event time with multiple Kafka partitions - posted by Yassin Marzouki <ya...@gmail.com> on 2016/07/25 13:39:13 UTC, 4 replies.
- [ANNOUNCE] Flink Forward 2016: First round of speakers and sessions is out - posted by Kostas Tzoumas <kt...@apache.org> on 2016/07/25 15:54:11 UTC, 0 replies.
- Question about Checkpoint Storage (RocksDB) - posted by Sameer W <sa...@axiomine.com> on 2016/07/25 18:50:38 UTC, 4 replies.
- tumbling time window, date boundary and timezone - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/07/26 10:50:57 UTC, 1 replies.
- Re: Question about Apache Flink Use Case - posted by Kostas Kloudas <k....@data-artisans.com> on 2016/07/26 11:42:47 UTC, 0 replies.
- .so linkage error in Cluster - posted by Debaditya Roy <ro...@gmail.com> on 2016/07/26 14:32:21 UTC, 6 replies.
- stop then start the job, how to load latest checkpoints automatically? - posted by Shaosu Liu <sh...@uber.com> on 2016/07/26 18:27:49 UTC, 2 replies.
- CEP and Within Clause - posted by Sameer W <sa...@axiomine.com> on 2016/07/27 01:21:25 UTC, 0 replies.
- If I chain two windows, what event-time would the second window have? - posted by Yassin Marzouki <ya...@gmail.com> on 2016/07/27 06:41:29 UTC, 2 replies.
- fault tolerance: suspend and resume? - posted by Istvan Soos <is...@gmail.com> on 2016/07/27 08:10:36 UTC, 1 replies.
- Sporadic exceptions when checkpointing to S3 - posted by Gary Yao <ga...@zalando.de> on 2016/07/27 08:56:09 UTC, 1 replies.
- [VOTE] Release Apache Flink 1.1.0 (RC1) - posted by Ufuk Celebi <uc...@apache.org> on 2016/07/27 09:50:22 UTC, 1 replies.
- JobManager trying to re-submit jobs after failover - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/07/27 12:00:44 UTC, 4 replies.
- OffHeap support in Flink - posted by Aakash Agrawal <Aa...@1eq.com> on 2016/07/27 13:19:49 UTC, 0 replies.
- how to start tuning to prevent OutOfMemory - posted by Istvan Soos <is...@gmail.com> on 2016/07/27 21:43:42 UTC, 1 replies.
- hash preservation - posted by Robert Schwarzenberg <sc...@campus.tu-berlin.de> on 2016/07/28 13:21:34 UTC, 1 replies.
- how does flink assign windows to task - posted by Vishnu Viswanath <vi...@gmail.com> on 2016/07/28 15:49:55 UTC, 3 replies.
- Flink kafka group question - posted by 王萌 <wa...@unicall.cc> on 2016/07/28 16:10:51 UTC, 1 replies.
- Reprocessing data in Flink / rebuilding Flink state - posted by Josh <jo...@gmail.com> on 2016/07/28 17:14:38 UTC, 7 replies.
- Container running beyond physical memory limits when processing DataStream - posted by Jack Huang <ja...@mz.com> on 2016/07/28 22:59:21 UTC, 2 replies.
- TimeWindowAll doeesn't assign properly - posted by Sendoh <un...@gmail.com> on 2016/07/29 14:46:24 UTC, 1 replies.
- Flink - Once and once processing - posted by M Singh <ma...@yahoo.com> on 2016/07/29 17:26:02 UTC, 3 replies.
- Flink and SQL - posted by Davran Muzafarov <da...@streamingedge.com> on 2016/07/29 18:24:05 UTC, 0 replies.
- Serialization of "not a valid POJO type" - posted by "Paschek, Robert" <ro...@tu-berlin.de> on 2016/07/30 10:04:25 UTC, 1 replies.