TEZ-4687: Spotless: enforce endWithNewline

pom.xml

@@ -1036,6 +1036,7 @@
               </importOrder>
               <removeUnusedImports/>
               <trimTrailingWhitespace/>
+              <endWithNewline/>
             </java>
           </configuration>
         </plugin>

tez-api/src/main/java/org/apache/tez/client/registry/package-info.java

@@ -21,4 +21,4 @@
 package org.apache.tez.client.registry;
 
 import org.apache.hadoop.classification.InterfaceAudience.Public;
-import org.apache.hadoop.classification.InterfaceStability.Evolving;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;

tez-api/src/main/java/org/apache/tez/common/GuavaShim.java

@@ -51,4 +51,4 @@ public static Executor directExecutor() {
       throw new RuntimeException(e);
     }
   }
-}
+}

tez-api/src/main/java/org/apache/tez/common/counters/AggregateTezCounter.java

@@ -28,4 +28,4 @@ public interface AggregateTezCounter {
 
   public abstract long getCount();
 
-}
+}

tez-api/src/main/java/org/apache/tez/common/counters/TaskCounter.java

@@ -237,4 +237,4 @@ public enum TaskCounter {
    * Represented in number of bytes
    */
   DATA_BYTES_VIA_EVENT
-}
+}

tez-api/src/main/java/org/apache/tez/common/security/HistoryACLPolicyException.java

@@ -31,4 +31,4 @@ public class HistoryACLPolicyException extends Exception {
   public HistoryACLPolicyException(String message, Throwable cause) {
     super(message, cause);
   }
-}
+}

tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java

@@ -370,4 +370,4 @@ public void reconfigureVertex(@Nullable Map<String, InputSpecUpdate> rootInputSp
    */
   Map<String, List<String>> getInputVertexGroups();
 
-}
+}

tez-api/src/main/java/org/apache/tez/dag/api/client/rpc/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.dag.api.client.rpc;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-api/src/main/java/org/apache/tez/runtime/api/Output.java

@@ -61,4 +61,4 @@ public interface Output {
    */
   public Writer getWriter() throws Exception;
 
-}
+}

tez-api/src/main/java/org/apache/tez/runtime/api/events/InputInitializerEvent.java

@@ -116,4 +116,4 @@ public String toString() {
     return "[TargetVertexName=" + targetVertexName + ", TargetInputName=" + targetInputName +
         ", SourceVertexName=" + sourceVertexName + " Payload=" + eventPayload + "]";
   }
-}
+}

tez-api/src/main/java/org/apache/tez/runtime/library/common/shuffle/api/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.runtime.library.common.shuffle.api;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java

@@ -174,4 +174,4 @@ public String toString() {
         ", taskCommunicatorDescriptors=" + Arrays.toString(taskCommunicatorDescriptors) +
         '}';
   }
-}
+}

tez-common/src/main/java/org/apache/tez/common/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.common;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-common/src/main/java/org/apache/tez/common/web/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.common.web;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-common/src/main/java/org/apache/tez/dag/records/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.dag.records;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-common/src/main/java/org/apache/tez/dag/utils/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.dag.utils;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-common/src/main/java/org/apache/tez/runtime/common/resources/InitialMemoryAllocator.java

@@ -44,4 +44,4 @@ public interface InitialMemoryAllocator extends Configurable {
   public abstract Iterable<Long> assignMemory(long availableForAllocation, int numTotalInputs,
       int numTotalOutputs, Iterable<InitialMemoryRequestContext> requests);
 
-}
+}

tez-common/src/main/java/org/apache/tez/runtime/common/resources/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.runtime.common.resources;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-common/src/main/java/org/apache/tez/runtime/hook/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.runtime.hook;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/AMRegistry.java

@@ -44,4 +44,4 @@ protected AMRegistry(String name) {
   /* Under typical usage, implementations should remove any stale AMRecords upon serviceStop. */
   public abstract void remove(AMRecord server) throws Exception;
 
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/package-info.java

@@ -21,4 +21,4 @@
 package org.apache.tez.dag.api.client.registry;
 
 import org.apache.hadoop.classification.InterfaceAudience.Public;
-import org.apache.hadoop.classification.InterfaceStability.Evolving;
+import org.apache.hadoop.classification.InterfaceStability.Evolving;

tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java

@@ -473,4 +473,4 @@ protected ContainerId getContainerForAttempt(TezTaskAttemptID taskAttemptId) {
   public long getTotalUsedMemory() {
     return registeredContainers.values().stream().mapToLong(c -> c.usedMemory).sum();
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateUpdateListener.java

@@ -30,4 +30,4 @@ public interface TaskStateUpdateListener {
   // Internal usage only. Currently only supporting onSuccess notifications for tasks.
   // Exposing the taskID is ok, since this isn't public
   public void onTaskSucceeded(String vertexName, TezTaskID taskId, int attemptId);
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java

@@ -35,4 +35,4 @@ public DAGEventStartDag(TezDAGID dagId, List<URL> additionalUrlsForClasspath) {
   public List<URL> getAdditionalUrlsForClasspath() {
     return this.additionalUrlsForClasspath;
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java

@@ -30,4 +30,4 @@ public TaskAttemptEventStartedRemotely(TezTaskAttemptID id) {
   public boolean isFromRecovery() {
     return false;
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventScheduleTask.java

@@ -47,4 +47,4 @@ public TaskLocationHint getTaskLocationHint() {
   public boolean isFromRecovery() {
     return fromRecovery;
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexShuffleDataDeletion.java

@@ -40,4 +40,4 @@ public Vertex getSourceVertex() {
   public Vertex getTargetVertex() {
     return targetVertex;
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/DataStatistics.java

@@ -104,4 +104,4 @@ public String toString() {
         + ", sumSquares is " + sumSquares + " mean is " + mean()
         + " std() is " + std() + ", meanCI() is " + meanCI();
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerOp.java

@@ -59,4 +59,4 @@ public String toString() {
         ", command=" + command +
         '}';
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAStateUpdated.java

@@ -39,4 +39,4 @@ public TaskAttempt getTaskAttempt() {
   public SchedulerTaskState getState() {
     return state;
   }
-}
+}

tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGRecoveredEvent.java

@@ -138,4 +138,4 @@ public String toString() {
         + ", recoveryFailureReason=" + recoveryFailureReason;
   }
 
-}
+}

tez-dag/src/main/java/org/apache/tez/state/OnStateChangedCallback.java

@@ -21,4 +21,4 @@
 
 public interface OnStateChangedCallback<STATE extends Enum<STATE>, OPERAND> {
   public void onStateChanged(OPERAND operand, STATE state);
-}
+}

tez-dag/src/test/java/org/apache/tez/test/EdgeManagerForTest.java

@@ -110,4 +110,4 @@ public int routeInputErrorEventToSource(int destinationTaskIndex, int destinatio
 
   // End of overridden methods
 
-}
+}

tez-ext-service-tests/src/test/java/org/apache/tez/dag/app/launcher/TezTestServiceContainerLauncherWithErrors.java

@@ -42,4 +42,4 @@ public void launchContainer(ContainerLaunchRequest launchRequest) {
   public void stopContainer(ContainerStopRequest stopRequest) {
     ErrorPluginConfiguration.processError(conf, getContext());
   }
-}
+}

tez-ext-service-tests/src/test/java/org/apache/tez/service/MiniTezTestServiceCluster.java

@@ -164,4 +164,4 @@ public int getNumSubmissions() {
     return tezTestService.getNumSubmissions();
   }
 
-}
+}

tez-ext-service-tests/src/test/java/org/apache/tez/service/TezTestServiceProtocolBlockingPB.java

@@ -19,4 +19,4 @@
 
 @ProtocolInfo(protocolName = "org.apache.tez.service.TezTestServiceProtocolBlockingPB", protocolVersion = 1)
 public interface TezTestServiceProtocolBlockingPB extends TezTestServiceProtocolProtos.TezTestServiceProtocol.BlockingInterface {
-}
+}

tez-ext-service-tests/src/test/java/org/apache/tez/service/impl/TezTestServiceProtocolClientImpl.java

@@ -80,4 +80,4 @@ public TezTestServiceProtocolBlockingPB createProxy() throws IOException {
         .getProxy(TezTestServiceProtocolBlockingPB.class, 0, serverAddr, conf);
     return p;
   }
-}
+}

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.mapreduce.client;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/grouper/SplitSizeEstimatorWrapperMapReduce.java

@@ -32,4 +32,4 @@ public long getEstimatedSize(SplitContainer rawContainer) throws IOException,
     MapReduceSplitContainer splitContainer = (MapReduceSplitContainer)rawContainer;
     return estimator.getEstimatedSize(splitContainer.getRawSplit());
   }
-}
+}

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfToTezTranslator.java

@@ -82,4 +82,4 @@ public static Configuration[] getStageConfs(Configuration conf) {
     }
     return confs;
   }
-}
+}

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.mapreduce.hadoop.mapred;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.mapreduce.hadoop.mapreduce;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.mapreduce.hadoop;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-mapreduce/src/main/java/org/apache/tez/mapreduce/lib/package-info.java

@@ -19,4 +19,4 @@
 @Private
 package org.apache.tez.mapreduce.lib;
 
-import org.apache.hadoop.classification.InterfaceAudience.Private;
+import org.apache.hadoop.classification.InterfaceAudience.Private;

tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ProtoHistoryParser.java

@@ -125,4 +125,4 @@ public void close() {
     };
     return source;
   }
-}
+}

tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/SimpleHistoryParser.java

@@ -333,4 +333,4 @@ private void mergeSubJSONArray(JSONObject source, JSONObject destination, String
       destination.getJSONArray(key).put(source.getJSONArray(key).get(i));
     }
   }
-}
+}

tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TaskReporterInterface.java

@@ -48,4 +48,4 @@ boolean taskKilled(TezTaskAttemptID taskAttemptId, Throwable cause, String diagn
 
   void shutdown();
 
-}
+}

tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TezTrapEvent.java

@@ -49,4 +49,4 @@ public TezTrapEvent(final List<TezEvent> events) {
   public final List<TezEvent> getTezEvents() {
     return tezEvents;
   }
-}
+}

tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner2.java

@@ -595,4 +595,4 @@ private TaskFailureType getTaskFailureType(Throwable e) {
     }
     return TaskFailureType.NON_FATAL;
   }
-}
+}

tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTrapEventHandler.java

@@ -91,4 +91,4 @@ public final void handle(final TezTrapEvent tezTrapEvent) {
     }
     tezUmbilical.addEvents(tezEvents);
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/http/SSLFactory.java

@@ -244,4 +244,4 @@ public void configure(DefaultAsyncHttpClientConfig.Builder builder) throws IOExc
       builder.setSslContext(jdkSslContext);
     }
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/TezBodyDeferringAsyncHandler.java

@@ -256,4 +256,4 @@ public Response getLastResponse() throws InterruptedException, ExecutionExceptio
       return future.get();
     }
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManager.java

@@ -106,4 +106,4 @@ public int getNumSourceTaskPhysicalOutputs(int srcTaskId) {
   public int getNumDestinationConsumerTasks(int sourceTaskIndex) {
     return edgeManagerReal.getNumDestinationConsumerTasks(sourceTaskIndex);
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManagerPartitioned.java

@@ -133,4 +133,4 @@ private void generateTaskIdMapping() {
   private int getIdealTaskId(int realTaskId) {
     return taskIdMapping[realTaskId];
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManager.java

@@ -233,4 +233,4 @@ public void onVertexStateUpdated(VertexStateUpdate stateUpdate) throws Exception
   public void onSourceTaskCompleted(TaskAttemptIdentifier attempt) throws Exception {
     vertexManagerReal.onSourceTaskCompleted(attempt);
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManagerPartitioned.java

@@ -205,4 +205,4 @@ private void tryScheduleTask() {
       getContext().scheduleTasks(scheduleTaskRequests);
     }
   }
-}
+}

tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductEdgeManager.java

@@ -172,4 +172,4 @@ public int getNumDestinationConsumerTasks(int sourceTaskIndex) {
       - grouper.getGroupId(sourceTaskIndex * numPartition) + 1;
     return numDestConsumerPerChunk * numChunk;
   }
-}
+}