You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Timestamp and key preservation over operators - posted by Averell <lv...@gmail.com> on 2019/05/01 00:24:35 UTC, 7 replies.
- Re: PatternFlatSelectAdapter - Serialization issue after 1.8 upgrade - posted by Oytun Tez <oy...@motaword.com> on 2019/05/01 01:16:43 UTC, 0 replies.
- RE: Can't build Flink for Scala 2.12 - posted by "Visser, M.J.H. (Martijn)" <ma...@ing.com> on 2019/05/01 06:05:56 UTC, 2 replies.
- Ask about running Flink sql-client.sh - posted by Rad Rad <ra...@gmail.com> on 2019/05/01 12:28:35 UTC, 0 replies.
- Ask about Running Flink Jobs From Eclipse - posted by Rad Rad <ra...@gmail.com> on 2019/05/01 12:31:30 UTC, 1 replies.
- Re: Ask about running Flink sql-client.sh - posted by Jeff Zhang <zj...@gmail.com> on 2019/05/01 13:42:52 UTC, 2 replies.
- configuration of standalone cluster - posted by Günter Hipler <gu...@bluewin.ch> on 2019/05/01 19:31:42 UTC, 5 replies.
- Re: Flink - Type Erasure Exception trying to use Tuple6 instead of Tuple - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/05/01 20:39:06 UTC, 1 replies.
- Type Erasure - Usage of class Tuple as a type is not allowed. Use a concrete subclass (e.g. Tuple1, Tuple2, etc. - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/05/01 20:40:39 UTC, 2 replies.
- Re: Preserve accumulators after failure in DataStream API - posted by Fabian Hueske <fh...@gmail.com> on 2019/05/02 07:35:12 UTC, 5 replies.
- Re: Flink dashboard+ program arguments - posted by Fabian Hueske <fh...@gmail.com> on 2019/05/02 07:37:11 UTC, 0 replies.
- Re: Filter push-down not working for a custom BatchTableSource - posted by Fabian Hueske <fh...@gmail.com> on 2019/05/02 07:42:23 UTC, 4 replies.
- Re: HA lock nodes, Checkpoints, and JobGraphs after failure - posted by Till Rohrmann <tr...@apache.org> on 2019/05/02 08:43:14 UTC, 0 replies.
- ClassNotFoundException on remote cluster - posted by Abhishek Jain <ab...@gmail.com> on 2019/05/02 11:38:16 UTC, 4 replies.
- Re: assignTimestampsAndWatermarks not work after KeyedStream.process - posted by an0 <an...@gmail.com> on 2019/05/02 15:48:12 UTC, 4 replies.
- Re: Exceptions when launching counts on a Flink DataSet concurrently - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2019/05/02 15:52:04 UTC, 0 replies.
- Re: Write batch function for apache flink - posted by anurag <an...@gmail.com> on 2019/05/02 19:00:14 UTC, 0 replies.
- DateTimeBucketAssigner using Element Timestamp - posted by Peter Groesbeck <pe...@gmail.com> on 2019/05/02 21:10:52 UTC, 3 replies.
- RocksDB native checkpoint time - posted by Gyula Fóra <gy...@gmail.com> on 2019/05/03 08:30:07 UTC, 5 replies.
- Re: Data loss when restoring from savepoint - posted by Juho Autio <ju...@rovio.com> on 2019/05/03 08:37:32 UTC, 0 replies.
- update the existing Keyed value state - posted by Selvaraj chennappan <se...@gmail.com> on 2019/05/03 09:14:12 UTC, 1 replies.
- Avro SerializationSchema for Confluent Registry - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/05/03 13:09:44 UTC, 0 replies.
- CoProcessFunction vs Temporal Table to enrich multiple streams with a slow stream - posted by Averell <lv...@gmail.com> on 2019/05/03 13:22:48 UTC, 3 replies.
- Re: Avro SerializationSchema for Confluent Registry - posted by Dawid Wysakowicz <dw...@apache.org> on 2019/05/03 13:25:48 UTC, 0 replies.
- Ask about submitting multiple stream jobs to Flink - posted by Rad Rad <ra...@gmail.com> on 2019/05/03 16:20:47 UTC, 0 replies.
- Re: [EXTERNAL] Re: Avro SerializationSchema for Confluent Registry - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/05/03 18:22:05 UTC, 0 replies.
- IllegalArgumentException with CEP & reinterpretAsKeyedStream - posted by Averell <lv...@gmail.com> on 2019/05/05 08:43:33 UTC, 4 replies.
- Unable to build flink from source - posted by syed <ms...@vu.edu.pk> on 2019/05/06 01:20:24 UTC, 3 replies.
- Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May - posted by Robert Metzger <rm...@apache.org> on 2019/05/06 07:44:20 UTC, 2 replies.
- Testing DataSet API's join - posted by "m@xi" <ma...@gmail.com> on 2019/05/06 08:34:21 UTC, 0 replies.
- How to convert protobuf to Row - posted by 刘建刚 <li...@gmail.com> on 2019/05/06 09:26:37 UTC, 0 replies.
- Class loader premature closure - NoClassDefFoundError: org/apache/kafka/clients/NetworkClient - posted by "Slotterback, Chris" <Ch...@comcast.com> on 2019/05/06 14:20:31 UTC, 2 replies.
- writeAsFormattedText sets only Unix/Linux line endings - posted by "Papadopoulos, Konstantinos" <Ko...@IRIworldwide.com> on 2019/05/06 14:31:03 UTC, 2 replies.
- Problem trying to read resource files. - posted by John Smith <ja...@gmail.com> on 2019/05/06 15:26:31 UTC, 0 replies.
- I want to use MapState on an unkeyed stream - posted by an0 <an...@gmail.com> on 2019/05/06 16:52:47 UTC, 8 replies.
- Approach to Auto Scaling Flink Job - posted by Anil <an...@gmail.com> on 2019/05/07 04:47:14 UTC, 7 replies.
- Unsubscribe me - posted by tarush grover <ta...@gmail.com> on 2019/05/07 05:45:47 UTC, 0 replies.
- How to export all not-null keyed ValueState - posted by Averell <lv...@gmail.com> on 2019/05/07 08:16:00 UTC, 9 replies.
- Re: TM occasionally hang in deploying state in Flink 1.5 - posted by qi luo <lu...@gmail.com> on 2019/05/07 09:09:06 UTC, 0 replies.
- flink 1.7 HA production setup going down completely - posted by Manjusha Vuyyuru <vm...@gmail.com> on 2019/05/07 11:46:06 UTC, 6 replies.
- RE: Constant backpressure on flink job - posted by Monika Hristova <mo...@sbtech.com> on 2019/05/07 12:54:35 UTC, 3 replies.
- Flink on YARN: TaskManager heap auto-sizing? - posted by Dylan Adams <dy...@gmail.com> on 2019/05/07 13:28:40 UTC, 2 replies.
- Re: Apache Flink - How to destroy global window and release it's resources - posted by Aljoscha Krettek <al...@apache.org> on 2019/05/07 13:32:11 UTC, 0 replies.
- Migration from flink 1.7.2 to 1.8.0 - posted by Farouk <fa...@gmail.com> on 2019/05/07 15:33:52 UTC, 2 replies.
- Getting async function call terminated with an exception - posted by Avi Levi <av...@bluevoyant.com> on 2019/05/07 18:29:58 UTC, 2 replies.
- Checkpointing and save pointing - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/05/07 19:55:54 UTC, 4 replies.
- Testing with ProcessingTime and FromElementsFunction with TestEnvironment - posted by Steven Nelson <sn...@sourceallies.com> on 2019/05/07 21:48:49 UTC, 3 replies.
- taskmanager.tmp.dirs vs io.tmp.dirs - posted by Flavio Pompermaier <po...@okkam.it> on 2019/05/08 13:31:33 UTC, 3 replies.
- Inconsistent documentation of Table Conditional functions - posted by Flavio Pompermaier <po...@okkam.it> on 2019/05/08 16:02:22 UTC, 3 replies.
- Rich and incrementally aggregating window functions - posted by an0 <an...@gmail.com> on 2019/05/08 21:14:24 UTC, 2 replies.
- Read data from HDFS on Hadoop3 - posted by Soheil Pourbafrani <so...@gmail.com> on 2019/05/08 22:13:01 UTC, 1 replies.
- Reconstruct object through partial select query - posted by shkob1 <sh...@gmail.com> on 2019/05/08 22:36:28 UTC, 8 replies.
- Checkpoint expired before completing with cleanupInRocksdbCompactFilter - posted by Mu Kong <ko...@gmail.com> on 2019/05/09 06:44:16 UTC, 1 replies.
- Re: [Discuss] Add JobListener (hook) in flink job lifecycle - posted by Flavio Pompermaier <po...@okkam.it> on 2019/05/09 08:13:28 UTC, 1 replies.
- Reduce key state - posted by Frank Wilson <fa...@gmail.com> on 2019/05/09 13:01:03 UTC, 1 replies.
- - posted by an0 <an...@gmail.com> on 2019/05/09 15:12:12 UTC, 3 replies.
- Re: Use case for StreamingFileSink: Different parquet writers within the Sink - posted by Kailash Dayanand <kd...@lyft.com> on 2019/05/10 16:27:53 UTC, 0 replies.
- problem with avro serialization - posted by Debasish Ghosh <gh...@gmail.com> on 2019/05/12 13:52:45 UTC, 2 replies.
- how to count kafka sink number - posted by "jszhouchong@163.com" <js...@163.com> on 2019/05/13 05:58:24 UTC, 1 replies.
- Flink and Prometheus setup in K8s - posted by Wouter Zorgdrager <W....@tudelft.nl> on 2019/05/13 12:16:34 UTC, 3 replies.
- AvroSerializer - posted by Debasish Ghosh <gh...@gmail.com> on 2019/05/13 16:50:01 UTC, 4 replies.
- State migration into multiple operators - posted by bastien dine <ba...@gmail.com> on 2019/05/14 07:55:36 UTC, 2 replies.
- Re: Avro state migration using Scala in Flink 1.7.2 (and 1.8) - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/05/14 08:43:09 UTC, 0 replies.
- Received fatal alert: certificate_unknown - posted by PedroMrChaves <pe...@gmail.com> on 2019/05/14 12:43:10 UTC, 2 replies.
- Table program cannot be compiled - posted by shkob1 <sh...@gmail.com> on 2019/05/14 18:23:57 UTC, 6 replies.
- Flink ML Use cases - posted by Abhishek Singh <as...@gmail.com> on 2019/05/14 20:44:53 UTC, 6 replies.
- RichAsyncFunction for Scala? - posted by Shannon Carey <sc...@expedia.com> on 2019/05/14 21:29:35 UTC, 2 replies.
- flink 1.4.2. java.lang.IllegalStateException: Could not initialize operator state backend - posted by anaray <an...@gmail.com> on 2019/05/15 03:43:06 UTC, 3 replies.
- Passing a custom SourceContext to a SourceFunction - posted by Debasish Ghosh <gh...@gmail.com> on 2019/05/15 07:30:07 UTC, 1 replies.
- Checkpoints periodically fail with hdfs as the state backend - Could not flush and close the file system output stream - posted by PedroMrChaves <pe...@gmail.com> on 2019/05/15 12:38:33 UTC, 0 replies.
- FlinkSQL fails when rowtime meets dirty data - posted by maidangdang <ma...@126.com> on 2019/05/15 14:49:49 UTC, 1 replies.
- Re: Migrating Existing TTL State to 1.8 - posted by Andrey Zagrebin <an...@ververica.com> on 2019/05/15 14:53:25 UTC, 1 replies.
- Getting java.lang.BootstrapMethodError: java.lang.NoClassDefFoundError when stopping/canceling job. - posted by John Smith <ja...@gmail.com> on 2019/05/15 14:57:16 UTC, 7 replies.
- NPE in Flink 1.8.0 - posted by Akshay Shinde <ak...@oracle.com> on 2019/05/15 16:07:58 UTC, 1 replies.
- User Interface not showing the actual count received and produced - posted by "PoolakkalMukkath, Shakir" <Sh...@comcast.com> on 2019/05/15 17:43:03 UTC, 1 replies.
- Flink with HBase - posted by Nikhil Goyal <no...@gmail.com> on 2019/05/15 18:17:09 UTC, 1 replies.
- Preventing Late events from getting triggered for custom trigger - posted by shkob1 <sh...@gmail.com> on 2019/05/15 22:29:29 UTC, 0 replies.
- Applying multiple calculation on data aggregated on window - posted by Soheil Pourbafrani <so...@gmail.com> on 2019/05/15 22:46:58 UTC, 1 replies.
- Error While Initializing S3A FileSystem - posted by Manish Bellani <ma...@gmail.com> on 2019/05/15 22:50:43 UTC, 4 replies.
- Re: Checkpoints periodically fail with hdfs as the state backend - Could not flush and close the file system output stream - posted by Andrey Zagrebin <an...@ververica.com> on 2019/05/16 07:46:51 UTC, 6 replies.
- BucketingSink and S3RecoverableWriters - posted by Manish Bellani <ma...@gmail.com> on 2019/05/16 13:36:41 UTC, 0 replies.
- Flink not giving full reason as to why job submission failed - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/05/16 14:04:43 UTC, 6 replies.
- Flink filesystem cepth support - posted by Hai <ha...@magicsoho.com> on 2019/05/16 16:47:27 UTC, 0 replies.
- Generic return type on a user-defined scalar function - posted by Morrisa Brenner <mo...@klaviyo.com> on 2019/05/16 21:18:51 UTC, 3 replies.
- run python job with flink 1.7 - posted by Joshua Fan <jo...@gmail.com> on 2019/05/17 03:47:03 UTC, 1 replies.
- RE: 回复：Memory Allocate/Deallocate related Thread Deadlock encountered when running a large job > 10k tasks - posted by "Narayanaswamy, Krishna" <Kr...@gs.com> on 2019/05/17 09:35:55 UTC, 7 replies.
- Flink 1.8.0: Akka starting actor system with IP address instead of host name - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/05/17 13:05:53 UTC, 0 replies.
- Issue with job crashing due to KinesisProducer - posted by Steven Nelson <sn...@sourceallies.com> on 2019/05/17 13:26:44 UTC, 0 replies.
- FlinkKinesisConsumer not getting data from Kinesis at a constant speed -lag of about 30-55 secs - posted by Vijay Balakrishnan <bv...@gmail.com> on 2019/05/17 15:46:54 UTC, 0 replies.
- Propagating delta from window upon trigger - posted by Nikhil Goyal <no...@gmail.com> on 2019/05/17 21:47:28 UTC, 5 replies.
- Possilby very slow keyBy in program with no parallelism - posted by Theo Diefenthal <th...@scoop-software.de> on 2019/05/19 12:16:41 UTC, 3 replies.
- 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/05/19 18:49:51 UTC, 1 replies.
- Queryable state formal release plan - posted by Praveen Chandna <pr...@ericsson.com> on 2019/05/20 06:08:06 UTC, 1 replies.
- monitor finished files on a Continues Reader - posted by Hanan Yehudai <ha...@radcom.com> on 2019/05/20 07:53:18 UTC, 2 replies.
- Connecting to a service (Eg: Kafka, Cassandra) with different keytabs from the same cluster - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/05/20 08:15:51 UTC, 1 replies.
- questions about yarn container（taskmanager）memory allocation - posted by XiangWei Huang <xw...@gmail.com> on 2019/05/20 08:46:40 UTC, 1 replies.
- Enabling detailed inbound/outbound network queue metrics - posted by Sergii Mykhalchuk <se...@booking.com> on 2019/05/20 12:39:51 UTC, 0 replies.
- [ANNOUNCE] Seattle Flink Meetup at AWS on May 30 - posted by Bowen Li <bo...@gmail.com> on 2019/05/20 16:46:32 UTC, 0 replies.
- Flink vs KStreams - posted by Peter Groesbeck <pe...@gmail.com> on 2019/05/20 22:30:20 UTC, 3 replies.
- Flink cluster log organization - posted by Soheil Pourbafrani <so...@gmail.com> on 2019/05/20 22:56:45 UTC, 1 replies.
- Queryable State race condition or serialization errors? - posted by burgesschen <tc...@bloomberg.net> on 2019/05/21 03:06:21 UTC, 3 replies.
- How to generate a sequential watermark which increases by one unit each time - posted by Averell <lv...@gmail.com> on 2019/05/21 12:37:17 UTC, 1 replies.
- Question regarding date conditions/row expirations on Dynamic Tables - posted by Wayne Heaney <wa...@gmail.com> on 2019/05/21 17:24:10 UTC, 1 replies.
- Flink on mesos - One cluster per job - Version 1.6 - posted by Juan Gentile <j....@criteo.com> on 2019/05/21 20:06:50 UTC, 0 replies.
- Connectors (specifically Kinesis Connector) - posted by Steven Nelson <sn...@sourceallies.com> on 2019/05/21 20:24:25 UTC, 1 replies.
- https://github.com/google/zetasql - posted by kant kodali <ka...@gmail.com> on 2019/05/22 00:55:26 UTC, 0 replies.
- [SURVEY] Usage of flink-ml and [DISCUSS] Delete flink-ml - posted by Shaoxuan Wang <ws...@gmail.com> on 2019/05/22 10:08:29 UTC, 7 replies.
- Count Window Trigger that only fires once - posted by Frank Wilson <fa...@gmail.com> on 2019/05/23 15:13:04 UTC, 1 replies.
- How many task managers to launch for a job? - posted by black chase <ch...@gmail.com> on 2019/05/23 15:41:56 UTC, 7 replies.
- How many task managers can a cluster reasonably handle? - posted by Antonio Verardi <an...@yelp.com> on 2019/05/23 18:33:17 UTC, 1 replies.
- Upgrading from 1.4 to 1.8, losing Kafka consumer state - posted by Nikolas Davis <nd...@newrelic.com> on 2019/05/23 23:50:46 UTC, 2 replies.
- How can i just implement a crontab function using flink? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/05/24 08:20:59 UTC, 2 replies.
- Re: How can i just implement a crontab function using flink? - posted by Puneet Kinra <pu...@customercentria.com> on 2019/05/24 08:32:58 UTC, 1 replies.
- What policies does YARN/Mesos use to distribute TaskManagers across physical machines? - posted by black chase <ch...@gmail.com> on 2019/05/24 09:34:54 UTC, 0 replies.
- [DISCUSS] Proposal to support disk spilling in HeapKeyedStateBackend - posted by Yu Li <ca...@gmail.com> on 2019/05/24 12:50:53 UTC, 1 replies.
- Job crashing cluster - posted by Timothy Victor <vi...@gmail.com> on 2019/05/24 13:47:46 UTC, 2 replies.
- Deploying and managing multiple jobs on EMR - posted by Gustavo Momenté <mo...@gmail.com> on 2019/05/24 21:00:12 UTC, 1 replies.
- Job cluster and HA - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/05/24 21:22:47 UTC, 2 replies.
- How to run Graph algorithms - posted by RAMALINGESWARA RAO THOTTEMPUDI <tr...@iitkgp.ac.in> on 2019/05/25 11:11:22 UTC, 0 replies.
- How can I add config file as classpath in taskmgr node when submitting a flink job? - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/05/25 16:06:15 UTC, 0 replies.
- Replacing AWS credentials provider for S3 filesystem - posted by Rafi Aroch <ra...@gmail.com> on 2019/05/26 11:53:51 UTC, 0 replies.
- Minicluster missing in scala runtime in version 1.8 source code - posted by Ravi Pullareddy <ra...@minlog.com.au> on 2019/05/26 23:02:56 UTC, 3 replies.
- Restore state class not found exception in 1.8 - posted by Lasse Nedergaard <la...@gmail.com> on 2019/05/27 11:52:30 UTC, 3 replies.
- Re: FileInputFormat that processes files in chronological order - posted by spoganshev <s....@slice.com> on 2019/05/27 13:30:30 UTC, 3 replies.
- NullPointerException on StreamTask - posted by bastien dine <ba...@gmail.com> on 2019/05/27 14:16:44 UTC, 1 replies.
- Re: How can I add config file as classpath in taskmgr node when submitting a flink job? - posted by Yang Wang <da...@gmail.com> on 2019/05/28 01:47:30 UTC, 1 replies.
- [External] Flink StreamingFileSink not ingesting to S3 when checkpointing is disabled - posted by Vishal Sharma <vi...@grab.com> on 2019/05/28 02:26:33 UTC, 1 replies.
- Flink 1.8: Job manager redirection not happening in High Availability mode - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/05/28 08:20:36 UTC, 0 replies.
- [ANNOUNCE] Munich meetup: "Let's talk about "Stream Processing with Apache Flink" - posted by Fabian Hueske <fh...@gmail.com> on 2019/05/28 08:43:08 UTC, 0 replies.
- Re: Distributed cache fault - posted by Till Rohrmann <tr...@apache.org> on 2019/05/28 08:53:51 UTC, 0 replies.
- Flink CLI distributed cache fault - posted by Vasyl Bervetskyi <vb...@softserveinc.com> on 2019/05/28 09:40:55 UTC, 0 replies.
- Flink SQL: Execute DELETE queries - posted by "Papadopoulos, Konstantinos" <Ko...@IRIworldwide.com> on 2019/05/28 14:25:15 UTC, 3 replies.
- Re: [External] Re: How many task managers can a cluster reasonably handle? - posted by Antonio Verardi <an...@yelp.com> on 2019/05/28 14:27:59 UTC, 0 replies.
- Building Flink distribution with Scala2.12 - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/05/28 22:37:49 UTC, 2 replies.
- Retention properties for CANCELED/FINISHED jobs - posted by Abdul Qadeer <qu...@gmail.com> on 2019/05/29 07:57:43 UTC, 0 replies.
- count(DISTINCT) in flink SQL - posted by Vinod Mehra <vm...@lyft.com> on 2019/05/29 20:49:29 UTC, 2 replies.
- Re: What are savepoint state manipulation support plans - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/05/30 04:32:07 UTC, 0 replies.
- How to build dependencies and connections between stream jobs? - posted by 徐涛 <ha...@gmail.com> on 2019/05/30 09:38:55 UTC, 0 replies.
- [External] Flink 1.7.1 on EMR metrics - posted by Padarn Wilson <pa...@grab.com> on 2019/05/30 10:20:00 UTC, 2 replies.
- Pipeline TimeOut with Beam SideInput - posted by bj...@gmail.com,
bj...@gmail.com on 2019/05/30 14:12:35 UTC, 0 replies.
- Re: Throttling/effective back-pressure on a Kafka sink - posted by Derek VerLee <de...@gmail.com> on 2019/05/30 17:48:55 UTC, 0 replies.
- Question about Kafka Flink consumer parallelism - posted by wang xuchen <be...@gmail.com> on 2019/05/31 01:48:16 UTC, 0 replies.
- BigQuery source ? - posted by Niels Basjes <Ni...@basjes.nl> on 2019/05/31 08:14:57 UTC, 0 replies.
- Limitations in StreamingFileSink BulkFormat - posted by Ayush Verma <ay...@gmail.com> on 2019/05/31 09:36:21 UTC, 1 replies.
- Re: Working around lack of SQL triggers - posted by deklanw <de...@gmail.com> on 2019/05/31 16:45:38 UTC, 0 replies.