scalastyle

apache · Jun 30, 2024 · 7b87ff8 · 7b87ff8
1 parent a109f0d
commit 7b87ff8
Showing 1 changed file with 4 additions and 11 deletions.
diff --git a/dev/diffs/3.5.1.diff b/dev/diffs/3.5.1.diff
@@ -2346,19 +2346,12 @@ index b4c4ec7acbf..20579284856 100644
 
          val aggregateExecsWithoutPartialAgg = allAggregateExecs.filter {
 diff --git a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala
-index 3e1bc57dfa2..47c36f1cbc9 100644
+index 3e1bc57dfa2..0d151977165 100644
 --- a/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala
 +++ b/sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingJoinSuite.scala
-@@ -21,17 +21,11 @@ import java.io.File
- import java.lang.{Integer => JInteger}
- import java.sql.Timestamp
- import java.util.{Locale, UUID}
--
- import scala.util.Random
--
- import org.apache.commons.io.FileUtils
+@@ -28,10 +28,7 @@ import org.apache.commons.io.FileUtils
  import org.scalatest.BeforeAndAfter
--
+ 
  import org.apache.spark.scheduler.ExecutorCacheTaskLocation
 -import org.apache.spark.sql.{DataFrame, Row, SparkSession}
 -import org.apache.spark.sql.catalyst.expressions.{AttributeReference, Expression}
@@ -2368,7 +2361,7 @@ index 3e1bc57dfa2..47c36f1cbc9 100644
  import org.apache.spark.sql.execution.streaming.{MemoryStream, StatefulOperatorStateInfo, StreamingSymmetricHashJoinExec, StreamingSymmetricHashJoinHelper}
  import org.apache.spark.sql.execution.streaming.state.{RocksDBStateStoreProvider, StateStore, StateStoreProviderId}
  import org.apache.spark.sql.functions._
-@@ -594,40 +588,9 @@ class StreamingInnerJoinSuite extends StreamingJoinSuite {
+@@ -594,40 +591,9 @@ class StreamingInnerJoinSuite extends StreamingJoinSuite {
        CheckNewAnswer((5, 10, 5, 15, 5, 25)))
    }