[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 <babulaljangir...@gmail.com> Authored: Mon Feb 12 01:02:30 2018 +0530 Committer: ravipesala <ravi.pes...@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"),
