Implementing CountWindow in Window Join and continuous joining for 2 datastreams

2018-02-23 Thread Tay Zhen Shen
Hi , I'm currently working on Flink with a simple stock market analysis.Basically i need to have the sum of 100 element (Count Window)(sliding size : 10) and also sum of 20 element(Count Window) (sliding size: 10) respectively. I realised that i have to calculate the both sum on 2 different st

Fw: Question on Flink on Window

2017-10-03 Thread Tay Zhen Shen
From: Tay Zhen Shen Sent: Tuesday, 3 October, 2017 1:03 PM To: user@flink.apache.org Subject: Question on Flink on Window Hi, I'm currently trying to setup Flink 1.3.2 on my Windows 10. When i was running the start-local.bat file, the command prompt

Could not connect to netcat on SocketStreamWordCount example

2017-10-09 Thread Tay Zhen Shen
Hi, As per guided by the Flink official page, i'm trying to run the SocketStreamWordCount example, $ nc -l 9000 however, after i run the netcat using the command, and i try to run bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000 the netcat console has return a statemen