Skip to content

Commit 65801a6

Browse files
committed
Address review comments from @tdas
* add test which restores query from Spark 2.3.1
1 parent 8629f59 commit 65801a6

File tree

26 files changed

+66
-0
lines changed

26 files changed

+66
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
v1
2+
{}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
v1
2+
{}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
{"id":"2f32aca2-1b97-458f-a48f-109328724f09"}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
v1
2+
{"batchWatermarkMs":0,"batchTimestampMs":1533784347136,"conf":{"spark.sql.shuffle.partitions":"5","spark.sql.streaming.stateStore.providerClass":"org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider"}}
3+
0
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
v1
2+
{"batchWatermarkMs":0,"batchTimestampMs":1533784349160,"conf":{"spark.sql.shuffle.partitions":"5","spark.sql.streaming.stateStore.providerClass":"org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider"}}
3+
1

0 commit comments

Comments
 (0)