You are viewing a plain text version of this content. The canonical link for it is here.
- Running yarn-session a kerberos secured Yarn/HBase cluster. - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/01 07:47:33 UTC, 3 replies.
- Flink Streaming API - posted by Siva <sb...@gmail.com> on 2016/08/01 07:48:50 UTC, 2 replies.
- Scala Table API with Java POJO - posted by "Dong-iL, Kim" <ki...@gmail.com> on 2016/08/01 08:18:18 UTC, 7 replies.
- Re: [VOTE] Release Apache Flink 1.1.0 (RC1) - posted by Stephan Ewen <se...@apache.org> on 2016/08/01 08:27:58 UTC, 0 replies.
- Re: TimeWindowAll doeesn't assign properly - posted by Sendoh <un...@gmail.com> on 2016/08/01 08:36:32 UTC, 3 replies.
- Re: Flink and SQL - posted by Timo Walther <tw...@apache.org> on 2016/08/01 08:39:16 UTC, 0 replies.
- Re: tumbling time window, date boundary and timezone - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/08/01 09:59:28 UTC, 0 replies.
- How to read AVRO data from Kafka using Flink - posted by "Alam, Zeeshan" <Ze...@fmr.com> on 2016/08/01 12:50:38 UTC, 3 replies.
- Re: Flink - Once and once processing - posted by Till Rohrmann <tr...@apache.org> on 2016/08/01 13:27:44 UTC, 1 replies.
- Re: how does flink assign windows to task - posted by Till Rohrmann <tr...@apache.org> on 2016/08/01 13:31:59 UTC, 1 replies.
- Loss of TaskManager Error - posted by Debaditya Roy <ro...@gmail.com> on 2016/08/01 13:49:22 UTC, 2 replies.
- partial savepoints/combining savepoints - posted by Claudia Wegmann <c....@kasasi.de> on 2016/08/01 13:49:49 UTC, 5 replies.
- Re: Reprocessing data in Flink / rebuilding Flink state - posted by Josh <jo...@gmail.com> on 2016/08/01 15:06:40 UTC, 4 replies.
- Window Functions with Incremental Aggregation - posted by "Ciar, David B." <dc...@ceh.ac.uk> on 2016/08/01 16:22:35 UTC, 1 replies.
- Re: Container running beyond physical memory limits when processing DataStream - posted by Jack Huang <ja...@mz.com> on 2016/08/01 17:48:06 UTC, 4 replies.
- OutOfMemoryError - posted by Paulo Cezar <pa...@gogeo.io> on 2016/08/01 19:15:10 UTC, 2 replies.
- Re: CEP and Within Clause - posted by Aljoscha Krettek <al...@apache.org> on 2016/08/01 21:12:50 UTC, 4 replies.
- Flink Kafka Consumer Behaviour - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/02 11:26:39 UTC, 7 replies.
- What is the recommended way to read AVRO data from Kafka using flink. - posted by "Alam, Zeeshan" <Ze...@fmr.com> on 2016/08/02 14:04:45 UTC, 4 replies.
- Programmatically Creating a Flink Cluster On YARN - posted by "Bostow, Ben" <be...@here.com> on 2016/08/02 21:09:17 UTC, 2 replies.
- What is output from DataSet.print()? - posted by Jon Yeargers <jo...@cedexis.com> on 2016/08/03 00:30:31 UTC, 1 replies.
- Flink Kafka more consumers than partitions - posted by neo21 zerro <ne...@yahoo.com> on 2016/08/03 08:14:38 UTC, 8 replies.
- Reading from latest offset in kafka consumer on restart - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/03 09:26:10 UTC, 6 replies.
- restart strategy with checkpointing - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/03 10:23:25 UTC, 1 replies.
- Kakfa batches - posted by Prabhu V <vp...@gmail.com> on 2016/08/03 12:07:33 UTC, 3 replies.
- Parallel execution on AllWindows - posted by Andrew Ge Wu <an...@eniro.com> on 2016/08/03 12:09:58 UTC, 4 replies.
- Flink Batch Processing with Kafka - posted by "Alam, Zeeshan" <Ze...@fmr.com> on 2016/08/03 12:21:46 UTC, 1 replies.
- Generate timestamps in front of event for event time windows - posted by Jason Brelloch <jb...@gmail.com> on 2016/08/03 18:29:36 UTC, 3 replies.
- How to avoid path conflict in zookeeper/HDFS - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/08/04 00:53:15 UTC, 2 replies.
- Parsing source JSON String as Scala Case Class - posted by Jack Huang <ja...@mz.com> on 2016/08/04 01:56:58 UTC, 2 replies.
- set yarn jvm options - posted by Prabhu V <vp...@gmail.com> on 2016/08/04 02:03:04 UTC, 1 replies.
- Regarding QueryableState - posted by vinay patil <vi...@gmail.com> on 2016/08/04 09:53:07 UTC, 3 replies.
- Re: set flink yarn jvm options - posted by Prabhu V <vp...@gmail.com> on 2016/08/04 18:10:39 UTC, 4 replies.
- Having a single copy of an object read in a RichMapFunction - posted by Theodore Vasiloudis <th...@gmail.com> on 2016/08/05 00:56:10 UTC, 5 replies.
- Facing Issues while migrating to S3A - posted by vinay patil <vi...@gmail.com> on 2016/08/05 09:32:53 UTC, 3 replies.
- Re: Flink kafka group question - posted by Mojes <mo...@ymail.com> on 2016/08/05 12:35:18 UTC, 2 replies.
- How to get latest offsets with FlinkKafkaConsumer - posted by "Mao, Wei" <we...@intel.com> on 2016/08/05 12:36:01 UTC, 4 replies.
- Flink 1.1 event-time windowing changes from 1.0.3 - posted by Adam Warski <ad...@warski.org> on 2016/08/06 10:33:18 UTC, 2 replies.
- Flink timestamps - posted by Davood Rafiei <ra...@gmail.com> on 2016/08/06 11:47:26 UTC, 1 replies.
- Output of KeyBy->TimeWindow->Reduce? - posted by Jon Yeargers <jo...@cedexis.com> on 2016/08/07 15:28:21 UTC, 1 replies.
- max aggregator dosen't work as expected - posted by Claudia Wegmann <c....@kasasi.de> on 2016/08/08 12:26:52 UTC, 3 replies.
- Re: Killing Yarn Session Leaves Lingering Flink Jobs - posted by Konstantin Gregor <ko...@tngtech.com> on 2016/08/08 13:16:40 UTC, 0 replies.
- Using RabbitMQ Sinks - posted by Paul Joireman <pa...@physiq.com> on 2016/08/08 14:33:37 UTC, 3 replies.
- [ANNOUNCE] Flink 1.1.0 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/08 16:36:26 UTC, 4 replies.
- Kafka producer connector - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/08 17:16:02 UTC, 1 replies.
- Classloader issue using AvroParquetInputFormat via HadoopInputFormat - posted by Shannon Carey <sc...@expedia.com> on 2016/08/08 19:46:45 UTC, 0 replies.
- Re: Classloader issue using AvroParquetInputFormat via HadoopInputFormat - posted by Shannon Carey <sc...@expedia.com> on 2016/08/08 21:08:55 UTC, 4 replies.
- Flink 1.1.0 : Hadoop 1/2 compatibility mismatch - posted by "LINZ, Arnaud" <AL...@bouyguestelecom.fr> on 2016/08/09 07:45:25 UTC, 4 replies.
- specify user name when connecting to hdfs - posted by "Dong-iL, Kim" <ki...@gmail.com> on 2016/08/09 09:00:42 UTC, 3 replies.
- Release notes 1.1.0? - posted by Andrew Ge Wu <an...@eniro.com> on 2016/08/09 09:32:57 UTC, 16 replies.
- Flink : CEP processing - posted by M Singh <ma...@yahoo.com> on 2016/08/09 16:17:51 UTC, 8 replies.
- Window function - iterator data - posted by Paul Joireman <pa...@physiq.com> on 2016/08/09 20:22:51 UTC, 2 replies.
- Connected Streams - Controlling Order of arrival on the two streams - posted by Sameer W <sa...@axiomine.com> on 2016/08/09 23:31:47 UTC, 1 replies.
- 回复：Re: Using RabbitMQ Sinks - posted by ri...@sina.cn on 2016/08/10 10:27:52 UTC, 1 replies.
- Firing windows multiple times - posted by Shannon Carey <sc...@expedia.com> on 2016/08/10 16:04:54 UTC, 15 replies.
- Maintaining global variables. Best practices. - posted by Dima Arbuzin <ar...@gmail.com> on 2016/08/10 16:18:40 UTC, 1 replies.
- Multiple Partitions (Source Functions) -> Event Time -> Watermarks -> Trigger - posted by Sameer W <sa...@axiomine.com> on 2016/08/10 19:11:17 UTC, 4 replies.
- flink no class found error - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/10 19:46:56 UTC, 7 replies.
- flink - Working with State example - posted by "Ramanan, Buvana (Nokia - US)" <bu...@nokia-bell-labs.com> on 2016/08/10 20:03:57 UTC, 10 replies.
- Get minimum or maximum value from a Dataset - posted by Punit Naik <na...@gmail.com> on 2016/08/10 21:06:21 UTC, 1 replies.
- Within interval for CEP - Wall Clock based or Event Timestamp based? - posted by Sameer W <sa...@axiomine.com> on 2016/08/10 22:39:49 UTC, 3 replies.
- flink shaded jar in yarn - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/10 23:17:26 UTC, 2 replies.
- [ANNOUNCE] Flink 1.1.1 Released - posted by Ufuk Celebi <uc...@apache.org> on 2016/08/11 08:00:57 UTC, 0 replies.
- ValueState is missing - posted by "Dong-iL, Kim" <ki...@gmail.com> on 2016/08/11 09:55:53 UTC, 13 replies.
- Strange behaviour of the flatMap Collector - posted by Yassin Marzouki <ya...@gmail.com> on 2016/08/11 12:29:22 UTC, 2 replies.
- Unit tests failing, losing stream contents - posted by "Ciar, David B." <dc...@ceh.ac.uk> on 2016/08/11 15:47:50 UTC, 4 replies.
- Is java.sql.Timestamp fully suported in Flink SQL? - posted by Davran Muzafarov <da...@streamingedge.com> on 2016/08/11 16:28:56 UTC, 1 replies.
- Using CustomPartitionerWrapper with KeyedStream - posted by Philippe Caparroy <ph...@orange.fr> on 2016/08/11 20:53:40 UTC, 0 replies.
- Does Flink DataStreams using combiners? - posted by Elias Levy <fe...@gmail.com> on 2016/08/12 00:51:49 UTC, 4 replies.
- Window not emitting output after upgrade to Flink 1.1.1 - posted by Yassine Marzougui <ya...@gmail.com> on 2016/08/12 08:30:35 UTC, 2 replies.
- Re: Using CustomPartitionerWrapper with KeyedStream - posted by Maximilian Michels <mx...@apache.org> on 2016/08/12 10:06:46 UTC, 1 replies.
- Updating stored window data - posted by Paul Joireman <pa...@physiq.com> on 2016/08/12 15:18:06 UTC, 2 replies.
- 1.1.1: JobManager config endpoint no longer supplies port - posted by Shannon Carey <sc...@expedia.com> on 2016/08/12 16:03:44 UTC, 4 replies.
- Ordering expectations of data - posted by Bart Wyatt <ba...@dsvolition.com> on 2016/08/12 20:48:17 UTC, 1 replies.
- Re: No output when using event time with multiple Kafka partitions - posted by Yassine Marzougui <ya...@gmail.com> on 2016/08/15 09:13:14 UTC, 0 replies.
- Kafka topic with an empty parition : parallelism issue and Timestamp monotony violated - posted by Yassine Marzougui <ya...@gmail.com> on 2016/08/15 10:38:15 UTC, 3 replies.
- Enriching events with data from external http resources - posted by Maciek Próchniak <mp...@touk.pl> on 2016/08/15 18:52:10 UTC, 2 replies.
- Error joining with Python API - posted by davis k <fo...@gmail.com> on 2016/08/15 20:14:27 UTC, 4 replies.
- Performance issues - is my topology not setup properly? - posted by Jon Yeargers <jo...@cedexis.com> on 2016/08/15 20:22:21 UTC, 1 replies.
- Running on AWS/EMR/Yarn - where is the WebUI? - posted by Jon Yeargers <jo...@cedexis.com> on 2016/08/15 21:24:02 UTC, 1 replies.
- flink on yarn - Fatal error in AM: The ContainerLaunchContext was not set - posted by Miroslav Gajdoš <mi...@firma.seznam.cz> on 2016/08/16 09:00:29 UTC, 8 replies.
- Azure Blob Storage Connector - posted by MIkkel Islay <my...@gmail.com> on 2016/08/16 12:37:09 UTC, 3 replies.
- TumblingEventTimeWindows with time characteristic set to 'ProcessingTime' - posted by Al-Isawi Rami <Ra...@comptel.com> on 2016/08/16 12:42:28 UTC, 3 replies.
- Cannot use WindowedStream.fold with EventTimeSessionWindows - posted by Jack Huang <ja...@mz.com> on 2016/08/17 01:21:52 UTC, 2 replies.
- applying where after group by in dataset - posted by subash basnet <ya...@gmail.com> on 2016/08/17 09:29:44 UTC, 1 replies.
- counting elements in datastream - posted by subash basnet <ya...@gmail.com> on 2016/08/17 14:39:14 UTC, 3 replies.
- Sorting in datastream - posted by subash basnet <ya...@gmail.com> on 2016/08/17 16:22:59 UTC, 2 replies.
- off heap memory deallocation - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/17 18:01:26 UTC, 1 replies.
- Compress DataSink Output - posted by Wesley Kerr <we...@gmail.com> on 2016/08/18 00:13:03 UTC, 2 replies.
- problem running flink using remote environment - posted by Baswaraj Kasture <ba...@persistent.com> on 2016/08/18 06:02:21 UTC, 1 replies.
- checkpoint state keeps on increasing - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/18 06:11:22 UTC, 2 replies.
- Batch jobs with a very large number of input splits - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/18 11:56:25 UTC, 3 replies.
- Checking for existance of output directory/files before running a batch job - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/18 12:02:34 UTC, 6 replies.
- Flink redshift table lookup and updates - posted by Harshith Chennamaneni <hc...@hiya.com> on 2016/08/19 03:20:25 UTC, 1 replies.
- Flink Cluster setup - posted by "Alam, Zeeshan" <Ze...@fmr.com> on 2016/08/19 13:50:00 UTC, 1 replies.
- How to share text file across tasks at run time in flink. - posted by Baswaraj Kasture <kb...@gmail.com> on 2016/08/20 10:33:14 UTC, 7 replies.
- Question tableEnv.toDataSet : Table to DataSet> - posted by Camelia Elena Ciolac <ca...@chalmers.se> on 2016/08/20 19:37:27 UTC, 1 replies.
- Re: Question tableEnv.toDataSet : Table to DataSet> - posted by Suneel Marthi <sm...@apache.org> on 2016/08/20 19:59:55 UTC, 0 replies.
- flink-shaded-hadoop - posted by ri...@sina.cn on 2016/08/22 05:47:59 UTC, 1 replies.
- Contain topic name in the stream - posted by Sendoh <un...@gmail.com> on 2016/08/22 08:58:46 UTC, 1 replies.
- Complex batch workflow needs (too) much time to create executionPlan - posted by Markus Nentwig <ne...@informatik.uni-leipzig.de> on 2016/08/22 11:50:12 UTC, 1 replies.
- how to get rid of duplicate rows group by in DataStream - posted by subash basnet <ya...@gmail.com> on 2016/08/22 15:58:28 UTC, 4 replies.
- "Failed to retrieve JobManager address" in Flink 1.1.1 with JM HA - posted by Hironori Ogibayashi <og...@gmail.com> on 2016/08/23 05:24:38 UTC, 6 replies.
- FLINK-4329 fix version - posted by Yassine Marzougui <ya...@gmail.com> on 2016/08/23 10:28:45 UTC, 2 replies.
- Default timestamps for Event Time when no Watermark Assigner used? - posted by Sameer W <sa...@axiomine.com> on 2016/08/23 10:42:21 UTC, 3 replies.
- Threading Model for Kinesis - posted by Sameer W <sa...@axiomine.com> on 2016/08/23 10:50:27 UTC, 6 replies.
- Setting up zeppelin with flink - posted by Frank Dekervel <ke...@gmail.com> on 2016/08/23 12:09:35 UTC, 10 replies.
- JobManager HA without Distributed FileSystem - posted by Konstantin Knauf <ko...@tngtech.com> on 2016/08/23 16:36:06 UTC, 3 replies.
- WordCount w/ YARN and EMR local filesystem and/or HDFS - posted by "Foster, Craig" <fo...@amazon.com> on 2016/08/23 17:54:42 UTC, 6 replies.
- sharded state, 2-step operation - posted by Michael Warnock <mi...@ripple.com> on 2016/08/23 18:03:42 UTC, 4 replies.
- How to get latency info from benchmark - posted by Eric Fukuda <e....@gmail.com> on 2016/08/24 01:25:02 UTC, 4 replies.
- Dealing with Multiple sinks in Flink - posted by Vinay Patil <vi...@gmail.com> on 2016/08/24 02:20:46 UTC, 8 replies.
- Re: How large a Flink cluster can have? - posted by Alexis Gendronneau <a....@gmail.com> on 2016/08/24 12:13:25 UTC, 1 replies.
- Setting number of TaskManagers - posted by "Foster, Craig" <fo...@amazon.com> on 2016/08/24 19:04:02 UTC, 3 replies.
- How to set a custom JAVA_HOME when run flink on YARN? - posted by Renkai <ga...@gmail.com> on 2016/08/25 03:52:09 UTC, 4 replies.
- Regarding Global Configuration in Flink - posted by Janardhan Reddy <ja...@olacabs.com> on 2016/08/25 04:33:16 UTC, 1 replies.
- Delaying starting the jobmanager in yarn? - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/25 08:24:07 UTC, 5 replies.
- Running multiple jobs on yarn (without yarn-session) - posted by Niels Basjes <Ni...@basjes.nl> on 2016/08/25 10:04:23 UTC, 3 replies.
- Re: Elasticsearch connector and number of shards - posted by Flavio Pompermaier <po...@okkam.it> on 2016/08/25 14:40:17 UTC, 0 replies.
- Flink long-running YARN configuration - posted by "Foster, Craig" <fo...@amazon.com> on 2016/08/25 15:02:19 UTC, 4 replies.
- Handling Kafka DeserializationSchema() exceptions - posted by Yassine Marzougui <ya...@gmail.com> on 2016/08/25 18:05:50 UTC, 2 replies.
- Kafka and Flink's partitions - posted by rss rss <rs...@gmail.com> on 2016/08/25 18:21:24 UTC, 2 replies.
- Enabling Encryption between slaves in Flink - posted by Vinay Patil <vi...@gmail.com> on 2016/08/25 18:48:38 UTC, 0 replies.
- Kinesis connector - Iterator expired exception - posted by Josh <jo...@gmail.com> on 2016/08/26 11:20:55 UTC, 3 replies.
- Flink WebUI on YARN behind firewall - posted by Trevor Grant <tr...@gmail.com> on 2016/08/26 17:52:27 UTC, 3 replies.
- Handle deserialization error - posted by Jack Huang <ja...@mz.com> on 2016/08/27 00:37:04 UTC, 1 replies.
- Apache siddhi into Flink - posted by "Aparup Banerjee (apbanerj)" <ap...@cisco.com> on 2016/08/27 06:23:30 UTC, 10 replies.
- Accessing state in connected streams - posted by aris kol <gi...@hotmail.com> on 2016/08/27 22:13:07 UTC, 9 replies.
- Programatically collect taskmanagers details from Job Manager - posted by Sreejith S <sr...@gmail.com> on 2016/08/28 13:03:38 UTC, 3 replies.
- different Kafka serialization for keyed and non keyed messages - posted by rss rss <rs...@gmail.com> on 2016/08/28 16:16:39 UTC, 1 replies.
- Bisecting K-Means - Working with intermediate results as DataSets - posted by Adrian Bartnik <ba...@campus.tu-berlin.de> on 2016/08/28 21:15:55 UTC, 0 replies.
- Dynamic scaling in flink - posted by Abhishek Agarwal <ab...@gmail.com> on 2016/08/29 07:00:58 UTC, 3 replies.
- Joda exclude in java quickstart maven archetype - posted by Flavio Pompermaier <po...@okkam.it> on 2016/08/29 09:00:58 UTC, 1 replies.
- flink datastream reduce - posted by ri...@sina.cn on 2016/08/29 09:08:12 UTC, 1 replies.
- Flink JMX - posted by Sreejith S <sr...@gmail.com> on 2016/08/29 10:09:46 UTC, 5 replies.
- Resource isolation in flink among multiple jobs - posted by Abhishek Agarwal <ab...@gmail.com> on 2016/08/29 11:41:13 UTC, 3 replies.
- Parquet sink - posted by Egor Mateshuk <eg...@ya.ru> on 2016/08/29 11:49:35 UTC, 0 replies.
- Submitting watermarks through a Kinesis stream - posted by Steffen Hausmann <st...@hausmann-family.de> on 2016/08/29 13:30:14 UTC, 2 replies.
- Gracefully Stopping Streaming Job Programmatically in LocalStreamEnvironment - posted by Konstantin Knauf <ko...@tngtech.com> on 2016/08/29 14:20:44 UTC, 2 replies.
- Data Transfer between TM should be encrypted - posted by vinay patil <vi...@gmail.com> on 2016/08/29 16:12:02 UTC, 5 replies.
- Cannot pass objects with null-valued fields to the next operator - posted by Jack Huang <ja...@mz.com> on 2016/08/29 18:04:24 UTC, 1 replies.
- CountTrigger FIRE or FIRE_AND_PURGE - posted by Paul Joireman <pa...@physiq.com> on 2016/08/29 22:25:46 UTC, 2 replies.
- flink dataStream operate dataSet - posted by ri...@sina.cn on 2016/08/30 14:31:01 UTC, 0 replies.
- ApacheCon Seville CFP closes September 9th - posted by Rich Bowen <rb...@apache.org> on 2016/08/30 15:03:41 UTC, 0 replies.
- Setting EventTime window width using stream data - posted by Paul Joireman <pa...@physiq.com> on 2016/08/30 19:28:29 UTC, 2 replies.
- "select as" in Flink SQL - posted by Davran Muzafarov <da...@streamingedge.com> on 2016/08/30 19:49:06 UTC, 2 replies.
- Not able to query : Queryable State - posted by Ashish Tadose <as...@gmail.com> on 2016/08/31 10:39:36 UTC, 3 replies.
- FlinkML ALS matrix factorization: java.io.IOException: Thread 'SortMerger Reading Thread' terminated due to an exception: null - posted by ANDREA SPINA <74...@studenti.unimore.it> on 2016/08/31 12:40:13 UTC, 2 replies.
- Re: Streaming - memory management - posted by vinay patil <vi...@gmail.com> on 2016/08/31 16:15:40 UTC, 1 replies.
- Wikiedit QuickStart with Kinesis - posted by "Foster, Craig" <fo...@amazon.com> on 2016/08/31 17:34:12 UTC, 0 replies.