You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Brian Hulette (Jira)" <ji...@apache.org> on 2020/09/15 23:32:00 UTC

[jira] [Commented] (BEAM-8829) PubsubJsonTableProvider throws error if input schema does not have event_timestamp

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

Brian Hulette commented on BEAM-8829:
-------------------------------------

Raising priority as this is a simple fix and I want Jira bot to bug me until I do it.

> PubsubJsonTableProvider throws error if input schema does not have event_timestamp
> ----------------------------------------------------------------------------------
>
>                 Key: BEAM-8829
>                 URL: https://issues.apache.org/jira/browse/BEAM-8829
>             Project: Beam
>          Issue Type: Bug
>          Components: dsl-sql
>            Reporter: Brian Hulette
>            Assignee: Brian Hulette
>            Priority: P2
>
> RowToPubsubMessage uses [DropFields.fields("event_timestamp")|https://github.com/apache/beam/blob/b446304f75078ca9c97437e685409c31ceab7503/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/RowToPubsubMessage.java#L69] which throws if the input schema doesn't contain event_timestamp.
> We should only drop the field if it exists.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)