You are viewing a plain text version of this content. The canonical link for it is here.
- Re: GroupReduce is interrupted on reading large CSV files - posted by Kurt Young <yk...@gmail.com> on 2017/04/01 07:20:22 UTC, 0 replies.
- flink-1.2.0 java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/filter/Filter - posted by ri...@sina.cn on 2017/04/01 09:50:41 UTC, 0 replies.
- Gelly Graph Processing - descriptive buzzwords - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2017/04/01 20:00:09 UTC, 0 replies.
- Doubt Regarding producing to kafka using flink - posted by Archit Mittal <ma...@gmail.com> on 2017/04/02 10:38:00 UTC, 3 replies.
- elasticsearch version compatibility with 1.3-SNAPSHOT version of flink - posted by Sathi Chowdhury <Sa...@elliemae.com> on 2017/04/02 18:44:44 UTC, 1 replies.
- Re: Flink Scheduling and FlinkML - posted by Theodore Vasiloudis <th...@gmail.com> on 2017/04/03 07:51:39 UTC, 0 replies.
- Flink streaming job with iterations gets stuck waiting for network buffers - posted by Andrey Melentyev <an...@gmail.com> on 2017/04/03 10:54:01 UTC, 4 replies.
- I²: Interactive Real-Time Visualization for Streaming Data - posted by Philipp Grulich <ph...@dfki.de> on 2017/04/03 12:57:57 UTC, 0 replies.
- Signal Trigger - posted by nragon <nu...@wedotechnologies.com> on 2017/04/03 16:45:05 UTC, 3 replies.
- Re: In-Memory data grid - posted by nragon <nu...@wedotechnologies.com> on 2017/04/03 16:55:30 UTC, 2 replies.
- PartitionNotFoundException on deploying streaming job - posted by Kamil Dziublinski <ka...@gmail.com> on 2017/04/04 09:19:59 UTC, 1 replies.
- Flink Cross Strategies - posted by gen-too <ge...@gmx-topmail.de> on 2017/04/04 09:21:50 UTC, 3 replies.
- Re: Cogrouped Stream never triggers tumbling event time window - posted by Aljoscha Krettek <al...@apache.org> on 2017/04/04 09:42:20 UTC, 0 replies.
- Re: concurrency? - posted by Aljoscha Krettek <al...@apache.org> on 2017/04/04 09:59:43 UTC, 0 replies.
- 回复：PartitionNotFoundException on deploying streaming job - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/04 16:03:31 UTC, 1 replies.
- Flink UI and records sent - posted by Flavio Pompermaier <po...@okkam.it> on 2017/04/05 07:55:08 UTC, 3 replies.
- ANN: Euphoria API - posted by Petr Novotnik <pe...@firma.seznam.cz> on 2017/04/05 08:29:04 UTC, 2 replies.
- Flink slots, threads, task, etc - posted by Flavio Pompermaier <po...@okkam.it> on 2017/04/05 17:43:00 UTC, 4 replies.
- Connector for REST End Point - posted by Archit Mittal <ma...@gmail.com> on 2017/04/06 07:40:59 UTC, 5 replies.
- Re: Should I decrease the taskmanager.memory.fraction ? - posted by nragon <nu...@wedotechnologies.com> on 2017/04/06 14:36:59 UTC, 4 replies.
- Shared DataStream - posted by nragon <nu...@wedotechnologies.com> on 2017/04/06 15:28:45 UTC, 2 replies.
- Submit Flink job programatically - posted by Jins George <ji...@aeris.net> on 2017/04/07 06:04:54 UTC, 1 replies.
- Disk I/O in Flink - posted by Robert Schmidtke <ro...@gmail.com> on 2017/04/07 08:20:14 UTC, 5 replies.
- Hi - posted by kant kodali <ka...@gmail.com> on 2017/04/07 09:32:39 UTC, 2 replies.
- hadoopcompatibility not in dist - posted by Petr Novotnik <pe...@firma.seznam.cz> on 2017/04/07 14:27:55 UTC, 4 replies.
- Flink + Druid example? - posted by Matt <dr...@gmail.com> on 2017/04/07 19:01:01 UTC, 7 replies.
- Flink to S3 streaming - posted by pradeep s <sr...@gmail.com> on 2017/04/08 06:09:19 UTC, 1 replies.
- has insufficient permissions to access it - Error - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2017/04/08 15:41:28 UTC, 3 replies.
- RE: Aggregation problem. - posted by Kürşat Kurt <ku...@kursatkurt.com> on 2017/04/08 22:38:23 UTC, 4 replies.
- Re: Task manager number mismatch container number on mesos - posted by Renjie Liu <li...@gmail.com> on 2017/04/10 06:05:48 UTC, 2 replies.
- Latest stable release binaries - broken links? - posted by Miguel Coimbra <mi...@gmail.com> on 2017/04/10 11:50:08 UTC, 2 replies.
- Docker PID 1 - posted by Kathleen Sharp <ka...@signavio.com> on 2017/04/10 16:00:15 UTC, 2 replies.
- Custom timer implementation using Flink - posted by jaxbihani <ja...@helpshift.com> on 2017/04/11 10:15:59 UTC, 2 replies.
- Problems with Kerberos Kafka connection in version 1.2.0 - posted by Diego Fustes Villadóniga <df...@oesia.com> on 2017/04/11 10:24:14 UTC, 1 replies.
- CEP timeout does not trigger under certain conditions - posted by vijayakumar palaniappan <vi...@gmail.com> on 2017/04/11 16:06:40 UTC, 3 replies.
- CEP Pattern detection progressively slower - posted by vijayakumar palaniappan <vi...@gmail.com> on 2017/04/11 17:57:04 UTC, 2 replies.
- Comparsion between Flink vs Kafka Stream Processing - posted by kant kodali <ka...@gmail.com> on 2017/04/11 21:24:23 UTC, 0 replies.
- Cassandra connector POJO - tombstone question - posted by Tarandeep Singh <ta...@gmail.com> on 2017/04/12 00:27:22 UTC, 2 replies.
- Changing timeout for cancel command - posted by Jürgen Thomann <ju...@innogames.com> on 2017/04/12 11:04:15 UTC, 0 replies.
- Re: Flink job on secure Yarn fails after many hours - posted by Robert Metzger <rm...@apache.org> on 2017/04/12 15:35:30 UTC, 1 replies.
- Maintaining Stream Partitioning after Mapping? - posted by Ryan Conway <ry...@gmail.com> on 2017/04/12 19:37:27 UTC, 2 replies.
- 回复：Changing timeout for cancel command - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/13 05:05:46 UTC, 1 replies.
- Kafka offset commits - posted by Gwenhael Pasquiers <gw...@ericsson.com> on 2017/04/13 14:55:04 UTC, 5 replies.
- Flink errors out and job fails--IOException from CollectSink.open() - posted by Sathi Chowdhury <Sa...@elliemae.com> on 2017/04/13 23:39:19 UTC, 10 replies.
- Using Contextual Data - posted by Doron Keller <do...@exabeam.com> on 2017/04/13 23:41:34 UTC, 1 replies.
- 回复：回复：Changing timeout for cancel command - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/14 06:45:19 UTC, 0 replies.
- Container is is running beyond physical memory limits. Current usage: 2.0 GB of 2 GB physical memory used; 2.9 GB of 4.2 GB virtual memory used. Killing container. - posted by sohimankotia <so...@gmail.com> on 2017/04/14 07:55:40 UTC, 2 replies.
- Parallel execution but keep order of kafka messages - posted by Benjamin Reißaus <be...@gmail.com> on 2017/04/14 17:22:38 UTC, 3 replies.
- Data duplication on a High Availability activated cluster after a Task Manager failure recovery - posted by "F.Amara" <fa...@wso2.com> on 2017/04/17 04:03:48 UTC, 2 replies.
- Why I am getting Null pointer exception while accessing RuntimeContext in FlinkKafkaProducer010 ? - posted by sohimankotia <so...@gmail.com> on 2017/04/17 10:35:17 UTC, 5 replies.
- All accumulators/ counters which are set to Kfka Source or Kafka Sink are missing after upgrading to Flink Kafka 0.10 ? - posted by sohimankotia <so...@gmail.com> on 2017/04/17 13:37:04 UTC, 0 replies.
- Beginner question - sum multiple edges - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2017/04/17 15:46:04 UTC, 4 replies.
- Index conversion - posted by Kürşat Kurt <ku...@kursatkurt.com> on 2017/04/17 20:33:22 UTC, 0 replies.
- Window Functions and Empty Panes - posted by Ryan Conway <ry...@gmail.com> on 2017/04/17 23:49:53 UTC, 6 replies.
- Key by Task number - posted by Telco Phone <te...@yahoo.com> on 2017/04/18 13:38:16 UTC, 3 replies.
- Re: Flink Kafka Consumer Behaviour - posted by sandeep6 <vr...@gmail.com> on 2017/04/18 21:00:48 UTC, 5 replies.
- Yarn terminating TM for pmem limit cascades causing all jobs to fail - posted by Shannon Carey <sc...@expedia.com> on 2017/04/18 22:26:21 UTC, 1 replies.
- Flink groupBy - posted by Alieh <sa...@informatik.uni-leipzig.de> on 2017/04/19 12:42:40 UTC, 1 replies.
- Generate Timestamps and emit Watermarks - unordered events - Kafka source - posted by Luis Lázaro <la...@keedio.com> on 2017/04/19 13:28:18 UTC, 4 replies.
- Flink memory usage - posted by "Newport, Billy" <Bi...@gs.com> on 2017/04/19 14:09:00 UTC, 9 replies.
- UnilateralSortMerger error (again) - posted by Flavio Pompermaier <po...@okkam.it> on 2017/04/19 18:22:02 UTC, 18 replies.
- 回复：Yarn terminating TM for pmem limit cascades causing all jobs to fail - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/20 02:15:39 UTC, 0 replies.
- Re: Read from and Write to Kafka through flink - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2017/04/20 05:17:30 UTC, 0 replies.
- wait for "writeAsText" to finish - posted by Lydia <ic...@googlemail.com> on 2017/04/20 07:46:52 UTC, 1 replies.
- Why TimerService interface in ProcessFunction doesn't have deleteEventTimeTimer - posted by Jagadish Bihani <ja...@helpshift.com> on 2017/04/20 09:56:00 UTC, 8 replies.
- reduceGroup - posted by Mary m <mm...@yahoo.com> on 2017/04/20 15:14:29 UTC, 1 replies.
- inconsistent behaviour in GenericCsvInputFormat - posted by JAVIER RODRIGUEZ BENITO <ja...@telefonica.com> on 2017/04/20 16:19:01 UTC, 2 replies.
- Fetching metrics failed. - posted by Jason Brelloch <jb...@gmail.com> on 2017/04/20 16:42:54 UTC, 1 replies.
- Using FlinkML from Java? - posted by Steve Jerman <st...@kloudspot.com> on 2017/04/20 16:56:58 UTC, 1 replies.
- Please participate in a research survey on graphs - posted by Siddhartha Sahu <s3...@uwaterloo.ca> on 2017/04/21 07:57:55 UTC, 0 replies.
- Failed checkpointing on HDFS : Flink don't use the right authentication - posted by Bruno Michelin Rakotondranaivo <br...@ericsson.com> on 2017/04/21 10:46:45 UTC, 1 replies.
- Setting operator parallelism of a running job - Flink 1.2 - posted by Dominik Safaric <do...@gmail.com> on 2017/04/21 13:22:27 UTC, 3 replies.
- R: WELCOME to user@flink.apache.org - posted by "giacomo90@libero.it" <gi...@libero.it> on 2017/04/21 15:42:08 UTC, 0 replies.
- Re-keying / sub-keying a stream without repartitioning - posted by Elias Levy <fe...@gmail.com> on 2017/04/22 05:15:44 UTC, 3 replies.
- Benchmarking Apache Flink via Query Plan - posted by "giacomo90@libero.it" <gi...@libero.it> on 2017/04/22 14:29:53 UTC, 1 replies.
- flink testing - posted by Georg Heiler <ge...@gmail.com> on 2017/04/23 05:57:24 UTC, 6 replies.
- Flink first project - posted by Georg Heiler <ge...@gmail.com> on 2017/04/23 16:02:33 UTC, 5 replies.
- put record to kinesis and then trying consume using flink connector - posted by Sathi Chowdhury <Sa...@elliemae.com> on 2017/04/23 16:33:15 UTC, 6 replies.
- Checkpoints very slow with high backpressure - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/04/23 18:53:45 UTC, 10 replies.
- Re: Kinesis connector SHARD_GETRECORDS_MAX default value - posted by Steffen Hausmann <st...@hausmann-family.de> on 2017/04/23 19:27:14 UTC, 1 replies.
- Re: Flink Checkpoint runs slow for low load stream - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/04/24 06:20:34 UTC, 0 replies.
- Flink on Ignite - Collocation? - posted by Matt <dr...@gmail.com> on 2017/04/24 09:47:49 UTC, 2 replies.
- Re: Queryable State - posted by Ufuk Celebi <uc...@apache.org> on 2017/04/24 11:54:18 UTC, 0 replies.
- in-memory optimization - posted by Robert Schwarzenberg <sc...@campus.tu-berlin.de> on 2017/04/24 14:20:02 UTC, 1 replies.
- Regarding exception relating to FlinkKafkaConsumer09 - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/04/24 15:56:40 UTC, 1 replies.
- Grafana plug-in for Flink - posted by Andy Gibraltar <an...@gmail.com> on 2017/04/24 16:04:33 UTC, 2 replies.
- Problems reading Parquet input from HDFS - posted by Lukas Kircher <lu...@uni-konstanz.de> on 2017/04/24 16:19:04 UTC, 4 replies.
- Writing a reliable Flink source for a NON-replay-able queue/protocol that supports message ACKs - posted by Martin Eden <ma...@gmail.com> on 2017/04/24 21:20:38 UTC, 1 replies.
- [BUG?] Cannot Load User Class on Local Environment - posted by Matt <dr...@gmail.com> on 2017/04/25 05:27:14 UTC, 7 replies.
- Re: Listening to timed-out patterns in Flink CEP - posted by Moiz Jinia <mo...@gmail.com> on 2017/04/25 07:37:31 UTC, 0 replies.
- Fault tolerance & idempotency on window functions - posted by Kamil Dziublinski <ka...@gmail.com> on 2017/04/25 17:54:10 UTC, 2 replies.
- Multiple consumers on a subpartition - posted by albertjonathan <al...@cs.umn.edu> on 2017/04/25 18:26:16 UTC, 2 replies.
- Flink docs in regards to State - posted by Sand Stone <sa...@gmail.com> on 2017/04/26 02:25:55 UTC, 5 replies.
- 回复：Multiple consumers on a subpartition - posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com> on 2017/04/26 03:58:56 UTC, 0 replies.
- CEP join across events - posted by Elias Levy <fe...@gmail.com> on 2017/04/26 05:48:24 UTC, 6 replies.
- about yarn - posted by lining jing <ji...@gmail.com> on 2017/04/26 06:16:37 UTC, 1 replies.
- Why flink 1.2.0 delete flink-connector-redis? - posted by yunfan123 <yu...@foxmail.com> on 2017/04/26 10:54:31 UTC, 1 replies.
- Lost connection to task manager - posted by 猎豹移动 李木柯 <li...@163.com> on 2017/04/26 12:12:52 UTC, 0 replies.
- Kafka 0.10 jaas multiple clients - posted by Gwenhael Pasquiers <gw...@ericsson.com> on 2017/04/26 12:47:36 UTC, 1 replies.
- Queries regarding Historical Reprocessing - posted by vinay patil <vi...@gmail.com> on 2017/04/26 13:10:59 UTC, 1 replies.
- Last chance: ApacheCon is just three weeks away - posted by Rich Bowen <rb...@rcbowen.com> on 2017/04/26 13:46:12 UTC, 0 replies.
- Iterating over keys in state backend - posted by Ken Krugler <kk...@transpac.com> on 2017/04/27 01:02:47 UTC, 3 replies.
- Behavior of the cancel command - posted by Jürgen Thomann <ju...@innogames.com> on 2017/04/27 08:27:56 UTC, 2 replies.
- REST API call in stream transformation - posted by "G.S.Vijay Raajaa" <gs...@gmail.com> on 2017/04/27 09:28:39 UTC, 1 replies.
- Join two kafka topics to do CEP - posted by tarek26 <ta...@gmail.com> on 2017/04/27 16:09:01 UTC, 2 replies.
- Graph iteration with triplets or access to edges - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2017/04/27 18:20:07 UTC, 2 replies.
- Multiple CEP Patterns - posted by mclendenin <ma...@gmail.com> on 2017/04/27 18:59:09 UTC, 6 replies.
- ElasticsearchSink Serialization Error - posted by Vijay Srinivasaraghavan <vi...@yahoo.com> on 2017/04/28 02:57:44 UTC, 1 replies.
- Writing the results of the stream onto a CSV File - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/04/28 09:18:37 UTC, 2 replies.
- Behaviour of the BucketingSink when checkpoints fail - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/04/28 09:22:50 UTC, 3 replies.
- gelly scatter/gather - posted by Alieh <sa...@informatik.uni-leipzig.de> on 2017/04/28 11:58:33 UTC, 2 replies.
- RocksDB error with flink 1.2.0 - posted by mclendenin <ma...@gmail.com> on 2017/04/28 15:05:09 UTC, 5 replies.
- Collector.collect - posted by Gaurav Khandelwal <ga...@gmail.com> on 2017/04/29 08:31:59 UTC, 0 replies.
- Batch source improvement - posted by Flavio Pompermaier <po...@okkam.it> on 2017/04/29 09:36:14 UTC, 0 replies.
- CEP timeout occurs even for a successful match when using followedBy - posted by Moiz S Jinia <mo...@gmail.com> on 2017/04/29 10:14:23 UTC, 8 replies.
- Weird serialization bug? - posted by Sebastian Neef <ge...@mailbox.tu-berlin.de> on 2017/04/29 11:26:58 UTC, 1 replies.
- Periodic flush sink? - posted by Niels Basjes <Ni...@basjes.nl> on 2017/04/29 14:32:38 UTC, 3 replies.
- The implementation of the CoGroupFunction is not serializable - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2017/04/30 18:13:09 UTC, 0 replies.