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 2021/01/05 19:41:00 UTC
[jira] [Updated] (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 updated BEAM-8829:
--------------------------------
Fix Version/s: 2.28.0
Resolution: Fixed
Status: Resolved (was: Open)
> 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
> Fix For: 2.28.0
>
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> 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)