Repository: phoenix Updated Branches: refs/heads/4.x-HBase-1.1 19599bf98 -> e7a3975ed
PHOENIX-3135 Addendum to fix unit test asserting no CSV support Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e7a3975e Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e7a3975e Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e7a3975e Branch: refs/heads/4.x-HBase-1.1 Commit: e7a3975eda704766ad20bd96f76f9750fac74d77 Parents: 19599bf Author: Josh Mahonin <jmaho...@gmail.com> Authored: Wed Feb 15 10:31:39 2017 -0500 Committer: Josh Mahonin <jmaho...@gmail.com> Committed: Wed Feb 15 10:42:52 2017 -0500 ---------------------------------------------------------------------- .../src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/phoenix/blob/e7a3975e/phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java ---------------------------------------------------------------------- diff --git a/phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java b/phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java index e78a964..867d1ad 100644 --- a/phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java +++ b/phoenix-flume/src/it/java/org/apache/phoenix/flume/PhoenixSinkIT.java @@ -99,7 +99,7 @@ public class PhoenixSinkIT extends BaseHBaseManagedTimeIT { sinkContext = new Context (); sinkContext.put(FlumeConstants.CONFIG_TABLE, "test"); sinkContext.put(FlumeConstants.CONFIG_JDBC_URL, getUrl()); - sinkContext.put(FlumeConstants.CONFIG_SERIALIZER,"csv"); + sinkContext.put(FlumeConstants.CONFIG_SERIALIZER,"unknown"); sinkContext.put(FlumeConstants.CONFIG_SERIALIZER_PREFIX + FlumeConstants.CONFIG_COLUMN_NAMES,"col1,col2"); sinkContext.put(FlumeConstants.CONFIG_SERIALIZER_PREFIX + FlumeConstants.CONFIG_ROWKEY_TYPE_GENERATOR,DefaultKeyGenerator.TIMESTAMP.name());
