From 27ba401af297e63c17a6fb8178288b34fe46f4fc Mon Sep 17 00:00:00 2001 From: AMit-Cloudsufi Date: Thu, 9 Jan 2025 07:49:01 +0000 Subject: [PATCH] removed unused import --- .../io/cdap/plugin/batch/aggregator/AggregationUtils.java | 1 - .../io/cdap/plugin/batch/aggregator/DistinctAggregator.java | 1 - .../io/cdap/plugin/batch/aggregator/GroupByAggregator.java | 2 +- pom.xml | 4 ++-- 4 files changed, 3 insertions(+), 5 deletions(-) diff --git a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/AggregationUtils.java b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/AggregationUtils.java index 384c4e7ed..23283c5b6 100644 --- a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/AggregationUtils.java +++ b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/AggregationUtils.java @@ -16,7 +16,6 @@ package io.cdap.plugin.batch.aggregator; -import com.google.common.base.Joiner; import io.cdap.cdap.api.data.schema.Schema; import io.cdap.cdap.api.exception.ErrorCategory; import io.cdap.cdap.api.exception.ErrorType; diff --git a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/DistinctAggregator.java b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/DistinctAggregator.java index bebd1a899..85fe11135 100644 --- a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/DistinctAggregator.java +++ b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/DistinctAggregator.java @@ -39,7 +39,6 @@ import java.util.ArrayList; import java.util.Collections; -import java.util.Iterator; import java.util.List; import javax.annotation.Nullable; diff --git a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/GroupByAggregator.java b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/GroupByAggregator.java index 9f8463845..12c030dca 100644 --- a/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/GroupByAggregator.java +++ b/core-plugins/src/main/java/io/cdap/plugin/batch/aggregator/GroupByAggregator.java @@ -450,7 +450,7 @@ private Schema getGroupKeySchema(Schema inputSchema) { "Cannot group by field '%s' because it does not exist in input schema %s", groupByField, inputSchema); throw ErrorUtils.getProgramFailureException(new ErrorCategory(ErrorCategory.ErrorCategoryEnum.PLUGIN), - error, error, ErrorType.USER, true, new IllegalArgumentException()); + error, error, ErrorType.USER, false, new IllegalArgumentException()); } fields.add(fieldSchema); } diff --git a/pom.xml b/pom.xml index 7d317cdfa..ce0827ca3 100644 --- a/pom.xml +++ b/pom.xml @@ -1004,12 +1004,12 @@ !cloudBuild - wrangler-transform +