Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Thu, 27 Apr 2017 02:02:04 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13065335.1492642831000.61679.1493258524097@Atlassian.JIRA>
In-Reply-To: <JIRA.13065335.1492642831000@Atlassian.JIRA>
References: <JIRA.13065335.1492642831000@Atlassian.JIRA> <JIRA.13065335.1492642831638@jira-lw-us.apache.org>
Subject: [jira] [Commented] (BEAM-2019) Count.globally() requires default
 values for non-GlobalWindows
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 27 Apr 2017 02:02:07 -0000


    [ https://issues.apache.org/jira/browse/BEAM-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985875#comment-15985875 ] 

ASF GitHub Bot commented on BEAM-2019:
--------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/beam/pull/2603


> Count.globally() requires default values for non-GlobalWindows
> --------------------------------------------------------------
>
>                 Key: BEAM-2019
>                 URL: https://issues.apache.org/jira/browse/BEAM-2019
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-core
>            Reporter: Xu Mingmin
>            Assignee: Xu Mingmin
>            Priority: Minor
>
> Here's my code:
> {code}
> .apply(Window.<String>into(FixedWindows.of(Duration.standardHours(1)))  .triggering(Repeatedly.forever(AfterProcessingTime.pastFirstElementInPane().plusDelayOf(Duration.standardMinutes(1))))
>           .withAllowedLateness(Duration.standardMinutes(10))
>           .accumulatingFiredPanes()
>           )
> .apply(Count.<String>globally());
> {code}
> And the error message as below:
> {code}
> Exception in thread "main" 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.
> 	at org.apache.beam.sdk.transforms.Combine$Globally.expand(Combine.java:1463)
> 	at org.apache.beam.sdk.transforms.Combine$Globally.expand(Combine.java:1336)
> 	at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:420)
> 	at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:334)
> 	at org.apache.beam.sdk.values.PCollection.apply(PCollection.java:154)
> {code}


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)