You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Beam JIRA Bot (Jira)" <ji...@apache.org> on 2020/09/04 17:07:01 UTC
[jira] [Commented] (BEAM-10297)
Group.globally().aggregate(Count.combineFn())) Throws Error
[ https://issues.apache.org/jira/browse/BEAM-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17190833#comment-17190833 ]
Beam JIRA Bot commented on BEAM-10297:
--------------------------------------
This issue was marked "stale-P2" and has not received a public comment in 14 days. It is now automatically moved to P3. If you are still affected by it, you can comment and move it back to P2.
> 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
> Priority: P3
>
> 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)