carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [12/25] carbondata git commit: [CARBONDATA-2161] update mergeTo column for compacted segment of streaming table
Date Sat, 03 Mar 2018 12:43:59 GMT
[CARBONDATA-2161] update mergeTo column for compacted segment of streaming table

This closes #1971


Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/36e770ce
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/36e770ce
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/36e770ce

Branch: refs/heads/branch-1.3
Commit: 36e770ce631e2bdb741fbd0d0ac60064399946f9
Parents: 95ac5ef
Author: BJangir <babulaljangir111@gmail.com>
Authored: Mon Feb 12 01:02:30 2018 +0530
Committer: ravipesala <ravi.pesala@gmail.com>
Committed: Sat Mar 3 17:55:40 2018 +0530

----------------------------------------------------------------------
 .../org/apache/spark/carbondata/TestStreamingTableOperation.scala  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/carbondata/blob/36e770ce/integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
b/integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
index 5644302..881af3a 100644
--- a/integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
+++ b/integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
@@ -1074,7 +1074,7 @@ class TestStreamingTableOperation extends QueryTest with BeforeAndAfterAll
{
     //Verify MergeTO column entry for compacted Segments
     newSegments.filter(_.getString(1).equals("Compacted")).foreach{ rw =>
       assertResult("Compacted")(rw.getString(1))
-      assert(Integer.parseInt(rw.getString(0)) < Integer.parseInt(rw.getString(4)))
+      assertResult((Integer.parseInt(rw.getString(0))+2).toString)(rw.getString(4))
     }
     checkAnswer(
       sql("select count(*) from streaming.stream_table_reopen"),


Mime
View raw message