Return-Path: 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 73F77200C4E for ; Fri, 21 Apr 2017 20:05:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 72C32160B97; Fri, 21 Apr 2017 18:05:08 +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 B9062160B86 for ; Fri, 21 Apr 2017 20:05:07 +0200 (CEST) Received: (qmail 24763 invoked by uid 500); 21 Apr 2017 18:05:06 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 24754 invoked by uid 99); 21 Apr 2017 18:05:06 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 21 Apr 2017 18:05:06 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 9153DC6750 for ; Fri, 21 Apr 2017 18:05:06 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-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 (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id rToU694xAR3X for ; Fri, 21 Apr 2017 18:05:06 +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 6A8515FAC2 for ; Fri, 21 Apr 2017 18:05:05 +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 BAD13E06C5 for ; Fri, 21 Apr 2017 18:05: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 664FF20D59 for ; Fri, 21 Apr 2017 18:05:04 +0000 (UTC) Date: Fri, 21 Apr 2017 18:05:04 +0000 (UTC) From: "Thomas Groh (JIRA)" To: commits@beam.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (BEAM-2047) PubsubStreamingWrite should use the input coder by default MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Fri, 21 Apr 2017 18:05:08 -0000 Thomas Groh created BEAM-2047: --------------------------------- Summary: PubsubStreamingWrite should use the input coder by default Key: BEAM-2047 URL: https://issues.apache.org/jira/browse/BEAM-2047 Project: Beam Issue Type: Improvement Components: runner-dataflow Reporter: Thomas Groh Assignee: Thomas Groh If there is no explicit coder nor format fn that converts an object to a byte[], we can reuse the input coder. If we do not, the graph fails to validate at job submission. We may be able to remove all of the coder checks when we no longer use coders to convert elements to bytes for pubsub. See also https://issues.apache.org/jira/browse/BEAM-1662 -- This message was sent by Atlassian JIRA (v6.3.15#6346)