You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2017/03/21 05:57:05 UTC
apex-malhar git commit: Fix compile error in RedshiftJdbc operator.
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 <th...@apache.org>
Authored: Mon Mar 20 22:12:21 2017 -0700
Committer: Thomas Weise <th...@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 {