user@flink.apache.org, 2018-02

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

- Flink on YARN || Monitoring REST API Not Working || Please help - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/02/01 02:36:04 UTC, 1 replies.
- Re: [EXTERNAL] Re: Flink on YARN || Monitoring REST API Not Working || Please help - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/02/01 03:24:14 UTC, 0 replies.
- How to enable “upsert mode” for dynamic tables? - posted by Austin York <ay...@gmail.com> on 2018/02/01 04:25:16 UTC, 3 replies.
- JobManager doesn't recover in HA mode - posted by Mu Kong <ko...@gmail.com> on 2018/02/01 06:11:08 UTC, 3 replies.
- queryable state API - posted by Maciek Próchniak <mp...@touk.pl> on 2018/02/01 08:19:51 UTC, 1 replies.
- RE: S3 for state backend in Flink 1.4.0 - posted by "Marchant, Hayden " <ha...@citi.com> on 2018/02/01 08:21:45 UTC, 2 replies.
- Re: Maintain heavy hitters in Flink application - posted by "m@xi" <ma...@gmail.com> on 2018/02/01 08:31:24 UTC, 2 replies.
- Re: Managed operator state treating state of all parallel operators as the same - posted by "m@xi" <ma...@gmail.com> on 2018/02/01 08:45:25 UTC, 0 replies.
- Reading bounded data from Kafka in Flink job - posted by "Marchant, Hayden " <ha...@citi.com> on 2018/02/01 10:42:17 UTC, 1 replies.
- Re: How does BucketingSink generate a SUCCESS file when a directory is finished - posted by Kien Truong <du...@gmail.com> on 2018/02/01 12:06:11 UTC, 7 replies.
- RE: Multiple Elasticsearch sinks not working in Flink - posted by Teena Kappen // BPRISE <te...@bprise.com> on 2018/02/01 13:42:20 UTC, 2 replies.
- Latest version of Kafka - posted by "Marchant, Hayden " <ha...@citi.com> on 2018/02/01 13:46:51 UTC, 2 replies.
- How to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job ? - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2018/02/01 15:23:11 UTC, 1 replies.
- Extending Flink Slots when running on Yarn - posted by Julio Biason <ju...@azion.com> on 2018/02/01 16:09:16 UTC, 1 replies.
- Get the JobID when Flink job fails - posted by Vinay Patil <vi...@gmail.com> on 2018/02/01 19:50:29 UTC, 3 replies.
- Re: Flink on K8s job submission best practices - posted by Christophe Jolif <cj...@gmail.com> on 2018/02/01 20:22:17 UTC, 0 replies.
- Flink on AWS EMR - how to use flink-log4j configuration? - posted by Ishwara Varnasi <iv...@gmail.com> on 2018/02/01 20:27:02 UTC, 0 replies.
- Flink REST API - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/02/01 20:29:00 UTC, 1 replies.
- CEP issue - posted by Vishal Santoshi <vi...@gmail.com> on 2018/02/01 21:53:46 UTC, 8 replies.
- Getting Key from keyBy() in ProcessFunction - posted by Jürgen Thomann <ju...@innogames.com> on 2018/02/02 14:24:04 UTC, 4 replies.
- RocksDB / checkpoint questions - posted by Christophe Jolif <cj...@gmail.com> on 2018/02/02 16:30:49 UTC, 4 replies.
- Flink not writing last few elements to disk - posted by geoff halmo <ge...@gmail.com> on 2018/02/02 17:32:35 UTC, 1 replies.
- Reduce parallelism without network transfer. - posted by Kien Truong <du...@gmail.com> on 2018/02/03 03:39:36 UTC, 3 replies.
- Kafka and parallelism - posted by Christophe Jolif <cj...@gmail.com> on 2018/02/03 17:53:42 UTC, 6 replies.
- Global window keyBy - posted by miki haiat <mi...@gmail.com> on 2018/02/04 14:39:02 UTC, 2 replies.
- Checkpoint is not triggering as per configuration - posted by syed <ms...@vu.edu.pk> on 2018/02/05 02:19:01 UTC, 1 replies.
- Why does jobmanager running needs slot ? - posted by mingleizhang <zm...@163.com> on 2018/02/05 07:38:37 UTC, 7 replies.
- Re: Spurious warning in logs about flink-queryable-state-runtime - posted by Fabian Hueske <fh...@gmail.com> on 2018/02/05 09:18:11 UTC, 1 replies.
- Re: Task Manager detached under load - posted by Till Rohrmann <tr...@apache.org> on 2018/02/05 10:55:53 UTC, 2 replies.
- Rebalance to subtasks in same TaskManager instance - posted by "johannes.barnard@clarivate.com" <jo...@clarivate.com> on 2018/02/05 14:16:39 UTC, 2 replies.
- ML and Stream - posted by Christophe Jolif <cj...@gmail.com> on 2018/02/05 15:43:53 UTC, 3 replies.
- how to match external checkpoints with jobs during recovery - posted by xiatao123 <ta...@udacity.com> on 2018/02/05 19:27:45 UTC, 1 replies.
- Re: Joining data in Streaming - posted by Steven Wu <st...@gmail.com> on 2018/02/06 01:46:04 UTC, 1 replies.
- Will that be a problem if POJO key type didn't override equals? - posted by Tony Wei <to...@gmail.com> on 2018/02/06 03:16:44 UTC, 4 replies.
- Testing flink class loading - posted by Data Engineer <da...@gmail.com> on 2018/02/06 06:55:58 UTC, 1 replies.
- deduplication with streaming sql - posted by Henri Heiskanen <he...@gmail.com> on 2018/02/06 10:11:33 UTC, 6 replies.
- kafka as recovery only source - posted by "Sofer, Tovi " <to...@citi.com> on 2018/02/06 14:31:16 UTC, 2 replies.
- Re: Flink CEP exception during RocksDB update - posted by Kostas Kloudas <k....@data-artisans.com> on 2018/02/06 17:03:53 UTC, 0 replies.
- Fwd: Question about flink checkpoint - posted by Chengzhi Zhao <w....@gmail.com> on 2018/02/06 18:15:38 UTC, 3 replies.
- Classloader leak with Kafka Mbeans / JMX Reporter - posted by Edward <eg...@hotmail.com> on 2018/02/06 20:30:36 UTC, 6 replies.
- How to monitor the latency? - posted by FatMouse <93...@qq.com> on 2018/02/07 03:40:16 UTC, 2 replies.
- Maximizing resource allocation in EMR (EC2) - posted by Ishwara Varnasi <iv...@gmail.com> on 2018/02/07 04:06:24 UTC, 0 replies.
- Flink CEP with files and no streams? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/07 08:40:31 UTC, 3 replies.
- Re: Triggering a Savepoint - posted by Fabian Hueske <fh...@gmail.com> on 2018/02/07 09:31:28 UTC, 0 replies.
- Re: How to handle multiple yarn sessions and choose at runtime the one to submit a ha streaming job ? - posted by Chesnay Schepler <ch...@apache.org> on 2018/02/07 13:52:22 UTC, 0 replies.
- Kafka as source for batch job - posted by "Marchant, Hayden " <ha...@citi.com> on 2018/02/08 09:44:31 UTC, 5 replies.
- Re: Two issues when deploying Flink on DC/OS - posted by Stavros Kontopoulos <st...@gmail.com> on 2018/02/08 10:58:44 UTC, 2 replies.
- Developing and running Flink applications in Linux through Windows editors or IDE's ? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/08 12:49:26 UTC, 1 replies.
- CEP for time series in csv-file - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/08 15:28:12 UTC, 5 replies.
- dataset sort - posted by david westwood <da...@gmail.com> on 2018/02/08 19:07:21 UTC, 4 replies.
- Measure the memory consumption of a job at runtime - posted by "Wang, Chao" <ch...@wustl.edu> on 2018/02/08 20:33:23 UTC, 6 replies.
- Strata San Jose - posted by ashish pok <as...@yahoo.com> on 2018/02/08 23:53:25 UTC, 2 replies.
- Flink batch job stalls on Yarn ... - posted by kedar mhaswade <ke...@gmail.com> on 2018/02/09 00:50:06 UTC, 3 replies.
- Batch Cascade application - posted by Puneet Kinra <pu...@customercentria.com> on 2018/02/09 09:43:43 UTC, 2 replies.
- No Job is getting Submitted through Flink 4.0 UI - posted by Puneet Kinra <pu...@customercentria.com> on 2018/02/09 11:40:48 UTC, 1 replies.
- Re: [EXTERNAL] Re: Flink REST API - posted by "Raja.Aravapalli" <Ra...@target.com> on 2018/02/09 14:54:38 UTC, 3 replies.
- Regarding BucketingSink - posted by Vishal Santoshi <vi...@gmail.com> on 2018/02/09 16:54:10 UTC, 13 replies.
- Optimizing multiple aggregate queries on a CEP using Flink - posted by Sahil Arora <sa...@gmail.com> on 2018/02/09 22:28:32 UTC, 4 replies.
- Share Spring Application context among operators - posted by Swapnil Dharane <sw...@gmail.com> on 2018/02/10 04:15:55 UTC, 3 replies.
- CoProcess() VS union.Process() - posted by "m@xi" <ma...@gmail.com> on 2018/02/10 05:06:21 UTC, 1 replies.
- Unable to submit job from the web UI in flink 4.0 - posted by Puneet Kinra <pu...@customercentria.com> on 2018/02/10 11:51:41 UTC, 4 replies.
- Deep Copy in FLINK, Kryo Copy is used in the different operator - posted by chen <er...@126.com> on 2018/02/12 03:00:33 UTC, 4 replies.
- Ceph configuration for checkpoints? - posted by Julio Biason <ju...@azion.com> on 2018/02/12 19:11:15 UTC, 2 replies.
- Re: CoProcess() VS union.Process() & Timers in them - posted by "m@xi" <ma...@gmail.com> on 2018/02/13 08:59:13 UTC, 9 replies.
- Python and Scala - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/13 12:21:52 UTC, 5 replies.
- Flink + Consul as HA backend. What do you think? - posted by Krzysztof Białek <kr...@gmail.com> on 2018/02/13 20:38:57 UTC, 5 replies.
- Deploying Flink with JobManager HA on Docker Swarm/Kubernetes - posted by Chirag Dewan <ch...@yahoo.in> on 2018/02/14 05:12:42 UTC, 5 replies.
- Sample project does not work ? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/14 08:43:16 UTC, 5 replies.
- Retrieve written records of a sink after job - posted by Flavio Pompermaier <po...@okkam.it> on 2018/02/14 11:22:21 UTC, 8 replies.
- NullPointerException when asking for batched TableEnvironment - posted by André Schütz <an...@wegtam.com> on 2018/02/14 12:01:21 UTC, 2 replies.
- Unexpected hop start & end timestamps after stream SQL join - posted by Juho Autio <ju...@rovio.com> on 2018/02/14 14:30:27 UTC, 5 replies.
- Architecture question - posted by robert <te...@yahoo.com> on 2018/02/14 21:18:35 UTC, 1 replies.
- How do I run SQL query on a dataStream that generates my custom type. - posted by nikhilsimha <r....@gmail.com> on 2018/02/14 21:35:36 UTC, 2 replies.
- Support COUNT(DISTINCT 'field') Query Yet? - posted by xiatao123 <ta...@udacity.com> on 2018/02/14 23:15:05 UTC, 1 replies.
- Retrieving name of last external checkpoint directory - posted by Dawid Wysakowicz <wy...@gmail.com> on 2018/02/15 09:55:25 UTC, 3 replies.
- Re: flink read hdfs file error - posted by Or Sher <or...@gmail.com> on 2018/02/15 10:12:44 UTC, 1 replies.
- Manipulating Processing elements of Network Buffers - posted by "m@xi" <ma...@gmail.com> on 2018/02/15 14:13:32 UTC, 2 replies.
- Java heap size in YARN - posted by Pawel Bartoszek <pa...@gmail.com> on 2018/02/15 16:03:11 UTC, 4 replies.
- [ANNOUNCE] Apache Flink 1.4.1 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2018/02/15 18:04:07 UTC, 3 replies.
- Diagnosing high cpu/memory issue in Flink - posted by Pawel Bartoszek <pa...@gmail.com> on 2018/02/15 19:34:14 UTC, 2 replies.
- Concurrent modification Exception when submitting multiple jobs - posted by Vinay Patil <vi...@gmail.com> on 2018/02/16 04:39:16 UTC, 1 replies.
- Sessions online for #flinkforward SF. Register with 25% discount code. - posted by Fabian Hueske <fh...@gmail.com> on 2018/02/16 08:33:12 UTC, 0 replies.
- How to find correct import packages ? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/16 10:03:31 UTC, 3 replies.
- Keyby multiple elements - posted by Björn Zachrisson <bj...@gmail.com> on 2018/02/16 11:05:39 UTC, 3 replies.
- Question about the need of consumer groups from kafka - posted by Ricardo Dinis <di...@gmail.com> on 2018/02/16 13:05:34 UTC, 1 replies.
- Regarding Task Slots allocation - posted by Vinay Patil <vi...@gmail.com> on 2018/02/16 18:14:32 UTC, 1 replies.
- Variable time gap in Session Window - posted by Teena Kappen // BPRISE <te...@bprise.com> on 2018/02/17 07:01:45 UTC, 1 replies.
- Correlation between number of operators and Job manager memory requirements - posted by Shailesh Jain <sh...@stellapps.com> on 2018/02/17 12:23:28 UTC, 7 replies.
- Only a single message processed - posted by Niclas Hedhman <ni...@apache.org> on 2018/02/18 07:14:41 UTC, 5 replies.
- A "per operator instance" window all ? - posted by Julien <jm...@gmail.com> on 2018/02/18 12:49:51 UTC, 7 replies.
- Need to understand the execution model of the Flink - posted by Darshan Singh <da...@gmail.com> on 2018/02/18 19:11:33 UTC, 9 replies.
- Iterating over state entries - posted by Ken Krugler <kk...@transpac.com> on 2018/02/18 23:10:12 UTC, 5 replies.
- How to find correct "imports" - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/19 08:56:55 UTC, 2 replies.
- Discarding bad data in Stream - posted by Niclas Hedhman <ni...@apache.org> on 2018/02/19 09:29:22 UTC, 2 replies.
- Stopping a kafka consumer gracefully (no losing of inflight events, StoppableFunction) - posted by Bart Kastermans <fl...@kasterma.net> on 2018/02/19 14:36:57 UTC, 6 replies.
- Managed State Custom Serializer with Avro - posted by Niels <ni...@gmail.com> on 2018/02/19 15:14:14 UTC, 8 replies.
- Window with recent messages - posted by Krzysztof Białek <kr...@gmail.com> on 2018/02/19 15:36:16 UTC, 5 replies.
- sink with BucketingSink to S3 files override - posted by galantaa <al...@gmail.com> on 2018/02/19 16:39:12 UTC, 1 replies.
- # of active session windows of a streaming job - posted by Dongwon Kim <ea...@gmail.com> on 2018/02/20 08:54:11 UTC, 1 replies.
- Flink Batch job: All slots for groupReduce task scheduled on same machine - posted by Aneesha Kaushal <an...@reflektion.com> on 2018/02/20 09:50:40 UTC, 3 replies.
- Re: Flink Batch job: All slots for groupReduce task scheduled on same machine - posted by Aneesha Kaushal <an...@reflektion.com> on 2018/02/20 10:09:45 UTC, 1 replies.
- Get which key groups are assigned to an operator - posted by gerardg <ge...@talaia.io> on 2018/02/20 12:44:46 UTC, 4 replies.
- Save the date: ApacheCon North America, September 24-27 in Montréal - posted by Rich Bowen <rb...@apache.org> on 2018/02/20 14:21:23 UTC, 0 replies.
- Secured communication with Zookeeper without Kerberos - posted by Edward Rojas <ed...@gmail.com> on 2018/02/20 17:05:09 UTC, 0 replies.
- SQL materialized upsert tables - posted by Elias Levy <fe...@gmail.com> on 2018/02/20 23:07:44 UTC, 4 replies.
- co-location groups vs slot sharing groups - posted by Deepak Sharma <de...@gmail.com> on 2018/02/21 04:21:12 UTC, 0 replies.
- Strange Kafka consumer behaviour - posted by Gyula Fóra <gy...@gmail.com> on 2018/02/21 10:21:58 UTC, 0 replies.
- FLIP-6 + Mesos - Questions - posted by Jared Stehler <ja...@intellifylearning.com> on 2018/02/21 13:59:32 UTC, 0 replies.
- Kryo Serializator to override AVRO default - posted by Enrico Agnoli <en...@workday.com> on 2018/02/21 16:05:05 UTC, 0 replies.
- Re: Important (proposed) CEP changes for Flink 1.5. - posted by Vishal Santoshi <vi...@gmail.com> on 2018/02/21 16:42:56 UTC, 1 replies.
- FINAL REMINDER: CFP for Apache EU Roadshow Closes 25th February - posted by Sharan F <sh...@apache.org> on 2018/02/21 17:18:07 UTC, 0 replies.
- TaskManager crashes with PageRank algorithm in Gelly - posted by santoshg <sa...@uber.com> on 2018/02/21 18:14:56 UTC, 2 replies.
- Machine Learning: Flink and MOA - posted by Christophe Salperwyck <ch...@gmail.com> on 2018/02/21 18:38:26 UTC, 2 replies.
- Problems to use toAppendStream - posted by Esa Heikkinen <he...@student.tut.fi> on 2018/02/21 18:49:47 UTC, 10 replies.
- Re: Use keyBy to deterministically hash each record to a processor/task/slot - posted by "m@xi" <ma...@gmail.com> on 2018/02/22 05:28:54 UTC, 0 replies.
- Re: Share state across operators - posted by "m@xi" <ma...@gmail.com> on 2018/02/22 05:47:14 UTC, 0 replies.
- Problem when uploading a java flink program to aws lambda - posted by Kulasangar <ku...@auxenta.com> on 2018/02/22 09:39:42 UTC, 1 replies.
- Timestamp from Kafka record and watermark generation - posted by Federico D'Ambrosio <fe...@gmail.com> on 2018/02/22 11:05:41 UTC, 2 replies.
- How to use Dimension table in Flink TableAPI with StreamExecutionEnvironment ? - posted by 叶振宝 <82...@qq.com> on 2018/02/22 16:16:49 UTC, 0 replies.
- Re: NoClassDefFoundError of a Avro class after cancel then resubmit the same job - posted by Elias Levy <fe...@gmail.com> on 2018/02/22 20:52:28 UTC, 2 replies.
- Task manager not able to rejoin job manager after network hicup - posted by jelmer <jk...@gmail.com> on 2018/02/23 07:59:54 UTC, 6 replies.
- Imports for example ? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/23 10:17:14 UTC, 0 replies.
- Is Flink easy to deploy ? - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/23 12:30:07 UTC, 6 replies.
- Which test cluster to use for checkpointing tests? - posted by Ken Krugler <kk...@transpac.com> on 2018/02/23 20:42:40 UTC, 3 replies.
- CEP: watermark not generated when using watermark - posted by hanhonggen <ha...@qiyi.com> on 2018/02/24 02:54:56 UTC, 0 replies.
- Implementing CountWindow in Window Join and continuous joining for 2 datastreams - posted by Tay Zhen Shen <tz...@student.usm.my> on 2018/02/24 06:58:23 UTC, 1 replies.
- Cannot used managed keyed state in sink - posted by Kien Truong <du...@gmail.com> on 2018/02/24 07:04:42 UTC, 1 replies.
- Re: Imports for example ? - posted by Hequn Cheng <ch...@gmail.com> on 2018/02/24 08:08:44 UTC, 0 replies.
- How to create TableEnvrionment using scala-shell - posted by kant kodali <ka...@gmail.com> on 2018/02/24 12:06:16 UTC, 1 replies.
- Caused by: java.lang.ClassNotFoundException: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase - posted by kant kodali <ka...@gmail.com> on 2018/02/25 02:36:02 UTC, 5 replies.
- Flink job stops when reading file from FTP - posted by Sugandha Amatya <su...@gmail.com> on 2018/02/25 06:04:47 UTC, 0 replies.
- Does Queryable State only support K/V queries not SQL? - posted by kant kodali <ka...@gmail.com> on 2018/02/25 13:26:49 UTC, 1 replies.
- 'Custom' mapping function on keyed WindowedStream - posted by "Marchant, Hayden " <ha...@citi.com> on 2018/02/26 11:32:02 UTC, 2 replies.
- CliFrontend hang in the local case? - posted by kedar mhaswade <ke...@gmail.com> on 2018/02/26 19:14:14 UTC, 2 replies.
- Flink Kafka reads too many bytes .... Very rarely - posted by Philip Doctor <ph...@physiq.com> on 2018/02/26 23:02:36 UTC, 4 replies.
- Suggested way to backfill for datastream - posted by Chengzhi Zhao <w....@gmail.com> on 2018/02/26 23:07:27 UTC, 1 replies.
- Fat jar fails deployment (streaming job too large) - posted by Niels <ni...@gmail.com> on 2018/02/27 08:31:28 UTC, 4 replies.
- State based event's searching from files - posted by Esa Heikkinen <es...@student.tut.fi> on 2018/02/27 08:47:16 UTC, 0 replies.
- Checkpointing Event Time Watermarks - posted by vijay kansal <vi...@gmail.com> on 2018/02/27 12:51:53 UTC, 0 replies.
- SQL Table API: Naming operations done in query - posted by Juan Gentile <j....@criteo.com> on 2018/02/27 13:26:40 UTC, 1 replies.
- Using RowTypeInfo with Table API - posted by Jens Grassel <je...@wegtam.com> on 2018/02/27 13:34:31 UTC, 5 replies.
- Re: logging question - posted by JP de Vooght <jp...@vooght.de> on 2018/02/27 17:25:42 UTC, 1 replies.
- Reading csv-files - posted by Esa Heikkinen <he...@student.tut.fi> on 2018/02/27 19:13:45 UTC, 4 replies.
- ClassNotFoundException with Flink 1.4.1 and Kafka connector - posted by Debasish Ghosh <gh...@gmail.com> on 2018/02/28 07:45:16 UTC, 4 replies.
- Kinesis Connector SequenceNumber deserialisation on restart from Savepoint/checkpoint - posted by dy...@salecycle.com, dy...@salecycle.com on 2018/02/28 15:38:29 UTC, 2 replies.
- Configuring hdfs with the MesosApplicationMasterRunner - posted by Guillaume Balaine <ig...@gmail.com> on 2018/02/28 15:53:55 UTC, 0 replies.
- Slow Flink program - posted by Supun Kamburugamuve <su...@gmail.com> on 2018/02/28 16:20:15 UTC, 0 replies.
- Questions about the FlinkCEP - posted by Esa Heikkinen <he...@student.tut.fi> on 2018/02/28 19:32:12 UTC, 0 replies.