Github user QiangCai commented on a diff in the pull request: https://github.com/apache/carbondata/pull/2163#discussion_r181008981 --- Diff: streaming/src/main/scala/org/apache/carbondata/streaming/StreamSinkFactory.scala --- @@ -45,11 +50,41 @@ import org.apache.carbondata.streaming.segment.StreamSegment */ object StreamSinkFactory { + val LOGGER = LogServiceFactory.getLogService(this.getClass.getCanonicalName) + + val locks = new util.concurrent.ConcurrentHashMap[String, ICarbonLock]() + + def lock(carbonTable: CarbonTable): Unit = { --- End diff -- ok, I will modify it in the future. This is a synchronized pr, better to keep same with previous.
---