Re: Flink join stream where one stream is coming 5 minutes late

gt; For your case, maybe you can try adding a 5 mins delay on event times (and > watermarks) of the faster stream. > > Hope that helps. > > Best, > Xingcan > > >> On Nov 26, 2018, at 12:44 PM, Abhijeet Kumar > <mailto:abhijeet.ku...@sentienz.com>> wro

Re: Flink join stream where one stream is coming 5 minutes late

t; use case? > > On Mon 26 Nov, 2018, 5:53 PM Abhijeet Kumar <mailto:abhijeet.ku...@sentienz.com> wrote: > Hello Team, > > I've to join two stream where one stream is coming late. So, I planned doing > it by creating two windows, for first window the size will be 5

Flink join stream where one stream is coming 5 minutes late

;t know whether one window will sync with other or not because one is getting finished earlier and another is late. If there is a better way to achieve the same, please let me know. Thanks, Abhijeet Kumar Software Development Engineer, Sentienz Solutions Pvt Ltd Cognitive Data Platform

Re: Window is not working in streaming

Hi Taher, Thanks for the quick response but, if you tell the problem in my code then it would be a great help. Thanks, Abhijeet Kumar Software Development Engineer, Sentienz Solutions Pvt Ltd Cognitive Data Platform - Perceive the Data ! abhijeet.ku...@sentienz.com <mailto:abhijeet

Window is not working in streaming

e correct me if I'm wrong. Thanks, Abhijeet Kumar Software Development Engineer, Sentienz Solutions Pvt Ltd Cognitive Data Platform - Perceive the Data ! abhijeet.ku...@sentienz.com <mailto:abhijeet.ku...@sentienz.com> |www.sentienz.com <http://www.sentienz.com/> | Bengaluru

Re: error while joining two datastream

m2 as described at > https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/event_timestamp_extractors.html > > <https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/event_timestamp_extractors.html> > > On Thu, Nov 22, 2018 at 10:55 PM Abhijeet Kumar <ma

error while joining two datastream

I checked by printing them. So, the issue is in the code which I shared. Thanks in advance!!! Thanks, Abhijeet Kumar Software Development Engineer, Sentienz Solutions Pvt Ltd Cognitive Data Platform - Perceive the Data ! abhijeet.ku...@sentienz.com <mailto:abhijeet.ku...@senti

Kafka: Unable to retrieve any partitions with KafkaTopicsDescriptor

e.tasks.StreamTask.invoke(StreamTask.java:290) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:711) at java.lang.Thread.run(Unknown Source) I'm using Kafka --> 1.1.0 Flink --> 1.6.1 Kafka flink connector --> 1.6.1 Thanks, Abhijeet Kumar Software D

Flink Streaming sink to InfluxDB

.util.Preconditions at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 3 more