You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Batkhuyag Batsaikhan (JIRA)" <ji...@apache.org> on 2018/04/18 22:59:00 UTC

[jira] [Assigned] (BEAM-3746) Count.globally should override getIncompatibleGlobalWindowErrorMessage to tell the user the usage that is currently only in javadoc

     [ https://issues.apache.org/jira/browse/BEAM-3746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Batkhuyag Batsaikhan reassigned BEAM-3746:
------------------------------------------

    Assignee: Batkhuyag Batsaikhan

> Count.globally should override getIncompatibleGlobalWindowErrorMessage to tell the user the usage that is currently only in javadoc
> -----------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-3746
>                 URL: https://issues.apache.org/jira/browse/BEAM-3746
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-core
>            Reporter: Kenneth Knowles
>            Assignee: Batkhuyag Batsaikhan
>            Priority: Major
>              Labels: beginner, newbie, starter
>
> https://beam.apache.org/documentation/sdks/javadoc/2.3.0/org/apache/beam/sdk/transforms/Count.html#globally--
> "Note: if the input collection uses a windowing strategy other than GlobalWindows, use Combine.globally(Count.<T>combineFn()).withoutDefaults() instead."
> But the actual crash a user gets is:
> "java.lang.IllegalStateException: Default values are not supported in Combine.globally() if the output PCollection is not windowed by GlobalWindows. Instead, use Combine.globally().withoutDefaults() to output an empty PCollection if the input PCollection is empty, or Combine.globally().asSingletonView() to get the default output of the CombineFn if the input PCollection is empty."
> There is a method that exists solely to make this actually useful, so we should use it!



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)