Hi Sam,
could you please also send the code of the timestamp/watermark assigner?
This could also affect things.
Best,
Aljoscha
On Thu, Mar 9, 2017, at 19:58, Sam Huang wrote:
> Hi Aljoscha,
>
> Here's the code:
> private static class DataFilterFunImpl extends
> RichCoFlatMapFunction {
Hi Aljoscha,
Here's the code:
private static class DataFilterFunImpl extends
RichCoFlatMapFunction {
private JSONParser parser;
private Map>
whiteListMap = new HashMap<>();
@Override
// tuple5(domain, device_type, type, key, count_or_sum)
public void flatM
Hi Sam,
could you please also send the code for the DataFilterFunImpl and
your timestamps/watermark assigner. That could help in figuring out
the problem.
Best,
Aljoscha
On Wed, Mar 8, 2017, at 19:56, Sam Huang wrote:
> Hi Timo,
>
> The window function sinks the data into InfluxDB, and
Hi Timo,
The window function sinks the data into InfluxDB, and it's not triggered.
If I comment the ".timeWindow", and print results after the reduce
function, it works
Code for window function is here:
private static class WindowFunImpl implements
WindowFunction {
@Override
public void a
Hi Sam,
could you explain the behavior a bit more? How does the window function
behave? Is it not triggered or what is the content? What is the result
if 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
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
".broadcast()", the data is successfully sinked.
Any help?
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.n
