Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2328#discussion_r196350296
--- 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 --
why is this removed?
---
