mvalleavila/Kafka-Spark-Hbase-Example

wheteher the rowKeyCounterMap shuould be clear

xiaofateng opened this issue · 0 comments

hello, Marcelo
In the Example, you use rowKeyCounterMap to store data, but never clear it.
Since, the HBaseCounterIncrementor is a singleton, in one jvm, the rowKeyCounterMap will continuous increase, I think.
I wonder am I right.

Also,I see the CounterMap.clear(), but seems never used.

Looking forward to your reply

Regards,
Xiao