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();