i had problem flink 0.9.0 release when run wordcount sample modified myself. found count window behaved local window different official document. , found fixed bug in https://issues.apache.org/jira/browse/flink-1657. right answer? appreciated! thank lot
the canonical answer right time global (since time global) , other windows local or not defined.
we aware of problems , reworking api bit next release. can read design documents here: https://cwiki.apache.org/confluence/display/flink/streams+and+operations+on+streams , https://cwiki.apache.org/confluence/display/flink/time+and+order+in+streams.
with changes trying make clear windows processed in parallel , global/local.
Comments
Post a Comment