You are viewing a plain text version of this content. The canonical link for it is here.
- How do I ensure binary comparisons are being used? - posted by ljwagerfield <la...@dmz.wagerfield.com> on 2017/01/01 14:13:02 UTC, 3 replies.
- Re: Problem with JodaTime - posted by Stephan Epping <st...@zweitag.de> on 2017/01/02 07:39:05 UTC, 0 replies.
- Flink streaming questions - posted by Henri Heiskanen <he...@gmail.com> on 2017/01/02 09:25:35 UTC, 4 replies.
- Programmatically get live values of accumulators - posted by Gwenhael Pasquiers <gw...@ericsson.com> on 2017/01/02 09:34:49 UTC, 2 replies.
- Hi, There is possibly an issue with EventTimeSessionWindows where a gap is specified for considering items in the same session. Here the logic is, if two adjacent items have a difference in event timestamps of more than the gap then the items are considered to be in separate session. The issue is, what happens if the gap between streaming records is never (or for a very long time) less than the session gap. This is likely to lead to a race condition. Is this a bug? How do we deal with this to process windows in finite time? Please could you suggest. Thanks. - posted by Sujit Sakre <su...@northgateps.com> on 2017/01/02 11:11:41 UTC, 1 replies.
- Re: Events are assigned to wrong window - posted by Nico <ni...@gmail.com> on 2017/01/02 14:04:42 UTC, 6 replies.
- 1.1.4 IntelliJ Problem - posted by Stephan Epping <st...@zweitag.de> on 2017/01/02 14:41:12 UTC, 7 replies.
- Re: Dynamic Scaling - posted by Jamie Grier <ja...@data-artisans.com> on 2017/01/02 19:48:10 UTC, 0 replies.
- Re: Set Parallelism and keyBy - posted by Jamie Grier <ja...@data-artisans.com> on 2017/01/02 20:48:35 UTC, 0 replies.
- Speedup of Flink Applications - posted by Hanna Prinz <ha...@yahoo.de> on 2017/01/03 11:25:27 UTC, 3 replies.
- [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) - posted by Robert Metzger <rm...@apache.org> on 2017/01/03 12:43:50 UTC, 1 replies.
- Cannot run using a savepoint with the same jar - posted by Al-Isawi Rami <Ra...@comptel.com> on 2017/01/03 22:44:32 UTC, 2 replies.
- Does Flink cluster security works in Flink 1.1.4 release? - posted by Zhangrucong <zh...@huawei.com> on 2017/01/04 06:25:34 UTC, 3 replies.
- Triggering a saveppoint failed the Job - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/01/04 09:52:28 UTC, 2 replies.
- Question about Scheduling of Batch Jobs - posted by Konstantin Knauf <ko...@tngtech.com> on 2017/01/04 12:30:34 UTC, 2 replies.
- Re: Reading worker-local input files - posted by Robert Schmidtke <ro...@gmail.com> on 2017/01/04 15:38:26 UTC, 0 replies.
- Re: Flink Checkpoint runs slow for low load stream - posted by Chakravarthy varaga <ch...@gmail.com> on 2017/01/04 15:51:18 UTC, 2 replies.
- RE: Serializing NULLs - posted by "Newport, Billy" <Bi...@gs.com> on 2017/01/04 18:25:11 UTC, 0 replies.
- Shared Object Instance over different RichMapFunctions - posted by Duck <kc...@protonmail.com> on 2017/01/04 20:05:12 UTC, 1 replies.
- Debugging Python-Api fails with NoClassDefFoundError - posted by Mathias Peters <ma...@gmx.org> on 2017/01/04 20:16:05 UTC, 3 replies.
- Rapidly failing job eventually causes "Not enough free slots" - posted by Shannon Carey <sc...@expedia.com> on 2017/01/05 00:21:16 UTC, 8 replies.
- Som question about Flink stream sql - posted by Hongyuhong <ho...@huawei.com> on 2017/01/05 03:40:26 UTC, 4 replies.
- Are heterogeneous DataStreams possible? - posted by ljwagerfield <la...@dmz.wagerfield.com> on 2017/01/05 05:40:35 UTC, 3 replies.
- Running into memory issues while running on Yarn - posted by Sachin Goel <sa...@gmail.com> on 2017/01/05 08:54:42 UTC, 1 replies.
- Re: Caching collected objects in .apply() - posted by Matt <dr...@gmail.com> on 2017/01/05 09:06:58 UTC, 2 replies.
- Sequential/ordered map - posted by Sebastian Neef <ge...@mailbox.tu-berlin.de> on 2017/01/05 10:51:48 UTC, 5 replies.
- Regarding ordering of events - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/01/05 10:57:06 UTC, 6 replies.
- 答复: Som question about Flink stream sql - posted by Hongyuhong <ho...@huawei.com> on 2017/01/05 11:00:08 UTC, 1 replies.
- Re: High virtual memory usage - posted by Paulo Cezar <pa...@gogeo.io> on 2017/01/05 12:34:25 UTC, 1 replies.
- Increasing parallelism skews/increases overall job processing time linearly - posted by Chakravarthy varaga <ch...@gmail.com> on 2017/01/05 13:21:37 UTC, 8 replies.
- Consistency guarantees on multiple sinks - posted by Nancy Estrada <na...@gmail.com> on 2017/01/05 13:24:39 UTC, 2 replies.
- Kafka KeyedStream source - posted by Niels Basjes <Ni...@basjes.nl> on 2017/01/05 17:37:57 UTC, 6 replies.
- failure-rate restart strategy not working? - posted by Shannon Carey <sc...@expedia.com> on 2017/01/05 19:50:53 UTC, 3 replies.
- re： Does Flink cluster security works in Flink 1.1.4 release? - posted by Zhangrucong <zh...@huawei.com> on 2017/01/06 03:19:52 UTC, 0 replies.
- HashMap/HashSet Serialization Issue - posted by Charith Wickramarachchi <ch...@gmail.com> on 2017/01/07 02:06:18 UTC, 4 replies.
- window function outputs two different values - posted by tao xiao <xi...@gmail.com> on 2017/01/07 12:30:43 UTC, 3 replies.
- keyBy called twice. Second time, INetAddress and Array[Byte] are empty - posted by Jonas <jo...@huntun.de> on 2017/01/08 02:28:48 UTC, 3 replies.
- Use Flink in Oozie Workflow - posted by Malte Schwarzer <im...@mieo.de> on 2017/01/08 12:01:09 UTC, 1 replies.
- Queryable State - posted by Dawid Wysakowicz <wy...@gmail.com> on 2017/01/08 15:43:02 UTC, 9 replies.
- Re: Changing parallelism - posted by abhishekrs <ab...@tetrationanalytics.com> on 2017/01/08 16:01:45 UTC, 1 replies.
- Joining two kafka streams - posted by "igor.berman" <ig...@gmail.com> on 2017/01/08 20:06:16 UTC, 2 replies.
- Regarding caching the evicted elements and re-emitting them to the next window - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/01/08 22:47:13 UTC, 2 replies.
- Passing App configuration file while running in YARN mode - posted by dinesh kumar <di...@gmail.com> on 2017/01/09 09:12:34 UTC, 0 replies.
- Kafka 09 consumer does not commit offsets - posted by Renjie Liu <li...@gmail.com> on 2017/01/09 10:51:59 UTC, 5 replies.
- Re: Continuous File monitoring not reading nested files - posted by Yassine MARZOUGUI <y....@mindlytix.com> on 2017/01/09 11:56:23 UTC, 10 replies.
- Re: Efficiently splitting a stream 3 ways - posted by Aljoscha Krettek <al...@apache.org> on 2017/01/09 13:41:20 UTC, 1 replies.
- Re: Finding the address of the jobmanager cluster leader - posted by Aljoscha Krettek <al...@apache.org> on 2017/01/09 13:42:12 UTC, 0 replies.
- Re: access to key in sink - posted by Aljoscha Krettek <al...@apache.org> on 2017/01/09 14:42:34 UTC, 1 replies.
- Re: Processing-Time Timers and Checkpoint State - posted by Aljoscha Krettek <al...@apache.org> on 2017/01/09 15:03:38 UTC, 1 replies.
- Sliding Event Time Window Processing: Window Function inconsistent behavior - posted by Sujit Sakre <su...@northgateps.com> on 2017/01/09 16:57:15 UTC, 6 replies.
- Re: 答复: [DISCUSS] Apache Flink 1.2.0 RC0 (Non-voting testing release candidate) - posted by Robert Metzger <rm...@apache.org> on 2017/01/10 14:16:38 UTC, 10 replies.
- Reading and Writing to S3 - posted by Samra Kasim <sa...@thehumangeo.com> on 2017/01/10 20:16:55 UTC, 5 replies.
- FLINK-5236. flink 1.1.3 and modifying the classpath to use another version of fasterxml. - posted by Estela Gallardo Zapata <eg...@oesia.com> on 2017/01/10 21:10:12 UTC, 1 replies.
- How to get help on ClassCastException when re-submitting a job - posted by Giuliano Caliari <gi...@gmail.com> on 2017/01/11 00:22:00 UTC, 10 replies.
- Custom writer with Rollingsink - posted by Biswajit Das <bi...@gmail.com> on 2017/01/11 02:13:32 UTC, 2 replies.
- manual scaling with savepoint - posted by gallenvara <ga...@gmail.com> on 2017/01/11 07:34:14 UTC, 2 replies.
- Re: About delta awareness caches - posted by Aljoscha Krettek <al...@apache.org> on 2017/01/11 11:28:10 UTC, 2 replies.
- Fault tolerance guarantees of Elasticsearch sink in flink-elasticsearch2? - posted by Andrew Roberts <ar...@fuze.com> on 2017/01/11 14:49:01 UTC, 3 replies.
- RE: Avro Parquet/Flink/Beam - posted by "Newport, Billy" <Bi...@gs.com> on 2017/01/11 15:20:15 UTC, 0 replies.
- Reading compressed XML data - posted by Sebastian Neef <ge...@mailbox.tu-berlin.de> on 2017/01/11 15:31:25 UTC, 1 replies.
- Making batches of small messages - posted by Gwenhael Pasquiers <gw...@ericsson.com> on 2017/01/11 16:16:47 UTC, 3 replies.
- Received an event in channel 0 while still having data from a record - posted by "Newport, Billy" <Bi...@gs.com> on 2017/01/11 20:16:27 UTC, 2 replies.
- Flink snapshotting to S3 - Timeout waiting for connection from pool - posted by Shannon Carey <sc...@expedia.com> on 2017/01/12 00:18:34 UTC, 8 replies.
- Flink on YARN: Cannot connect to JobManager - posted by Malte Schwarzer <im...@mieo.de> on 2017/01/12 15:13:47 UTC, 1 replies.
- Kafka topic partition skewness causes watermark not being emitted - posted by tao xiao <xi...@gmail.com> on 2017/01/12 16:28:25 UTC, 2 replies.
- Getting key from keyed stream - posted by Paul Joireman <pa...@physiq.com> on 2017/01/12 20:53:52 UTC, 2 replies.
- 1.1.4 on YARN - vcores change? - posted by Shannon Carey <sc...@expedia.com> on 2017/01/12 23:51:50 UTC, 3 replies.
- Objects accessible from all Flink nodes - posted by Matt <dr...@gmail.com> on 2017/01/13 02:11:38 UTC, 2 replies.
- the attribute order in sql 'select * from...' - posted by Hongyuhong <ho...@huawei.com> on 2017/01/13 08:54:12 UTC, 5 replies.
- Strategies for Complex Event Processing with guaranteed data consistency - posted by Kathleen Sharp <ka...@signavio.com> on 2017/01/13 10:04:58 UTC, 4 replies.
- Re: some questions about submit flink job on flink-yarn - posted by Till Rohrmann <tr...@apache.org> on 2017/01/13 10:21:43 UTC, 1 replies.
- Terminology: Split, Group and Partition - posted by Robert Schmidtke <ro...@gmail.com> on 2017/01/13 11:14:12 UTC, 6 replies.
- Apache Flink 1.1.4 - Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException - posted by Miguel Coimbra <mi...@gmail.com> on 2017/01/13 16:12:59 UTC, 5 replies.
- WindowFunction to push data from Kafka to S3 - posted by Samra Kasim <sa...@thehumangeo.com> on 2017/01/13 16:48:55 UTC, 1 replies.
- Can serialization be disabled between chains? - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/13 20:31:35 UTC, 5 replies.
- Deduplicate messages from Kafka topic - posted by ljwagerfield <la...@dmz.wagerfield.com> on 2017/01/14 17:11:34 UTC, 1 replies.
- Restart the job from a checkpoint - posted by tao xiao <xi...@gmail.com> on 2017/01/16 04:51:34 UTC, 3 replies.
- Measuring Execution Time - posted by Charith Wickramarachchi <ch...@gmail.com> on 2017/01/16 06:36:53 UTC, 4 replies.
- State in flink jobs - posted by Janardhan Reddy <ja...@olacabs.com> on 2017/01/16 07:47:26 UTC, 1 replies.
- Re: Multiple Sources and Isolated Analytics - posted by Jonas <jo...@huntun.de> on 2017/01/16 16:40:30 UTC, 0 replies.
- Re: How to read from a Kafka topic from the beginning - posted by Jonas <jo...@huntun.de> on 2017/01/16 18:26:38 UTC, 2 replies.
- Three input stream operator and back pressure - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/16 23:20:43 UTC, 5 replies.
- Help using HBase with Flink 1.1.4 - posted by Giuliano Caliari <gi...@gmail.com> on 2017/01/17 00:50:26 UTC, 6 replies.
- Release 1.2? - posted by de...@thomsonreuters.com on 2017/01/17 09:04:54 UTC, 7 replies.
- Possible JVM native memory leak - posted by Avihai Berkovitz <Av...@microsoft.com> on 2017/01/17 13:52:39 UTC, 2 replies.
- Flink Run command :Replace placeholder value in spring xml - posted by raikarsunil <rs...@gmail.com> on 2017/01/17 13:55:43 UTC, 4 replies.
- Zeppelin: Flink Kafka Connector - posted by Neil Derraugh <ne...@intellifylearning.com> on 2017/01/17 14:58:32 UTC, 7 replies.
- Re: 1.1.1: JobManager config endpoint no longer supplies port - posted by Shannon Carey <sc...@expedia.com> on 2017/01/17 22:14:22 UTC, 0 replies.
- Rolling sink parquet/Avro output - posted by Biswajit Das <bi...@gmail.com> on 2017/01/18 02:11:57 UTC, 4 replies.
- Window limitations on groupBy - posted by Raman Gupta <ro...@gmail.com> on 2017/01/18 14:39:59 UTC, 3 replies.
- Tasks crashing when using Kafka with different paralelism. - posted by Niels Basjes <Ni...@basjes.nl> on 2017/01/18 15:38:30 UTC, 3 replies.
- Kafka Fetch Failed / DisconnectException - posted by Jonas <jo...@huntun.de> on 2017/01/18 16:37:54 UTC, 2 replies.
- ApacheCon CFP closing soon (11 February) - posted by Rich Bowen <rb...@apache.org> on 2017/01/18 16:45:41 UTC, 0 replies.
- seeding a stream job - posted by Jared Stehler <ja...@intellifylearning.com> on 2017/01/18 17:35:27 UTC, 1 replies.
- Keep bootstrapped config updated with stream from Kafka - posted by Nihat Hosgur <nh...@gmail.com> on 2017/01/19 01:53:05 UTC, 2 replies.
- Flink SQL on JSON data without schema - posted by Nihat Hosgur <nh...@gmail.com> on 2017/01/19 01:59:51 UTC, 3 replies.
- Register a user scope metric in window reduce function - posted by tao xiao <xi...@gmail.com> on 2017/01/19 02:51:47 UTC, 1 replies.
- Cluster failure after zookeeper glitch. - posted by Andrew Ge Wu <an...@eniro.com> on 2017/01/19 12:16:57 UTC, 4 replies.
- NPE in JobManager - posted by Dave Marion <dl...@comcast.net> on 2017/01/19 16:57:06 UTC, 8 replies.
- Operational concerns with state (was Re: Window limitations on groupBy) - posted by Raman Gupta <ro...@gmail.com> on 2017/01/19 18:02:01 UTC, 2 replies.
- Rate-limit processing - posted by Florian König <fl...@micardo.com> on 2017/01/20 09:53:39 UTC, 4 replies.
- Streaming file source? - posted by Niels Basjes <Ni...@basjes.nl> on 2017/01/20 10:20:25 UTC, 2 replies.
- Apache Flink 1.1.4 - Gelly - LocalClusteringCoefficient - Returning values above 1? - posted by Miguel Coimbra <mi...@gmail.com> on 2017/01/20 18:31:49 UTC, 4 replies.
- Kryo Deserializer - posted by Biswajit Das <bi...@gmail.com> on 2017/01/21 01:15:53 UTC, 1 replies.
- machine learning choice - posted by community tech <co...@dnsbed.com> on 2017/01/22 09:46:37 UTC, 1 replies.
- accessing flink HA cluster with scala shell/zeppelin notebook - posted by Maciek Próchniak <mp...@touk.pl> on 2017/01/22 14:58:20 UTC, 1 replies.
- Expected behaviour of windows - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/01/22 22:07:53 UTC, 4 replies.
- weird client failure/timeout - posted by "Abhishek R. Singh" <ab...@tetrationanalytics.com> on 2017/01/23 08:41:28 UTC, 8 replies.
- Count window on partition - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/23 10:05:34 UTC, 2 replies.
- Flink configuration - posted by Nancy Estrada <na...@gmail.com> on 2017/01/23 10:49:23 UTC, 2 replies.
- Improving Flink performance - posted by Jonas <jo...@huntun.de> on 2017/01/23 11:08:04 UTC, 4 replies.
- Queryable State and Windows - posted by Joe Olson <te...@nododos.com> on 2017/01/23 13:46:01 UTC, 1 replies.
- Is there any difference between Checkpointed and CheckpointedAsynchronously? - posted by Tao Meng <oa...@gmail.com> on 2017/01/23 14:36:00 UTC, 1 replies.
- Custom Partitioning and windowing questions/concerns - posted by "Katsipoulakis, Nikolaos Romanos" <ka...@cs.pitt.edu> on 2017/01/23 16:50:43 UTC, 5 replies.
- Better way to read several stream sources - posted by Sendoh <un...@gmail.com> on 2017/01/23 17:55:47 UTC, 3 replies.
- TestStreamEnvironment: await last flush of processing time-based windows - posted by Steven Ruppert <st...@fullcontact.com> on 2017/01/23 22:19:33 UTC, 2 replies.
- multi tenant workflow execution - posted by Chen Qin <qi...@gmail.com> on 2017/01/23 23:41:11 UTC, 3 replies.
- How to get top N elements in a DataSet? - posted by Ivan Mushketyk <iv...@gmail.com> on 2017/01/24 09:10:49 UTC, 6 replies.
- Problem with state Apache Flink 1.2.0 RC0 - posted by Salou Guillaume <g....@gmail.com> on 2017/01/24 10:08:29 UTC, 3 replies.
- Improving Flink Performance - posted by Jonas <jo...@huntun.de> on 2017/01/24 11:15:27 UTC, 11 replies.
- Why is IdentityObjectIntMap.get called so often? - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/24 11:47:07 UTC, 1 replies.
- Kafka data not read in FlinkKafkaConsumer09 second time from command line - posted by Sujit Sakre <su...@northgateps.com> on 2017/01/24 13:27:49 UTC, 4 replies.
- REST api: how to upload jar? - posted by Cliff Resnick <cr...@gmail.com> on 2017/01/24 21:54:50 UTC, 2 replies.
- Flink with Yarn on MapR - posted by "ani.desh1512" <an...@gmail.com> on 2017/01/24 23:12:25 UTC, 1 replies.
- How to configure max parallelism? - posted by Gyula Fóra <gy...@gmail.com> on 2017/01/25 08:05:55 UTC, 2 replies.
- When is the StreamPartitioner selectChannel() method called - posted by "Katsipoulakis, Nikolaos Romanos" <ka...@cs.pitt.edu> on 2017/01/25 13:12:44 UTC, 3 replies.
- Re: benchmarking flink streaming - posted by Stephan Ewen <se...@apache.org> on 2017/01/25 15:11:00 UTC, 3 replies.
- Issues while restarting a job on HA cluster - posted by "ani.desh1512" <an...@gmail.com> on 2017/01/25 16:10:02 UTC, 2 replies.
- Debugging, logging and measuring operator subtask performance - posted by Dominik Safaric <do...@gmail.com> on 2017/01/25 18:51:31 UTC, 1 replies.
- Flink dependencies shading - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/25 19:24:42 UTC, 2 replies.
- CEP and KeyedStreams doubt - posted by Oriol <or...@gmail.com> on 2017/01/26 12:04:54 UTC, 1 replies.
- State Descriptors / Queryable State Question - posted by Joe Olson <te...@nododos.com> on 2017/01/26 13:10:43 UTC, 1 replies.
- User configuration - posted by Dmitry Golubets <dg...@gmail.com> on 2017/01/26 16:38:47 UTC, 2 replies.
- start-cluster.sh issue - posted by Lior Amar <li...@parallelmachines.com> on 2017/01/26 17:10:19 UTC, 1 replies.
- Re: Many operations cause StackOverflowError with AWS EMR YARN cluster - posted by Geoffrey Mon <ge...@gmail.com> on 2017/01/26 19:33:04 UTC, 0 replies.
- Dummy DataStream - posted by Duck <kc...@protonmail.com> on 2017/01/26 20:07:43 UTC, 1 replies.
- parallelism for window operations - posted by Ovidiu-Cristian MARCU <ov...@inria.fr> on 2017/01/26 21:30:00 UTC, 0 replies.
- Proper ways to write iterative DataSets with dependencies - posted by Li Peng <li...@elementanalytics.com> on 2017/01/26 21:34:19 UTC, 0 replies.
- .keyBy() on ConnectedStream - posted by Matt <dr...@gmail.com> on 2017/01/27 06:21:04 UTC, 3 replies.
- Re: parallelism for window operations - posted by Fabian Hueske <fh...@gmail.com> on 2017/01/27 09:13:48 UTC, 2 replies.
- Datastream - writeAsCsv creates empty File - posted by Nico <ni...@gmail.com> on 2017/01/27 10:06:40 UTC, 1 replies.
- setParallelism() for addSource() in streaming - posted by Sendoh <un...@gmail.com> on 2017/01/27 10:09:34 UTC, 1 replies.
- TaskManager randomly dies - posted by Malte Schwarzer <im...@mieo.de> on 2017/01/27 15:13:28 UTC, 1 replies.
- Applying the same operator twice on a windowed stream - posted by Abdul Salam Shaikh <ab...@gmail.com> on 2017/01/27 20:27:16 UTC, 2 replies.
- Cyclic ConnectedStream - posted by Matt <dr...@gmail.com> on 2017/01/28 17:39:57 UTC, 4 replies.
- Regarding Flink as a web service - posted by Sam Hawk <dj...@gmail.com> on 2017/01/29 21:35:57 UTC, 2 replies.
- Calling external services/databases from DataStream API - posted by Diego Fustes Villadóniga <df...@oesia.com> on 2017/01/30 11:56:58 UTC, 4 replies.
- allowed lateness on windowed join? - posted by Saiph Kappa <sa...@gmail.com> on 2017/01/30 16:38:27 UTC, 0 replies.
- Connection refused error when writing to socket? - posted by Li Peng <li...@elementanalytics.com> on 2017/01/31 03:15:02 UTC, 2 replies.
- Re: Flink survey by data Artisans - posted by Mike Winters <mi...@data-artisans.com> on 2017/01/31 10:27:38 UTC, 0 replies.
- Cannot cancel job with savepoint due to timeout - posted by Bruno Aranda <ba...@apache.org> on 2017/01/31 14:47:40 UTC, 0 replies.
- Bug in Table api CsvTableSink - posted by Flavio Pompermaier <po...@okkam.it> on 2017/01/31 15:25:04 UTC, 3 replies.
- readFile - Continuous file processing - posted by Nancy Estrada <na...@gmail.com> on 2017/01/31 17:17:31 UTC, 1 replies.