Skip to content

Commit

Permalink
fix checkstyle
Browse files Browse the repository at this point in the history
  • Loading branch information
georgew5656 committed Aug 21, 2023
1 parent 12374be commit ea8a37b
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;

import java.io.File;
import java.io.IOException;
Expand Down Expand Up @@ -130,7 +129,8 @@ protected synchronized TaskStatus join(long timeout)
}

@Test
public void test_run_useTaskManager() throws IOException {
public void test_run_useTaskManager() throws IOException
{
TaskConfig taskConfigTaskManager = new TaskConfigBuilder().setEnableTaskPayloadManagerPerTask(true).build();
KubernetesPeonLifecycle peonLifecycle = new KubernetesPeonLifecycle(
task,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,12 +64,9 @@
import org.apache.druid.server.log.StartupLoggingConfig;
import org.apache.druid.tasklogs.NoopTaskLogs;
import org.apache.druid.tasklogs.TaskLogs;
import org.easymock.EasyMockRunner;
import org.easymock.EasyMockSupport;
import org.junit.Assert;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;

import java.io.ByteArrayInputStream;
Expand Down Expand Up @@ -292,7 +289,7 @@ public void toTask_useTaskPayloadManager() throws IOException

Job job = new JobBuilder()
.editSpec().editTemplate().editMetadata()
.addToAnnotations(DruidK8sConstants.TASK_ID,"ID")
.addToAnnotations(DruidK8sConstants.TASK_ID, "ID")
.endMetadata().endTemplate().endSpec().build();

Task taskFromJob = adapter.toTask(job);
Expand All @@ -315,7 +312,7 @@ public void getTaskId() throws IOException
);
Job job = new JobBuilder()
.editSpec().editTemplate().editMetadata()
.addToAnnotations(DruidK8sConstants.TASK_ID,"ID")
.addToAnnotations(DruidK8sConstants.TASK_ID, "ID")
.endMetadata().endTemplate().endSpec().build();

assertEquals(new K8sTaskId("ID"), adapter.getTaskId(job));
Expand Down Expand Up @@ -359,7 +356,7 @@ public void getTaskId_missingTaskIdAnnotation()
);
Job job = new JobBuilder()
.editSpec().editTemplate().editMetadata()
.addToAnnotations(DruidK8sConstants.TASK_GROUP_ID,"ID")
.addToAnnotations(DruidK8sConstants.TASK_GROUP_ID, "ID")
.endMetadata().endTemplate().endSpec()
.editMetadata().withName("job").endMetadata().build();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
package org.apache.druid.k8s.overlord.taskadapter;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Optional;
import io.fabric8.kubernetes.api.model.PodTemplate;
import io.fabric8.kubernetes.api.model.batch.v1.Job;
import io.fabric8.kubernetes.api.model.batch.v1.JobBuilder;
Expand All @@ -37,7 +36,6 @@
import org.apache.druid.k8s.overlord.common.DruidK8sConstants;
import org.apache.druid.k8s.overlord.common.K8sTaskId;
import org.apache.druid.k8s.overlord.common.K8sTestUtils;
import org.apache.druid.k8s.overlord.common.TestKubernetesClient;
import org.apache.druid.server.DruidNode;
import org.apache.druid.tasklogs.TaskLogs;
import org.easymock.EasyMock;
Expand Down Expand Up @@ -338,7 +336,7 @@ public void test_getTaskId() throws IOException
);
Job job = new JobBuilder()
.editSpec().editTemplate().editMetadata()
.addToAnnotations(DruidK8sConstants.TASK_ID,"ID")
.addToAnnotations(DruidK8sConstants.TASK_ID, "ID")
.endMetadata().endTemplate().endSpec().build();

assertEquals(new K8sTaskId("ID"), adapter.getTaskId(job));
Expand Down Expand Up @@ -386,7 +384,7 @@ public void test_getTaskId_missingTaskIdAnnotation() throws IOException
);
Job job = new JobBuilder()
.editSpec().editTemplate().editMetadata()
.addToAnnotations(DruidK8sConstants.TASK_GROUP_ID,"ID")
.addToAnnotations(DruidK8sConstants.TASK_GROUP_ID, "ID")
.endMetadata().endTemplate().endSpec()
.editMetadata().withName("job").endMetadata().build();

Expand Down

0 comments on commit ea8a37b

Please sign in to comment.