You are viewing a plain text version of this content. The canonical link for it is here.
- Re: Stream in loop and not getting to sink (Parquet writer ) - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/01 06:55:49 UTC, 5 replies.
- Re: Questions about UDTF in flink SQL - posted by wangsan <wa...@163.com> on 2018/12/01 06:56:32 UTC, 0 replies.
- Re: Using FlinkKinesisConsumer through a proxy - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/01 09:19:50 UTC, 0 replies.
- [ANNOUNCE] Call for Presentations Extended for Flink Forward San Francisco 2019 - posted by Fabian Hueske <fh...@gmail.com> on 2018/12/01 11:26:55 UTC, 0 replies.
- Re: Memory does not be released after job cancellation - posted by Nastaran Motavali <N....@son.ir> on 2018/12/01 13:39:30 UTC, 0 replies.
- Re: Dulicated messages in kafka sink topic using flink cancel-with-savepoint operation - posted by Nastaran Motavali <N....@son.ir> on 2018/12/01 13:44:05 UTC, 1 replies.
- Re: [Table API example] Table program cannot be compiled. This is a bug. Please file an issue - posted by Hequn Cheng <ch...@gmail.com> on 2018/12/02 06:35:26 UTC, 1 replies.
- Re: Check-pointing error - posted by Congxian Qiu <qc...@gmail.com> on 2018/12/02 11:56:32 UTC, 0 replies.
- Looking for example for bucketingSink / StreamingFileSink - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/03 10:45:40 UTC, 1 replies.
- Re: flink list and flink run commands timeout - posted by Aneesha Kaushal <an...@reflektion.com> on 2018/12/03 11:10:04 UTC, 2 replies.
- not able to join data coming from kafka - posted by Rakesh Kumar <ra...@gmail.com> on 2018/12/03 11:19:28 UTC, 1 replies.
- Re: Weird behavior in actorSystem shutdown in akka - posted by Till Rohrmann <tr...@apache.org> on 2018/12/03 11:41:56 UTC, 0 replies.
- If you are an expert in flink sql, then I really need your help... - posted by clay4444 <cl...@gmail.com> on 2018/12/03 15:15:12 UTC, 6 replies.
- Flink CEP support pattern match involving fields of previous events - posted by Spico Florin <sp...@gmail.com> on 2018/12/03 15:34:41 UTC, 1 replies.
- CKAN inputFormat (batch) - posted by Flavio Pompermaier <po...@okkam.it> on 2018/12/03 17:01:33 UTC, 3 replies.
- Flink Exception - AmazonS3Exception and ExecutionGraph - Error in failover strategy - posted by Flink Developer <de...@protonmail.com> on 2018/12/03 19:02:10 UTC, 1 replies.
- High Job BackPressure - posted by Sayat Satybaldiyev <st...@gmail.com> on 2018/12/03 19:07:16 UTC, 1 replies.
- FlinkKafkaProducer011 fails when kafka broker crash - posted by 陈卓 <zh...@yirendai.com> on 2018/12/04 03:54:41 UTC, 1 replies.
- Re: long lived standalone job session cluster in kubernetes - posted by Dawid Wysakowicz <dw...@apache.org> on 2018/12/04 09:22:02 UTC, 3 replies.
- AW: number of files in checkpoint directory grows endlessly - posted by Be...@Dev.Helaba.de on 2018/12/04 09:40:24 UTC, 12 replies.
- Using port ranges to connect with the Flink Client - posted by Gyula Fóra <gy...@gmail.com> on 2018/12/04 14:11:47 UTC, 2 replies.
- Over-requesting Containers on YARN - posted by Austin Cawley-Edwards <au...@gmail.com> on 2018/12/04 16:24:53 UTC, 2 replies.
- Query big mssql Data Source [Batch] - posted by miki haiat <mi...@gmail.com> on 2018/12/04 16:31:27 UTC, 7 replies.
- Error deploying task manager after failure in Yarn - posted by Anil <an...@gmail.com> on 2018/12/04 18:15:31 UTC, 0 replies.
- Flink 1.7 job cluster (restore from checkpoint error) - posted by Hao Sun <ha...@zendesk.com> on 2018/12/04 23:29:28 UTC, 4 replies.
- Spring Boot and Apache Flink. - posted by Durga Durga <du...@gmail.com> on 2018/12/04 23:30:11 UTC, 0 replies.
- How to distribute subtasks evenly across taskmanagers? - posted by Sunny Yun <se...@gmail.com> on 2018/12/05 01:07:04 UTC, 1 replies.
- Re:kafka connector[specificStartOffset cannot auto commit offset to zookeeper] - posted by 孙森 <se...@creditease.cn> on 2018/12/05 02:47:48 UTC, 0 replies.
- TTL state migration - posted by Ning Shi <ni...@gmail.com> on 2018/12/05 03:20:02 UTC, 2 replies.
- S3A AWSS3IOException from Flink's BucketingSink to S3 - posted by Flink Developer <de...@protonmail.com> on 2018/12/05 08:44:34 UTC, 2 replies.
- Support for multiple slots per task manager in Flink 1.5 - posted by Pawel Bartoszek <pa...@gmail.com> on 2018/12/05 11:41:19 UTC, 1 replies.
- Assigning a port range to rest.port - posted by Gyula Fóra <gy...@gmail.com> on 2018/12/05 12:04:18 UTC, 4 replies.
- Re: Kafka offset auto-commit stops after timeout - posted by Anil <an...@gmail.com> on 2018/12/05 12:42:29 UTC, 0 replies.
- Is there an example of flink cluster "as a job" deployment on k8s ? - posted by Vishal Santoshi <vi...@gmail.com> on 2018/12/05 21:50:12 UTC, 3 replies.
- NoClassDefFoundError javax.xml.bind.DatatypeConverterImpl - posted by Mike Mintz <mi...@gmail.com> on 2018/12/06 06:13:02 UTC, 1 replies.
- About [FLINK-9740] Support group windows over intervals of months - posted by x1q1j1 <x1...@qq.com> on 2018/12/06 08:25:17 UTC, 0 replies.
- Discuss [FLINK-9740] Support group windows over intervals of months - posted by x1q1j1 <x1...@qq.com> on 2018/12/06 08:45:58 UTC, 1 replies.
- delay one of the datastream when performing join operation on event-time and watermark - posted by Rakesh Kumar <ra...@gmail.com> on 2018/12/06 11:09:58 UTC, 1 replies.
- flink-s3-fs-presto:1.7.0 is missing shaded com/facebook/presto/hadoop - posted by Sergei Poganshev <s....@slice.com> on 2018/12/06 13:03:01 UTC, 1 replies.
- Run simple flink application via "java -jar" - posted by Krishna Kalyan <kr...@zoi.de> on 2018/12/06 13:36:08 UTC, 1 replies.
- Backpressure metrics as JMX Bean - posted by sayat <st...@gmail.com> on 2018/12/06 15:04:06 UTC, 2 replies.
- runtime.resourcemanager - posted by Alieh <sa...@informatik.uni-leipzig.de> on 2018/12/06 16:34:25 UTC, 5 replies.
- A question on the Flink "rolling" FoldFunction - posted by mi...@ubs.com on 2018/12/07 08:12:10 UTC, 1 replies.
- Use event time - posted by mi...@ubs.com on 2018/12/07 08:22:30 UTC, 3 replies.
- Flink with Docker: docker-compose and FLINK_JOB_ARGUMENT exception - posted by Marke Builder <ma...@gmail.com> on 2018/12/07 09:55:07 UTC, 3 replies.
- Failed to resume job from checkpoint - posted by Ben Yan <ya...@gmail.com> on 2018/12/07 10:28:27 UTC, 12 replies.
- [ANNOUNCE] Weekly community update #49 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/07 15:21:31 UTC, 0 replies.
- [SURVEY] Usage of flink-python and flink-streaming-python - posted by Till Rohrmann <tr...@apache.org> on 2018/12/07 15:29:31 UTC, 1 replies.
- Flink Yarn Deployment Issue - 1.7.0 - posted by sohimankotia <so...@gmail.com> on 2018/12/08 17:15:12 UTC, 4 replies.
- Question regarding rescale api - posted by 祁明良 <mq...@xiaohongshu.com> on 2018/12/09 10:20:33 UTC, 2 replies.
- Trying to write to parquet file (kafka as a source) yields thousands of "in progress" files - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/09 12:13:15 UTC, 1 replies.
- Checkpoints replication over data centers synchronized with ZooKeeper in HA mode - posted by "Shimony, Shay " <sh...@citi.com> on 2018/12/09 16:47:20 UTC, 0 replies.
- Flink issue while setting up in Kubernetes - posted by "Thakur, Abhi" <Ab...@netapp.com> on 2018/12/10 06:29:36 UTC, 1 replies.
- Flink 1.7.0 and 1.5.5 - Returning excess container issue - posted by sohimankotia <so...@gmail.com> on 2018/12/10 06:39:13 UTC, 0 replies.
- Flink - excessive amount of yarn container requests for versions > 1.4.0 - posted by sohimankotia <so...@gmail.com> on 2018/12/10 07:27:29 UTC, 0 replies.
- Flink job execution graph hints - posted by Taher Koitawala <ta...@gslab.com> on 2018/12/10 07:34:13 UTC, 0 replies.
- Re: Flink - excessive amount of yarn container requests for versions > 1.4.0 - posted by Shuyi Chen <su...@gmail.com> on 2018/12/10 07:46:12 UTC, 1 replies.
- Error while reading from hadoop sequence file - posted by Akshay Mendole <ak...@gmail.com> on 2018/12/10 12:35:08 UTC, 4 replies.
- [ANNOUNCE] Weekly community update #50 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/10 14:12:51 UTC, 0 replies.
- After job cancel, leftover ZK state prevents job manager startup - posted by Micah Wylde <mw...@lyft.com> on 2018/12/11 04:19:57 UTC, 3 replies.
- Something wrong with the until condition FLINK-CEP - posted by bupt_ljy <bu...@163.com> on 2018/12/11 06:00:20 UTC, 1 replies.
- Very slow checkpoints occasionally occur - posted by Dongwon Kim <ea...@gmail.com> on 2018/12/11 09:26:14 UTC, 5 replies.
- sql program throw exception when new kafka with csv format - posted by Marvin777 <xy...@gmail.com> on 2018/12/11 09:41:23 UTC, 2 replies.
- CodeCache is full - Issues with job deployments - posted by PedroMrChaves <pe...@gmail.com> on 2018/12/11 11:56:50 UTC, 3 replies.
- How many times Flink initialize an operator? - posted by Hao Sun <ha...@zendesk.com> on 2018/12/11 22:01:17 UTC, 2 replies.
- Re: Cannot configure akka.ask.timeout - posted by Alex Vinnik <al...@gmail.com> on 2018/12/11 23:07:35 UTC, 6 replies.
- Singleton in a taskmanager - posted by burgesschen <tc...@bloomberg.net> on 2018/12/12 00:10:57 UTC, 1 replies.
- Question about key group / key state & parallelism - posted by bastien dine <ba...@gmail.com> on 2018/12/12 10:21:10 UTC, 4 replies.
- Connection leak with flink elastic Sink - posted by Vijay Bhaskar <bh...@gmail.com> on 2018/12/12 12:31:38 UTC, 6 replies.
- Flink 1.7 jobmanager tries to lookup taskmanager by its hostname in k8s environment - posted by Sergei Poganshev <s....@slice.com> on 2018/12/12 13:07:43 UTC, 1 replies.
- Flink with Openstack Swift example - posted by Tejash Tarun <te...@gmail.com> on 2018/12/12 13:54:10 UTC, 2 replies.
- Read all json files from a hdfs partition folder - posted by Rakesh Kumar <ra...@gmail.com> on 2018/12/12 14:02:40 UTC, 3 replies.
- Apache Flink CEP how to detect if event did not occur within x seconds? - posted by Spico Florin <sp...@gmail.com> on 2018/12/12 15:24:57 UTC, 5 replies.
- RocksDB "shared" directory on HDFS getting bigger - posted by Dongwon Kim <ea...@gmail.com> on 2018/12/12 18:41:20 UTC, 0 replies.
- Encountered the following Expired Iterator exception in getRecords using FlinkKinesisConsumer - posted by Vijay Balakrishnan <bv...@gmail.com> on 2018/12/12 22:52:53 UTC, 4 replies.
- problem submitting job, it hangs there - posted by Chang Liu <fl...@gmail.com> on 2018/12/13 11:01:16 UTC, 6 replies.
- Setting up FsStateBackend with hdfs storage location - posted by Steven Nelson <sn...@sourceallies.com> on 2018/12/13 21:08:21 UTC, 0 replies.
- SANSA 0.5 (Scalable Semantic Analytics Stack) Released - posted by GezimSejdiu <g....@gmail.com> on 2018/12/14 08:23:04 UTC, 2 replies.
- Generating processing time watermarks in idle event time kafka streams? - posted by William Saar <wi...@saar.se> on 2018/12/14 08:52:39 UTC, 2 replies.
- StreamingFileSink causing AmazonS3Exception - posted by "Hausmann, Steffen" <sh...@amazon.de> on 2018/12/14 13:53:09 UTC, 2 replies.
- TimerService Troubleshooting/Metrics - posted by sayat <st...@gmail.com> on 2018/12/14 15:01:42 UTC, 1 replies.
- Watermark not firing to push data - posted by Vijay Balakrishnan <bv...@gmail.com> on 2018/12/14 16:59:40 UTC, 3 replies.
- Connection time out - DataStream API Tutorial - posted by Brett Marcott <br...@gmail.com> on 2018/12/15 09:38:30 UTC, 3 replies.
- Re: CEP - Support for multiple pattern - posted by "fudian.fd" <fu...@alibaba-inc.com> on 2018/12/17 02:17:39 UTC, 1 replies.
- A problem about flink latency metrics - posted by Lee tinker <li...@gmail.com> on 2018/12/17 03:27:05 UTC, 0 replies.
- Flink metrics in kubernetes deployment - posted by eric hoffmann <si...@gmail.com> on 2018/12/17 17:12:29 UTC, 1 replies.
- Re: Dataset column statistics - posted by Kurt Young <yk...@gmail.com> on 2018/12/18 02:26:09 UTC, 1 replies.
- How to update Flink applications gracefully - posted by Yuta Morisawa <yu...@kddi-research.jp> on 2018/12/18 03:00:09 UTC, 2 replies.
- Need the way to create custom metrics - posted by Gaurav Luthra <ga...@gmail.com> on 2018/12/18 05:29:16 UTC, 2 replies.
- How to migrate Kafka Producer ? - posted by Edward Rojas <ed...@gmail.com> on 2018/12/18 13:33:32 UTC, 2 replies.
- Kafka consumer, is there a way to filter out messages using key only? - posted by Hao Sun <ha...@zendesk.com> on 2018/12/18 19:22:22 UTC, 3 replies.
- Custom S3 endpoint - posted by "Martin, Nick" <Ni...@ngc.com> on 2018/12/18 22:40:27 UTC, 1 replies.
- Custom Metrics in Windowed AggregateFunction - posted by Chirag Dewan <ch...@yahoo.in> on 2018/12/19 03:30:55 UTC, 2 replies.
- question on Flink memory management - posted by Chang Liu <fl...@gmail.com> on 2018/12/19 11:11:08 UTC, 3 replies.
- Flink on Kubernetes (Minikube) - posted by Alexandru Gutan <al...@gmail.com> on 2018/12/19 11:58:26 UTC, 6 replies.
- getting an error when configuring state backend to hdfs - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/19 14:03:53 UTC, 7 replies.
- Question about Flink optimizer on Stream API - posted by Felipe Gutierrez <fe...@gmail.com> on 2018/12/19 14:14:08 UTC, 0 replies.
- Can't list logs or stdout through web console on Flink 1.7 Kubernetes - posted by William Saar <wi...@saar.se> on 2018/12/19 15:40:54 UTC, 3 replies.
- Re: Unbalanced Kafka consumer consumption - posted by Gerard Garcia <ge...@talaia.io> on 2018/12/19 16:38:52 UTC, 1 replies.
- Re: flink operator's latency metrics continues to increase. - posted by Till Rohrmann <tr...@apache.org> on 2018/12/19 16:49:50 UTC, 0 replies.
- Issue with Flink not able to properly read the ResourceManager address for a HA setup - posted by Sai Inampudi <sa...@gmail.com> on 2018/12/19 19:18:17 UTC, 1 replies.
- Flink 1.5 + resource elasticity resulting in overloaded workers - posted by jelmer <jk...@gmail.com> on 2018/12/19 19:26:19 UTC, 2 replies.
- Use s3 on Flink on kubernetes - posted by William Saar <wi...@saar.se> on 2018/12/20 11:08:01 UTC, 0 replies.
- Serious stability issues when running on YARN (Flink 1.7.0) - posted by Gyula Fóra <gy...@gmail.com> on 2018/12/20 13:33:01 UTC, 3 replies.
- How to test window - posted by עדן שרקון <sh...@gmail.com> on 2018/12/20 14:12:04 UTC, 1 replies.
- [ANNOUNCE] Weekly community update #51 - posted by Till Rohrmann <tr...@apache.org> on 2018/12/20 15:40:00 UTC, 0 replies.
- RE: EXT :Re: Custom S3 endpoint - posted by "Martin, Nick" <Ni...@ngc.com> on 2018/12/20 18:12:05 UTC, 0 replies.
- buffer pool is destroyed - posted by "Chan, Shuang " <sh...@credit-suisse.com> on 2018/12/21 03:12:01 UTC, 0 replies.
- Getting "ProducerFenced" exception while using flink kafka producer - posted by Gaurav Luthra <ga...@gmail.com> on 2018/12/21 06:45:42 UTC, 0 replies.
- 回复：buffer pool is destroyed - posted by zhijiang <wa...@aliyun.com> on 2018/12/21 08:40:13 UTC, 1 replies.
- Flink 1.7 doesn't work with Kafka Table Source Descriptors - posted by dhanuka ranasinghe <dh...@gmail.com> on 2018/12/21 10:21:53 UTC, 6 replies.
- Clarification around versioning and flink's state serialization - posted by Padarn Wilson <pa...@grab.com> on 2018/12/21 12:10:49 UTC, 5 replies.
- Re: Data loss when restoring from savepoint - posted by Juho Autio <ju...@rovio.com> on 2018/12/21 12:33:33 UTC, 0 replies.
- HA with HDFS question - posted by Steven Nelson <sn...@sourceallies.com> on 2018/12/21 18:48:25 UTC, 2 replies.
- [ANNOUNCE] Berlin Buzzwords 2019 - Call for Presentations open until Febr. 17th - posted by Fabian Hueske <fh...@gmail.com> on 2018/12/21 20:24:53 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.7.1 released - posted by Chesnay Schepler <ch...@apache.org> on 2018/12/22 19:34:56 UTC, 2 replies.
- Connecting to kafka with tls - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/23 10:02:10 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.6.3 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/12/23 13:35:42 UTC, 4 replies.
- Running Flink on Yarn - posted by Anil <an...@gmail.com> on 2018/12/23 18:35:36 UTC, 5 replies.
- Iterations and back pressure problem - posted by Sergei Poganshev <s....@slice.com> on 2018/12/24 16:16:22 UTC, 2 replies.
- getting Timeout expired while fetching topic metadata - posted by Avi Levi <av...@bluevoyant.com> on 2018/12/24 18:19:33 UTC, 2 replies.
- Unable to serialize org.apache.kafka.common.config.types.Password - posted by tao xiao <xi...@gmail.com> on 2018/12/25 15:04:47 UTC, 2 replies.
- no log exists in JM and TM when updated to Flink 1.7 - posted by Joshua Fan <jo...@gmail.com> on 2018/12/26 10:18:44 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.5.6 released - posted by Thomas Weise <th...@apache.org> on 2018/12/26 20:03:33 UTC, 5 replies.
- Row format or bulk format - posted by Taher Koitawala <ta...@gslab.com> on 2018/12/27 09:23:41 UTC, 1 replies.
- Flink SQL client always cost 2 minutes to submit job to a local cluster - posted by "yinhua.dai" <yi...@outlook.com> on 2018/12/28 03:52:43 UTC, 2 replies.
- Access Flink configuration in user functions - posted by Paul Lam <pa...@gmail.com> on 2018/12/28 04:56:21 UTC, 1 replies.
- Timestamp conversion problem in Flink Table/SQL - posted by jia yichao <yc...@qq.com> on 2018/12/28 07:14:54 UTC, 1 replies.
- How to shut down Flink Web Dashboard in detached Yarn session? - posted by Sai Inampudi <sa...@gmail.com> on 2018/12/28 20:42:13 UTC, 3 replies.
- When could flink 1.7.1 be downloaded from maven repository - posted by 徐涛 <ha...@gmail.com> on 2018/12/29 01:33:38 UTC, 1 replies.
- Flink HA setup on Kubernetes - posted by Steven Nelson <sn...@sourceallies.com> on 2018/12/31 16:52:14 UTC, 0 replies.