fix some compiler warnings (apache#188)

mdedetrich · Jun 27, 2023 · a7e23f7 · a7e23f7
1 parent cbc4f9d
commit a7e23f7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala b/csv/src/main/scala/org/apache/pekko/stream/connectors/csv/impl/CsvParser.scala
@@ -102,9 +102,9 @@ import scala.collection.mutable
   /**
    * Reset after each row.
    */
-  private[this] var columns = mutable.ListBuffer[ByteString]()
+  private[this] val columns = mutable.ListBuffer[ByteString]()
   private[this] var state: State = LineStart
-  private[this] var fieldBuilder = new FieldBuilder
+  private[this] val fieldBuilder = new FieldBuilder
 
   /**
    * Current iterator being parsed.

diff --git a/.../src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala b/.../src/main/scala/org/apache/pekko/stream/connectors/elasticsearch/SourceSettingsBase.scala
@@ -17,8 +17,6 @@ import org.apache.pekko
 import pekko.util.JavaDurationConverters._
 import java.util.concurrent.TimeUnit
 
-import pekko.stream.connectors.elasticsearch.ElasticsearchConnectionSettings
-
 import scala.concurrent.duration.FiniteDuration
 
 /**