Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2328#discussion_r196444770
--- 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"
generateCSVDataFile(spark, idStart = 10, rowNums = 5, csvDataDir)
generateCSVDataFile(spark, idStart = 10, rowNums = 5, csvDataDir,
SaveMode.Append)
- csvDataDir = new File("target/csvdata").getCanonicalPath
- // streaming ingest 10 rows
- generateCSVDataFile(spark, idStart = 10, rowNums = 10, csvDataDir)
--- End diff --
I added it in individual test case
---
