Repository: apex-malhar Updated Branches: refs/heads/master 2b3c2aa88 -> 6a31088c0
Fix compile error in RedshiftJdbc operator. Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/6a31088c Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/6a31088c Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/6a31088c Branch: refs/heads/master Commit: 6a31088c0b5076559522ce5be347a064ef3ab7ad Parents: 2b3c2aa Author: Thomas Weise <[email protected]> Authored: Mon Mar 20 22:12:21 2017 -0700 Committer: Thomas Weise <[email protected]> Committed: Mon Mar 20 22:12:21 2017 -0700 ---------------------------------------------------------------------- .../db/redshift/RedshiftJdbcTransactionableOutputOperator.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/6a31088c/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java index 286e852..fa11fc7 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java @@ -33,7 +33,6 @@ import org.apache.apex.malhar.lib.fs.FSRecordCompactionOperator; import org.apache.hadoop.classification.InterfaceStability; import com.google.common.base.Preconditions; -import com.sun.tools.javac.util.Assert; import com.datatorrent.api.Context; import com.datatorrent.api.annotation.OperatorAnnotation; @@ -74,9 +73,9 @@ public class RedshiftJdbcTransactionableOutputOperator extends AbstractJdbcTrans public void setup(Context.OperatorContext context) { if (readerMode == RedshiftOutputModule.READER_MODE.READ_FROM_S3) { - Assert.checkNonNull(bucketName); + Preconditions.checkNotNull(bucketName); } else { - Assert.checkNonNull(emrClusterId); + Preconditions.checkNotNull(emrClusterId); } super.setup(context); try {
