[beam] branch master updated: [BEAM-14300] Fix Java precommit failure

[heejong]

This is an automated email from the ASF dual-hosted git repository.

heejong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 29e3b1466a1 [BEAM-14300] Fix Java precommit failure
     new e7636bac435 Merge pull request #17353 from ihji/BEAM-14300
29e3b1466a1 is described below

commit 29e3b1466a1024686ed4d342c2c2ecc704b33019
Author: Heejong Lee <heej...@gmail.com>
AuthorDate: Tue Apr 12 11:10:24 2022 -0700

    [BEAM-14300] Fix Java precommit failure
---
 .../beam/sdk/io/snowflake/test/unit/read/SnowflakeIOReadTest.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/read/SnowflakeIOReadTest.java
 
b/sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/read/SnowflakeIOReadTest.java
index 4a4d2608d48..8ce41de621d 100644
--- 
a/sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/read/SnowflakeIOReadTest.java
+++ 
b/sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/unit/read/SnowflakeIOReadTest.java
@@ -111,7 +111,7 @@ public class SnowflakeIOReadTest implements Serializable {
     thrown.expectMessage("staging bucket name cannot be empty");
 
     pipeline.apply(
-        SnowflakeIO.<GenericRecord>read(snowflakeService)
+        SnowflakeIO.<GenericRecord>read(snowflakeServices)
             .withDataSourceConfiguration(dataSourceConfiguration)
             .fromTable(FAKE_TABLE)
             .withStorageIntegrationName(options.getStorageIntegrationName())
@@ -144,7 +144,7 @@ public class SnowflakeIOReadTest implements Serializable {
     thrown.expectMessage("storage integration cannot be empty");
 
     pipeline.apply(
-        SnowflakeIO.<GenericRecord>read(snowflakeService)
+        SnowflakeIO.<GenericRecord>read(snowflakeServices)
             .withDataSourceConfiguration(dataSourceConfiguration)
             .fromTable(FAKE_TABLE)
             
.withStorageIntegrationName(ValueProvider.StaticValueProvider.of(null))
@@ -209,7 +209,7 @@ public class SnowflakeIOReadTest implements Serializable {
     thrown.expectMessage("table or query is required");
 
     pipeline.apply(
-        SnowflakeIO.<GenericRecord>read(snowflakeService)
+        SnowflakeIO.<GenericRecord>read(snowflakeServices)
             .withDataSourceConfiguration(dataSourceConfiguration)
             .withStagingBucketName(options.getStagingBucketName())
             .withStorageIntegrationName(options.getStorageIntegrationName())