apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject apex-malhar git commit: Fix compile error in RedshiftJdbc operator.
Date Tue, 21 Mar 2017 05:57:05 GMT
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 <thw@apache.org>
Authored: Mon Mar 20 22:12:21 2017 -0700
Committer: Thomas Weise <thw@apache.org>
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 {


Mime
View raw message