mustafa elbehery created FLINK-1959:
---------------------------------------
Summary: Accumulators BROKEN after Partitioning
Key: FLINK-1959
URL: https://issues.apache.org/jira/browse/FLINK-1959
Project: Flink
Issue Type: Bug
Components: Examples
Affects Versions: 0.8.1
Reporter: mustafa elbehery
Priority: Critical
Fix For: 0.8.1
while running the Accumulator example in
https://github.com/Elbehery/flink/blob/master/flink-examples/flink-java-examples/src/main/java/org/apache/flink/examples/java/relational/EmptyFieldsCountAccumulator.java,
I tried to alter the data flow with "PartitionByHash" function before applying
"Filter", and the resulted accumulator was NULL.
By Debugging, I could see the accumulator in the RunTime Map. However, by
retrieving the accumulator from the JobExecutionResult object, it was NULL.
The line caused the problem is "file.partitionByHash(1).filter(new
EmptyFieldFilter())" instead of "file.filter(new EmptyFieldFilter())"
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
