Drew Hodun created BEAM-10297:
---------------------------------
Summary: Group.<Row>globally().aggregate(Count.combineFn()))
Throws Error
Key: BEAM-10297
URL: https://issues.apache.org/jira/browse/BEAM-10297
Project: Beam
Issue Type: Bug
Components: sdk-java-core
Affects Versions: 2.19.0
Reporter: Drew Hodun
Trying to Count the number of rows in a window with Group and Combiner (as
opposed to GroupBy "*" or a any field), but get an error:
.apply("WindowByMinute",
Window.into(FixedWindows.of(Duration.standardSeconds(60))))
.apply("CountPerMinute",
Group.<Row>globally().aggregate(Count.combineFn()))
threw:
ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.6.0:java
(default-cli) on project advanced-dataflow-lab: An exception occured while
executing the Java class. If the input collection uses a windowing strategy
other than GlobalWindows, use
Combine.globally(Count.<T>combineFn()).withoutDefaults() instead. ->
Reuven Lax has indicated this is likely a bug.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
