gt;
>>> .tag(*TAG_TYPE*, kvTypeTuple.f2)
>>>
>>>
>>>
>>>
>>> .tag(*TAG_KEY*, kvTypeTuple.f3)
>>>
>>>
>>>
>>>
>>> .addField(*FIELD*, kvTypeT
; you don't use a window function?
>
> Timo
>
>
> Am 08/03/17 um 02:59 schrieb Sam Huang:
>
> btw, the reduce function works well, I've printed out the data, and they
> are
> all correct. So are the timestamps and watermarks. And if I remove
> ".broadca
t;
>> Timo
>>
>>
>> Am 08/03/17 um 02:59 schrieb Sam Huang:
>>
>>> btw, the reduce function works well, I've printed out the data, and
>>> they are
>>> all correct. So are the timestamps and watermarks. And if I remove
>>
ct. So are the timestamps and watermarks. And if I remove
>> ".broadcast()", the data is successfully sinked.
>>
>> Any help?
>>
>>
>>
>> --
>> View this message in context: http://apache-flink-user-maili
>> ng-list-archive.2336050.n4.nabb
ed out the data, and they are
all correct. So are the timestamps and watermarks. And if I remove
".broadcast()", the data is successfully sinked.
Any help?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/window-function-not-working
hive.2336050.n4.nabble.com/window-function-not-working-when-control-stream-broadcast-tp12093p12094.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hi all,
I connected my data stream with my control stream and create event time
tumbling window, everything works fine. But when I add .broadcast()
function to the control stream, the window function doesn't work anymore.
I'm running that on my local, the code is here:
public static void main(St
