Repository: beam Updated Branches: refs/heads/master 0aae7aa5f -> d03a1284c
Fix failing test. Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9ac94e7d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9ac94e7d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9ac94e7d Branch: refs/heads/master Commit: 9ac94e7d45b0c57ba16f48f129c595bbbf041c1f Parents: 518c158 Author: Reuven Lax <[email protected]> Authored: Thu Aug 17 12:57:47 2017 -0700 Committer: Reuven Lax <[email protected]> Committed: Thu Aug 17 20:25:19 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/9ac94e7d/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java index 43a494e..0ece3ee 100644 --- a/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java +++ b/sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTest.java @@ -1955,7 +1955,7 @@ public class BigQueryIOTest implements Serializable { String tableName = String.format("project-id:dataset-id.table%05d", i); TableDestination tableDestination = new TableDestination(tableName, tableName); for (int j = 0; j < numPartitions; ++j) { - String tempTableId = BigQueryHelpers.createJobId(jobIdToken, tableDestination, j, -1); + String tempTableId = BigQueryHelpers.createJobId(jobIdToken, tableDestination, j, 0); List<String> filesPerPartition = Lists.newArrayList(); for (int k = 0; k < numFilesPerPartition; ++k) { String filename = Paths.get(baseDir.toString(),
