You are viewing a plain text version of this content. The canonical link for it is here.
- Re: watermark trigger doesn't check whether element's timestamp is passed - posted by Manu Zhang <ow...@gmail.com> on 2016/11/01 01:26:55 UTC, 6 replies.
- Question about the checkpoint mechanism in Flink. - posted by Li Wang <wa...@gmail.com> on 2016/11/01 07:05:34 UTC, 9 replies.
- Re: Kinesis Connector Dependency Problems - posted by Till Rohrmann <tr...@apache.org> on 2016/11/01 10:57:06 UTC, 10 replies.
- Re: Elasticsearch sink: Java.lang.NoSuchMethodError: org.elasticsearch.common.settings.Settings.settingsBuilder - posted by Till Rohrmann <tr...@apache.org> on 2016/11/01 13:05:30 UTC, 0 replies.
- BoundedOutOfOrdernessTimestampExtractor and timestamps in the future - posted by Dominik Bruhn <do...@dbruhn.de> on 2016/11/01 14:05:25 UTC, 2 replies.
- Re: Looping over a DataSet and accesing another DataSet - posted by Greg Hogan <co...@greghogan.com> on 2016/11/01 16:13:40 UTC, 2 replies.
- Re: Can we do batch writes on cassandra using flink while leveraging the locality? - posted by Stephan Ewen <se...@apache.org> on 2016/11/01 19:29:16 UTC, 1 replies.
- Re: A custom FileInputFormat - posted by Fabian Hueske <fh...@gmail.com> on 2016/11/01 20:59:01 UTC, 1 replies.
- Re: Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation - posted by Jamie Grier <ja...@data-artisans.com> on 2016/11/01 21:43:01 UTC, 8 replies.
- Re: Flink on YARN - Fault Tolerance | use case supported or not - posted by Anchit Jatana <de...@gmail.com> on 2016/11/01 23:37:51 UTC, 0 replies.
- TimelyFlatMapFunction and DataStream - posted by Ken Krugler <kk...@transpac.com> on 2016/11/02 00:59:19 UTC, 3 replies.
- Best Practices/Advice - Execution of jobs - posted by PedroMrChaves <pe...@gmail.com> on 2016/11/02 09:16:20 UTC, 2 replies.
- Questions about FoldFunction and WindowFunction - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/11/02 09:42:16 UTC, 5 replies.
- Re: NotSerializableException: jdk.nashorn.api.scripting.NashornScriptEngine - posted by PedroMrChaves <pe...@gmail.com> on 2016/11/02 14:47:01 UTC, 1 replies.
- Testing DataStreams - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/11/02 15:58:09 UTC, 2 replies.
- Flink Application on YARN failed on losing Job Manager | No recovery | Need help debug the cause from logs - posted by Anchit Jatana <de...@gmail.com> on 2016/11/02 17:44:54 UTC, 9 replies.
- Why are externalized checkpoints deleted on Job Manager exit? - posted by Clifford Resnick <cr...@mediamath.com> on 2016/11/02 20:52:23 UTC, 5 replies.
- Reg. custom sink for Flink streaming - posted by Sandeep Vakacharla <sv...@fanatics.com> on 2016/11/02 23:00:57 UTC, 0 replies.
- Link read avro from Kafka Connect Issue - posted by Will Du <wi...@gmail.com> on 2016/11/02 23:31:16 UTC, 0 replies.
- Re: Accessing StateBackend snapshots outside of Flink - posted by bwong247 <bw...@247-inc.com> on 2016/11/03 00:20:16 UTC, 1 replies.
- Flink Kafka 0.10.0.0 connector - posted by Dominik Safaric <do...@gmail.com> on 2016/11/03 07:05:47 UTC, 4 replies.
- Best way of doing some global initialization - posted by Satish Chandra Gupta <sc...@gmail.com> on 2016/11/03 08:26:39 UTC, 3 replies.
- Re: emit partial state in window (streaming) - posted by Luis Mariano Guerra <ma...@event-fabric.com> on 2016/11/03 10:31:02 UTC, 5 replies.
- Re: ExpiredIteratorException when reading from a Kinesis stream - posted by Josh <jo...@gmail.com> on 2016/11/03 11:46:32 UTC, 6 replies.
- Using Flink with Accumulo - posted by Oliver Swoboda <os...@gmail.com> on 2016/11/03 12:57:35 UTC, 3 replies.
- Freeing resources in SourceFunction - posted by Yury Ruchin <yu...@gmail.com> on 2016/11/03 13:45:20 UTC, 1 replies.
- Re: Reg. custom sink for Flink streaming - posted by Fabian Hueske <fh...@gmail.com> on 2016/11/03 13:50:26 UTC, 0 replies.
- Re: What is the best way to load/add patterns dynamically (at runtime) with Flink? - posted by PedroMrChaves <pe...@gmail.com> on 2016/11/03 17:30:21 UTC, 6 replies.
- Flink Time Window State - posted by Daniel Santos <ds...@cryptolab.net> on 2016/11/03 18:43:16 UTC, 7 replies.
- Release Process - posted by Dominik Bruhn <do...@dbruhn.de> on 2016/11/03 21:50:41 UTC, 2 replies.
- Re: Retrieving a single element from a DataSet - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/04 09:52:20 UTC, 3 replies.
- Flink Kafka Connector behaviour on leader change and broker upgrade - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/11/04 10:19:32 UTC, 1 replies.
- Flink stream job change and recovery - posted by Renjie Liu <li...@gmail.com> on 2016/11/04 10:24:15 UTC, 3 replies.
- Parallelizing DataStream operations on Array elements - posted by Daniel Suo <ds...@CS.Princeton.EDU> on 2016/11/04 16:45:13 UTC, 4 replies.
- Re: window-like use case - posted by Maciek Próchniak <mp...@touk.pl> on 2016/11/04 19:43:09 UTC, 1 replies.
- Stephan "Apache Flink to very Large State" - posted by Alberto Ramón <a....@gmail.com> on 2016/11/05 13:26:11 UTC, 2 replies.
- Last event of each window belongs to the next window - Wrong - posted by Samir Abdou <ab...@gmail.com> on 2016/11/06 11:11:49 UTC, 6 replies.
- Csv to windows? - posted by Felix Neutatz <ne...@googlemail.com> on 2016/11/06 11:36:50 UTC, 7 replies.
- Datastream reset variable in every-time window in map function - posted by subash basnet <ya...@gmail.com> on 2016/11/06 21:15:41 UTC, 1 replies.
- Lot of RocksDB files in tmp Directory - posted by Dominique Rondé <do...@allsecur.de> on 2016/11/07 00:24:11 UTC, 5 replies.
- Flink failed when can not connect to BlobServer - posted by Si-li Liu <un...@gmail.com> on 2016/11/07 09:02:21 UTC, 1 replies.
- Last-Event-Only Timer (Custom Trigger) - posted by Julian Bauß <ju...@gmail.com> on 2016/11/07 10:34:55 UTC, 2 replies.
- automatically submit a job to a HA cluster - posted by Andrew Ge Wu <an...@gmail.com> on 2016/11/07 12:00:25 UTC, 0 replies.
- Re: automatically submit a job to a HA cluster - posted by Ufuk Celebi <uc...@apache.org> on 2016/11/07 12:44:54 UTC, 0 replies.
- Cannot see all events in window apply() for big input - posted by Sendoh <un...@gmail.com> on 2016/11/07 15:15:39 UTC, 9 replies.
- Kafka Monitoring - posted by Vinay Patil <vi...@gmail.com> on 2016/11/07 19:13:54 UTC, 14 replies.
- Memory on Aggr - posted by Alberto Ramón <a....@gmail.com> on 2016/11/07 20:33:50 UTC, 4 replies.
- Flink on Yarn delegation token renewal - posted by Theofilos Kakantousis <tk...@kth.se> on 2016/11/08 09:25:50 UTC, 2 replies.
- Re: Listening to timed-out patterns in Flink CEP - posted by Till Rohrmann <tr...@apache.org> on 2016/11/08 14:25:24 UTC, 1 replies.
- Custom Window Assigner With Lateness - posted by Seth Wiesman <sw...@mediamath.com> on 2016/11/08 16:19:07 UTC, 1 replies.
- Window PURGE Behaviour 1.0.2 vs 1.1.3 - posted by Konstantin Knauf <ko...@tngtech.com> on 2016/11/08 17:17:26 UTC, 13 replies.
- Why did the Flink Cluster JM crash? - posted by amir bahmanyari <am...@yahoo.com> on 2016/11/08 20:33:33 UTC, 9 replies.
- Too few memory segments provided. Hash Table needs at least 33 memory segments. - posted by Miguel Coimbra <mi...@gmail.com> on 2016/11/08 21:35:15 UTC, 4 replies.
- An idea for a parallel AllWindowedStream - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/11/09 05:35:02 UTC, 1 replies.
- [DISCUSS] Changing Window Cleanup Semantics - posted by Aljoscha Krettek <al...@apache.org> on 2016/11/09 13:22:51 UTC, 0 replies.
- Processing streams of events with unpredictable delays - posted by PedroMrChaves <pe...@gmail.com> on 2016/11/09 16:46:50 UTC, 1 replies.
- Flink 1.1.3 | Shutting down YarnClusterClient from the client shutdown hook | happening frequently - posted by Anchit Jatana <de...@gmail.com> on 2016/11/10 01:01:46 UTC, 1 replies.
- Re: Maintaining watermarks per key, instead of per operator instance - posted by Stephan Epping <st...@zweitag.de> on 2016/11/10 10:01:07 UTC, 12 replies.
- Fwd: Flink - Exception Handling best practices - posted by Michel Betancourt <mi...@gmail.com> on 2016/11/11 01:33:13 UTC, 1 replies.
- Kafka Stream to Database batch inserts - posted by criss <ct...@gmail.com> on 2016/11/11 13:09:49 UTC, 2 replies.
- Flink Avro Kafka Reading/Writing - posted by daviD <du...@yahoo.com> on 2016/11/11 14:05:14 UTC, 2 replies.
- WindowOperator - element's timestamp - posted by Petr Novotnik <pe...@firma.seznam.cz> on 2016/11/11 15:16:58 UTC, 4 replies.
- Programmatically abort checkpoint - posted by Lorenzo Affetti <lo...@polimi.it> on 2016/11/11 16:15:30 UTC, 5 replies.
- Flink work with raw S3 (S3FileSystem or other), not a HDFS backed by S3 (S3AFileSystem, NativeS3FileSystem)? - posted by Steve Morin <st...@stevemorin.com> on 2016/11/11 16:35:16 UTC, 1 replies.
- Apache Flink Introduction Guide - posted by Manish Shukla <ma...@gmail.com> on 2016/11/11 16:48:40 UTC, 2 replies.
- Order by which windows are processed on event time - posted by Saiph Kappa <sa...@gmail.com> on 2016/11/11 18:57:27 UTC, 2 replies.
- TaskManager log thread - posted by Dominik Safaric <do...@gmail.com> on 2016/11/11 20:02:00 UTC, 1 replies.
- Flink - Nifi Connectors - Class not found - posted by "PACE, JAMES" <jp...@att.com> on 2016/11/11 20:23:39 UTC, 0 replies.
- "Too many open files" in Job Manager - posted by static-max <fl...@googlemail.com> on 2016/11/12 10:33:26 UTC, 1 replies.
- Task managers cant start on YARN cluster - posted by Gyula Fóra <gy...@gmail.com> on 2016/11/12 12:11:22 UTC, 6 replies.
- Compile for Java 1.8 - posted by Alberto Ramón <a....@gmail.com> on 2016/11/12 23:29:33 UTC, 5 replies.
- Re: Flink - Nifi Connectors - Class not found - posted by Robert Metzger <rm...@apache.org> on 2016/11/13 05:53:06 UTC, 1 replies.
- - posted by Thomas FOURNIER <th...@gmail.com> on 2016/11/13 22:38:49 UTC, 0 replies.
- Global Sort + ZipWithIndex - posted by Thomas FOURNIER <th...@gmail.com> on 2016/11/13 22:44:48 UTC, 0 replies.
- get trigger context from WindowFunction - posted by "Griess, Andrew" <an...@sap.com> on 2016/11/14 00:36:58 UTC, 2 replies.
- Many operations cause StackOverflowError with AWS EMR YARN cluster - posted by Geoffrey Mon <ge...@gmail.com> on 2016/11/14 07:02:07 UTC, 4 replies.
- Flink job restart at checkpoint interval - posted by Satish Chandra Gupta <sc...@gmail.com> on 2016/11/14 09:50:59 UTC, 6 replies.
- apply with fold- and window function - posted by Stephan Epping <st...@zweitag.de> on 2016/11/14 13:49:14 UTC, 2 replies.
- Proper way of adding external jars - posted by Gyula Fóra <gy...@gmail.com> on 2016/11/14 15:59:22 UTC, 5 replies.
- map is not executed when using 'bin/flink run' - posted by Meghashyam Sandeep V <vr...@gmail.com> on 2016/11/14 16:19:16 UTC, 1 replies.
- Retrieving values from a dataset of datasets - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/14 19:44:07 UTC, 3 replies.
- Why use Kafka after all? - posted by Dromit <dr...@gmail.com> on 2016/11/15 07:14:46 UTC, 9 replies.
- Data Loss in HDFS after Job failure - posted by Dominique Rondé <do...@allsecur.de> on 2016/11/15 13:57:38 UTC, 4 replies.
- RDF/SPARQL and Flink - posted by Tomas Knap <t....@semantic-web.at> on 2016/11/15 14:47:28 UTC, 1 replies.
- Subtask keeps on discovering new Kinesis shard when using Kinesalite - posted by Philipp Bussche <ph...@gmail.com> on 2016/11/15 20:51:40 UTC, 4 replies.
- Re: Error handling - posted by criss <ct...@gmail.com> on 2016/11/16 09:26:55 UTC, 3 replies.
- Is incremental checkpointing already supported? - posted by 魏偉哲 <to...@gmail.com> on 2016/11/16 11:05:51 UTC, 1 replies.
- 33 segments problem with configuration set - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/16 11:24:39 UTC, 3 replies.
- Additional steps needed for the Java quickstart guide - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/11/16 13:49:35 UTC, 1 replies.
- Any way to increase sort buffer size? - posted by Gábor Hermann <ma...@gaborhermann.com> on 2016/11/16 16:29:12 UTC, 2 replies.
- Tame Flink UI? - posted by Cliff Resnick <cr...@gmail.com> on 2016/11/16 17:40:18 UTC, 4 replies.
- Running the JobManager and TaskManager on the same node in a cluster - posted by Dominik Safaric <do...@gmail.com> on 2016/11/16 20:49:52 UTC, 1 replies.
- spark vs flink batch performance - posted by CPC <ac...@gmail.com> on 2016/11/16 21:38:06 UTC, 7 replies.
- Enforce an operation to run in an exact host in flink - posted by Eranga Heshan <er...@gmail.com> on 2016/11/17 06:26:55 UTC, 5 replies.
- Docker - posted by Stephan Epping <st...@zweitag.de> on 2016/11/17 10:19:24 UTC, 0 replies.
- Could not find job with id XXXXX - posted by Sendoh <un...@gmail.com> on 2016/11/17 12:21:37 UTC, 3 replies.
- Type of TypeVariable 'K' in 'class <> could not be determined - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/17 12:31:29 UTC, 11 replies.
- Re: add FLINK_LIB_DIR to classpath on yarn -> add properties file to class path on yarn - posted by vinay patil <vi...@gmail.com> on 2016/11/17 13:37:19 UTC, 4 replies.
- fileInpuFormat of type json - posted by daviD <du...@yahoo.com> on 2016/11/17 19:59:14 UTC, 1 replies.
- Cross product of datastream and dataset - posted by Charlie Moad <ch...@geofeedia.com> on 2016/11/17 21:36:04 UTC, 1 replies.
- Regarding time window based on the values received in the stream - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2016/11/18 00:04:14 UTC, 3 replies.
- FLINK-2821 - Flink on Kubernetes - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2016/11/18 00:29:35 UTC, 1 replies.
- Flink survey by data Artisans - posted by Kostas Tzoumas <kt...@apache.org> on 2016/11/18 15:28:13 UTC, 4 replies.
- CodeAnalysisMode in Flink - posted by Vinay Patil <vi...@gmail.com> on 2016/11/18 16:41:35 UTC, 1 replies.
- Flink streaming with 1+ TB of managed state - posted by Steven Ruppert <st...@fullcontact.com> on 2016/11/19 00:41:35 UTC, 5 replies.
- Re: flink-dist shading - posted by "Foster, Craig" <fo...@amazon.com> on 2016/11/19 00:48:13 UTC, 5 replies.
- Error while running Yahoo Streaming Benchmarks on a single machine - posted by Muhammad Haseeb Javed <11...@seecs.edu.pk> on 2016/11/19 02:59:59 UTC, 1 replies.
- Streaming program gets stucks when accesing to AWS Kinesis - posted by IvanFernandez <iv...@gmail.com> on 2016/11/19 09:03:02 UTC, 1 replies.
- ContinuousEventTimeTrigger breaks coGrouped windowed streams? - posted by William Saar <wi...@saar.se> on 2016/11/19 17:28:35 UTC, 9 replies.
- Early events - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/11/20 04:31:00 UTC, 3 replies.
- Failure to donwload flink-contrib dependency - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/11/20 20:21:00 UTC, 2 replies.
- Regarding dividing the streams using keyby - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2016/11/21 01:07:19 UTC, 1 replies.
- IterativeStream seems to ignore maxWaitTimeMillis - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/11/21 06:57:40 UTC, 4 replies.
- Understanding connected streams use without timestamps - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/11/21 11:06:44 UTC, 3 replies.
- Flink Material & Papers - posted by Hanna Prinz <ha...@yahoo.de> on 2016/11/21 16:53:22 UTC, 2 replies.
- Re: PathIsNotEmptyDirectoryException in Namenode HDFS log when using Jobmanager HA in YARN - posted by static-max <fl...@googlemail.com> on 2016/11/21 20:51:08 UTC, 2 replies.
- Cassandra Connector - posted by Stephan Epping <st...@zweitag.de> on 2016/11/22 07:06:43 UTC, 3 replies.
- Fwd: Flink application and curator integration issues - posted by Liu Tongwei <li...@gmail.com> on 2016/11/22 08:30:14 UTC, 4 replies.
- Flink Streaming Data Source Node - posted by Adrienne Kole <ad...@gmail.com> on 2016/11/22 09:14:51 UTC, 1 replies.
- Can not stop cluster gracefully - posted by Andrew Ge Wu <an...@eniro.com> on 2016/11/22 10:27:24 UTC, 2 replies.
- Reading files from an S3 folder - posted by Alex Reid <al...@gmail.com> on 2016/11/22 18:42:18 UTC, 3 replies.
- Creating Job Savepoints at Regular Intervals - posted by Scott Kidder <ki...@gmail.com> on 2016/11/22 19:01:25 UTC, 1 replies.
- questions about how to implement some functionality in Flink - posted by Drew Verlee <dr...@gmail.com> on 2016/11/22 21:50:33 UTC, 0 replies.
- S3 checkpointing in AWS in Frankfurt - posted by Jonathan Share <jo...@gmail.com> on 2016/11/23 07:52:00 UTC, 9 replies.
- Sink not switched to "RUNUNG" even though a task slot is available - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/11/23 13:03:04 UTC, 2 replies.
- Problem - Negative currentWatermark if the watermark assignment is made before connecting the streams - posted by PedroMrChaves <pe...@gmail.com> on 2016/11/23 18:08:40 UTC, 2 replies.
- State Serializer/Deserializer between savepoints - posted by Daniel Santos <ds...@cryptolab.net> on 2016/11/23 18:16:42 UTC, 1 replies.
- Cannot connect to the JobManager - Flink 1.1.3 cluster mode - posted by Dominik Safaric <do...@gmail.com> on 2016/11/23 21:05:06 UTC, 1 replies.
- Container JMX port setting / discovery for Flink on YARN - posted by Yury Ruchin <yu...@gmail.com> on 2016/11/24 15:47:59 UTC, 4 replies.
- JobManager shows TaskManager was lost/killed while TaskManger Process is still running and the network is OK. - posted by Renkai <ga...@gmail.com> on 2016/11/25 03:54:50 UTC, 3 replies.
- Re: ContinuousFileMonitoringFunction - deleting file after processing - posted by Maciek Próchniak <mp...@touk.pl> on 2016/11/26 20:40:17 UTC, 1 replies.
- multiple k-means in parallel - posted by Lydia Ickler <ic...@googlemail.com> on 2016/11/27 10:48:48 UTC, 1 replies.
- DB connection and query inside map function - posted by Anastasios Skarlatidis <a....@gmail.com> on 2016/11/27 21:11:35 UTC, 1 replies.
- How Flink decide which slots to use? - posted by Renkai Ge <ga...@gmail.com> on 2016/11/28 10:32:24 UTC, 0 replies.
- How to let 1.1.3 not drop late events as verion 1.0.3 does - posted by Sendoh <un...@gmail.com> on 2016/11/28 12:24:22 UTC, 5 replies.
- Problems with RollingSink - posted by Diego Fustes Villadóniga <df...@oesia.com> on 2016/11/28 16:37:41 UTC, 5 replies.
- Split csv file in equally sized slices (less than or equal) - posted by Flavio Pompermaier <po...@okkam.it> on 2016/11/28 17:32:04 UTC, 4 replies.
- Executing graph algorithms on Gelly that are larger then memmory - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/28 20:43:51 UTC, 2 replies.
- flink-job-in-yarn,has max memory - posted by ri...@sina.cn on 2016/11/29 11:43:27 UTC, 0 replies.
- CEP issue - posted by "kieran ." <ki...@hotmail.com> on 2016/11/29 14:18:40 UTC, 0 replies.
- JVM Non Heap Memory - posted by Daniel Santos <ds...@cryptolab.net> on 2016/11/29 14:26:15 UTC, 3 replies.
- About delta awareness caches - posted by xingcan <xi...@gmail.com> on 2016/11/29 14:46:56 UTC, 0 replies.
- 回复：JVM Non Heap Memory - posted by ri...@sina.cn on 2016/11/29 14:54:42 UTC, 0 replies.
- Collect() freeze on yarn cluster on strange recover/deserialization error - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2016/11/29 17:14:57 UTC, 2 replies.
- Flink 1.1.3 OOME Permgen - posted by Konstantin Knauf <ko...@tngtech.com> on 2016/11/29 17:39:21 UTC, 2 replies.
- Query regarding tumbling event time windows with ingestion time - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/11/29 18:25:34 UTC, 5 replies.
- Gelly simple program but: java.lang.RuntimeException: Memory ran out - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/11/30 15:07:55 UTC, 0 replies.
- Regarding windows and custom trigger - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2016/11/30 15:37:22 UTC, 1 replies.
- Time To Live-Setting for State/StateDescriptor - posted by Julian Bauß <ju...@gmail.com> on 2016/11/30 16:13:30 UTC, 0 replies.
- Save the date: ApacheCon Miami, May 15-19, 2017 - posted by Rich Bowen <rb...@apache.org> on 2016/11/30 19:24:52 UTC, 0 replies.