Merge pull request #1000 from data-integrations/remove-override

remove override

Author: yaojiefeng

src/main/java/io/cdap/plugin/gcp/gcs/sink/GCSBatchSink.java

@@ -33,7 +33,6 @@
 import io.cdap.cdap.api.annotation.Plugin;
 import io.cdap.cdap.api.data.schema.Schema;
 import io.cdap.cdap.api.plugin.PluginConfig;
-import io.cdap.cdap.etl.api.Arguments;
 import io.cdap.cdap.etl.api.FailureCollector;
 import io.cdap.cdap.etl.api.PipelineConfigurer;
 import io.cdap.cdap.etl.api.StageMetrics;
@@ -50,7 +49,6 @@
 import io.cdap.plugin.format.plugin.FileSinkProperties;
 import io.cdap.plugin.gcp.common.CmekUtils;
 import io.cdap.plugin.gcp.common.GCPConnectorConfig;
-import io.cdap.plugin.gcp.common.GCPReferenceSinkConfig;
 import io.cdap.plugin.gcp.common.GCPUtils;
 import io.cdap.plugin.gcp.gcs.Formats;
 import io.cdap.plugin.gcp.gcs.GCSPath;
@@ -87,7 +85,6 @@ public class GCSBatchSink extends AbstractFileSink<GCSBatchSink.GCSBatchSinkConf
   private final GCSBatchSinkConfig config;
   private String outputPath;
 
-
   public GCSBatchSink(GCSBatchSinkConfig config) {
     super(config);
     this.config = config;
@@ -138,6 +135,7 @@ public void prepareRun(BatchSinkContext context) throws Exception {
     if (bucket == null) {
       GCPUtils.createBucket(storage, config.getBucket(), config.getLocation(), cmekKeyName);
     }
+    this.outputPath = getOutputDir(context);
   }
 
   @Override
@@ -156,12 +154,6 @@ protected Map<String, String> getFileSystemProperties(BatchSinkContext context)
     return properties;
   }
 
-  @Override
-  protected String getOutputDir(long logicalStartTime) {
-    this.outputPath = super.getOutputDir(logicalStartTime);
-    return this.outputPath;
-  }
-
   @Override
   protected void recordLineage(LineageRecorder lineageRecorder, List<String> outputFields) {
     lineageRecorder.recordWrite("Write", "Wrote to Google Cloud Storage.", outputFields);