You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Broadcast state - posted by Oytun Tez <oy...@motaword.com> on 2019/10/01 00:40:44 UTC, 8 replies.
- [SURVEY] What is the most subtle/hard to catch bug that people have seen? - posted by Konstantinos Kallas <ko...@hotmail.com> on 2019/10/01 02:18:46 UTC, 4 replies.
- Fencing token exceptions from Job Manager High Availability mode - posted by "Hanson, Bruce" <br...@here.com> on 2019/10/01 03:50:47 UTC, 9 replies.
- Re: Flink Join Time Window - posted by Rong Rong <wa...@gmail.com> on 2019/10/01 04:50:41 UTC, 0 replies.
- Re: Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows - posted by Congxian Qiu <qc...@gmail.com> on 2019/10/01 05:48:19 UTC, 3 replies.
- CEP operator in SQL pattern match does not clear it's state - posted by Muhammad Hakim <mu...@gojek.com> on 2019/10/01 07:08:22 UTC, 2 replies.
- Re: Best way to link static data to event data? - posted by John Smith <ja...@gmail.com> on 2019/10/01 15:22:04 UTC, 0 replies.
- Increasing number of task slots in the task manager - posted by Vishwas Siravara <vs...@gmail.com> on 2019/10/01 18:59:36 UTC, 1 replies.
- Flink KPL based on a custom class object - posted by Andres Angel <in...@gmail.com> on 2019/10/01 18:59:38 UTC, 1 replies.
- POJO serialization vs immutability - posted by Stephen Connolly <st...@gmail.com> on 2019/10/02 12:17:05 UTC, 6 replies.
- State Processor API not working with Scala based Flink Jobs - posted by "Teunissen, F.G.J. (Fred)" <Fr...@ing.com> on 2019/10/02 12:36:20 UTC, 0 replies.
- containThrowable missing in ExceptionUtils - posted by Nicholas Walton <nw...@me.com> on 2019/10/02 13:48:09 UTC, 1 replies.
- Re: Implementing CheckpointableInputFormat - posted by Lu Niu <qq...@gmail.com> on 2019/10/03 04:38:46 UTC, 1 replies.
- Finding the Maximum Value Received so far in a Stream - posted by Komal Mariam <ko...@gmail.com> on 2019/10/03 06:25:50 UTC, 5 replies.
- kinesis consumer metrics user variables - posted by Yitzchak Lieberman <yi...@sentinelone.com> on 2019/10/03 07:09:38 UTC, 3 replies.
- Warnings connecting to Akka - posted by John Smith <ja...@gmail.com> on 2019/10/03 15:01:38 UTC, 9 replies.
- Flink using Oozie in Kerberized cluster - posted by "Srivastava,Rajat" <Ra...@cerner.com> on 2019/10/03 19:51:18 UTC, 5 replies.
- Questions about how to use State Processor API - posted by Tony Wei <to...@gmail.com> on 2019/10/04 08:39:50 UTC, 1 replies.
- Re: How to prevent from launching 2 jobs at the same time - posted by Theo Diefenthal <th...@scoop-software.de> on 2019/10/04 10:55:42 UTC, 0 replies.
- Multiple Taskmanagers per node for standalone cluster - posted by Ethan Li <et...@gmail.com> on 2019/10/04 21:02:08 UTC, 0 replies.
- How to write stream data to other Hadoop Cluster by StreamingFileSink - posted by Jun Zhang <82...@qq.com> on 2019/10/05 05:44:59 UTC, 2 replies.
- [ANNOUNCE] Weekly Community Update 2019/40 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/10/06 16:40:02 UTC, 0 replies.
- Difficult to debug reason for checkpoint decline - posted by Daniel Harper <Da...@bbc.co.uk> on 2019/10/07 07:51:29 UTC, 1 replies.
- Re[2]: POJO serialization vs immutability - posted by Протченко Алексей <tv...@mail.ru> on 2019/10/07 14:17:45 UTC, 0 replies.
- Building Flink 1.6.4 fails with "object scala in compiler mirror not found" - posted by "Aikio, Torste" <to...@f-secure.com> on 2019/10/07 15:36:40 UTC, 3 replies.
- Group by multiple fields - posted by Miguel Farrajota <mi...@feedzai.com> on 2019/10/07 15:52:20 UTC, 2 replies.
- kafka offset not working - posted by Benjamin Cuthbert <cu...@gmail.com> on 2019/10/07 15:52:26 UTC, 2 replies.
- [SURVEY] How do people upgrade their Flink applications? - posted by Konstantinos Kallas <ko...@hotmail.com> on 2019/10/07 19:59:30 UTC, 2 replies.
- Kafka producer throws exceptions when publishing a keyed stream - posted by Shahid Chohan <ch...@stripe.com> on 2019/10/07 22:42:34 UTC, 0 replies.
- [QUESTION] How to parallelize with explicit punctuation in Flink? - posted by Filip Niksic <fn...@seas.upenn.edu> on 2019/10/08 00:55:56 UTC, 11 replies.
- Apache Flink Kafka Stream get all messages and stop - posted by "k.leshakov@yandex.ru" <k....@yandex.ru> on 2019/10/08 05:46:08 UTC, 0 replies.
- Computing two aggregate functions on the same window - posted by Frank Wilson <fa...@gmail.com> on 2019/10/08 10:09:21 UTC, 1 replies.
- State & Fault Tolerance in Table API and SQL Implementations - posted by Vaibhav Singh <aw...@gmail.com> on 2019/10/08 10:09:21 UTC, 1 replies.
- Passing parameters to filter function (in DataStreams) - posted by Komal Mariam <ko...@gmail.com> on 2019/10/08 10:46:12 UTC, 3 replies.
- Problem with savepoint deserialization - posted by Steven Nelson <sn...@sourceallies.com> on 2019/10/08 15:17:01 UTC, 5 replies.
- Backpressure tuning/failure - posted by Owen Rees-Hayward <ow...@googlemail.com> on 2019/10/08 16:10:42 UTC, 4 replies.
- Flink restoring a job from a checkpoint - posted by Vishwas Siravara <vs...@gmail.com> on 2019/10/08 16:54:22 UTC, 13 replies.
- flink 1.9 - posted by Vishal Santoshi <vi...@gmail.com> on 2019/10/08 20:47:24 UTC, 7 replies.
- Re: Challenges Deploying Flink With Savepoints On Kubernetes - posted by Yang Wang <da...@gmail.com> on 2019/10/09 03:21:36 UTC, 10 replies.
- Hiding the user Configurations from the flink dashboard - posted by vivekanand yaram <ya...@gmail.com> on 2019/10/09 06:26:32 UTC, 1 replies.
- Best way to pass Program arguments securely in flink 1.8 - posted by vivekanand yaram <ya...@gmail.com> on 2019/10/09 14:36:27 UTC, 1 replies.
- Re: [DISCUSS] Drop Python 2 support for 1.10 - posted by Dian Fu <di...@gmail.com> on 2019/10/10 02:26:49 UTC, 0 replies.
- [SURVEY] How do you use ExternallyInducedSource or WithMasterCheckpointHook - posted by Biao Liu <mm...@gmail.com> on 2019/10/10 04:06:37 UTC, 0 replies.
- about Kafka sink and 2PC function - posted by "121476721@qq.com" <12...@qq.com> on 2019/10/10 05:15:54 UTC, 2 replies.
- Flink metrics reporters documentation - posted by Flavio Pompermaier <po...@okkam.it> on 2019/10/10 08:49:48 UTC, 2 replies.
- Batch Job in a Flink 1.9 Standalone Cluster - posted by Timothy Victor <vi...@gmail.com> on 2019/10/10 11:55:22 UTC, 6 replies.
- Re:Memory constrains running Flink on Kubernetes - posted by shengjk1 <js...@163.com> on 2019/10/10 12:37:42 UTC, 1 replies.
- Difference between windows in Spark and Flink - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/10/10 12:39:59 UTC, 4 replies.
- Async and checkpointing - posted by anurag <an...@gmail.com> on 2019/10/10 18:03:13 UTC, 2 replies.
- Where are uploaded Job jars stored? - posted by John Smith <ja...@gmail.com> on 2019/10/10 18:06:25 UTC, 5 replies.
- Re: Best coding practises guide while programming using flink apis - posted by Yun Tang <my...@live.com> on 2019/10/10 18:30:44 UTC, 0 replies.
- Flink 1.8.0 S3 Checkpoints fail with java.security.ProviderException: Could not initialize NSS - posted by Austin Cawley-Edwards <au...@gmail.com> on 2019/10/10 22:28:52 UTC, 1 replies.
- [PROPOSAL] Contribute Stateful Functions to Apache Flink - posted by Stephan Ewen <se...@apache.org> on 2019/10/11 09:38:04 UTC, 15 replies.
- Re: [DISCUSS] Best practice to run flink on kubernetes - posted by Till Rohrmann <tr...@apache.org> on 2019/10/11 16:20:43 UTC, 0 replies.
- add() method of AggregateFunction not called even though new watermark is emitted - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/10/11 19:37:09 UTC, 6 replies.
- Discard message on deserialization errors. - posted by John Smith <ja...@gmail.com> on 2019/10/11 21:35:28 UTC, 4 replies.
- StreamingFileSink - posted by John O <so...@samsung.com> on 2019/10/11 23:07:03 UTC, 1 replies.
- 【flink sql】table in subquery join temporal table raise java.lang.NullPointerException - posted by hzp <hz...@qq.com> on 2019/10/12 15:31:31 UTC, 2 replies.
- [flink sql] table in subquery join temporal table raise java.lang.NullPointerException - posted by hzp <hz...@qq.com> on 2019/10/12 15:42:01 UTC, 1 replies.
- [ANNOUNCE] Weekly Community Update 2019/41 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/10/13 11:18:43 UTC, 0 replies.
- kafka-json row_time register - posted by as333vvvvv <wp...@icloud.com> on 2019/10/14 09:00:14 UTC, 0 replies.
- FLINK-13497 / "Could not create file for checking if truncate works" / HDFS - posted by Adrian Vasiliu <va...@fr.ibm.com> on 2019/10/14 13:10:11 UTC, 4 replies.
- Fwd: Is it possible to get Flink job name in an operator? - posted by 马阳阳 <ma...@163.com> on 2019/10/15 06:53:38 UTC, 3 replies.
- JDBC Table Sink doesn't seem to sink to database. - posted by John Smith <ja...@gmail.com> on 2019/10/15 19:54:31 UTC, 7 replies.
- Mirror Maker 2.0 cluster and starting from latest offset and other queries - posted by Vishal Santoshi <vi...@gmail.com> on 2019/10/15 20:00:52 UTC, 4 replies.
- Kinesis Connector and Savepoint/Checkpoint restore. - posted by Steven Nelson <sn...@sourceallies.com> on 2019/10/15 20:31:55 UTC, 5 replies.
- Jar Uploads in High Availability (Flink 1.7.2) - posted by "Martin, Nick J [US] (IS)" <Ni...@ngc.com> on 2019/10/15 23:15:03 UTC, 1 replies.
- Verifying correctness of StreamingFileSink (Kafka -> S3) - posted by amran dean <ad...@gmail.com> on 2019/10/16 01:54:24 UTC, 1 replies.
- Elasticsearch6UpsertTableSink how to trigger es delete index。 - posted by ouywl <ou...@139.com> on 2019/10/16 07:25:34 UTC, 1 replies.
- Should I use static database connection pool? - posted by Xin Ma <ke...@gmail.com> on 2019/10/16 14:02:51 UTC, 6 replies.
- Flink State Migration Version 1.8.2 - posted by ApoorvK <ap...@razorpay.com> on 2019/10/16 14:17:40 UTC, 5 replies.
- RE: EXT :Re: Jar Uploads in High Availability (Flink 1.7.2) - posted by "Martin, Nick J [US] (IS)" <Ni...@ngc.com> on 2019/10/16 15:58:21 UTC, 3 replies.
- Consumer group and flink - posted by Vishwas Siravara <vs...@gmail.com> on 2019/10/16 18:40:06 UTC, 1 replies.
- standalone flink savepoint restoration - posted by Matt Anger <ma...@li.me> on 2019/10/16 21:46:25 UTC, 2 replies.
- ElasticSearch failing when parallelised - posted by Nicholas Walton <nw...@me.com> on 2019/10/17 09:19:22 UTC, 0 replies.
- Querying nested JSON stream? - posted by srikanth flink <fl...@gmail.com> on 2019/10/17 13:58:42 UTC, 1 replies.
- currentWatermark for Event Time is not increasing fast enough to go past the window.maxTimestamp - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/10/17 16:47:36 UTC, 0 replies.
- Managing Job Deployments in Production - posted by Peter Groesbeck <pe...@gmail.com> on 2019/10/17 20:21:51 UTC, 0 replies.
- ProcessFunction Timer - posted by Navneeth Krishnan <re...@gmail.com> on 2019/10/17 21:04:07 UTC, 2 replies.
- Data processing with HDFS local or remote - posted by Pritam Sadhukhan <sa...@gmail.com> on 2019/10/18 02:59:40 UTC, 4 replies.
- Flink cluster on k8s with rocksdb state backend - posted by dhanesh arole <da...@gmail.com> on 2019/10/18 04:31:48 UTC, 1 replies.
- Unable to change job manager port when launching session cluster on Docker - posted by "Papadopoulos, Konstantinos" <Ko...@IRIworldwide.com> on 2019/10/18 12:55:25 UTC, 4 replies.
- Flink S3 sink unable to compress data - posted by amran dean <ad...@gmail.com> on 2019/10/18 18:30:18 UTC, 1 replies.
- Customize Part file naming (Flink 1.9.0) - posted by amran dean <ad...@gmail.com> on 2019/10/19 01:53:42 UTC, 2 replies.
- [ANNOUNCE] Apache Flink 1.9.1 released - posted by Jark Wu <im...@gmail.com> on 2019/10/19 13:07:40 UTC, 4 replies.
- Submitting jobs via REST - posted by Timothy Victor <vi...@gmail.com> on 2019/10/19 14:36:27 UTC, 4 replies.
- [ANNOUNCE] Weekly Community Update 2019/42 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/10/20 17:27:39 UTC, 0 replies.
- Configuration Best Practices for Batch Processing - posted by Micah Whitacre <mk...@gmail.com> on 2019/10/20 23:31:23 UTC, 0 replies.
- - posted by Utopia <ge...@gmail.com> on 2019/10/21 05:48:51 UTC, 0 replies.
- multi-tenancy without a kafka partition per tenant - posted by Constantinos Papadopoulos <cp...@gmail.com> on 2019/10/21 07:24:46 UTC, 1 replies.
- Comparing Storm and Flink resource requirements - posted by Gyula Fóra <gy...@gmail.com> on 2019/10/21 12:15:34 UTC, 2 replies.
- Questions about tumbling windows - posted by Wiedo Harkema <Aj...@live.nl> on 2019/10/21 16:05:36 UTC, 0 replies.
- Issue with BulkWriter - posted by amran dean <ad...@gmail.com> on 2019/10/22 02:10:24 UTC, 3 replies.
- Monitor number of keys per Taskmanager - posted by Flavio Pompermaier <po...@okkam.it> on 2019/10/22 08:00:09 UTC, 3 replies.
- Flink grpc-netty-shaded NoClassDefFoundError - posted by dhanesh arole <da...@gmail.com> on 2019/10/22 08:36:46 UTC, 2 replies.
- The RMClient's and YarnResourceManagers internal state about the number of pending container requests has diverged - posted by "Chan, Regina" <Re...@gs.com> on 2019/10/22 16:40:22 UTC, 16 replies.
- RE: Could not load the native RocksDB library - posted by Thad Truman <tt...@neovest.com> on 2019/10/22 17:33:01 UTC, 2 replies.
- [Problem] Unable to do join on TumblingEventTimeWindows using SQL - posted by Manoj Kumar <ma...@bigzetta.com> on 2019/10/23 07:18:00 UTC, 1 replies.
- Problem creating tumbling windows based on number of rows - posted by "A. V." <aa...@live.nl> on 2019/10/23 07:32:36 UTC, 1 replies.
- Docker flink 1.9.1 - posted by Farouk <fa...@gmail.com> on 2019/10/23 12:23:59 UTC, 3 replies.
- How many events can Flink process each second - posted by "A. V." <aa...@live.nl> on 2019/10/23 14:23:47 UTC, 3 replies.
- Flink StreamingFileSink part file behavior - posted by amran dean <ad...@gmail.com> on 2019/10/23 20:39:04 UTC, 1 replies.
- Issue with writeAsText() to S3 bucket - posted by "Nguyen, Michael" <Mi...@T-Mobile.com> on 2019/10/23 20:41:38 UTC, 2 replies.
- How to create an empty test stream - posted by Dmitry Minaev <mi...@gmail.com> on 2019/10/23 21:37:50 UTC, 3 replies.
- Does operator uid() have to be unique across all jobs? - posted by John Smith <ja...@gmail.com> on 2019/10/23 21:42:08 UTC, 11 replies.
- Flink Kafka->S3 exactly once guarantees - posted by amran dean <ad...@gmail.com> on 2019/10/23 22:33:32 UTC, 0 replies.
- Using STSAssumeRoleSessionCredentialsProvider for cross account access - posted by Vinay Patil <vi...@gmail.com> on 2019/10/24 05:31:46 UTC, 3 replies.
- Flink 1.9 measuring time taken by each operator in DataStream API - posted by Komal Mariam <ko...@gmail.com> on 2019/10/24 07:06:27 UTC, 1 replies.
- JDBCInputFormat does not support json type - posted by Fanbin Bu <fa...@coinbase.com> on 2019/10/24 07:36:49 UTC, 2 replies.
- Can a Flink query outputs nested json? - posted by srikanth flink <fl...@gmail.com> on 2019/10/24 10:24:10 UTC, 1 replies.
- Guarantee of event-time order in FlinkKafkaConsumer - posted by Wojciech Indyk <wo...@gmail.com> on 2019/10/24 11:03:09 UTC, 1 replies.
- Flink 1.5+ performance in a Java standalone environment - posted by Jakub Danilewicz <jd...@alto-analytics.com> on 2019/10/24 17:36:51 UTC, 5 replies.
- Can flink 1.9.1 use flink-shaded 2.8.3-1.8.2 - posted by Jeff Zhang <zj...@gmail.com> on 2019/10/25 07:54:08 UTC, 4 replies.
- Tumbling tables in the SQL API - posted by "A. V." <aa...@live.nl> on 2019/10/25 09:53:00 UTC, 0 replies.
- No FileSystem for scheme "file" for S3A in and state processor api in 1.9 - posted by spoganshev <s....@slice.com> on 2019/10/26 21:11:34 UTC, 4 replies.
- Custom Partitioning with keyed state - posted by Heidi Hazem Mohamed <H....@nu.edu.eg> on 2019/10/27 15:03:50 UTC, 1 replies.
- [ANNOUNCE] Weekly Community Update 2019/43 - posted by Konstantin Knauf <ko...@ververica.com> on 2019/10/27 17:00:29 UTC, 0 replies.
- Cannot modify parallelism (rescale job) more than once - posted by Pankaj Chand <pa...@gmail.com> on 2019/10/28 02:45:14 UTC, 2 replies.
- Watermark won't advance in ProcessFunction - posted by 杨力 <bi...@gmail.com> on 2019/10/28 03:59:21 UTC, 5 replies.
- DynamoStreams Consumer millisBehindLatest metric - posted by Vinay Patil <vi...@gmail.com> on 2019/10/28 07:01:47 UTC, 0 replies.
- Complex SQL Queries on Java Streams - posted by Mohammed Tabreaz <md...@gmail.com> on 2019/10/28 07:10:49 UTC, 2 replies.
- Testing AggregateFunction() and ProcessWindowFunction() on KeyedDataStream - posted by "Nguyen, Michael" <Mi...@T-Mobile.com> on 2019/10/28 07:17:52 UTC, 3 replies.
- PreAggregate operator with timeout trigger - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/10/28 09:09:49 UTC, 1 replies.
- Flink 1.8.1 HDFS 2.6.5 issue - posted by "V N, Suchithra (Nokia - IN/Bangalore)" <su...@nokia.com> on 2019/10/28 11:14:15 UTC, 5 replies.
- Add custom fields into Json - posted by srikanth flink <fl...@gmail.com> on 2019/10/29 06:51:17 UTC, 3 replies.
- How to use two continuously window with EventTime in sql - posted by 刘建刚 <li...@gmail.com> on 2019/10/29 07:39:16 UTC, 1 replies.
- [FlinkSQL] is there a way to read/write local json data in Flink SQL like that of kafka? - posted by Anyang Hu <hu...@gmail.com> on 2019/10/29 09:59:51 UTC, 4 replies.
- Streaming File Sink - Parquet File Writer - posted by Vinay Patil <vi...@gmail.com> on 2019/10/29 11:56:57 UTC, 1 replies.
- low performance in running queries - posted by Habib Mostafaei <ha...@inet.tu-berlin.de> on 2019/10/29 13:27:19 UTC, 6 replies.
- How to stream intermediate data that is stored in external storage? - posted by kant kodali <ka...@gmail.com> on 2019/10/29 15:42:05 UTC, 11 replies.
- Flink checkpointing behavior - posted by amran dean <ad...@gmail.com> on 2019/10/29 18:58:47 UTC, 1 replies.
- Flink batch app occasionally hang - posted by Caio Aoque <ca...@gmail.com> on 2019/10/30 00:24:57 UTC, 2 replies.
- flink run jar throw java.lang.ClassNotFoundException: com.mysql.jdbc.Driver - posted by Alex Wang <he...@gmail.com> on 2019/10/30 03:40:36 UTC, 3 replies.
- [DISCUSS] Semantic and implementation of per-job mode - posted by tison <wa...@gmail.com> on 2019/10/30 07:29:58 UTC, 9 replies.
- clear method of Trigger not be called after purge - posted by Utopia <ge...@gmail.com> on 2019/10/30 11:35:44 UTC, 0 replies.
- Sending custom statsd tags - posted by Prakhar Mathur <pr...@gojek.com> on 2019/10/30 11:52:03 UTC, 3 replies.
- Flink S3 error - posted by Harrison Xu <hx...@quora.com> on 2019/10/30 21:23:26 UTC, 1 replies.
- Preserving (best effort) messages order between operators - posted by Averell <lv...@gmail.com> on 2019/10/31 04:56:02 UTC, 0 replies.
- Flink SQL + savepoint - posted by Fanbin Bu <fa...@coinbase.com> on 2019/10/31 05:17:32 UTC, 1 replies.
- Async operator with a KeyedStream - posted by bastien dine <ba...@gmail.com> on 2019/10/31 07:58:29 UTC, 0 replies.
- RemoteEnvironment cannot execute job from local. - posted by Simon Su <ba...@163.com> on 2019/10/31 08:00:43 UTC, 2 replies.
- Re: possible backwards compatibility issue between 1.8->1.9? - posted by Piotr Nowojski <pi...@ververica.com> on 2019/10/31 08:44:46 UTC, 1 replies.
- Are Dynamic tables backed by rocksdb? - posted by kant kodali <ka...@gmail.com> on 2019/10/31 08:50:20 UTC, 1 replies.
- Stateful functions presentation code (UI part) - posted by Flavio Pompermaier <po...@okkam.it> on 2019/10/31 08:52:43 UTC, 6 replies.
- State restoration from checkpoint - posted by Parth Sarathy <pa...@microfocus.com> on 2019/10/31 14:26:26 UTC, 0 replies.