[BAHIR-172 ] Replace FileInputStream with Files.newInputStream (apach…

…e#92)
SubhraTheGeek · Sep 3, 2019 · 68ac1be · 68ac1be
1 parent 549c50b
commit 68ac1be
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTTestUtils.scala b/sql-streaming-mqtt/src/test/scala/org/apache/bahir/sql/streaming/mqtt/MQTTTestUtils.scala
@@ -18,9 +18,9 @@
 package org.apache.bahir.sql.streaming.mqtt
 
 import java.io.File
-import java.io.FileInputStream
 import java.net.{ServerSocket, URI}
 import java.nio.charset.Charset
+import java.nio.file.Files
 import java.security.{KeyStore, SecureRandom}
 import java.util.Properties
 import javax.net.ssl.KeyManagerFactory
@@ -63,7 +63,7 @@ class MQTTTestUtils(tempDir: File, port: Int = 0, ssl: Boolean = false) extends
  val protocol = if (ssl) "mqtt+ssl" else "mqtt"
  if (ssl) {
  val keyStore = KeyStore.getInstance("JKS")
- keyStore.load(new FileInputStream(serverKeyStore), serverKeyStorePassword.toCharArray)
+ keyStore.load(Files.newInputStream(serverKeyStore.toPath), serverKeyStorePassword.toCharArray)
  val keyManagerFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm)
  keyManagerFactory.init(keyStore, serverKeyStorePassword.toCharArray)
  broker.setSslContext(

diff --git a/streaming-pubsub/src/main/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentials.scala b/streaming-pubsub/src/main/scala/org/apache/spark/streaming/pubsub/SparkGCPCredentials.scala
@@ -86,7 +86,7 @@ private[pubsub] final case class EMailPrivateKeyCredentials(
  override def provider: Credential = {
  val tempFile = File.createTempFile(emailAccount, ".p12")
  tempFile.deleteOnExit()
- val p12Out = new FileOutputStream(tempFile)
+ val p12Out = Files.newOutputStream(tempFile.toPath)
  p12Out.write(p12Content, 0, p12Content.length)
  p12Out.flush()
  p12Out.close()