Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2328#discussion_r196350110
--- Diff:
integration/spark2/src/test/scala/org/apache/spark/carbondata/TestStreamingTableOperation.scala
---
@@ -123,12 +123,9 @@ class TestStreamingTableOperation extends QueryTest
with BeforeAndAfterAll {
createTable(tableName = "agg_table", streaming = true, withBatchLoad =
false)
- var csvDataDir = new File("target/csvdatanew").getCanonicalPath
+ val csvDataDir = integrationPath + "target/csvdatanew"
--- End diff --
it should be `integrationPath + "/spark2/target/csvdatanew`
---
