Can you post your whole program (both versions if possible)? Otherwise I have only a wild guess: A common mistake is not to assign the stream variable properly:
DataStream ds = ... ds = ds.APPLY_FUNCTIONS ds.APPLY_MORE_FUNCTIONS In your code example, the assignment is missing -- but maybe it just missing in your email. -Matthias On 08/31/2015 04:38 PM, Dipl.-Inf. Rico Bergmann wrote: > Hi! > > I have a problem that I cannot really track down. I'll try to describe > the issue. > > My streaming flink program computes something. At the end I'm doing the > follwing on my DataStream ds > ds.window(2, TimeUnit.SECONDS) > .groupBy(/*custom KeySelector converting input to a String > representation*/) > .mapWindow(/*TypeConversion*/) > .flatten() > > Then the result is written to a Kafka topic. > > The purpose of this is output deduplication within a 2 seconds window... > > Without the above the program works fine. But with the above I don't get > any output and no error appears in the log. The program keeps running. > Am I doing something wrong? > > I would be happy for help! > > Cheers, Rico.
signature.asc
Description: OpenPGP digital signature
