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/11/20 16:43:00 UTC
[jira] [Assigned] (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:all-tabpanel ]
Brian Hulette reassigned BEAM-8829:
-----------------------------------
Assignee: Brian Hulette
> 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)