Return-Path: <commits-return-31075-archive-asf-public=cust-asf.ponee.io@beam.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id 1B612200C70
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Thu, 20 Apr 2017 01:01:18 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id 19D57160BAA; Wed, 19 Apr 2017 23:01:18 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 63861160B9C
	for <archive-asf-public@cust-asf.ponee.io>; Thu, 20 Apr 2017 01:01:17 +0200 (CEST)
Received: (qmail 63804 invoked by uid 500); 19 Apr 2017 23:01:16 -0000
Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@beam.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@beam.apache.org>
List-Post: <mailto:commits@beam.apache.org>
List-Id: <commits.beam.apache.org>
Reply-To: dev@beam.apache.org
Delivered-To: mailing list commits@beam.apache.org
Received: (qmail 63795 invoked by uid 99); 19 Apr 2017 23:01:16 -0000
Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Apr 2017 23:01:16 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 433C41A0464
	for <commits@beam.apache.org>; Wed, 19 Apr 2017 23:01:16 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: -100.002
X-Spam-Level: 
X-Spam-Status: No, score=-100.002 tagged_above=-999 required=6.31
	tests=[RP_MATCHES_RCVD=-0.001, SPF_PASS=-0.001,
	USER_IN_WHITELIST=-100] autolearn=disabled
Received: from mx1-lw-eu.apache.org ([10.40.0.8])
	by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024)
	with ESMTP id DdSEwa8kWAjm for <commits@beam.apache.org>;
	Wed, 19 Apr 2017 23:01:15 +0000 (UTC)
Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139])
	by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTP id 257CB5F5A5
	for <commits@beam.apache.org>; Wed, 19 Apr 2017 23:01:10 +0000 (UTC)
Received: from jira-lw-us.apache.org (unknown [207.244.88.139])
	by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 6F2D4E0641
	for <commits@beam.apache.org>; Wed, 19 Apr 2017 23:01:04 +0000 (UTC)
Received: from jira-lw-us.apache.org (localhost [127.0.0.1])
	by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 2BDE120D59
	for <commits@beam.apache.org>; Wed, 19 Apr 2017 23:01:04 +0000 (UTC)
Date: Wed, 19 Apr 2017 23:01:04 +0000 (UTC)
From: "Xu Mingmin (JIRA)" <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13065335.1492642831000.170.1492642864175@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] [Created] (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
X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394
archived-at: Wed, 19 Apr 2017 23:01:18 -0000

Xu Mingmin created BEAM-2019:
--------------------------------

             Summary: 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)