This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git


The following commit(s) were added to refs/heads/master by this push:
     new 7a1fe86d [hotfix][SECURITY] Fix Temporary File Information Disclosure 
Vulnerability
7a1fe86d is described below

commit 7a1fe86d23ecabd6069e2eef2ac7ce849835599b
Author: Jonathan Leitschuh <[email protected]>
AuthorDate: Sun Nov 20 23:34:40 2022 -0800

    [hotfix][SECURITY] Fix Temporary File Information Disclosure Vulnerability
    
    This closes #392
---
 .../test/java/org/apache/flink/table/store/spark/SparkReadITCase.java  | 3 ++-
 .../test/java/org/apache/flink/table/store/spark/SparkReadITCase.java  | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
 
b/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
index c32ab2eb..c55b49d3 100644
--- 
a/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
+++ 
b/flink-table-store-spark/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
@@ -53,6 +53,7 @@ import org.junit.jupiter.api.Test;
 
 import java.io.File;
 import java.io.IOException;
+import java.nio.file.Files;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
@@ -79,7 +80,7 @@ public class SparkReadITCase {
 
     @BeforeAll
     public static void startMetastoreAndSpark() throws Exception {
-        warehouse = File.createTempFile("warehouse", null);
+        warehouse = Files.createTempFile("warehouse", null).toFile();
         assertThat(warehouse.delete()).isTrue();
         warehousePath = new Path("file:" + warehouse);
         spark = SparkSession.builder().master("local[2]").getOrCreate();
diff --git 
a/flink-table-store-spark2/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
 
b/flink-table-store-spark2/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
index 86427f09..e7151cc1 100644
--- 
a/flink-table-store-spark2/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
+++ 
b/flink-table-store-spark2/src/test/java/org/apache/flink/table/store/spark/SparkReadITCase.java
@@ -37,6 +37,7 @@ import org.junit.jupiter.api.Test;
 
 import java.io.File;
 import java.io.IOException;
+import java.nio.file.Files;
 import java.util.Arrays;
 import java.util.List;
 
@@ -55,7 +56,7 @@ public class SparkReadITCase {
 
     @BeforeAll
     public static void startSpark() throws Exception {
-        warehouse = File.createTempFile("warehouse", null);
+        warehouse = Files.createTempFile("warehouse", null).toFile();
         assertThat(warehouse.delete()).isTrue();
         Path warehousePath = new Path("file:" + warehouse);
         spark = SparkSession.builder().master("local[2]").getOrCreate();

Reply via email to