You are viewing a plain text version of this content. The canonical link for it is here.
- Re: [External] Flink 1.7.1 on EMR metrics - posted by Padarn Wilson <pa...@gmail.com> on 2019/06/02 02:30:06 UTC, 2 replies.
- What does flink session mean ? - posted by Jeff Zhang <zj...@gmail.com> on 2019/06/02 13:19:42 UTC, 3 replies.
- Re: Limitations in StreamingFileSink BulkFormat - posted by "Woessner, Leo" <le...@pearson.com> on 2019/06/02 15:22:56 UTC, 0 replies.
- Kinesis Analytics - posted by "Woessner, Leo" <le...@pearson.com> on 2019/06/02 16:36:44 UTC, 0 replies.
- Flink HA cluster on YARN is restarted more than yarn.application-attempts value - posted by 新平和礼 <k....@gmail.com> on 2019/06/02 16:48:19 UTC, 2 replies.
- Table API and nested JSON - posted by Pramit Vamsi <pr...@gmail.com> on 2019/06/02 18:32:37 UTC, 1 replies.
- Re: How to build dependencies and connections between stream jobs? - posted by Konstantin Knauf <ko...@ververica.com> on 2019/06/03 08:01:20 UTC, 1 replies.
- Is there any way to get the ExecutionGraph of a Job - posted by Debasish Ghosh <gh...@gmail.com> on 2019/06/03 09:32:16 UTC, 2 replies.
- Re: Restore state class not found exception in 1.8 - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/06/03 10:50:07 UTC, 1 replies.
- Re: count(DISTINCT) in flink SQL - posted by Fabian Hueske <fh...@gmail.com> on 2019/06/03 11:51:42 UTC, 3 replies.
- Flink job server with HA - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/06/03 14:05:33 UTC, 6 replies.
- Re: Pipeline TimeOut with Beam SideInput - posted by bj...@gmail.com,
bj...@gmail.com on 2019/06/03 15:07:04 UTC, 0 replies.
- Clean way of expressing UNNEST operations - posted by Piyush Narang <p....@criteo.com> on 2019/06/03 16:20:10 UTC, 3 replies.
- Issue using Flink on EMR - posted by Ayush Verma <ay...@gmail.com> on 2019/06/03 18:02:20 UTC, 0 replies.
- Controlling the amount of checkpoint files - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/06/03 22:45:24 UTC, 3 replies.
- Is it possible to configure Flink pre-flight type serialization scanning? - posted by John Tipper <jo...@hotmail.com> on 2019/06/03 23:07:11 UTC, 0 replies.
- Read file from S3 and write to kafka - posted by anurag <an...@gmail.com> on 2019/06/04 02:57:06 UTC, 1 replies.
- Re: 回复：Memory Allocate/Deallocate related Thread Deadlock encountered when running a large job > 10k tasks - posted by zhijiang <wa...@aliyun.com> on 2019/06/04 07:56:22 UTC, 3 replies.
- error in flink - posted by yuvraj singh <19...@gmail.com> on 2019/06/04 10:52:21 UTC, 1 replies.
- Re: BigQuery source ? - posted by Richard Deurwaarder <ri...@xeli.eu> on 2019/06/04 12:01:04 UTC, 0 replies.
- Job recovers from an old dangling CheckPoint in case of Job Cluster based Flink pipeline - posted by Vishal Santoshi <vi...@gmail.com> on 2019/06/04 16:32:34 UTC, 9 replies.
- Does Flink Kafka connector has max_pending_offsets concept? - posted by wang xuchen <be...@gmail.com> on 2019/06/04 17:47:20 UTC, 4 replies.
- Flink 1.8 - posted by Vishal Santoshi <vi...@gmail.com> on 2019/06/04 18:41:07 UTC, 2 replies.
- can flink sql handle udf-generated timestamp field - posted by Yu Yang <yu...@gmail.com> on 2019/06/05 06:57:24 UTC, 5 replies.
- [Flink 1.6.1] _metadata file in retained checkpoint - posted by Rinat <r....@cleverdata.ru> on 2019/06/05 13:36:02 UTC, 2 replies.
- Weird behavior with CoFlatMapFunction - posted by Andy Hoang <an...@parcelperform.com> on 2019/06/06 10:29:02 UTC, 1 replies.
- Change sink topology - posted by Smirnov Sergey Vladimirovich <s....@tinkoff.ru> on 2019/06/06 11:50:42 UTC, 2 replies.
- Ipv6 supported? - posted by Siew Wai Yow <wa...@hotmail.com> on 2019/06/06 14:25:33 UTC, 2 replies.
- Flink 1.7.1 flink-s3-fs-hadoop-1.7.1 doesn't delete older chk- directories - posted by anaray <an...@gmail.com> on 2019/06/06 19:03:50 UTC, 2 replies.
- NotSerializableException: DropwizardHistogramWrapper inside AggregateFunction - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/06/06 21:03:57 UTC, 2 replies.
- No yarn option in self-built flink version - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2019/06/07 09:03:18 UTC, 4 replies.
- Re: Building Flink distribution with Scala2.12 - posted by Chesnay Schepler <ch...@apache.org> on 2019/06/07 09:28:40 UTC, 0 replies.
- RE: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component - posted by Georgi Stoyanov <gs...@live.com> on 2019/06/07 11:03:52 UTC, 1 replies.
- Avro serde classes in Flink - posted by Debasish Ghosh <gh...@gmail.com> on 2019/06/07 16:00:40 UTC, 2 replies.
- What happens when: high-availability.storageDir: is not available? - posted by John Smith <ja...@gmail.com> on 2019/06/07 20:16:26 UTC, 4 replies.
- Loading state from sink/understanding recovery options - posted by Eduardo Winpenny Tejedor <ed...@gmail.com> on 2019/06/08 13:10:59 UTC, 3 replies.
- How are timestamps treated within an iterative DataStream loop within Flink? - posted by John Tipper <jo...@hotmail.com> on 2019/06/08 13:19:24 UTC, 1 replies.
- About SerializationSchema/DeserializationSchema's concurrency safety - posted by Chase Zhang <yu...@gmail.com> on 2019/06/10 03:24:49 UTC, 1 replies.
- Troubleshooting java.io.IOException: Connecting the channel failed: Connecting to remote task manager has failed. This might indicate that the remote task manager has been lost. - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/06/10 11:31:18 UTC, 1 replies.
- [ANNOUNCEMENT] June 2019 Bay Area Apache Flink Meetup - posted by Xuefu Zhang <xu...@apache.org> on 2019/06/11 02:50:18 UTC, 2 replies.
- StreamingFileSink in version 1.8 - posted by Yitzchak Lieberman <yi...@sentinelone.com> on 2019/06/11 07:16:25 UTC, 2 replies.
- How can I improve this Flink application for "Distinct Count of elements" in the data stream? - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/06/11 08:26:45 UTC, 7 replies.
- Oracle data streaming using Flink - posted by Kailash Kota <Ka...@jda.com> on 2019/06/11 12:11:11 UTC, 0 replies.
- [DISCUSS] Deprecate previous Python APIs - posted by Stephan Ewen <se...@apache.org> on 2019/06/11 13:30:21 UTC, 16 replies.
- Local blobStore not freed - posted by Dede <ro...@gmail.com> on 2019/06/11 15:06:32 UTC, 2 replies.
- Apache Flink - Disabling system metrics and collecting only specific metrics - posted by M Singh <ma...@yahoo.com> on 2019/06/11 16:30:18 UTC, 2 replies.
- How to config user for passwordless ssh? - posted by John Smith <ja...@gmail.com> on 2019/06/11 19:30:24 UTC, 0 replies.
- Savepoint status check fails with error Operation not found under key - posted by anaray <an...@gmail.com> on 2019/06/11 21:35:32 UTC, 1 replies.
- RE: EXT :How to config user for passwordless ssh? - posted by "Martin, Nick" <Ni...@ngc.com> on 2019/06/12 01:01:26 UTC, 1 replies.
- java.io.FileNotFoundException in implementing exactly once - posted by syed <ms...@vu.edu.pk> on 2019/06/12 02:16:16 UTC, 1 replies.
- Re: Flink 1.2.1 JobManager Election Deadlock - posted by Mar_zieh <m....@gmail.com> on 2019/06/12 10:10:28 UTC, 0 replies.
- ApacheCon North America 2019 Schedule Now Live! - posted by Rich Bowen <rb...@rcbowen.com> on 2019/06/12 15:16:40 UTC, 0 replies.
- How to restart/recover on reboot? - posted by John Smith <ja...@gmail.com> on 2019/06/12 17:02:29 UTC, 6 replies.
- TableException - posted by Pramit Vamsi <pr...@gmail.com> on 2019/06/12 17:34:30 UTC, 1 replies.
- Source code question - about the logic of calculating network buffer - posted by 徐涛 <ha...@gmail.com> on 2019/06/13 02:22:52 UTC, 2 replies.
- Building flink from source---error of resolving dependencies - posted by syed <ms...@vu.edu.pk> on 2019/06/13 07:47:10 UTC, 2 replies.
- Flink end to end intergration test - posted by mi...@ubs.com on 2019/06/13 08:24:29 UTC, 2 replies.
- java.lang.NoClassDefFoundError --- FlinkKafkaConsumer - posted by syed <ms...@vu.edu.pk> on 2019/06/13 08:28:09 UTC, 1 replies.
- Latency Monitoring in Flink application - posted by "Halfon, Roey" <ro...@sap.com> on 2019/06/13 10:19:27 UTC, 2 replies.
- Deletion of topic from a pattern in KafkaConsumer if auto-create is true will always recreate the topic - posted by Vishal Santoshi <vi...@gmail.com> on 2019/06/13 19:02:10 UTC, 4 replies.
- How to join/group 2 streams by key? - posted by John Tipper <jo...@hotmail.com> on 2019/06/14 07:24:25 UTC, 1 replies.
- Flink sent/received bytes related metrics: how are they calculated? - posted by Andrea Spina <an...@radicalbit.io> on 2019/06/14 07:49:09 UTC, 4 replies.
- Error while using session window - posted by Abhishek Jain <ab...@gmail.com> on 2019/06/14 08:14:44 UTC, 1 replies.
- Re: Re: How can i just implement a crontab function using flink? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/06/14 09:32:21 UTC, 0 replies.
- How to trigger the window function even there's no message input in this window? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/06/14 10:08:06 UTC, 1 replies.
- privacy preserving on streaming Kmeans in Flink - posted by alaa <al...@hotmail.com> on 2019/06/14 13:06:44 UTC, 1 replies.
- Optimizing Heap usage for Streaming Jobs - posted by Andrea Spina <an...@radicalbit.io> on 2019/06/14 14:42:41 UTC, 1 replies.
- Effect of increasing parallelism on throughput - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/06/14 16:19:43 UTC, 1 replies.
- Apache Flink - Question about metric registry and reporter and context information - posted by M Singh <ma...@yahoo.com> on 2019/06/14 18:13:23 UTC, 2 replies.
- Apache Flink Sql - How to access EXPR$0, EXPR$1 values from a Row in a table - posted by M Singh <ma...@yahoo.com> on 2019/06/14 20:54:53 UTC, 1 replies.
- Timeout about local test case - posted by aitozi <gj...@gmail.com> on 2019/06/15 11:21:22 UTC, 1 replies.
- Best practice to process DB stored log (is Flink the right choice?) - posted by Stefano Lissa <sa...@gmail.com> on 2019/06/15 16:27:38 UTC, 1 replies.
- Asynchronous I/O - posted by "Halfon, Roey" <ro...@sap.com> on 2019/06/16 12:50:29 UTC, 0 replies.
- A little doubt about the blog A Deep To Flink's NetworkStack - posted by aitozi <gj...@gmail.com> on 2019/06/16 14:19:20 UTC, 2 replies.
- [ANNOUNCE] Weekly Community Update 2019/24 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/06/16 16:10:08 UTC, 2 replies.
- StreamingFileSink with hdfs less than 2.7 - posted by Rinat <r....@cleverdata.ru> on 2019/06/17 09:29:42 UTC, 0 replies.
- Flink state: complex value state pojos vs explicitly managed fields - posted by Frank Wilson <fa...@gmail.com> on 2019/06/17 09:59:14 UTC, 2 replies.
- What order are events processed in iterative loop? - posted by John Tipper <jo...@hotmail.com> on 2019/06/17 10:18:34 UTC, 0 replies.
- Unexpected behavior from interval join in Flink - posted by Wouter Zorgdrager <W....@tudelft.nl> on 2019/06/17 11:20:15 UTC, 4 replies.
- Has Flink a kafka processing location strategy? - posted by Theo Diefenthal <th...@scoop-software.de> on 2019/06/17 12:57:31 UTC, 1 replies.
- Why the current time of my window never reaches the end time when I use KeyedProcessFunction? - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/06/17 13:51:50 UTC, 3 replies.
- Calculate a 4 hour time window for sum,count with sum and count output every 5 mins - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/06/17 17:06:03 UTC, 4 replies.
- Re: [ANNOUNCEMENT] March 2019 Bay Area Apache Flink Meetup - posted by Xuefu Zhang <xu...@apache.org> on 2019/06/17 17:31:32 UTC, 1 replies.
- InvalidProgramException in streaming execution - posted by Akash Jain <ak...@gmail.com> on 2019/06/17 17:36:56 UTC, 0 replies.
- Need for user class path accessibility on all nodes - posted by Abdul Qadeer <qu...@gmail.com> on 2019/06/17 19:07:59 UTC, 5 replies.
- Checkpointing & File stream with - posted by Sung Gon Yi <sk...@mac.com> on 2019/06/18 06:13:22 UTC, 2 replies.
- Role of Job Manager - posted by Pankaj Chand <pa...@gmail.com> on 2019/06/18 07:42:02 UTC, 3 replies.
- Maybe a flink bug. Job keeps in FAILING state - posted by Joshua Fan <jo...@gmail.com> on 2019/06/18 10:14:43 UTC, 8 replies.
- Side output in ProcessFunction.onTimer - posted by Frank Wilson <fa...@gmail.com> on 2019/06/18 15:41:51 UTC, 1 replies.
- Flink error handling - posted by Steven Nelson <sn...@sourceallies.com> on 2019/06/18 16:02:14 UTC, 0 replies.
- Re: [EXTERNAL] Re: How to restart/recover on reboot? - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/06/18 21:15:06 UTC, 4 replies.
- unsubscribe - posted by Sheel Pancholi <sh...@gmail.com> on 2019/06/19 03:20:51 UTC, 1 replies.
- Simple stateful polling source - posted by Flavio Pompermaier <po...@okkam.it> on 2019/06/19 10:33:16 UTC, 6 replies.
- partition columns with StreamingFileSink - posted by Yitzchak Lieberman <yi...@sentinelone.com> on 2019/06/19 12:36:35 UTC, 0 replies.
- [External] checkpoint metadata not in configured directory state.checkpoints.dir - posted by Vishal Sharma <vi...@grab.com> on 2019/06/19 14:26:45 UTC, 5 replies.
- Updated Flink Documentation and tutorials - posted by Pankaj Chand <pa...@gmail.com> on 2019/06/19 17:17:52 UTC, 4 replies.
- Re: can we do Flink CEP on event stream or batch or both? - posted by kant kodali <ka...@gmail.com> on 2019/06/19 21:15:41 UTC, 0 replies.
- CoFlatMapFunction vs BroadcastProcessFunction - posted by Andy Hoang <an...@parcelperform.com> on 2019/06/20 10:39:57 UTC, 1 replies.
- metrics for checking whether a broker throttles requests based on its quota limits? - posted by Yu Yang <yu...@gmail.com> on 2019/06/20 17:18:22 UTC, 0 replies.
- Unable to set S3 like object storage for state backend. - posted by Vishwas Siravara <vs...@gmail.com> on 2019/06/20 21:46:12 UTC, 2 replies.
- dynamic metric - posted by David Morin <mo...@gmail.com> on 2019/06/20 22:35:45 UTC, 3 replies.
- [External] Using scala parallel collection with ForkJoinPool - posted by Vishal Sharma <vi...@grab.com> on 2019/06/21 02:41:33 UTC, 0 replies.
- Flink Kafka consumer with low latency requirement - posted by wang xuchen <be...@gmail.com> on 2019/06/21 03:48:29 UTC, 6 replies.
- Idle windows - posted by Ustinov Anton <us...@gmail.com> on 2019/06/21 10:23:07 UTC, 1 replies.
- [FLINK-10868] the job cannot be exited immediately if job manager is timed out - posted by Young <zz...@163.com> on 2019/06/21 12:43:34 UTC, 0 replies.
- Use Partitioner to forward messages to subtask by index - posted by Joshua Griffith <jo...@gmail.com> on 2019/06/21 17:15:04 UTC, 1 replies.
- WebUI show custom config - posted by Dominik Wosiński <wo...@gmail.com> on 2019/06/21 21:31:25 UTC, 0 replies.
- Does making synchronize call might choke the whole pipeline - posted by wang xuchen <be...@gmail.com> on 2019/06/23 04:31:45 UTC, 0 replies.
- Unable to left join on windowed session - posted by Tal Shargal <ta...@hunters.ai> on 2019/06/23 12:04:18 UTC, 0 replies.
- Linkage Error RocksDB and flink-1.6.4 - posted by Andrea Spina <an...@radicalbit.io> on 2019/06/23 18:20:51 UTC, 3 replies.
- [ANNOUNCE] Weekly Community Update 2019/25 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/06/23 20:18:32 UTC, 0 replies.
- Batch mode with Flink 1.8 unstable? - posted by Ken Krugler <kk...@transpac.com> on 2019/06/24 00:32:09 UTC, 4 replies.
- Akka tcp address on AWS EMR between job/task managers - posted by Andy Hoang <an...@parcelperform.com> on 2019/06/24 05:04:03 UTC, 0 replies.
- Process Function's timers "postponing" - posted by Andrea Spina <an...@radicalbit.io> on 2019/06/24 18:06:43 UTC, 4 replies.
- Building some specific modules in flink - posted by syed <ms...@vu.edu.pk> on 2019/06/25 01:14:20 UTC, 2 replies.
- Error checkpointing to S3 like FS (EMC ECS) - posted by Vishwas Siravara <vs...@gmail.com> on 2019/06/25 01:26:28 UTC, 0 replies.
- Unable to restore state value after job failed using RocksDBStateBackend - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/06/25 12:11:11 UTC, 4 replies.
- open() setup method not being called for AggregateFunctions? - posted by Piyush Narang <p....@criteo.com> on 2019/06/25 19:16:05 UTC, 1 replies.
- [FLINK-10868] job cannot be exited immediately if job manager is timed out for some reason - posted by Anyang Hu <hu...@gmail.com> on 2019/06/26 08:52:34 UTC, 0 replies.
- Best Flink SQL length proposal - posted by Simon Su <ba...@163.com> on 2019/06/26 09:49:19 UTC, 3 replies.
- Hello-world example of Flink Table API using a edited Calcite rule - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/06/26 10:03:48 UTC, 5 replies.
- Re: Apache Flink - How to pass configuration params in the flink-config.yaml file to local execution environment - posted by M Singh <ma...@yahoo.com> on 2019/06/26 13:07:47 UTC, 0 replies.
- Apache Flink - Running application with different flink configurations (flink-conf.yml) on EMR - posted by M Singh <ma...@yahoo.com> on 2019/06/26 13:13:35 UTC, 4 replies.
- Error when creating InMemoryExternalCatalog to populate using another stream. - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/06/26 15:09:24 UTC, 0 replies.
- HDFS checkpoints for rocksDB state backend: - posted by Andrea Spina <an...@radicalbit.io> on 2019/06/26 17:56:54 UTC, 3 replies.
- Any tutorial/example/blogpost/doc for Hive Source and Hive Sink with Flink streaming job? - posted by Elkhan Dadashov <el...@gmail.com> on 2019/06/26 18:35:46 UTC, 0 replies.
- Re:Limit number of jobs or Job Managers - posted by Haibo Sun <su...@163.com> on 2019/06/27 11:45:34 UTC, 2 replies.
- Apache Flink - Are counters reliable and accurate ? - posted by M Singh <ma...@yahoo.com> on 2019/06/27 15:36:22 UTC, 3 replies.
- Debug Kryo.Serialization Exception - posted by Fabian Wollert <fa...@zalando.de> on 2019/06/27 16:29:32 UTC, 3 replies.
- Flink batch job memory/disk leak when invoking set method on a static Configuration object. - posted by Vadim Vararu <va...@adswizz.com> on 2019/06/27 16:46:43 UTC, 2 replies.
- About "Flink 1.7.0 HA based on zookeepers " - posted by 胡逸才 <hu...@163.com> on 2019/06/28 03:09:26 UTC, 1 replies.
- [External] Regarding kinesis data analytics for flink - posted by Vishal Sharma <vi...@grab.com> on 2019/06/28 03:12:45 UTC, 0 replies.
- Re: How to run Graph algorithms - posted by Robert Metzger <rm...@apache.org> on 2019/06/28 07:55:03 UTC, 0 replies.
- LookupableTableSource question - posted by Flavio Pompermaier <po...@okkam.it> on 2019/06/28 12:48:04 UTC, 4 replies.
- Providing external files to flink classpath - posted by Vishwas Siravara <vs...@gmail.com> on 2019/06/28 16:43:38 UTC, 1 replies.
- Why did JM fail on K8s (see original thread below) - posted by Timothy Victor <vi...@gmail.com> on 2019/06/29 13:35:12 UTC, 3 replies.
- Flink Kafka ordered offset commit & unordered processing - posted by wang xuchen <be...@gmail.com> on 2019/06/30 02:47:25 UTC, 0 replies.
- Weekly Community Update 2019/26 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/06/30 07:10:12 UTC, 0 replies.
- Flink question - posted by Marzieh Ghasemy <as...@yahoo.com> on 2019/06/30 11:26:52 UTC, 0 replies.
- Connection refused while trying to query state - posted by Avi Levi <av...@bluevoyant.com> on 2019/06/30 14:37:21 UTC, 0 replies.