You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "AJ (JIRA)" <ji...@apache.org> on 2017/11/15 22:11:00 UTC
[jira] [Commented] (BEAM-3198) Improve error message in BigqueryIO
when withNumFileShards is not specified
[ https://issues.apache.org/jira/browse/BEAM-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16254302#comment-16254302 ]
AJ commented on BEAM-3198:
--------------------------
My write to Biguqery is similar to the following:
{code}
unboundedPcollection.apply("Write to BQ",
BigQueryIO.<...>write()
.to(...)
.withFormatFunction(...)
.withTriggeringFrequency(Duration.standardMinutes(1))
.withMethod(BigQueryIO.Write.Method.FILE_LOADS) .
{code}
And this throws "Exception in thread "main" java.lang.IllegalArgumentException".
Adding .withNumFileShards(...) resolves it.
> Improve error message in BigqueryIO when withNumFileShards is not specified
> ---------------------------------------------------------------------------
>
> Key: BEAM-3198
> URL: https://issues.apache.org/jira/browse/BEAM-3198
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-gcp
> Reporter: Luke Cwik
> Assignee: Chamikara Jayalath
> Priority: Minor
>
> Reported in [https://lists.apache.org/thread.html/88c8da5eaf34ab1c7dc83372e0e2b1c31426b22aa4844b65b54ad16c@%3Cuser.beam.apache.org%3E]
> I am trying to use Method.FILE_LOADS for loading data into BQ in my streaming pipeline using 2.2.0. It looks like withNumFileShards needs to be also set for using this.
> * Can we throw a better error message when it is not set? The exception thrown by the pipeline if this is not set is "Exception in thread "main" java.lang.IllegalArgumentException" without any message.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)