user@flink.apache.org, 2016-10

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

- Re: SVM classification problem. - posted by Simone Robutti <si...@radicalbit.io> on 2016/10/02 13:06:32 UTC, 0 replies.
- Regarding Late Elements - posted by Vinay Patil <vi...@gmail.com> on 2016/10/03 03:21:34 UTC, 11 replies.
- Using Flink - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/10/03 06:08:20 UTC, 4 replies.
- RE: How to stop job through java API - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2016/10/03 08:31:21 UTC, 2 replies.
- Re: Flink job fails to restore RocksDB state after upgrading to 1.2-SNAPSHOT - posted by Josh <jo...@gmail.com> on 2016/10/03 11:37:22 UTC, 2 replies.
- Side Inputs vs. Connected Streams - posted by Sameer W <sa...@axiomine.com> on 2016/10/03 12:31:06 UTC, 2 replies.
- Re: Flink Checkpoint runs slow for low load stream - posted by Chakravarthy varaga <ch...@gmail.com> on 2016/10/03 13:40:08 UTC, 4 replies.
- Exception while running Flink jobs (1.0.0) - posted by Tarandeep Singh <ta...@gmail.com> on 2016/10/03 19:49:53 UTC, 14 replies.
- Re: Enriching a tuple mapped from a datastream with data coming from a JDBC source - posted by Philipp Bussche <ph...@gmail.com> on 2016/10/04 01:41:21 UTC, 2 replies.
- Re: Flink Kafka Consumer Behaviour - posted by ankitcha <an...@gmail.com> on 2016/10/04 03:51:19 UTC, 3 replies.
- Re: Controlling savepoints from inside an application - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/04 07:32:22 UTC, 0 replies.
- Available for freelancing - posted by Deepak Sharma <de...@gmail.com> on 2016/10/04 07:37:09 UTC, 0 replies.
- Re: Using Flink and Cassandra with Scala - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/04 07:49:37 UTC, 0 replies.
- Re: Iterations vs. combo source/sink - posted by Till Rohrmann <tr...@apache.org> on 2016/10/04 09:25:50 UTC, 0 replies.
- Presented Flink use case in Japan - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/10/04 12:04:54 UTC, 8 replies.
- Flink scala or Java - Dataload from CSV to database.. - posted by ram kumar <ra...@gmail.com> on 2016/10/04 12:18:13 UTC, 1 replies.
- TimeWindow Trigger which only fires when the values have changed - posted by Dominik Bruhn <do...@dbruhn.de> on 2016/10/04 12:54:30 UTC, 2 replies.
- Re: Blobstorage Locally and on HDFS - posted by Konstantin Knauf <ko...@tngtech.com> on 2016/10/04 14:54:46 UTC, 1 replies.
- Handling decompression exceptions - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/10/04 15:43:39 UTC, 9 replies.
- ExpiredIteratorException when reading from a Kinesis stream - posted by Steffen Hausmann <st...@hausmann-family.de> on 2016/10/04 18:55:41 UTC, 1 replies.
- AWS S3 and Reshift - posted by sunny patel <su...@gmail.com> on 2016/10/05 06:15:02 UTC, 3 replies.
- Processing events through web socket - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2016/10/05 07:48:19 UTC, 3 replies.
- Flink job throws ClassNotFoundException on job restart - posted by none none <fl...@googlemail.com> on 2016/10/05 09:50:19 UTC, 3 replies.
- Is it a good practice to create lots of jobs in a flink cluster ? - posted by Christophe Julien <ch...@gmail.com> on 2016/10/06 08:42:55 UTC, 1 replies.
- Sensor's Data Aggregation Out of order with EventTime. - posted by Steve <sd...@gmail.com> on 2016/10/06 08:53:45 UTC, 1 replies.
- Listening to timed-out patterns in Flink CEP - posted by David Koch <og...@googlemail.com> on 2016/10/06 13:08:19 UTC, 14 replies.
- readCsvFile - posted by Alberto Ramón <a....@gmail.com> on 2016/10/06 18:59:51 UTC, 6 replies.
- Csv data stream - posted by drystan mazur <dr...@gmail.com> on 2016/10/06 20:08:59 UTC, 2 replies.
- DataStream csv reading - posted by drystan mazur <dr...@gmail.com> on 2016/10/06 20:21:02 UTC, 4 replies.
- Merging N parallel/partitioned WindowedStreams together, one-to-one, into a global window stream - posted by AJ Heller <aj...@drfloob.com> on 2016/10/06 20:39:04 UTC, 4 replies.
- Compression for AvroOutputFormat - posted by la...@posteo.de on 2016/10/07 10:40:32 UTC, 1 replies.
- Tuple vs Row - posted by Flavio Pompermaier <po...@okkam.it> on 2016/10/07 11:48:03 UTC, 1 replies.
- Re: Data Transfer between TM should be encrypted - posted by vinay patil <vi...@gmail.com> on 2016/10/07 16:26:54 UTC, 5 replies.
- jdbc.JDBCInputFormat - posted by Alberto Ramón <a....@gmail.com> on 2016/10/07 19:38:34 UTC, 15 replies.
- Re: more complex patterns for CEP (was: CEP two transitions to the same state) - posted by lg...@yahoo.com on 2016/10/07 22:42:33 UTC, 2 replies.
- Re: Iterative queries on Flink - posted by Flavio Pompermaier <po...@okkam.it> on 2016/10/08 14:41:29 UTC, 2 replies.
- Executing a flink program - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2016/10/08 17:35:23 UTC, 3 replies.
- Regarding - posted by Rashmi Varma <rs...@gmail.com> on 2016/10/08 19:24:07 UTC, 3 replies.
- Current alternatives for async I/O - posted by Ken Krugler <kk...@transpac.com> on 2016/10/09 01:31:21 UTC, 2 replies.
- Wordindex conversation. - posted by Kürşat Kurt <ku...@kursatkurt.com> on 2016/10/10 21:49:47 UTC, 2 replies.
- "Slow ReadProcessor" warnings when using BucketSink - posted by static-max <fl...@googlemail.com> on 2016/10/11 08:51:47 UTC, 3 replies.
- Re: Create stream from multiple files using "env.readFile(format, input1, FileProcessingMode.PROCESS_CONTINUOUSLY, 1000, FilePathFilter.createDefaultFilter())" ? - posted by Aljoscha Krettek <al...@apache.org> on 2016/10/11 09:57:48 UTC, 0 replies.
- Exception when restoring state from RocksDB - how to recover? - posted by Josh <jo...@gmail.com> on 2016/10/11 10:40:02 UTC, 6 replies.
- About Sliding window - posted by Zhangrucong <zh...@huawei.com> on 2016/10/11 11:20:41 UTC, 7 replies.
- CEP and slightly out of order elements - posted by Sameer W <sa...@axiomine.com> on 2016/10/11 11:51:38 UTC, 2 replies.
- PathIsNotEmptyDirectoryException in Namenode HDFS log when using Jobmanager HA in YARN - posted by static-max <fl...@googlemail.com> on 2016/10/11 15:25:25 UTC, 1 replies.
- What is the best way to load/add patterns dynamically (at runtime) with Flink? - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/11 21:01:26 UTC, 6 replies.
- mapreduce.HadoopOutputFormat config value issue - posted by Shannon Carey <sc...@expedia.com> on 2016/10/11 21:40:39 UTC, 1 replies.
- Flink Kafka connector08 not updating the offsets with the zookeeper - posted by Anchit Jatana <de...@gmail.com> on 2016/10/12 00:35:35 UTC, 3 replies.
- Distributing Tasks over Task manager - posted by Jürgen Thomann <ju...@innogames.com> on 2016/10/12 10:52:44 UTC, 5 replies.
- bucketing in RollingSink - posted by ro...@hyatt.com on 2016/10/12 12:10:48 UTC, 4 replies.
- Re: Tumbling window rich functionality - posted by Swapnil Chougule <th...@gmail.com> on 2016/10/12 12:25:56 UTC, 1 replies.
- Keyed join Flink Streaming - posted by Adrienne Kole <ad...@gmail.com> on 2016/10/12 14:10:12 UTC, 2 replies.
- Error with table sql query - No match found for function signature TUMBLE(, ) - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/12 16:51:18 UTC, 5 replies.
- question about making a temporal Graph with Gelly - posted by Wouter Ligtenberg <wo...@onzichtbaar.net> on 2016/10/12 20:29:54 UTC, 2 replies.
- java.lang.IllegalArgumentException: JDBC-Class not found. - org.postgresql.jdbc.Driver - posted by sunny patel <su...@gmail.com> on 2016/10/12 21:18:27 UTC, 2 replies.
- Clean up history of job manager - posted by Sendoh <un...@gmail.com> on 2016/10/13 08:49:49 UTC, 2 replies.
- Evolution algorithm on flink - posted by Andrew Ge Wu <an...@gmail.com> on 2016/10/13 09:00:34 UTC, 2 replies.
- Allowed Lateness and Window State - posted by swiesman <sw...@mediamath.com> on 2016/10/13 14:16:22 UTC, 2 replies.
- [DISCUSS] Drop Hadoop 1 support with Flink 1.2 - posted by Robert Metzger <rm...@apache.org> on 2016/10/13 14:47:36 UTC, 2 replies.
- [ANNOUNCE] Flink 1.1.3 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/10/13 15:23:29 UTC, 0 replies.
- JsonMappingException: No content to map due to end-of-input - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/13 15:56:30 UTC, 1 replies.
- SVM Multiclass classification - posted by Kürşat Kurt <ku...@kursatkurt.com> on 2016/10/13 18:52:20 UTC, 1 replies.
- ConcurrentModificationException when using histogram accumulators - posted by Yukun Guo <gy...@gmail.com> on 2016/10/14 06:32:49 UTC, 1 replies.
- HivePartitionTap is not working with cascading flink - posted by Santlal J Gupta <Sa...@bitwiseglobal.com> on 2016/10/14 06:43:31 UTC, 2 replies.
- [DISCUSS] Deprecate Hadoop source method from (batch) ExecutionEnvironment - posted by Fabian Hueske <fh...@gmail.com> on 2016/10/14 09:29:22 UTC, 5 replies.
- job failure with checkpointing enabled - posted by ro...@hyatt.com on 2016/10/14 15:37:05 UTC, 3 replies.
- Flink Cluster is savepointing jobmanager instead of external filesystem - posted by Jason Brelloch <jb...@gmail.com> on 2016/10/14 16:39:08 UTC, 4 replies.
- Task and Operator Monitoring via JMX / naming - posted by Philipp Bussche <ph...@gmail.com> on 2016/10/14 22:07:14 UTC, 10 replies.
- A question regarding to the checkpoint mechanism - posted by Li Wang <wa...@gmail.com> on 2016/10/15 03:17:38 UTC, 4 replies.
- How to debug why Flink makes and executes only partial plan - posted by Satish Chandra Gupta <sc...@gmail.com> on 2016/10/15 03:25:52 UTC, 1 replies.
- "java.net.SocketException: No buffer space available (maximum connections reached?)" when reading from HDFS - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/10/15 20:11:00 UTC, 3 replies.
- Flink strange stream join behavior - posted by Davood Rafiei <ra...@gmail.com> on 2016/10/15 21:28:05 UTC, 1 replies.
- First Program with WordCount - Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/functions/FlatMapFunction - posted by "Kaepke, Marc" <ma...@haw-hamburg.de> on 2016/10/16 17:26:33 UTC, 0 replies.
- Flink Metrics - posted by Govindarajan Srinivasaraghavan <go...@gmail.com> on 2016/10/17 03:26:11 UTC, 4 replies.
- Re: First Program with WordCount - Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/functions/FlatMapFunction - posted by Stefan Richter <s....@data-artisans.com> on 2016/10/17 08:50:38 UTC, 1 replies.
- how can I name a sink? - posted by 侯林蔚 <ti...@gmail.com> on 2016/10/17 09:48:17 UTC, 2 replies.
- BoundedOutOfOrdernessTimestampExtractor and allowedlateness - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/10/17 09:52:20 UTC, 3 replies.
- Testing a streaming data flow - posted by ba...@kpn.com on 2016/10/17 13:21:11 UTC, 1 replies.
- Flink SQL Stream Parser based on calcite - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/17 14:43:32 UTC, 4 replies.
- FlinkML - Fail to execute QuickStart example - posted by Thomas FOURNIER <th...@gmail.com> on 2016/10/17 16:22:10 UTC, 2 replies.
- ContinuousFileMonitoringFunction - deleting file after processing - posted by Maciek Próchniak <mp...@touk.pl> on 2016/10/18 07:40:32 UTC, 4 replies.
- Queryable state using JDBC - posted by Alberto Ramón <a....@gmail.com> on 2016/10/18 09:28:35 UTC, 5 replies.
- Read Apache Kylin from Apache Flink - posted by Alberto Ramón <a....@gmail.com> on 2016/10/18 17:40:24 UTC, 2 replies.
- Issue while restarting from SavePoint - posted by Anirudh Mallem <an...@247-inc.com> on 2016/10/18 21:07:46 UTC, 3 replies.
- Multiclass classification example - posted by Kürşat Kurt <ku...@kursatkurt.com> on 2016/10/18 22:32:19 UTC, 1 replies.
- native snappy library not available - posted by ro...@hyatt.com on 2016/10/19 11:07:17 UTC, 4 replies.
- Flink and factories? - posted by Sebastian Neef <ge...@mailbox.tu-berlin.de> on 2016/10/19 16:07:29 UTC, 4 replies.
- multiple processing of streams - posted by ro...@hyatt.com on 2016/10/19 16:28:40 UTC, 4 replies.
- NoClassDefFoundError on cluster with httpclient 4.5.2 - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/10/19 16:41:36 UTC, 3 replies.
- ApacheCon is now less than a month away! - posted by Rich Bowen <rb...@apache.org> on 2016/10/19 18:20:03 UTC, 0 replies.
- Feasability Question: Distributed FlinkCEP - posted by Lucas Konstantin Bärenfänger <lu...@stud.tu-darmstadt.de> on 2016/10/20 10:27:41 UTC, 1 replies.
- org.apache.flink.core.fs.Path error? - posted by Radu Tudoran <ra...@huawei.com> on 2016/10/20 11:17:45 UTC, 7 replies.
- Flink error: Too few memory segments provided - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/10/20 15:24:51 UTC, 5 replies.
- question for generic streams - posted by Radu Tudoran <ra...@huawei.com> on 2016/10/20 16:15:19 UTC, 1 replies.
- ValueState in RichCoFlatMap, possible 1.2-SNAPSHOT regression - posted by Seth Wiesman <sw...@mediamath.com> on 2016/10/20 21:22:42 UTC, 1 replies.
- Session windows - Evaluation of addition of element + window expires/gets discarded after some set time of inactivity - posted by Anchit Jatana <de...@gmail.com> on 2016/10/21 07:08:08 UTC, 6 replies.
- Unit testing a Kafka stream based application? - posted by Niels Basjes <Ni...@basjes.nl> on 2016/10/21 14:00:08 UTC, 2 replies.
- FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/21 14:42:01 UTC, 0 replies.
- About stateful transformations - posted by Juan Rodríguez Hortalá <ju...@gmail.com> on 2016/10/23 20:29:47 UTC, 4 replies.
- watermark trigger doesn't check whether element's timestamp is passed - posted by Manu Zhang <ow...@gmail.com> on 2016/10/24 04:30:24 UTC, 5 replies.
- Watermarks and window firing - posted by Paul Joireman <pa...@physiq.com> on 2016/10/24 14:56:35 UTC, 1 replies.
- Event time, watermarks and windows - posted by Paul Joireman <pa...@physiq.com> on 2016/10/24 15:02:16 UTC, 1 replies.
- Trigger evaluate - posted by Alberto Ramón <a....@gmail.com> on 2016/10/24 15:10:23 UTC, 5 replies.
- missing data in window.reduce() while apply() is ok - posted by Sendoh <un...@gmail.com> on 2016/10/24 16:03:06 UTC, 1 replies.
- Checkpointing large RocksDB state to S3 - tips? - posted by Josh <jo...@gmail.com> on 2016/10/24 17:06:22 UTC, 3 replies.
- Re: FlinkKafkaConsumerBase - Received confirmation for unknown checkpoint - posted by Aljoscha Krettek <al...@apache.org> on 2016/10/24 17:25:14 UTC, 4 replies.
- Elasticsearch Http Connector - posted by Madhukar Thota <ma...@gmail.com> on 2016/10/25 01:53:41 UTC, 4 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/10/25 06:28:16 UTC, 1 replies.
- Bug: Plan generation for Unions picked a ship strategy between binary plan operators. - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2016/10/25 10:33:40 UTC, 2 replies.
- Side effects or multiple sinks on streaming jobs? - posted by Luis Mariano Guerra <ma...@event-fabric.com> on 2016/10/25 13:30:53 UTC, 3 replies.
- Re: window-like use case - posted by Aljoscha Krettek <al...@apache.org> on 2016/10/25 14:41:31 UTC, 0 replies.
- TIMESTAMP TypeInformation - posted by Radu Tudoran <ra...@huawei.com> on 2016/10/25 14:45:51 UTC, 8 replies.
- Broadcast Config-Values through connected Configuration Stream - posted by Julian Bauß <ju...@gmail.com> on 2016/10/26 12:01:09 UTC, 5 replies.
- Retrieving a single element from a DataSet - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/10/26 12:41:51 UTC, 4 replies.
- Re: Reprocessing data in Flink / rebuilding Flink state - posted by Konstantin Gregor <ko...@tngtech.com> on 2016/10/26 13:06:52 UTC, 2 replies.
- Flushing the result of a groupReduce to a Sink before all reduces complete - posted by Paul Wilson <pa...@gmail.com> on 2016/10/26 17:07:01 UTC, 2 replies.
- Testing iterative data flows - posted by Ken Krugler <kk...@transpac.com> on 2016/10/26 21:10:32 UTC, 1 replies.
- Flink Cassandra Connector is not working - posted by NagaSaiPradeep <pa...@innominds.com> on 2016/10/27 05:13:04 UTC, 1 replies.
- Can we do batch writes on cassandra using flink while leveraging the locality? - posted by kant kodali <ka...@gmail.com> on 2016/10/27 08:17:29 UTC, 2 replies.
- emit partial state in window (streaming) - posted by Luis Mariano Guerra <ma...@event-fabric.com> on 2016/10/27 14:31:49 UTC, 1 replies.
- Yahoo! Streaming Benchmark with Flink - posted by Eric Fukuda <e....@gmail.com> on 2016/10/28 00:47:11 UTC, 2 replies.
- A custom FileInputFormat - posted by Niklas Semmler <ni...@inet.tu-berlin.de> on 2016/10/28 16:38:34 UTC, 0 replies.
- Elasticsearch sink: Java.lang.NoSuchMethodError: org.elasticsearch.common.settings.Settings.settingsBuilder - posted by PedroMrChaves <pe...@gmail.com> on 2016/10/28 16:59:43 UTC, 0 replies.
- Flink Metrics - InfluxDB + Grafana | Help with query influxDB query for Grafana to plot 'numRecordsIn' & 'numRecordsOut' for each operator/operation - posted by Anchit Jatana <de...@gmail.com> on 2016/10/28 21:53:25 UTC, 0 replies.
- Flink on YARN - Fault Tolerance | use case supported or not - posted by Anchit Jatana <de...@gmail.com> on 2016/10/28 22:13:27 UTC, 2 replies.
- Looping over a DataSet and accesing another DataSet - posted by otherwise777 <wo...@onzichtbaar.net> on 2016/10/30 07:25:55 UTC, 4 replies.
- Kafka + Flink, Basic Questions - posted by Dromit <dr...@gmail.com> on 2016/10/31 02:37:18 UTC, 1 replies.
- Kinesis Connector Dependency Problems - posted by Justin Yan <ju...@remitly.com> on 2016/10/31 19:22:25 UTC, 0 replies.