Skip to content

Commit 0dbfa3e

Browse files
committed
more linting fixes
1 parent 9f94c32 commit 0dbfa3e

File tree

3 files changed

+23
-14
lines changed

3 files changed

+23
-14
lines changed

dataproc/src/test/java/CreateClusterWithAutoscalingTest.java

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,17 +14,14 @@
1414
* limitations under the License.
1515
*/
1616

17-
import static junit.framework.TestCase.assertNotNull;
18-
import static org.hamcrest.MatcherAssert.assertThat;
19-
2017
import com.google.api.gax.longrunning.OperationFuture;
21-
import com.google.cloud.dataproc.v1.*;
18+
import com.google.cloud.dataproc.v1.AutoscalingPolicyName;
19+
import com.google.cloud.dataproc.v1.AutoscalingPolicyServiceClient;
20+
import com.google.cloud.dataproc.v1.AutoscalingPolicyServiceSettings;
21+
import com.google.cloud.dataproc.v1.ClusterControllerClient;
22+
import com.google.cloud.dataproc.v1.ClusterControllerSettings;
23+
import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
2224
import com.google.protobuf.Empty;
23-
import java.io.ByteArrayOutputStream;
24-
import java.io.IOException;
25-
import java.io.PrintStream;
26-
import java.util.UUID;
27-
import java.util.concurrent.ExecutionException;
2825
import org.hamcrest.CoreMatchers;
2926
import org.junit.After;
3027
import org.junit.Before;
@@ -33,6 +30,15 @@
3330
import org.junit.runner.RunWith;
3431
import org.junit.runners.JUnit4;
3532

33+
import java.io.ByteArrayOutputStream;
34+
import java.io.IOException;
35+
import java.io.PrintStream;
36+
import java.util.UUID;
37+
import java.util.concurrent.ExecutionException;
38+
39+
import static junit.framework.TestCase.assertNotNull;
40+
import static org.hamcrest.MatcherAssert.assertThat;
41+
3642
@RunWith(JUnit4.class)
3743
public class CreateClusterWithAutoscalingTest {
3844

@@ -75,7 +81,7 @@ public void tearDown() throws IOException, InterruptedException, ExecutionExcept
7581

7682
try (ClusterControllerClient clusterControllerClient =
7783
ClusterControllerClient.create(clusterControllerSettings);
78-
AutoscalingPolicyServiceClient autoscalingPolicyServiceClient =
84+
AutoscalingPolicyServiceClient autoscalingPolicyServiceClient =
7985
AutoscalingPolicyServiceClient.create(autoscalingPolicyServiceSettings)) {
8086

8187
OperationFuture<Empty, ClusterOperationMetadata> deleteClusterAsyncRequest =

dataproc/src/test/java/SubmitHadoopFSJobTest.java renamed to dataproc/src/test/java/SubmitHadoopFsJobTest.java

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,10 @@
1515
*/
1616

1717
import com.google.api.gax.longrunning.OperationFuture;
18-
import com.google.cloud.dataproc.v1.*;
18+
import com.google.cloud.dataproc.v1.Cluster;
19+
import com.google.cloud.dataproc.v1.ClusterControllerClient;
20+
import com.google.cloud.dataproc.v1.ClusterControllerSettings;
21+
import com.google.cloud.dataproc.v1.ClusterOperationMetadata;
1922
import com.google.protobuf.Empty;
2023
import org.hamcrest.CoreMatchers;
2124
import org.junit.After;
@@ -35,7 +38,7 @@
3538
import static org.hamcrest.MatcherAssert.assertThat;
3639

3740
@RunWith(JUnit4.class)
38-
public class SubmitHadoopFSJobTest {
41+
public class SubmitHadoopFsJobTest {
3942

4043
private static final String CLUSTER_NAME =
4144
String.format("java-fs-test--%s", UUID.randomUUID().toString());
@@ -77,8 +80,8 @@ public void setUp() throws IOException, ExecutionException, InterruptedException
7780
}
7881

7982
@Test
80-
public void submitHadoopFSJobTest() throws IOException, InterruptedException {
81-
SubmitHadoopFSJob.submitHadoopFSJob(PROJECT_ID, REGION, CLUSTER_NAME, HADOOP_FS_QUERY);
83+
public void submitHadoopFsJobTest() throws IOException, InterruptedException {
84+
SubmitHadoopFsJob.submitHadoopFsJob(PROJECT_ID, REGION, CLUSTER_NAME, HADOOP_FS_QUERY);
8285
String output = bout.toString();
8386

8487
assertThat(output, CoreMatchers.containsString("/tmp"));

0 commit comments

Comments
 (0)