diff --git a/pom.xml b/pom.xml index fb55d591f8..bea537c2f5 100644 --- a/pom.xml +++ b/pom.xml @@ -1036,6 +1036,7 @@ + diff --git a/tez-api/src/main/java/org/apache/tez/client/registry/package-info.java b/tez-api/src/main/java/org/apache/tez/client/registry/package-info.java index f08bdfc8db..23edb6fff6 100644 --- a/tez-api/src/main/java/org/apache/tez/client/registry/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceStability.Evolving; diff --git a/tez-api/src/main/java/org/apache/tez/common/GuavaShim.java b/tez-api/src/main/java/org/apache/tez/common/GuavaShim.java index 357f3b6295..55f695d54d 100644 --- a/tez-api/src/main/java/org/apache/tez/common/GuavaShim.java +++ b/tez-api/src/main/java/org/apache/tez/common/GuavaShim.java @@ -51,4 +51,4 @@ public static Executor directExecutor() { throw new RuntimeException(e); } } -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/common/counters/AggregateTezCounter.java b/tez-api/src/main/java/org/apache/tez/common/counters/AggregateTezCounter.java index 2bccd154f5..67e131314d 100644 --- a/tez-api/src/main/java/org/apache/tez/common/counters/AggregateTezCounter.java +++ b/tez-api/src/main/java/org/apache/tez/common/counters/AggregateTezCounter.java @@ -28,4 +28,4 @@ public interface AggregateTezCounter { public abstract long getCount(); -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/common/counters/TaskCounter.java b/tez-api/src/main/java/org/apache/tez/common/counters/TaskCounter.java index 19d5bbdffa..4da490227b 100644 --- a/tez-api/src/main/java/org/apache/tez/common/counters/TaskCounter.java +++ b/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 -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/common/security/HistoryACLPolicyException.java b/tez-api/src/main/java/org/apache/tez/common/security/HistoryACLPolicyException.java index 80229bc34e..969662123e 100644 --- a/tez-api/src/main/java/org/apache/tez/common/security/HistoryACLPolicyException.java +++ b/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); } -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java b/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java index 814bcc10f0..6da618391a 100644 --- a/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java +++ b/tez-api/src/main/java/org/apache/tez/dag/api/VertexManagerPluginContext.java @@ -370,4 +370,4 @@ public void reconfigureVertex(@Nullable Map rootInputSp */ Map> getInputVertexGroups(); -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/dag/api/client/rpc/package-info.java b/tez-api/src/main/java/org/apache/tez/dag/api/client/rpc/package-info.java index 3c18e02a5b..6e87aeffba 100644 --- a/tez-api/src/main/java/org/apache/tez/dag/api/client/rpc/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-api/src/main/java/org/apache/tez/runtime/api/Output.java b/tez-api/src/main/java/org/apache/tez/runtime/api/Output.java index e0e75a280c..e7f2a8ca4f 100644 --- a/tez-api/src/main/java/org/apache/tez/runtime/api/Output.java +++ b/tez-api/src/main/java/org/apache/tez/runtime/api/Output.java @@ -61,4 +61,4 @@ public interface Output { */ public Writer getWriter() throws Exception; -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/runtime/api/events/InputInitializerEvent.java b/tez-api/src/main/java/org/apache/tez/runtime/api/events/InputInitializerEvent.java index d8e29360f3..c96c41a388 100644 --- a/tez-api/src/main/java/org/apache/tez/runtime/api/events/InputInitializerEvent.java +++ b/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 + "]"; } -} \ No newline at end of file +} diff --git a/tez-api/src/main/java/org/apache/tez/runtime/library/common/shuffle/api/package-info.java b/tez-api/src/main/java/org/apache/tez/runtime/library/common/shuffle/api/package-info.java index 9ad8e61d50..c4001e1bfc 100644 --- a/tez-api/src/main/java/org/apache/tez/runtime/library/common/shuffle/api/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java index fd199fe76a..ea9c0cf9bf 100644 --- a/tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java +++ b/tez-api/src/main/java/org/apache/tez/serviceplugins/api/ServicePluginsDescriptor.java @@ -174,4 +174,4 @@ public String toString() { ", taskCommunicatorDescriptors=" + Arrays.toString(taskCommunicatorDescriptors) + '}'; } -} \ No newline at end of file +} diff --git a/tez-common/src/main/java/org/apache/tez/common/package-info.java b/tez-common/src/main/java/org/apache/tez/common/package-info.java index 88a5e8607a..477d0dc68e 100644 --- a/tez-common/src/main/java/org/apache/tez/common/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-common/src/main/java/org/apache/tez/common/web/package-info.java b/tez-common/src/main/java/org/apache/tez/common/web/package-info.java index 2fbda31fda..2782911d00 100644 --- a/tez-common/src/main/java/org/apache/tez/common/web/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-common/src/main/java/org/apache/tez/dag/records/package-info.java b/tez-common/src/main/java/org/apache/tez/dag/records/package-info.java index 319ab6b99a..2f04ca74b4 100644 --- a/tez-common/src/main/java/org/apache/tez/dag/records/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-common/src/main/java/org/apache/tez/dag/utils/package-info.java b/tez-common/src/main/java/org/apache/tez/dag/utils/package-info.java index 0cfda8411a..dca9ae4ad3 100644 --- a/tez-common/src/main/java/org/apache/tez/dag/utils/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-common/src/main/java/org/apache/tez/runtime/common/resources/InitialMemoryAllocator.java b/tez-common/src/main/java/org/apache/tez/runtime/common/resources/InitialMemoryAllocator.java index 6910f239c0..f74bffa910 100644 --- a/tez-common/src/main/java/org/apache/tez/runtime/common/resources/InitialMemoryAllocator.java +++ b/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 assignMemory(long availableForAllocation, int numTotalInputs, int numTotalOutputs, Iterable requests); -} \ No newline at end of file +} diff --git a/tez-common/src/main/java/org/apache/tez/runtime/common/resources/package-info.java b/tez-common/src/main/java/org/apache/tez/runtime/common/resources/package-info.java index 49689e09ec..b9f397ab50 100644 --- a/tez-common/src/main/java/org/apache/tez/runtime/common/resources/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-common/src/main/java/org/apache/tez/runtime/hook/package-info.java b/tez-common/src/main/java/org/apache/tez/runtime/hook/package-info.java index d977897d86..64364dba57 100644 --- a/tez-common/src/main/java/org/apache/tez/runtime/hook/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/AMRegistry.java b/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/AMRegistry.java index 8c6ab58984..889556c978 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/AMRegistry.java +++ b/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; -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/package-info.java b/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/package-info.java index 943f5197bd..b92543190d 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/api/client/registry/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceStability.Evolving; diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java b/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java index b2e750bb21..411e3cd0d4 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/TezTaskCommunicatorImpl.java +++ b/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(); } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateUpdateListener.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateUpdateListener.java index c4a382cad5..e0f8db897d 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateUpdateListener.java +++ b/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); -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java index 164fc65f21..02432d44d6 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java @@ -35,4 +35,4 @@ public DAGEventStartDag(TezDAGID dagId, List additionalUrlsForClasspath) { public List getAdditionalUrlsForClasspath() { return this.additionalUrlsForClasspath; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java index d83eda97ea..c5516ad6dc 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventScheduleTask.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventScheduleTask.java index dd6bb8046c..9cee034520 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventScheduleTask.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexShuffleDataDeletion.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexShuffleDataDeletion.java index 8ea3a154b3..03298926fc 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexShuffleDataDeletion.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/DataStatistics.java b/tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/DataStatistics.java index bbfb950741..5cae5c2536 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/dag/speculation/legacy/DataStatistics.java +++ b/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(); } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerOp.java b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerOp.java index d058cf55e8..f4f2543190 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerOp.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerOp.java @@ -59,4 +59,4 @@ public String toString() { ", command=" + command + '}'; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAStateUpdated.java b/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAStateUpdated.java index 95a56e565d..e5ed5b9b52 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAStateUpdated.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGRecoveredEvent.java b/tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGRecoveredEvent.java index 698db6f6b9..dcd9103455 100644 --- a/tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGRecoveredEvent.java +++ b/tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGRecoveredEvent.java @@ -138,4 +138,4 @@ public String toString() { + ", recoveryFailureReason=" + recoveryFailureReason; } -} \ No newline at end of file +} diff --git a/tez-dag/src/main/java/org/apache/tez/state/OnStateChangedCallback.java b/tez-dag/src/main/java/org/apache/tez/state/OnStateChangedCallback.java index 53767fcd70..64ac543554 100644 --- a/tez-dag/src/main/java/org/apache/tez/state/OnStateChangedCallback.java +++ b/tez-dag/src/main/java/org/apache/tez/state/OnStateChangedCallback.java @@ -21,4 +21,4 @@ public interface OnStateChangedCallback, OPERAND> { public void onStateChanged(OPERAND operand, STATE state); -} \ No newline at end of file +} diff --git a/tez-dag/src/test/java/org/apache/tez/test/EdgeManagerForTest.java b/tez-dag/src/test/java/org/apache/tez/test/EdgeManagerForTest.java index 08313a69c4..a50808e0a0 100644 --- a/tez-dag/src/test/java/org/apache/tez/test/EdgeManagerForTest.java +++ b/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 -} \ No newline at end of file +} diff --git a/tez-ext-service-tests/src/test/java/org/apache/tez/dag/app/launcher/TezTestServiceContainerLauncherWithErrors.java b/tez-ext-service-tests/src/test/java/org/apache/tez/dag/app/launcher/TezTestServiceContainerLauncherWithErrors.java index 3fc9a960cd..d791085134 100644 --- a/tez-ext-service-tests/src/test/java/org/apache/tez/dag/app/launcher/TezTestServiceContainerLauncherWithErrors.java +++ b/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()); } -} \ No newline at end of file +} diff --git a/tez-ext-service-tests/src/test/java/org/apache/tez/service/MiniTezTestServiceCluster.java b/tez-ext-service-tests/src/test/java/org/apache/tez/service/MiniTezTestServiceCluster.java index 5226fa8f1a..ebd8922fe9 100644 --- a/tez-ext-service-tests/src/test/java/org/apache/tez/service/MiniTezTestServiceCluster.java +++ b/tez-ext-service-tests/src/test/java/org/apache/tez/service/MiniTezTestServiceCluster.java @@ -164,4 +164,4 @@ public int getNumSubmissions() { return tezTestService.getNumSubmissions(); } -} \ No newline at end of file +} diff --git a/tez-ext-service-tests/src/test/java/org/apache/tez/service/TezTestServiceProtocolBlockingPB.java b/tez-ext-service-tests/src/test/java/org/apache/tez/service/TezTestServiceProtocolBlockingPB.java index 1108f72913..80e3d57d2a 100644 --- a/tez-ext-service-tests/src/test/java/org/apache/tez/service/TezTestServiceProtocolBlockingPB.java +++ b/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 { -} \ No newline at end of file +} diff --git a/tez-ext-service-tests/src/test/java/org/apache/tez/service/impl/TezTestServiceProtocolClientImpl.java b/tez-ext-service-tests/src/test/java/org/apache/tez/service/impl/TezTestServiceProtocolClientImpl.java index fb2838ad51..f18ad06889 100644 --- a/tez-ext-service-tests/src/test/java/org/apache/tez/service/impl/TezTestServiceProtocolClientImpl.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/package-info.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/package-info.java index 4366a673e5..40e3546d62 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/client/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/grouper/SplitSizeEstimatorWrapperMapReduce.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/grouper/SplitSizeEstimatorWrapperMapReduce.java index df6e3c9759..3bf633c7fa 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/grouper/SplitSizeEstimatorWrapperMapReduce.java +++ b/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()); } -} \ No newline at end of file +} diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfToTezTranslator.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfToTezTranslator.java index 5487e670fc..fad2b6cd8c 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfToTezTranslator.java +++ b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/MultiStageMRConfToTezTranslator.java @@ -82,4 +82,4 @@ public static Configuration[] getStageConfs(Configuration conf) { } return confs; } -} \ No newline at end of file +} diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/package-info.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/package-info.java index 73874b842d..869715e3f3 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapred/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/package-info.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/package-info.java index c12a8ac3fd..510c4e901b 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/mapreduce/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/package-info.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/package-info.java index 3cc21db0f4..c70fe69b22 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/hadoop/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/lib/package-info.java b/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/lib/package-info.java index 04a9500c4c..2c41cd880e 100644 --- a/tez-mapreduce/src/main/java/org/apache/tez/mapreduce/lib/package-info.java +++ b/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; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ProtoHistoryParser.java b/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ProtoHistoryParser.java index a64f47bb74..244263647a 100644 --- a/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ProtoHistoryParser.java +++ b/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/ProtoHistoryParser.java @@ -125,4 +125,4 @@ public void close() { }; return source; } -} \ No newline at end of file +} diff --git a/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/SimpleHistoryParser.java b/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/SimpleHistoryParser.java index 15b5f57fc7..3ec6fabcbc 100644 --- a/tez-plugins/tez-history-parser/src/main/java/org/apache/tez/history/parser/SimpleHistoryParser.java +++ b/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)); } } -} \ No newline at end of file +} diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TaskReporterInterface.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TaskReporterInterface.java index 6e8950c86b..852ebd6130 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TaskReporterInterface.java +++ b/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(); -} \ No newline at end of file +} diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TezTrapEvent.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TezTrapEvent.java index 69e28ce7d3..7ef4beeacc 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TezTrapEvent.java +++ b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/internals/api/TezTrapEvent.java @@ -49,4 +49,4 @@ public TezTrapEvent(final List events) { public final List getTezEvents() { return tezEvents; } -} \ No newline at end of file +} diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner2.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner2.java index 7f953e3bbd..af5555d88e 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTaskRunner2.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTrapEventHandler.java b/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTrapEventHandler.java index 3944ca9c80..65afa05cc3 100644 --- a/tez-runtime-internals/src/main/java/org/apache/tez/runtime/task/TezTrapEventHandler.java +++ b/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); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/http/SSLFactory.java b/tez-runtime-library/src/main/java/org/apache/tez/http/SSLFactory.java index 2f0caf805b..807b33031a 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/http/SSLFactory.java +++ b/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); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/TezBodyDeferringAsyncHandler.java b/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/TezBodyDeferringAsyncHandler.java index f83b8ed8f0..d052fa876f 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/http/async/netty/TezBodyDeferringAsyncHandler.java +++ b/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(); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManager.java index 1c4fe00d92..6d6af8df80 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManager.java +++ b/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); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManagerPartitioned.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManagerPartitioned.java index b06aab8734..76caa3018d 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductEdgeManagerPartitioned.java +++ b/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]; } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManager.java index cfeeb15bc1..c80182765a 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManager.java +++ b/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); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManagerPartitioned.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManagerPartitioned.java index da424f82ee..401f82fd0c 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManagerPartitioned.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/CartesianProductVertexManagerPartitioned.java @@ -205,4 +205,4 @@ private void tryScheduleTask() { getContext().scheduleTasks(scheduleTaskRequests); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductEdgeManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductEdgeManager.java index dfdbbe5f39..85cf45c24d 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductEdgeManager.java +++ b/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; } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductVertexManager.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductVertexManager.java index d798da05c0..992c302f36 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductVertexManager.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/cartesianproduct/FairCartesianProductVertexManager.java @@ -584,4 +584,4 @@ private void scheduleTasksDependOnCompletion(TaskAttemptIdentifier attempt) { getContext().scheduleTasks(requests); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/MemoryUpdateCallbackHandler.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/MemoryUpdateCallbackHandler.java index 0264363191..1ecb2c71c6 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/MemoryUpdateCallbackHandler.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/MemoryUpdateCallbackHandler.java @@ -43,4 +43,4 @@ public synchronized long getMemoryAssigned() { public synchronized void validateUpdateReceived() { Preconditions.checkState(updated == true, "Iniital memory update not received"); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/package-info.java index 686edff314..4f2f1b0d22 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.shuffle.impl; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/package-info.java index 1d3210144b..dc41c96c59 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.shuffle.orderedgrouped; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/package-info.java index 974932e11d..ea8b8176cb 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/shuffle/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.shuffle; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/package-info.java index 3cf4e9cc3c..f9d4df2043 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/dflt/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.sort.impl.dflt; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/package-info.java index e9737bc658..1a007658b4 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.sort.impl; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/task/local/output/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/task/local/output/package-info.java index 14f7fcc4fb..2f2847d823 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/task/local/output/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/task/local/output/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.task.local.output; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/package-info.java index 2376c99e66..a3cb00539a 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/writers/package-info.java @@ -19,4 +19,4 @@ @Private package org.apache.tez.runtime.library.common.writers; -import org.apache.hadoop.classification.InterfaceAudience.Private; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceAudience.Private; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/conf/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/conf/package-info.java index 16dd5fff34..2df643a226 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/conf/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/conf/package-info.java @@ -21,4 +21,4 @@ package org.apache.tez.runtime.library.conf; import org.apache.hadoop.classification.InterfaceAudience.Public; -import org.apache.hadoop.classification.InterfaceStability.Evolving; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceStability.Evolving; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValueInput.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValueInput.java index 542b44a8ce..150e277251 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValueInput.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValueInput.java @@ -118,4 +118,4 @@ public float getProgress() throws ProgressFailedException, InterruptedException throw new ProgressFailedException("getProgress encountered IOException ", e); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValuesInput.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValuesInput.java index aceb489bb5..fedbcd9da0 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValuesInput.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/ConcatenatedMergedKeyValuesInput.java @@ -120,4 +120,4 @@ public float getProgress() throws ProgressFailedException, InterruptedException throw new ProgressFailedException("getProgress encountered IOException ", e); } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/package-info.java index 9d5d29bdfe..9c9bc2bc04 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/input/package-info.java @@ -21,4 +21,4 @@ package org.apache.tez.runtime.library.input; import org.apache.hadoop.classification.InterfaceAudience.Public; -import org.apache.hadoop.classification.InterfaceStability.Evolving; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceStability.Evolving; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/package-info.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/package-info.java index 4b71be26ec..e933900c62 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/package-info.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/output/package-info.java @@ -21,4 +21,4 @@ package org.apache.tez.runtime.library.output; import org.apache.hadoop.classification.InterfaceAudience.Public; -import org.apache.hadoop.classification.InterfaceStability.Evolving; \ No newline at end of file +import org.apache.hadoop.classification.InterfaceStability.Evolving; diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/utils/CodecUtils.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/utils/CodecUtils.java index a29be881c2..660c8699eb 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/utils/CodecUtils.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/utils/CodecUtils.java @@ -207,4 +207,4 @@ public static int getDefaultBufferSize(Configuration conf, String codecClassName return DEFAULT_BUFFER_SIZE; } } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestCartesianProductConfig.java b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestCartesianProductConfig.java index eba4053e0e..b064bd26af 100644 --- a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestCartesianProductConfig.java +++ b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestCartesianProductConfig.java @@ -144,4 +144,4 @@ public void testFairCartesianProductConfig() { assertEquals(0.75f, proto.getGroupingFraction(), 0.01); assertEquals(25, proto.getNumPartitionsForFairCase()); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestFairCartesianProductEdgeManager.java b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestFairCartesianProductEdgeManager.java index 13ec8f42a3..cddd194d08 100644 --- a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestFairCartesianProductEdgeManager.java +++ b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/cartesianproduct/TestFairCartesianProductEdgeManager.java @@ -243,4 +243,4 @@ public void testNumPartition() throws Exception { edgeManager.initialize(builder.build()); assertEquals(20, edgeManager.getNumSourceTaskPhysicalOutputs(0)); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/TestConfigUtils.java b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/TestConfigUtils.java index 650477782e..bef4cb022d 100644 --- a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/TestConfigUtils.java +++ b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/common/TestConfigUtils.java @@ -83,4 +83,4 @@ public void getIntermediateInputKeyComparator() { CustomKey customKey = (CustomKey) rawComparator.newKey(); assertEquals(testValue, customKey.getConf().get(testKey)); } -} \ No newline at end of file +} diff --git a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/testutils/KVDataGen.java b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/testutils/KVDataGen.java index 62fd2bf174..b6818634eb 100644 --- a/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/testutils/KVDataGen.java +++ b/tez-runtime-library/src/test/java/org/apache/tez/runtime/library/testutils/KVDataGen.java @@ -97,4 +97,4 @@ public IntWritable getvalue() { return this.value; } } -} \ No newline at end of file +} diff --git a/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/AnalyzerDriver.java b/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/AnalyzerDriver.java index 9eda46294e..4cfd40251e 100644 --- a/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/AnalyzerDriver.java +++ b/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/plugins/AnalyzerDriver.java @@ -70,4 +70,4 @@ public static void main(String argv[]){ System.exit(exitCode); } -} \ No newline at end of file +} diff --git a/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/utils/SVGUtils.java b/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/utils/SVGUtils.java index 2919bfcca1..ac95d89a0b 100644 --- a/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/utils/SVGUtils.java +++ b/tez-tools/analyzers/job-analyzer/src/main/java/org/apache/tez/analyzer/utils/SVGUtils.java @@ -335,4 +335,4 @@ private void saveFileStr(String fileName) { } -} \ No newline at end of file +}