Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/19416
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142583033
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142562531
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user yssharma commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142368186
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142304163
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142303254
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala
---
@@ -376,9 +388,35 @@ class FlatMapGroupsWithStateSuite
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142303281
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala
---
@@ -376,9 +388,35 @@ class FlatMapGroupsWithStateSuite
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142303228
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/FlatMapGroupsWithStateSuite.scala
---
@@ -397,50 +435,23 @@ class
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142303057
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142303019
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/FlatMapGroupsWithState_StateManager.scala
---
@@ -0,0 +1,143 @@
+/*
Github user tdas commented on a diff in the pull request:
https://github.com/apache/spark/pull/19416#discussion_r142302989
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FlatMapGroupsWithStateExec.scala
---
@@ -62,26 +60,7 @@ case class
GitHub user tdas opened a pull request:
https://github.com/apache/spark/pull/19416
[SPARK-22187][SS] Update unsaferow format for saved state such that we can
set timeouts when state is null
## What changes were proposed in this pull request?
Currently, the group state of
12 matches
Mail list logo