user@flink.apache.org, 2019-02

You are viewing a plain text version of this content. The canonical link for it is here.

- Videos and slides on Flink Forward Beijing - posted by Paul Lam <pa...@gmail.com> on 2019/02/01 07:18:40 UTC, 3 replies.
- Get UnknownTaskExecutorException when I add a new configuration in flink-conf.yaml - posted by "yinhua.dai" <yi...@outlook.com> on 2019/02/01 07:55:42 UTC, 0 replies.
- Table API zipWithIndex - posted by Flavio Pompermaier <po...@okkam.it> on 2019/02/01 10:16:35 UTC, 2 replies.
- Submit a job to a remote cluster : RemoteEnvironnement or ClientLevel ? - posted by bastien dine <ba...@gmail.com> on 2019/02/01 11:41:02 UTC, 0 replies.
- Re: Writing a custom Rocksdb statistics collector - posted by Yun Tang <my...@live.com> on 2019/02/01 13:37:30 UTC, 0 replies.
- Add header to a file produced using the writeAsFormattedText method - posted by "Papadopoulos, Konstantinos" <Ko...@IRIworldwide.com> on 2019/02/01 15:04:36 UTC, 3 replies.
- Reverse of KeyBy - posted by "Aggarwal, Ajay" <Aj...@netapp.com> on 2019/02/01 21:42:39 UTC, 6 replies.
- Version "Unknown" - Flink 1.7.0 - posted by anaray <an...@gmail.com> on 2019/02/01 23:45:00 UTC, 2 replies.
- Is the order guaranteed with Windowall - posted by mo...@gmail.com, mo...@gmail.com on 2019/02/02 16:11:17 UTC, 4 replies.
- Test harness for CoProcessFunction outputting Protobuf messages - posted by Alexey Trenikhun <ye...@msn.com> on 2019/02/02 18:39:23 UTC, 3 replies.
- Re: How to load multiple same-format files with single batch job? - posted by françois lacombe <fr...@dcbrain.com> on 2019/02/04 11:06:28 UTC, 5 replies.
- How to add caching to async function? - posted by William Saar <wi...@saar.se> on 2019/02/04 16:59:42 UTC, 5 replies.
- Regarding json/xml/csv file splitting - posted by madan <ma...@gmail.com> on 2019/02/04 17:12:04 UTC, 1 replies.
- Re: Gelly Scatter-Gather Iteration, In a single superstep, GatherFunction.updateVertex invoked more then once - posted by Greg Hogan <co...@greghogan.com> on 2019/02/04 18:03:38 UTC, 0 replies.
- KakfaConsumer - posted by Vishal Santoshi <vi...@gmail.com> on 2019/02/04 23:31:39 UTC, 3 replies.
- Re: AssertionError: mismatched type $5 TIMESTAMP(3) - posted by Chris Miller <ch...@gmail.com> on 2019/02/05 10:30:06 UTC, 2 replies.
- Endorsed lib in Flink - posted by Chirag Dewan <ch...@yahoo.in> on 2019/02/05 12:02:35 UTC, 1 replies.
- Re: Dataset column statistics - posted by Flavio Pompermaier <po...@okkam.it> on 2019/02/05 13:04:51 UTC, 0 replies.
- late element and expired state - posted by "Aggarwal, Ajay" <Aj...@netapp.com> on 2019/02/05 14:54:42 UTC, 2 replies.
- Running JobManager as Deployment instead of Job - posted by Sergey Belikov <be...@gmail.com> on 2019/02/05 15:11:52 UTC, 5 replies.
- Kafka Sinking from DataSet - posted by Jonny Graham <Jo...@niceactimize.com> on 2019/02/05 15:22:51 UTC, 0 replies.
- H-A Deployment : Job / task manager configuration - posted by bastien dine <ba...@gmail.com> on 2019/02/05 15:59:24 UTC, 1 replies.
- What async Scala HTTP client do people use with Flink async functions? - posted by William Saar <wi...@saar.se> on 2019/02/05 16:43:52 UTC, 0 replies.
- 1.7.1 and hadoop pre 2.7 - posted by Vishal Santoshi <vi...@gmail.com> on 2019/02/05 21:21:08 UTC, 0 replies.
- JDBCAppendTableSink on Data stream - posted by Chirag Dewan <ch...@yahoo.in> on 2019/02/06 06:29:52 UTC, 1 replies.
- Exactly Once Guarantees with StreamingFileSink to S3 - posted by Kaustubh Rudrawar <ka...@box.com> on 2019/02/06 06:47:02 UTC, 3 replies.
- graceful shutdown of taskmanager - posted by Be...@Dev.Helaba.de on 2019/02/06 10:54:08 UTC, 1 replies.
- Re: No resource available error while testing HA - posted by Gary Yao <ga...@da-platform.com> on 2019/02/06 11:04:56 UTC, 4 replies.
- Get nested Rows from Json string - posted by françois lacombe <fr...@dcbrain.com> on 2019/02/06 11:06:04 UTC, 4 replies.
- Using custom evictor and trigger on Table API - posted by eastcirclek <ea...@gmail.com> on 2019/02/06 12:14:43 UTC, 1 replies.
- HA HDFS - posted by Steven Nelson <sn...@sourceallies.com> on 2019/02/06 18:47:22 UTC, 3 replies.
- Avro serialization and deserialization to Kafka in Scala - posted by Wouter Zorgdrager <W....@tudelft.nl> on 2019/02/07 10:04:22 UTC, 1 replies.
- How to use ExceptionUtils.findThrowable() in Scala - posted by Averell <lv...@gmail.com> on 2019/02/07 10:49:05 UTC, 1 replies.
- Flink and S3 AWS keys rotation - posted by Antonio Verardi <an...@yelp.com> on 2019/02/07 12:32:10 UTC, 2 replies.
- Re: [External] Re: Flink and S3 AWS keys rotation - posted by Antonio Verardi <an...@yelp.com> on 2019/02/07 15:27:57 UTC, 0 replies.
- stream of large objects - posted by "Aggarwal, Ajay" <Aj...@netapp.com> on 2019/02/07 19:37:38 UTC, 6 replies.
- Flink Job and Watermarking - posted by Kaustubh Rudrawar <ka...@box.com> on 2019/02/08 02:19:56 UTC, 1 replies.
- Re: MapState - TypeSerializer - posted by Alexey Trenikhun <ye...@msn.com> on 2019/02/08 02:38:51 UTC, 4 replies.
- Couldn't figure out - How to do this in Flink? - Pls assist with suggestions - posted by Titus Rakkesh <ti...@gmail.com> on 2019/02/08 06:43:33 UTC, 2 replies.
- Sliding window buffering on restart without save point - posted by shater93 <wi...@niradynamics.se> on 2019/02/08 08:52:18 UTC, 1 replies.
- Dataset statistics - posted by Flavio Pompermaier <po...@okkam.it> on 2019/02/08 09:35:53 UTC, 2 replies.
- Running single Flink job in a job cluster, problem starting JobManager - posted by Thomas Eckestad <Th...@verisure.com> on 2019/02/08 11:14:39 UTC, 3 replies.
- Reduce one event under multiple keys - posted by Stephen Connolly <st...@gmail.com> on 2019/02/08 12:21:46 UTC, 6 replies.
- Flink Standalone cluster - logging problem - posted by simpleusr <ce...@gmail.com> on 2019/02/08 14:06:12 UTC, 7 replies.
- Flink Standalone cluster - dumps - posted by simpleusr <ce...@gmail.com> on 2019/02/08 14:06:51 UTC, 2 replies.
- Flink Standalone cluster - production settings - posted by simpleusr <ce...@gmail.com> on 2019/02/08 14:07:28 UTC, 3 replies.
- Broadcast state before events stream consumption - posted by Vadim Vararu <va...@adswizz.com> on 2019/02/08 14:15:22 UTC, 6 replies.
- Help with a stream processing use case - posted by "Sandybayev, Turar (CAI - Atlanta)" <Tu...@coxautoinc.com> on 2019/02/08 15:43:13 UTC, 2 replies.
- [Table] Types of query result and tablesink do not match error - posted by françois lacombe <fr...@dcbrain.com> on 2019/02/08 16:58:54 UTC, 1 replies.
- Can an Aggregate the key from a WindowedStream.aggregate() - posted by st...@gmail.com, st...@gmail.com on 2019/02/08 17:24:10 UTC, 3 replies.
- Re: long lived standalone job session cluster in kubernetes - posted by Heath Albritton <ha...@harm.org> on 2019/02/08 19:49:55 UTC, 5 replies.
- Per-workflow configurations for an S3-related property - posted by Ken Krugler <kk...@transpac.com> on 2019/02/08 22:18:22 UTC, 0 replies.
- ElasticSearchSink - retrying doesn't work in ActionRequestFailureHandler - posted by Averell <lv...@gmail.com> on 2019/02/09 07:27:27 UTC, 9 replies.
- fllink 1.7.1 and RollingFileSink - posted by Vishal Santoshi <vi...@gmail.com> on 2019/02/10 15:12:52 UTC, 10 replies.
- Is there a windowing strategy that allows a different offset per key? - posted by Stephen Connolly <st...@gmail.com> on 2019/02/10 19:55:48 UTC, 4 replies.
- Flink 1.7 Notebook Environment - posted by Faizan Ahmed <ah...@gmail.com> on 2019/02/11 03:43:44 UTC, 1 replies.
- Anyone tried to do blue-green topology deployments? - posted by Stephen Connolly <st...@gmail.com> on 2019/02/11 13:26:04 UTC, 3 replies.
- Flink Job sometimes does not stop as expected on cancelling. - posted by Mahantesh Patil <ma...@gmail.com> on 2019/02/11 23:50:14 UTC, 1 replies.
- Dynamic Rules Creation For Flink CEP - posted by Titus Rakkesh <ti...@gmail.com> on 2019/02/12 01:32:46 UTC, 2 replies.
- Frequent Heartbeat timeout - posted by sohimankotia <so...@gmail.com> on 2019/02/12 04:34:52 UTC, 0 replies.
- Limit in batch flink sql job - posted by "yinhua.dai" <yi...@outlook.com> on 2019/02/12 06:01:57 UTC, 3 replies.
- error while querying state - posted by yuvraj singh <19...@gmail.com> on 2019/02/12 09:36:59 UTC, 1 replies.
- [ANNOUNCE] New Flink PMC member Thomas Weise - posted by Fabian Hueske <fh...@apache.org> on 2019/02/12 09:59:12 UTC, 17 replies.
- Program of Flink Forward San Francisco 2019 announced - posted by Fabian Hueske <fh...@apache.org> on 2019/02/12 15:26:16 UTC, 1 replies.
- In-Memory state serialization with kryo fails - posted by Rinat <r....@cleverdata.ru> on 2019/02/12 18:56:27 UTC, 2 replies.
- How to register TypeInfoFactory for 'external' class - posted by Alexey Trenikhun <ye...@msn.com> on 2019/02/13 00:28:58 UTC, 2 replies.
- Flink 1.6 Yarn Session behavior - posted by Jins George <Ji...@aeris.net> on 2019/02/13 00:33:02 UTC, 5 replies.
- ProducerFencedException when running 2 jobs with FlinkKafkaProducer - posted by "Slotterback, Chris" <Ch...@comcast.com> on 2019/02/13 01:15:08 UTC, 3 replies.
- Using RemoteExecutionEnvironment from IDE - posted by Benjamin Burkhardt <pr...@benjaminburkhardt.de> on 2019/02/13 11:15:13 UTC, 4 replies.
- [DISCUSS] Adding a mid-term roadmap to the Flink website - posted by Stephan Ewen <se...@apache.org> on 2019/02/13 11:21:11 UTC, 18 replies.
- Re: Data loss when restoring from savepoint - posted by Juho Autio <ju...@rovio.com> on 2019/02/13 13:37:04 UTC, 5 replies.
- Production readiness - posted by Avi Levi <av...@bluevoyant.com> on 2019/02/13 15:57:45 UTC, 4 replies.
- Impact of occasional big pauses in stream processing - posted by "Aggarwal, Ajay" <Aj...@netapp.com> on 2019/02/13 16:50:34 UTC, 5 replies.
- flink restoring from state - posted by Avi Levi <av...@bluevoyant.com> on 2019/02/14 00:19:50 UTC, 2 replies.
- How to clear state immediately after a keyed window is processed? - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/02/14 10:53:17 UTC, 3 replies.
- Flink DataStream: A few dates are getting through very slowly - posted by Marke Builder <ma...@gmail.com> on 2019/02/14 12:20:13 UTC, 1 replies.
- TaskManager gets confused after the JobManager restarts - posted by Ethan Li <et...@gmail.com> on 2019/02/14 15:40:33 UTC, 3 replies.
- Synchronize reading from two Kafka Topics of different size - posted by Olle Noren <ol...@niradynamics.se> on 2019/02/14 16:37:22 UTC, 1 replies.
- StandAlone job on k8s fails with "Unknown method truncate" on restore - posted by Vishal Santoshi <vi...@gmail.com> on 2019/02/14 18:42:11 UTC, 5 replies.
- [ANNOUNCEMENT] March 2019 Bay Area Apache Flink Meetup - posted by Xuefu Zhang <xu...@apache.org> on 2019/02/15 00:32:18 UTC, 0 replies.
- Re: Linkage error when using DropwizardMeterWrapper - posted by shkob1 <sh...@gmail.com> on 2019/02/15 01:34:25 UTC, 0 replies.
- Window elements for certain period for delayed processing - posted by simpleusr <ce...@gmail.com> on 2019/02/15 05:15:50 UTC, 3 replies.
- Incorrect Javadoc in CheckpointedFunction.java? - posted by Chirag Dewan <ch...@yahoo.in> on 2019/02/15 05:31:04 UTC, 1 replies.
- [flink-cep] - What is the difference between GroupPattern and Pattern? - posted by bupt_ljy <bu...@163.com> on 2019/02/15 08:10:48 UTC, 1 replies.
- Test FileUtilsTest.testDeleteDirectory failed when building Flink - posted by Paul Lam <pa...@gmail.com> on 2019/02/15 08:50:27 UTC, 3 replies.
- Re: KafkaTopicPartition internal class treated as generic type serialization - posted by Eric Troies <er...@gmail.com> on 2019/02/15 10:08:17 UTC, 1 replies.
- [flink :: connected-streams :: integration-tests] - posted by Rinat <r....@cleverdata.ru> on 2019/02/15 11:36:02 UTC, 1 replies.
- [Meetup] Apache Flink+Beam+others in Seattle. Feb 21. - posted by Pablo Estrada <pa...@google.com> on 2019/02/15 19:42:05 UTC, 1 replies.
- read a finite number of messages from Kafka using Kafka connector without extending it? - posted by Yu Yang <yu...@gmail.com> on 2019/02/16 00:10:35 UTC, 1 replies.
- Is group.id required in Kafka connector for offsets to be stored in checkpoint? - posted by David Corley <da...@gmail.com> on 2019/02/16 23:54:02 UTC, 3 replies.
- flink submit job rest api classpath jar - posted by WeiWen Fan <yu...@gmail.com> on 2019/02/17 13:23:07 UTC, 1 replies.
- Reading messages from start - new job submission - posted by Avi Levi <av...@bluevoyant.com> on 2019/02/17 17:15:29 UTC, 4 replies.
- Jira issue Flink-11127 - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/02/17 20:51:50 UTC, 9 replies.
- Starting Flink cluster and running a job - posted by Boris Lublinsky <bo...@lightbend.com> on 2019/02/18 00:07:36 UTC, 15 replies.
- [ANNOUNCE] Apache Flink 1.7.2 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2019/02/18 02:29:26 UTC, 5 replies.
- Re: StreamingFileSink causing AmazonS3Exception - posted by Padarn Wilson <pa...@grab.com> on 2019/02/18 02:48:28 UTC, 2 replies.
- Each yarn container only use 1 vcore even if taskmanager.numberOfTaskSlots is set - posted by 徐涛 <ha...@gmail.com> on 2019/02/18 02:49:24 UTC, 0 replies.
- Confusion in Heartbeat configurations - posted by sohimankotia <so...@gmail.com> on 2019/02/18 06:40:17 UTC, 2 replies.
- Re: Each yarn container only use 1 vcore even if taskmanager.numberOfTaskSlots is set - posted by Gary Yao <ga...@ververica.com> on 2019/02/18 06:48:16 UTC, 0 replies.
- Submitting job to Flink on yarn timesout on flip-6 1.5.x - posted by Richard Deurwaarder <ri...@xeli.eu> on 2019/02/18 10:59:43 UTC, 3 replies.
- Dataset sampling - posted by Flavio Pompermaier <po...@okkam.it> on 2019/02/18 14:44:32 UTC, 1 replies.
- Flink Streaming Job with OutputFormat stops without error message - posted by Marke Builder <ma...@gmail.com> on 2019/02/18 18:36:25 UTC, 0 replies.
- subscribe - posted by Artur Mrozowski <ar...@gmail.com> on 2019/02/18 19:34:01 UTC, 2 replies.
- The submitting is hanging when register a hdfs file as registerCacheFile in 1.7 based on RestClusterClient - posted by Joshua Fan <jo...@gmail.com> on 2019/02/19 02:54:40 UTC, 0 replies.
- How to use my custom log4j.properties when running minicluster in idea - posted by peibin wang <wa...@gmail.com> on 2019/02/19 04:04:34 UTC, 1 replies.
- Stream enrichment with static data, side inputs for DataStream - posted by Artur Mrozowski <ar...@gmail.com> on 2019/02/19 10:02:55 UTC, 2 replies.
- How to debug difference between Kinesis and Kafka - posted by Stephen Connolly <st...@gmail.com> on 2019/02/19 11:14:41 UTC, 9 replies.
- FLIP-16, FLIP-15 Status Updates? - posted by John Tipper <jo...@hotmail.com> on 2019/02/19 11:47:15 UTC, 4 replies.
- BucketingSink - Could not invoke truncate while recovering from state - posted by sohimankotia <so...@gmail.com> on 2019/02/19 12:44:01 UTC, 1 replies.
- RE: EXT :Re: How to debug difference between Kinesis and Kafka - posted by "Martin, Nick" <Ni...@ngc.com> on 2019/02/19 15:59:21 UTC, 2 replies.
- Metrics for number of "open windows"? - posted by Andrew Roberts <ar...@fuze.com> on 2019/02/19 20:14:18 UTC, 3 replies.
- Assigning timestamps and watermarks several times, several datastreams? - posted by Aakarsh Madhavan <aa...@uber.com> on 2019/02/19 22:33:52 UTC, 1 replies.
- Can I make an Elasticsearch Sink effectively exactly once? - posted by Stephen Connolly <st...@gmail.com> on 2019/02/21 13:26:08 UTC, 1 replies.
- Docker using flink socketwordcount example - posted by Samet Yılmaz <yi...@gmail.com> on 2019/02/21 13:57:09 UTC, 0 replies.
- Why don't Tuple types implement Comparable? - posted by Frank Grimes <fr...@yahoo.com> on 2019/02/21 18:29:16 UTC, 3 replies.
- Is there a Flink DataSet equivalent to Spark's RDD.persist? - posted by Frank Grimes <fr...@yahoo.com> on 2019/02/21 18:41:21 UTC, 1 replies.
- SinkFunction.Context - posted by Durga Durga <du...@gmail.com> on 2019/02/22 00:59:36 UTC, 2 replies.
- Flink 1.6.1 Kerberos configuration - posted by Marke Builder <ma...@gmail.com> on 2019/02/22 08:28:50 UTC, 1 replies.
- Calculating over multiple streams... - posted by Oytun Tez <oy...@motaword.com> on 2019/02/22 16:15:36 UTC, 2 replies.
- Re: Flink Streaming Job Task is getting cancelled silently and causing job to restart - posted by sohimankotia <so...@gmail.com> on 2019/02/24 03:14:54 UTC, 5 replies.
- Share broadcast state between multiple operators - posted by Richard Deurwaarder <ri...@xeli.eu> on 2019/02/25 10:45:08 UTC, 3 replies.
- Re: Standalone HA cluster: Fatal error occurred in the cluster entrypoint. - posted by Alexander Smirnov <al...@gmail.com> on 2019/02/25 15:15:20 UTC, 0 replies.
- Flink 1.6.4 signing key file in docker-flink repo? - posted by William Saar <wi...@saar.se> on 2019/02/25 16:15:49 UTC, 1 replies.
- left join failing with FlinkLogicalJoinConverter NPE - posted by Karl Jin <ka...@gmail.com> on 2019/02/25 21:35:33 UTC, 6 replies.
- Flink window triggering and timing on connected streams - posted by Andrew Roberts <ar...@fuze.com> on 2019/02/25 21:54:09 UTC, 4 replies.
- StreamingFileSink on EMR - posted by "Bohinski, Kevin (Contractor)" <Ke...@comcast.com> on 2019/02/25 23:15:30 UTC, 10 replies.
- What are blobstore files and why do they keep filling up /tmp directory? - posted by "Kumar Bolar, Harshith" <hk...@arity.com> on 2019/02/26 01:48:31 UTC, 6 replies.
- Collapsing watermarks after keyby - posted by Padarn Wilson <pa...@gmail.com> on 2019/02/26 01:53:22 UTC, 6 replies.
- cast from bigdecimal to bigint throws ArithmeticException - posted by 徐涛 <ha...@gmail.com> on 2019/02/26 02:14:25 UTC, 2 replies.
- - posted by "Chua, Jace D." <ja...@amazon.com> on 2019/02/26 03:47:14 UTC, 0 replies.
- Sftp source in flink - posted by Siew Wai Yow <wa...@hotmail.com> on 2019/02/26 15:39:00 UTC, 0 replies.
- Reducing the number of unique metrics - posted by shkob1 <sh...@gmail.com> on 2019/02/26 20:02:29 UTC, 0 replies.
- One source is much slower than the other side when join history data - posted by 刘建刚 <li...@gmail.com> on 2019/02/27 02:02:46 UTC, 2 replies.
- ProgramInvocationException when I submit job by 'flink run' after running Flink stand-alone more than 1 month? - posted by Son Mai <ho...@gmail.com> on 2019/02/27 02:27:17 UTC, 2 replies.
- okio and okhttp not shaded in the Flink Uber Jar on EMR - posted by Austin Cawley-Edwards <au...@gmail.com> on 2019/02/27 03:59:21 UTC, 6 replies.
- Errors running user jars with flink in docker flink x - posted by Paroma Sengupta <p....@gmail.com> on 2019/02/27 06:19:14 UTC, 1 replies.
- Re: flink list and flink run commands timeout - posted by sen <se...@163.com> on 2019/02/27 06:54:58 UTC, 1 replies.
- submit job failed on Yarn HA - posted by 孙森 <se...@163.com> on 2019/02/27 07:09:07 UTC, 6 replies.
- Split Stream on a Split Stream - posted by Taher Koitawala <ta...@gslab.com> on 2019/02/27 07:35:48 UTC, 2 replies.
- How to add unit test for flink sql ? - posted by Lifei Chen <hu...@gmail.com> on 2019/02/27 08:19:54 UTC, 4 replies.
- KeyBy distribution across taskslots - posted by "Aggarwal, Ajay" <Aj...@netapp.com> on 2019/02/27 16:23:38 UTC, 2 replies.
- event time & watermarks in connected streams with broadcast state - posted by Rinat <r....@cleverdata.ru> on 2019/02/27 20:31:57 UTC, 2 replies.
- Flink performance drops when async checkpoint is slow - posted by Paul Lam <pa...@gmail.com> on 2019/02/28 07:17:16 UTC, 2 replies.
- Two Kubernetes clusters and one Flink cluster? - posted by Thomas Eckestad <Th...@verisure.com> on 2019/02/28 08:46:42 UTC, 0 replies.
- Re: Breakage in Flink CLI in 1.5.0 - posted by sen <se...@163.com> on 2019/02/28 09:24:24 UTC, 0 replies.
- Checkpoints and catch-up burst (heavy back pressure) - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2019/02/28 09:25:31 UTC, 3 replies.
- Setting source vs sink vs window parallelism with data increase - posted by Padarn Wilson <pa...@gmail.com> on 2019/02/28 09:50:20 UTC, 0 replies.
- How do I compute the average and keep track of a state over a window in DataStream? - posted by Felipe Gutierrez <fe...@gmail.com> on 2019/02/28 14:46:44 UTC, 0 replies.
- Flink Kinesis Consumer - posted by Steven Nelson <sn...@sourceallies.com> on 2019/02/28 20:57:34 UTC, 0 replies.