[MINOR] Remove redundant lines in StreamSync and TestStreamSyncUnitTe…

…sts (apache#11027)
zhuanshenbsj1 · Apr 16, 2024 · c54be84 · c54be84
1 parent 40d4f48
commit c54be84
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 24 deletions.
diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java
@@ -278,7 +278,6 @@ public class StreamSync implements Serializable, Closeable {
     this.formatAdapter = formatAdapter;
     this.transformer = transformer;
     this.useRowWriter = useRowWriter;
-
   }
 
   @Deprecated
@@ -501,7 +500,6 @@ private Option<String> getLastPendingCompactionInstant(Option<HoodieTimeline> co
    * @return Pair<InputBatch and Boolean> Input data read from upstream source, and boolean is true if empty.
    * @throws Exception in case of any Exception
    */
-
   public InputBatch readFromSource(String instantTime, HoodieTableMetaClient metaClient) throws IOException {
     // Retrieve the previous round checkpoints, if any
     Option<String> resumeCheckpointStr = Option.empty();
@@ -564,7 +562,6 @@ private InputBatch fetchFromSourceAndPrepareRecords(Option<String> resumeCheckpo
     // handle empty batch with change in checkpoint
     hoodieSparkContext.setJobStatus(this.getClass().getSimpleName(), "Checking if input is empty: " + cfg.targetTableName);
 
-
     if (useRowWriter) { // no additional processing required for row writer.
       return inputBatch;
     } else {
@@ -1297,5 +1294,4 @@ public JavaRDD<WriteStatus> getWriteStatusRDD() {
       return writeStatusRDD;
     }
   }
-
 }
diff --git a/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java b/hudi-utilities/src/test/java/org/apache/hudi/utilities/streamer/TestStreamSyncUnitTests.java
@@ -17,25 +17,6 @@
  * under the License.
  */
 
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
 package org.apache.hudi.utilities.streamer;
 
 import org.apache.hudi.DataSourceWriteOptions;
@@ -75,7 +56,6 @@
 import static org.mockito.Mockito.when;
 
 public class TestStreamSyncUnitTests {
-
   @ParameterizedTest
   @MethodSource("testCasesFetchNextBatchFromSource")
   void testFetchNextBatchFromSource(Boolean useRowWriter, Boolean hasTransformer, Boolean hasSchemaProvider,