This is an automated email from the ASF dual-hosted git repository.
srowen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 9f817379c68 [SPARK-45341][CORE] Correct the title level in the
comments of KVStore.java to make `sbt doc` run successfully with Java 17
add b7763a7eae2 [SPARK-45338][CORE][SQL] Replace
`scala.collection.JavaConverters` to `scala.jdk.CollectionConverters`
No new revisions were added by this update.
Summary of changes:
.../scala/org/apache/spark/ErrorClassesJSONReader.scala | 2 +-
.../src/main/scala/org/apache/spark/SparkException.scala | 2 +-
.../scala/org/apache/spark/SparkThrowableHelper.scala | 2 +-
.../main/scala/org/apache/spark/internal/Logging.scala | 2 +-
.../org/apache/spark/sql/avro/AvroDeserializer.scala | 2 +-
.../org/apache/spark/sql/avro/AvroOutputWriter.scala | 2 +-
.../scala/org/apache/spark/sql/avro/AvroSerializer.scala | 2 +-
.../main/scala/org/apache/spark/sql/avro/AvroUtils.scala | 2 +-
.../org/apache/spark/sql/avro/SchemaConverters.scala | 2 +-
.../main/scala/org/apache/spark/sql/avro/functions.scala | 2 +-
.../scala/org/apache/spark/sql/v2/avro/AvroScan.scala | 2 +-
.../scala/org/apache/spark/sql/v2/avro/AvroTable.scala | 2 +-
.../org/apache/spark/sql/avro/AvroFunctionsSuite.scala | 2 +-
.../test/scala/org/apache/spark/sql/avro/AvroSuite.scala | 2 +-
.../jvm/src/main/scala/org/apache/spark/sql/Column.scala | 2 +-
.../org/apache/spark/sql/DataFrameNaFunctions.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameReader.scala | 2 +-
.../org/apache/spark/sql/DataFrameStatFunctions.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameWriter.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameWriterV2.scala | 2 +-
.../src/main/scala/org/apache/spark/sql/Dataset.scala | 2 +-
.../org/apache/spark/sql/KeyValueGroupedDataset.scala | 2 +-
.../org/apache/spark/sql/RelationalGroupedDataset.scala | 2 +-
.../main/scala/org/apache/spark/sql/SparkSession.scala | 2 +-
.../main/scala/org/apache/spark/sql/avro/functions.scala | 2 +-
.../scala/org/apache/spark/sql/catalog/Catalog.scala | 2 +-
.../spark/sql/expressions/UserDefinedFunction.scala | 2 +-
.../org/apache/spark/sql/expressions/WindowSpec.scala | 2 +-
.../src/main/scala/org/apache/spark/sql/functions.scala | 2 +-
.../scala/org/apache/spark/sql/protobuf/functions.scala | 2 +-
.../apache/spark/sql/streaming/DataStreamReader.scala | 2 +-
.../apache/spark/sql/streaming/DataStreamWriter.scala | 2 +-
.../org/apache/spark/sql/streaming/StreamingQuery.scala | 2 +-
.../spark/sql/streaming/StreamingQueryManager.scala | 2 +-
.../scala/org/apache/spark/sql/streaming/progress.scala | 2 +-
.../scala/org/apache/spark/sql/ClientE2ETestSuite.scala | 2 +-
.../scala/org/apache/spark/sql/ColumnTestSuite.scala | 2 +-
.../org/apache/spark/sql/DataFrameNaFunctionSuite.scala | 2 +-
.../scala/org/apache/spark/sql/FunctionTestSuite.scala | 2 +-
.../org/apache/spark/sql/PlanGenerationTestSuite.scala | 2 +-
.../spark/sql/UserDefinedFunctionE2ETestSuite.scala | 2 +-
.../apache/spark/sql/connect/client/ArtifactSuite.scala | 2 +-
.../sql/connect/client/SparkConnectClientSuite.scala | 2 +-
.../spark/sql/streaming/ClientStreamingQuerySuite.scala | 2 +-
.../spark/sql/connect/client/ArtifactManager.scala | 2 +-
.../apache/spark/sql/connect/client/ClassFinder.scala | 2 +-
.../connect/client/CustomSparkConnectBlockingStub.scala | 2 +-
.../client/ExecutePlanResponseReattachableIterator.scala | 2 +-
.../sql/connect/client/GrpcExceptionConverter.scala | 2 +-
.../spark/sql/connect/client/SparkConnectClient.scala | 2 +-
.../sql/connect/client/arrow/ArrowEncoderUtils.scala | 2 +-
.../spark/sql/connect/client/arrow/ArrowSerializer.scala | 2 +-
.../sql/connect/common/LiteralValueProtoConverter.scala | 2 +-
.../org/apache/spark/sql/connect/common/ProtoUtils.scala | 2 +-
.../org/apache/spark/sql/connect/common/UdfUtils.scala | 2 +-
.../apache/spark/sql/connect/SparkConnectPlugin.scala | 2 +-
.../connect/artifact/SparkConnectArtifactManager.scala | 2 +-
.../scala/org/apache/spark/sql/connect/dsl/package.scala | 2 +-
.../connect/execution/SparkConnectPlanExecution.scala | 2 +-
.../spark/sql/connect/planner/SparkConnectPlanner.scala | 2 +-
.../connect/planner/StreamingForeachBatchHelper.scala | 2 +-
.../apache/spark/sql/connect/service/ExecuteHolder.scala | 2 +-
.../apache/spark/sql/connect/service/SessionHolder.scala | 2 +-
.../sql/connect/service/SparkConnectAnalyzeHandler.scala | 2 +-
.../service/SparkConnectArtifactStatusesHandler.scala | 2 +-
.../sql/connect/service/SparkConnectConfigHandler.scala | 2 +-
.../connect/service/SparkConnectExecutionManager.scala | 2 +-
.../connect/service/SparkConnectInterruptHandler.scala | 2 +-
.../apache/spark/sql/connect/utils/MetricGenerator.scala | 2 +-
.../sql/connect/planner/SparkConnectPlannerSuite.scala | 2 +-
.../sql/connect/planner/SparkConnectProtoSuite.scala | 2 +-
.../sql/connect/planner/SparkConnectServiceSuite.scala | 2 +-
.../sql/connect/service/AddArtifactsHandlerSuite.scala | 2 +-
.../connect/service/ArtifactStatusesHandlerSuite.scala | 2 +-
.../connect/service/SparkConnectSessionHodlerSuite.scala | 2 +-
.../spark/sql/jdbc/DockerJDBCIntegrationSuite.scala | 2 +-
.../org/apache/spark/sql/jdbc/v2/DB2NamespaceSuite.scala | 2 +-
.../spark/sql/jdbc/v2/MsSqlServerNamespaceSuite.scala | 2 +-
.../apache/spark/sql/jdbc/v2/MySQLNamespaceSuite.scala | 2 +-
.../apache/spark/sql/jdbc/v2/OracleNamespaceSuite.scala | 2 +-
.../spark/sql/jdbc/v2/PostgresNamespaceSuite.scala | 2 +-
.../apache/spark/sql/jdbc/v2/V2JDBCNamespaceTest.scala | 2 +-
.../test/scala/org/apache/spark/util/DockerUtils.scala | 2 +-
.../org/apache/spark/sql/kafka010/ConsumerStrategy.scala | 2 +-
.../spark/sql/kafka010/KafkaMicroBatchStream.scala | 2 +-
.../spark/sql/kafka010/KafkaOffsetReaderAdmin.scala | 2 +-
.../spark/sql/kafka010/KafkaOffsetReaderConsumer.scala | 2 +-
.../spark/sql/kafka010/KafkaRecordToRowConverter.scala | 2 +-
.../apache/spark/sql/kafka010/KafkaSourceProvider.scala | 2 +-
.../org/apache/spark/sql/kafka010/KafkaWriteTask.scala | 2 +-
.../spark/sql/kafka010/consumer/KafkaDataConsumer.scala | 2 +-
.../kafka010/producer/InternalKafkaProducerPool.scala | 2 +-
.../spark/sql/kafka010/ConsumerStrategySuite.scala | 2 +-
.../spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala | 2 +-
.../sql/kafka010/KafkaOffsetRangeCalculatorSuite.scala | 2 +-
.../spark/sql/kafka010/KafkaSourceProviderSuite.scala | 2 +-
.../org/apache/spark/sql/kafka010/KafkaTestUtils.scala | 2 +-
.../org/apache/spark/sql/kafka010/RecordBuilder.scala | 2 +-
.../sql/kafka010/consumer/FetchedDataPoolSuite.scala | 2 +-
.../consumer/InternalKafkaConsumerPoolSuite.scala | 2 +-
.../sql/kafka010/consumer/KafkaDataConsumerSuite.scala | 2 +-
.../org/apache/spark/kafka010/KafkaConfigUpdater.scala | 2 +-
.../scala/org/apache/spark/kafka010/KafkaTokenUtil.scala | 2 +-
.../apache/spark/kafka010/KafkaConfigUpdaterSuite.scala | 2 +-
.../org/apache/spark/kafka010/KafkaTokenUtilSuite.scala | 2 +-
.../spark/streaming/kafka010/ConsumerStrategy.scala | 2 +-
.../streaming/kafka010/DirectKafkaInputDStream.scala | 2 +-
.../spark/streaming/kafka010/KafkaDataConsumer.scala | 2 +-
.../spark/streaming/kafka010/LocationStrategy.scala | 2 +-
.../streaming/kafka010/JavaConsumerStrategySuite.java | 12 +++++-------
.../streaming/kafka010/JavaLocationStrategySuite.java | 5 ++---
.../streaming/kafka010/DirectKafkaStreamSuite.scala | 2 +-
.../streaming/kafka010/KafkaDataConsumerSuite.scala | 2 +-
.../apache/spark/streaming/kafka010/KafkaRDDSuite.scala | 2 +-
.../apache/spark/streaming/kafka010/KafkaTestUtils.scala | 2 +-
.../spark/examples/streaming/KinesisExampleUtils.scala | 2 +-
.../spark/streaming/kinesis/KinesisBackedBlockRDD.scala | 2 +-
.../spark/streaming/kinesis/KinesisInputDStream.scala | 2 +-
.../apache/spark/streaming/kinesis/KinesisReceiver.scala | 2 +-
.../spark/streaming/kinesis/KinesisTestUtils.scala | 2 +-
.../kinesis/KinesisInputDStreamBuilderSuite.scala | 2 +-
.../spark/sql/protobuf/ProtobufDataToCatalyst.scala | 2 +-
.../apache/spark/sql/protobuf/ProtobufSerializer.scala | 2 +-
.../scala/org/apache/spark/sql/protobuf/functions.scala | 2 +-
.../apache/spark/sql/protobuf/utils/ProtobufUtils.scala | 2 +-
.../spark/sql/protobuf/utils/SchemaConverters.scala | 2 +-
.../spark/sql/protobuf/ProtobufFunctionsSuite.scala | 2 +-
.../org/apache/spark/sql/protobuf/ProtobufTestBase.scala | 2 +-
.../apache/spark/shuffle/sort/UnsafeShuffleWriter.java | 4 ++--
.../main/scala/org/apache/spark/BarrierTaskContext.scala | 2 +-
.../src/main/scala/org/apache/spark/ContextCleaner.scala | 2 +-
core/src/main/scala/org/apache/spark/FutureAction.scala | 2 +-
.../main/scala/org/apache/spark/MapOutputTracker.scala | 2 +-
core/src/main/scala/org/apache/spark/SparkConf.scala | 2 +-
core/src/main/scala/org/apache/spark/SparkContext.scala | 2 +-
core/src/main/scala/org/apache/spark/SparkEnv.scala | 2 +-
.../apache/spark/SparkFileAlreadyExistsException.scala | 2 +-
.../main/scala/org/apache/spark/TaskContextImpl.scala | 2 +-
core/src/main/scala/org/apache/spark/TestUtils.scala | 2 +-
.../scala/org/apache/spark/api/java/JavaHadoopRDD.scala | 2 +-
.../org/apache/spark/api/java/JavaNewHadoopRDD.scala | 2 +-
.../scala/org/apache/spark/api/java/JavaPairRDD.scala | 2 +-
.../scala/org/apache/spark/api/java/JavaRDDLike.scala | 4 ++--
.../org/apache/spark/api/java/JavaSparkContext.scala | 2 +-
.../org/apache/spark/api/python/PythonHadoopUtil.scala | 2 +-
.../scala/org/apache/spark/api/python/PythonRDD.scala | 2 +-
.../scala/org/apache/spark/api/python/PythonRunner.scala | 2 +-
.../scala/org/apache/spark/api/python/PythonUtils.scala | 2 +-
.../apache/spark/api/python/PythonWorkerFactory.scala | 2 +-
.../scala/org/apache/spark/api/python/SerDeUtil.scala | 2 +-
.../apache/spark/api/python/StreamingPythonRunner.scala | 2 +-
.../api/python/WriteInputFormatTestDataGenerator.scala | 2 +-
core/src/main/scala/org/apache/spark/api/r/RRDD.scala | 2 +-
.../org/apache/spark/broadcast/TorrentBroadcast.scala | 2 +-
.../org/apache/spark/deploy/ExternalShuffleService.scala | 2 +-
.../scala/org/apache/spark/deploy/PythonRunner.scala | 2 +-
.../scala/org/apache/spark/deploy/RPackageUtils.scala | 2 +-
.../src/main/scala/org/apache/spark/deploy/RRunner.scala | 2 +-
.../scala/org/apache/spark/deploy/SparkCuratorUtil.scala | 2 +-
.../scala/org/apache/spark/deploy/SparkHadoopUtil.scala | 2 +-
.../main/scala/org/apache/spark/deploy/SparkSubmit.scala | 2 +-
.../org/apache/spark/deploy/SparkSubmitArguments.scala | 2 +-
.../apache/spark/deploy/history/ApplicationCache.scala | 2 +-
.../spark/deploy/history/EventLogFileCompactor.scala | 2 +-
.../apache/spark/deploy/history/FsHistoryProvider.scala | 2 +-
.../org/apache/spark/deploy/history/HybridStore.scala | 2 +-
.../spark/deploy/master/ZooKeeperPersistenceEngine.scala | 2 +-
.../security/HadoopFSDelegationTokenProvider.scala | 2 +-
.../org/apache/spark/deploy/worker/CommandUtils.scala | 2 +-
.../org/apache/spark/deploy/worker/DriverRunner.scala | 2 +-
.../org/apache/spark/deploy/worker/ExecutorRunner.scala | 2 +-
.../scala/org/apache/spark/errors/SparkCoreErrors.scala | 2 +-
.../main/scala/org/apache/spark/executor/Executor.scala | 2 +-
.../scala/org/apache/spark/executor/ExecutorSource.scala | 2 +-
.../scala/org/apache/spark/executor/TaskMetrics.scala | 2 +-
.../org/apache/spark/input/PortableDataStream.scala | 2 +-
.../apache/spark/input/WholeTextFileInputFormat.scala | 2 +-
.../apache/spark/internal/plugin/PluginContainer.scala | 2 +-
.../org/apache/spark/launcher/WorkerCommandBuilder.scala | 2 +-
.../org/apache/spark/metrics/ExecutorMetricType.scala | 2 +-
.../scala/org/apache/spark/metrics/MetricsConfig.scala | 2 +-
.../apache/spark/metrics/sink/PrometheusServlet.scala | 2 +-
.../org/apache/spark/metrics/sink/StatsdReporter.scala | 2 +-
.../apache/spark/network/netty/NettyBlockRpcServer.scala | 2 +-
.../spark/network/netty/NettyBlockTransferService.scala | 2 +-
.../apache/spark/network/netty/SparkTransportConf.scala | 2 +-
.../main/scala/org/apache/spark/rdd/NewHadoopRDD.scala | 2 +-
.../scala/org/apache/spark/rdd/PairRDDFunctions.scala | 2 +-
core/src/main/scala/org/apache/spark/rdd/PipedRDD.scala | 2 +-
.../main/scala/org/apache/spark/rdd/SubtractedRDD.scala | 2 +-
.../apache/spark/resource/ExecutorResourceRequests.scala | 2 +-
.../org/apache/spark/resource/ResourceProfile.scala | 2 +-
.../apache/spark/resource/ResourceProfileBuilder.scala | 2 +-
.../org/apache/spark/resource/TaskResourceRequests.scala | 2 +-
.../scala/org/apache/spark/rpc/netty/Dispatcher.scala | 2 +-
.../apache/spark/scheduler/EventLoggingListener.scala | 2 +-
.../org/apache/spark/scheduler/InputFormatInfo.scala | 2 +-
.../org/apache/spark/scheduler/LiveListenerBus.scala | 2 +-
.../src/main/scala/org/apache/spark/scheduler/Pool.scala | 2 +-
.../org/apache/spark/scheduler/TaskDescription.scala | 2 +-
.../spark/scheduler/dynalloc/ExecutorMonitor.scala | 2 +-
.../org/apache/spark/security/CryptoStreamUtils.scala | 2 +-
.../org/apache/spark/serializer/KryoSerializer.scala | 6 +++---
.../apache/spark/shuffle/sort/SortShuffleManager.scala | 2 +-
.../org/apache/spark/status/AppStatusListener.scala | 2 +-
.../scala/org/apache/spark/status/AppStatusStore.scala | 2 +-
.../org/apache/spark/status/ElementTrackingStore.scala | 2 +-
.../src/main/scala/org/apache/spark/status/KVUtils.scala | 2 +-
.../main/scala/org/apache/spark/status/LiveEntity.scala | 2 +-
.../org/apache/spark/status/api/v1/StagesResource.scala | 2 +-
.../ApplicationEnvironmentInfoWrapperSerializer.scala | 2 +-
.../protobuf/ApplicationInfoWrapperSerializer.scala | 2 +-
.../protobuf/ExecutorSummaryWrapperSerializer.scala | 2 +-
.../spark/status/protobuf/JobDataWrapperSerializer.scala | 2 +-
.../status/protobuf/KVStoreProtobufSerializer.scala | 2 +-
.../spark/status/protobuf/PoolDataSerializer.scala | 2 +-
.../protobuf/ProcessSummaryWrapperSerializer.scala | 2 +-
.../protobuf/RDDOperationGraphWrapperSerializer.scala | 2 +-
.../protobuf/RDDStorageInfoWrapperSerializer.scala | 2 +-
.../status/protobuf/StageDataWrapperSerializer.scala | 2 +-
.../org/apache/spark/storage/BlockInfoManager.scala | 2 +-
.../scala/org/apache/spark/storage/BlockManager.scala | 2 +-
.../spark/storage/BlockManagerDecommissioner.scala | 2 +-
.../spark/storage/BlockManagerMasterEndpoint.scala | 2 +-
.../org/apache/spark/storage/memory/MemoryStore.scala | 2 +-
.../src/main/scala/org/apache/spark/ui/GraphUIData.scala | 2 +-
.../scala/org/apache/spark/ui/HttpSecurityFilter.scala | 2 +-
core/src/main/scala/org/apache/spark/ui/PagedTable.scala | 2 +-
core/src/main/scala/org/apache/spark/ui/UIUtils.scala | 2 +-
.../org/apache/spark/util/BoundedPriorityQueue.scala | 2 +-
.../scala/org/apache/spark/util/ClosureCleaner.scala | 2 +-
.../main/scala/org/apache/spark/util/JsonProtocol.scala | 2 +-
.../main/scala/org/apache/spark/util/ListenerBus.scala | 4 ++--
.../main/scala/org/apache/spark/util/SignalUtils.scala | 2 +-
.../scala/org/apache/spark/util/TimeStampedHashMap.scala | 2 +-
core/src/main/scala/org/apache/spark/util/Utils.scala | 2 +-
.../scala/org/apache/spark/util/collection/Utils.scala | 2 +-
.../test/java/test/org/apache/spark/JavaAPISuite.java | 5 ++---
.../scala/org/apache/spark/MapOutputTrackerSuite.scala | 2 +-
core/src/test/scala/org/apache/spark/ShuffleSuite.scala | 2 +-
.../test/scala/org/apache/spark/SortShuffleSuite.scala | 2 +-
.../src/test/scala/org/apache/spark/SparkConfSuite.scala | 2 +-
core/src/test/scala/org/apache/spark/SparkFunSuite.scala | 2 +-
core/src/test/scala/org/apache/spark/ThreadAudit.scala | 2 +-
.../org/apache/spark/api/python/PythonRDDSuite.scala | 2 +-
.../scala/org/apache/spark/benchmark/Benchmarks.scala | 2 +-
.../apache/spark/deploy/DecommissionWorkerSuite.scala | 2 +-
.../deploy/ExternalShuffleServiceMetricsSuite.scala | 2 +-
.../org/apache/spark/deploy/RPackageUtilsSuite.scala | 2 +-
.../org/apache/spark/deploy/SparkSubmitUtilsSuite.scala | 2 +-
.../apache/spark/deploy/history/HistoryServerSuite.scala | 2 +-
.../org/apache/spark/deploy/master/MasterSuite.scala | 2 +-
.../apache/spark/internal/config/ConfigReaderSuite.scala | 2 +-
.../spark/internal/plugin/PluginContainerSuite.scala | 2 +-
.../apache/spark/metrics/sink/GraphiteSinkSuite.scala | 2 +-
.../spark/metrics/sink/PrometheusServletSuite.scala | 2 +-
.../org/apache/spark/metrics/sink/StatsdSinkSuite.scala | 2 +-
.../test/scala/org/apache/spark/rdd/PipedRDDSuite.scala | 2 +-
.../scala/org/apache/spark/rdd/RDDCleanerSuite.scala | 2 +-
core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala | 2 +-
.../test/scala/org/apache/spark/rpc/RpcEnvSuite.scala | 2 +-
.../org/apache/spark/scheduler/DAGSchedulerSuite.scala | 2 +-
.../org/apache/spark/scheduler/SparkListenerSuite.scala | 2 +-
.../apache/spark/serializer/KryoSerializerSuite.scala | 2 +-
.../BlockManagerDecommissionIntegrationSuite.scala | 2 +-
.../org/apache/spark/storage/BlockManagerInfoSuite.scala | 2 +-
.../org/apache/spark/storage/BlockManagerSuite.scala | 2 +-
.../spark/storage/ShuffleBlockFetcherIteratorSuite.scala | 2 +-
.../org/apache/spark/ui/HttpSecurityFilterSuite.scala | 2 +-
.../scala/org/apache/spark/util/EventLoopSuite.scala | 2 +-
.../scala/org/apache/spark/util/FileAppenderSuite.scala | 2 +-
.../scala/org/apache/spark/util/JsonProtocolSuite.scala | 2 +-
.../apache/spark/util/MutableURLClassLoaderSuite.scala | 2 +-
.../org/apache/spark/examples/DriverSubmissionTest.scala | 2 +-
.../spark/examples/pythonconverters/AvroConverters.scala | 2 +-
.../main/scala/org/apache/spark/ml/linalg/Vectors.scala | 2 +-
mllib/src/main/scala/org/apache/spark/ml/Pipeline.scala | 2 +-
.../org/apache/spark/ml/feature/VectorIndexer.scala | 2 +-
.../scala/org/apache/spark/ml/image/ImageSchema.scala | 2 +-
.../main/scala/org/apache/spark/ml/param/params.scala | 2 +-
.../scala/org/apache/spark/ml/recommendation/ALS.scala | 2 +-
.../scala/org/apache/spark/ml/stat/Correlation.scala | 2 +-
.../org/apache/spark/ml/tuning/CrossValidator.scala | 2 +-
.../apache/spark/ml/tuning/TrainValidationSplit.scala | 2 +-
.../main/scala/org/apache/spark/ml/util/ReadWrite.scala | 2 +-
.../mllib/api/python/GaussianMixtureModelWrapper.scala | 4 ++--
.../apache/spark/mllib/api/python/LDAModelWrapper.scala | 8 ++++----
.../apache/spark/mllib/api/python/PythonMLLibAPI.scala | 2 +-
.../spark/mllib/api/python/Word2VecModelWrapper.scala | 2 +-
.../apache/spark/mllib/classification/NaiveBayes.scala | 2 +-
.../org/apache/spark/mllib/clustering/KMeansModel.scala | 2 +-
.../apache/spark/mllib/evaluation/RankingMetrics.scala | 2 +-
.../scala/org/apache/spark/mllib/feature/HashingTF.scala | 2 +-
.../scala/org/apache/spark/mllib/feature/Word2Vec.scala | 2 +-
.../org/apache/spark/mllib/fpm/AssociationRules.scala | 2 +-
.../main/scala/org/apache/spark/mllib/fpm/FPGrowth.scala | 2 +-
.../scala/org/apache/spark/mllib/fpm/PrefixSpan.scala | 2 +-
.../scala/org/apache/spark/mllib/linalg/Vectors.scala | 2 +-
.../mllib/recommendation/MatrixFactorizationModel.scala | 2 +-
.../spark/mllib/regression/IsotonicRegression.scala | 2 +-
.../scala/org/apache/spark/mllib/tree/DecisionTree.scala | 2 +-
.../scala/org/apache/spark/mllib/tree/RandomForest.scala | 2 +-
.../apache/spark/mllib/tree/configuration/Strategy.scala | 2 +-
.../apache/spark/mllib/util/LinearDataGenerator.scala | 2 +-
.../spark/ml/classification/JavaOneVsRestSuite.java | 7 +++----
.../test/scala/org/apache/spark/ml/PipelineSuite.scala | 2 +-
.../ml/classification/LogisticRegressionSuite.scala | 2 +-
.../org/apache/spark/ml/recommendation/ALSSuite.scala | 2 +-
.../spark/ml/regression/LinearRegressionSuite.scala | 2 +-
.../scala/org/apache/spark/ml/tree/impl/TreeTests.scala | 2 +-
.../mllib/classification/LogisticRegressionSuite.scala | 2 +-
.../org/apache/spark/mllib/classification/SVMSuite.scala | 2 +-
.../spark/mllib/optimization/GradientDescentSuite.scala | 2 +-
.../org/apache/spark/mllib/recommendation/ALSSuite.scala | 2 +-
.../org/apache/spark/mllib/tree/DecisionTreeSuite.scala | 2 +-
project/SparkBuild.scala | 2 +-
python/pyspark/context.py | 4 ++--
.../org/apache/spark/deploy/k8s/KubernetesUtils.scala | 2 +-
.../deploy/k8s/features/BasicDriverFeatureStep.scala | 2 +-
.../deploy/k8s/features/BasicExecutorFeatureStep.scala | 2 +-
.../deploy/k8s/features/DriverCommandFeatureStep.scala | 2 +-
.../DriverKubernetesCredentialsFeatureStep.scala | 2 +-
.../deploy/k8s/features/DriverServiceFeatureStep.scala | 2 +-
.../deploy/k8s/features/EnvSecretsFeatureStep.scala | 2 +-
.../k8s/features/HadoopConfDriverFeatureStep.scala | 2 +-
.../k8s/features/KerberosConfDriverFeatureStep.scala | 2 +-
.../spark/deploy/k8s/features/LocalDirsFeatureStep.scala | 2 +-
.../deploy/k8s/features/MountVolumesFeatureStep.scala | 2 +-
.../apache/spark/deploy/k8s/submit/K8sSubmitOps.scala | 2 +-
.../deploy/k8s/submit/KubernetesClientApplication.scala | 2 +-
.../spark/deploy/k8s/submit/KubernetesClientUtils.scala | 2 +-
.../scheduler/cluster/k8s/ExecutorPodsAllocator.scala | 2 +-
.../cluster/k8s/ExecutorPodsLifecycleManager.scala | 2 +-
.../cluster/k8s/ExecutorPodsPollingSnapshotSource.scala | 2 +-
.../scheduler/cluster/k8s/ExecutorPodsSnapshot.scala | 2 +-
.../cluster/k8s/ExecutorPodsSnapshotsStoreImpl.scala | 2 +-
.../spark/scheduler/cluster/k8s/ExecutorRollPlugin.scala | 2 +-
.../scheduler/cluster/k8s/StatefulSetPodsAllocator.scala | 2 +-
.../apache/spark/deploy/k8s/KubernetesUtilsSuite.scala | 2 +-
.../org/apache/spark/deploy/k8s/PodBuilderSuite.scala | 2 +-
.../org/apache/spark/deploy/k8s/SecretVolumeUtils.scala | 2 +-
.../k8s/features/BasicDriverFeatureStepSuite.scala | 2 +-
.../k8s/features/BasicExecutorFeatureStepSuite.scala | 2 +-
.../k8s/features/DriverCommandFeatureStepSuite.scala | 2 +-
.../DriverKubernetesCredentialsFeatureStepSuite.scala | 2 +-
.../k8s/features/DriverServiceFeatureStepSuite.scala | 2 +-
.../deploy/k8s/features/EnvSecretsFeatureStepSuite.scala | 2 +-
.../k8s/features/HadoopConfDriverFeatureStepSuite.scala | 2 +-
.../features/KerberosConfDriverFeatureStepSuite.scala | 2 +-
.../k8s/features/KubernetesFeaturesTestUtils.scala | 2 +-
.../k8s/features/MountVolumesFeatureStepSuite.scala | 2 +-
.../org/apache/spark/deploy/k8s/submit/ClientSuite.scala | 2 +-
.../spark/deploy/k8s/submit/K8sSubmitOpSuite.scala | 2 +-
.../deploy/k8s/submit/KubernetesClientUtilsSuite.scala | 2 +-
.../cluster/k8s/ExecutorLifecycleTestUtils.scala | 2 +-
.../cluster/k8s/ExecutorPodsAllocatorSuite.scala | 2 +-
.../deploy/k8s/integrationtest/BasicTestsSuite.scala | 2 +-
.../k8s/integrationtest/ClientModeTestsSuite.scala | 2 +-
.../deploy/k8s/integrationtest/DecommissionSuite.scala | 2 +-
.../deploy/k8s/integrationtest/DepsTestsSuite.scala | 2 +-
.../deploy/k8s/integrationtest/KubernetesSuite.scala | 2 +-
.../k8s/integrationtest/KubernetesTestComponents.scala | 2 +-
.../spark/deploy/k8s/integrationtest/PVTestsSuite.scala | 2 +-
.../spark/deploy/k8s/integrationtest/ProcessUtils.scala | 2 +-
.../deploy/k8s/integrationtest/SecretsTestsSuite.scala | 2 +-
.../apache/spark/deploy/k8s/integrationtest/Utils.scala | 2 +-
.../deploy/k8s/integrationtest/VolcanoTestsSuite.scala | 2 +-
.../spark/deploy/mesos/MesosExternalShuffleService.scala | 2 +-
.../org/apache/spark/executor/MesosExecutorBackend.scala | 2 +-
.../cluster/mesos/MesosClusterPersistenceEngine.scala | 2 +-
.../scheduler/cluster/mesos/MesosClusterScheduler.scala | 2 +-
.../mesos/MesosCoarseGrainedSchedulerBackend.scala | 2 +-
.../cluster/mesos/MesosFineGrainedSchedulerBackend.scala | 2 +-
.../spark/scheduler/cluster/mesos/MesosProtoUtils.scala | 2 +-
.../scheduler/cluster/mesos/MesosSchedulerUtils.scala | 2 +-
.../cluster/mesos/MesosClusterSchedulerSuite.scala | 2 +-
.../mesos/MesosCoarseGrainedSchedulerBackendSuite.scala | 2 +-
.../mesos/MesosFineGrainedSchedulerBackendSuite.scala | 2 +-
.../cluster/mesos/MesosSchedulerUtilsSuite.scala | 2 +-
.../org/apache/spark/scheduler/cluster/mesos/Utils.scala | 2 +-
.../main/scala/org/apache/spark/deploy/yarn/Client.scala | 2 +-
.../org/apache/spark/deploy/yarn/ExecutorRunnable.scala | 2 +-
.../LocalityPreferredContainerPlacementStrategy.scala | 2 +-
.../org/apache/spark/deploy/yarn/SparkRackResolver.scala | 2 +-
.../org/apache/spark/deploy/yarn/YarnAllocator.scala | 2 +-
.../deploy/yarn/YarnAllocatorNodeHealthTracker.scala | 2 +-
.../org/apache/spark/deploy/yarn/YarnRMClient.scala | 2 +-
.../apache/spark/deploy/yarn/BaseYarnClusterSuite.scala | 2 +-
.../scala/org/apache/spark/deploy/yarn/ClientSuite.scala | 2 +-
.../spark/deploy/yarn/ResourceRequestTestHelper.scala | 2 +-
.../apache/spark/deploy/yarn/YarnAllocatorSuite.scala | 2 +-
.../network/yarn/YarnShuffleServiceMetricsSuite.scala | 2 +-
.../spark/network/yarn/YarnShuffleServiceSuite.scala | 2 +-
scalastyle-config.xml | 11 +++++++++--
.../scala/org/apache/spark/sql/AnalysisException.scala | 2 +-
sql/api/src/main/scala/org/apache/spark/sql/Row.scala | 2 +-
.../apache/spark/sql/catalyst/JavaTypeInference.scala | 2 +-
.../spark/sql/catalyst/parser/DataTypeAstBuilder.scala | 2 +-
.../org/apache/spark/sql/catalyst/parser/parsers.scala | 2 +-
.../scala/org/apache/spark/sql/types/StructType.scala | 2 +-
.../scala/org/apache/spark/sql/util/ArrowUtils.scala | 2 +-
.../spark/sql/connector/expressions/Expressions.java | 4 ++--
.../apache/spark/sql/catalyst/QueryPlanningTracker.scala | 2 +-
.../sql/catalyst/expressions/codegen/CodeGenerator.scala | 2 +-
.../spark/sql/catalyst/expressions/objects/objects.scala | 2 +-
.../sql/catalyst/expressions/regexpExpressions.scala | 2 +-
.../apache/spark/sql/catalyst/parser/AstBuilder.scala | 2 +-
.../sql/catalyst/rules/QueryExecutionMetering.scala | 2 +-
.../org/apache/spark/sql/catalyst/trees/TreeNode.scala | 2 +-
.../spark/sql/catalyst/util/GenericArrayData.scala | 2 +-
.../apache/spark/sql/catalyst/xml/StaxXmlParser.scala | 2 +-
.../spark/sql/catalyst/xml/StaxXmlParserUtils.scala | 2 +-
.../org/apache/spark/sql/catalyst/xml/XSDToSchema.scala | 2 +-
.../apache/spark/sql/catalyst/xml/XmlInferSchema.scala | 2 +-
.../spark/sql/connector/catalog/CatalogV2Util.scala | 2 +-
.../org/apache/spark/sql/connector/catalog/V1Table.scala | 2 +-
.../apache/spark/sql/execution/arrow/ArrowWriter.scala | 2 +-
.../execution/datasources/v2/DataSourceV2Implicits.scala | 2 +-
.../scala/org/apache/spark/sql/internal/SQLConf.scala | 2 +-
.../org/apache/spark/sql/catalyst/SQLKeywordSuite.scala | 2 +-
.../spark/sql/catalyst/analysis/AnalysisSuite.scala | 2 +-
.../sql/catalyst/analysis/TableLookupCacheSuite.scala | 2 +-
.../catalyst/expressions/ObjectExpressionsSuite.scala | 2 +-
.../sql/catalyst/optimizer/ComputeCurrentTimeSuite.scala | 4 ++--
.../spark/sql/catalyst/parser/ParserUtilsSuite.scala | 2 +-
.../spark/sql/catalyst/util/DateTimeTestUtils.scala | 2 +-
.../sql/connector/catalog/CatalogManagerSuite.scala | 2 +-
.../spark/sql/connector/catalog/CatalogSuite.scala | 2 +-
.../sql/connector/catalog/EnumTypeSetBenchmark.scala | 2 +-
.../spark/sql/connector/catalog/InMemoryCatalog.scala | 2 +-
.../sql/connector/catalog/InMemoryPartitionTable.scala | 2 +-
.../sql/connector/catalog/InMemoryTableCatalog.scala | 2 +-
.../catalog/SupportsPartitionManagementSuite.scala | 2 +-
.../spark/sql/util/CaseInsensitiveStringMapSuite.scala | 2 +-
.../parquet/VectorizedParquetRecordReader.java | 8 ++++----
.../src/main/scala/org/apache/spark/sql/Column.scala | 2 +-
.../org/apache/spark/sql/DataFrameNaFunctions.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameReader.scala | 2 +-
.../org/apache/spark/sql/DataFrameStatFunctions.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameWriter.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameWriterV2.scala | 2 +-
.../src/main/scala/org/apache/spark/sql/Dataset.scala | 2 +-
.../org/apache/spark/sql/KeyValueGroupedDataset.scala | 2 +-
.../main/scala/org/apache/spark/sql/Observation.scala | 6 ++----
.../org/apache/spark/sql/RelationalGroupedDataset.scala | 2 +-
.../main/scala/org/apache/spark/sql/SparkSession.scala | 2 +-
.../main/scala/org/apache/spark/sql/api/r/SQLUtils.scala | 2 +-
.../scala/org/apache/spark/sql/catalog/Catalog.scala | 2 +-
.../sql/execution/BaseScriptTransformationExec.scala | 2 +-
.../spark/sql/execution/ColumnarEvaluatorFactory.scala | 2 +-
.../org/apache/spark/sql/execution/SparkSqlParser.scala | 2 +-
.../sql/execution/adaptive/AdaptiveSparkPlanExec.scala | 2 +-
.../spark/sql/execution/arrow/ArrowConverters.scala | 2 +-
.../apache/spark/sql/execution/command/commands.scala | 2 +-
.../org/apache/spark/sql/execution/command/tables.scala | 2 +-
.../spark/sql/execution/datasources/DataSource.scala | 2 +-
.../sql/execution/datasources/DataSourceUtils.scala | 2 +-
.../sql/execution/datasources/FallBackFileSourceV2.scala | 2 +-
.../sql/execution/datasources/FileStatusCache.scala | 2 +-
.../sql/execution/datasources/jdbc/DriverRegistry.scala | 2 +-
.../spark/sql/execution/datasources/jdbc/JDBCRDD.scala | 2 +-
.../spark/sql/execution/datasources/jdbc/JdbcUtils.scala | 2 +-
.../jdbc/connection/BasicConnectionProvider.scala | 2 +-
.../jdbc/connection/SecureConnectionProvider.scala | 2 +-
.../spark/sql/execution/datasources/orc/OrcUtils.scala | 2 +-
.../datasources/parquet/ParquetFileFormat.scala | 2 +-
.../execution/datasources/parquet/ParquetFilters.scala | 2 +-
.../datasources/parquet/ParquetReadSupport.scala | 2 +-
.../datasources/parquet/ParquetRowConverter.scala | 2 +-
.../datasources/parquet/ParquetRowIndexUtil.scala | 2 +-
.../datasources/parquet/ParquetWriteSupport.scala | 2 +-
.../sql/execution/datasources/v2/AddPartitionExec.scala | 2 +-
.../sql/execution/datasources/v2/CreateIndexExec.scala | 2 +-
.../execution/datasources/v2/CreateNamespaceExec.scala | 2 +-
.../sql/execution/datasources/v2/CreateTableExec.scala | 2 +-
.../sql/execution/datasources/v2/DataSourceV2Utils.scala | 2 +-
.../execution/datasources/v2/DescribeNamespaceExec.scala | 2 +-
.../sql/execution/datasources/v2/DescribeTableExec.scala | 2 +-
.../sql/execution/datasources/v2/FileDataSourceV2.scala | 2 +-
.../spark/sql/execution/datasources/v2/FileTable.scala | 2 +-
.../spark/sql/execution/datasources/v2/FileWrite.scala | 2 +-
.../sql/execution/datasources/v2/ReplaceTableExec.scala | 2 +-
.../execution/datasources/v2/ShowCreateTableExec.scala | 2 +-
.../datasources/v2/ShowTablePropertiesExec.scala | 2 +-
.../sql/execution/datasources/v2/TextBasedFileScan.scala | 2 +-
.../sql/execution/datasources/v2/V2SessionCatalog.scala | 2 +-
.../datasources/v2/WriteToDataSourceV2Exec.scala | 2 +-
.../spark/sql/execution/datasources/v2/csv/CSVScan.scala | 2 +-
.../sql/execution/datasources/v2/csv/CSVTable.scala | 2 +-
.../sql/execution/datasources/v2/jdbc/JDBCTable.scala | 2 +-
.../execution/datasources/v2/jdbc/JDBCTableCatalog.scala | 2 +-
.../sql/execution/datasources/v2/json/JsonScan.scala | 2 +-
.../sql/execution/datasources/v2/json/JsonTable.scala | 2 +-
.../spark/sql/execution/datasources/v2/orc/OrcScan.scala | 2 +-
.../execution/datasources/v2/orc/OrcScanBuilder.scala | 2 +-
.../sql/execution/datasources/v2/orc/OrcTable.scala | 2 +-
.../execution/datasources/v2/parquet/ParquetScan.scala | 2 +-
.../datasources/v2/parquet/ParquetScanBuilder.scala | 2 +-
.../execution/datasources/v2/parquet/ParquetTable.scala | 2 +-
.../sql/execution/datasources/v2/text/TextScan.scala | 2 +-
.../org/apache/spark/sql/execution/debug/package.scala | 2 +-
.../scala/org/apache/spark/sql/execution/objects.scala | 2 +-
.../python/ApplyInPandasWithStatePythonRunner.scala | 2 +-
.../execution/python/ApplyInPandasWithStateWriter.scala | 2 +-
.../spark/sql/execution/python/ArrowEvalPythonExec.scala | 2 +-
.../sql/execution/python/ArrowEvalPythonUDTFExec.scala | 2 +-
.../spark/sql/execution/python/BatchEvalPythonExec.scala | 2 +-
.../sql/execution/python/BatchEvalPythonUDTFExec.scala | 2 +-
.../spark/sql/execution/python/EvaluatePython.scala | 2 +-
.../execution/python/MapInBatchEvaluatorFactory.scala | 2 +-
.../spark/sql/execution/python/PandasGroupUtils.scala | 2 +-
.../spark/sql/execution/python/PythonArrowOutput.scala | 2 +-
.../sql/execution/python/UserDefinedPythonFunction.scala | 2 +-
.../python/WindowInPandasEvaluatorFactory.scala | 2 +-
.../org/apache/spark/sql/execution/r/ArrowRRunner.scala | 2 +-
.../spark/sql/execution/streaming/AsyncCommitLog.scala | 2 +-
.../sql/execution/streaming/AsyncOffsetSeqLog.scala | 2 +-
.../spark/sql/execution/streaming/HDFSMetadataLog.scala | 2 +-
.../spark/sql/execution/streaming/ProgressReporter.scala | 2 +-
.../spark/sql/execution/streaming/StreamExecution.scala | 2 +-
.../streaming/state/HDFSBackedStateStoreMap.scala | 2 +-
.../streaming/state/HDFSBackedStateStoreProvider.scala | 2 +-
.../execution/streaming/state/RocksDBFileManager.scala | 2 +-
.../sql/execution/streaming/statefulOperators.scala | 2 +-
.../spark/sql/execution/ui/SQLAppStatusListener.scala | 2 +-
.../src/main/scala/org/apache/spark/sql/functions.scala | 2 +-
.../main/scala/org/apache/spark/sql/jdbc/H2Dialect.scala | 2 +-
.../apache/spark/sql/streaming/DataStreamReader.scala | 2 +-
.../apache/spark/sql/streaming/DataStreamWriter.scala | 2 +-
.../spark/sql/streaming/StreamingQueryException.scala | 2 +-
.../spark/sql/streaming/StreamingQueryManager.scala | 2 +-
.../scala/org/apache/spark/sql/streaming/progress.scala | 2 +-
.../sql/streaming/ui/StreamingQueryStatisticsPage.scala | 2 +-
.../apache/spark/sql/util/QueryExecutionListener.scala | 2 +-
.../protobuf/sql/SQLExecutionUIDataSerializer.scala | 2 +-
.../protobuf/sql/SparkPlanGraphWrapperSerializer.scala | 2 +-
.../test/org/apache/spark/sql/JavaDataFrameSuite.java | 4 ++--
.../apache/spark/sql/JavaHigherOrderFunctionsSuite.java | 16 ++++++++--------
.../scala/org/apache/spark/sql/ComplexTypesSuite.scala | 2 +-
.../scala/org/apache/spark/sql/CsvFunctionsSuite.scala | 2 +-
.../org/apache/spark/sql/DataFrameAsOfJoinSuite.scala | 2 +-
.../scala/org/apache/spark/sql/DataFrameJoinSuite.scala | 2 +-
.../org/apache/spark/sql/DataFrameNaFunctionsSuite.scala | 2 +-
.../org/apache/spark/sql/DataFrameWriterV2Suite.scala | 2 +-
.../org/apache/spark/sql/IntegratedUDFTestUtils.scala | 2 +-
.../src/test/scala/org/apache/spark/sql/JoinSuite.scala | 2 +-
.../scala/org/apache/spark/sql/JsonFunctionsSuite.scala | 2 +-
.../src/test/scala/org/apache/spark/sql/QueryTest.scala | 2 +-
.../org/apache/spark/sql/SparkSessionBuilderSuite.scala | 2 +-
.../scala/org/apache/spark/sql/TPCDSQueryTestSuite.scala | 2 +-
.../org/apache/spark/sql/connector/AlterTableTests.scala | 2 +-
.../spark/sql/connector/DataSourceV2SQLSuite.scala | 2 +-
.../spark/sql/connector/SimpleWritableDataSource.scala | 2 +-
.../spark/sql/connector/TestV2SessionCatalogBase.scala | 2 +-
.../spark/sql/connector/V1WriteFallbackSuite.scala | 2 +-
.../ExternalAppendOnlyUnsafeRowArraySuite.scala | 2 +-
.../apache/spark/sql/execution/SQLViewTestSuite.scala | 2 +-
.../apache/spark/sql/execution/SparkSqlParserSuite.scala | 2 +-
.../execution/benchmark/DataSourceReadBenchmark.scala | 2 +-
.../execution/columnar/CachedBatchSerializerSuite.scala | 2 +-
.../sql/execution/command/CreateNamespaceSuiteBase.scala | 2 +-
.../apache/spark/sql/execution/command/DDLSuite.scala | 2 +-
.../command/v2/AlterTableSetLocationSuite.scala | 2 +-
.../execution/datasources/FileMetadataStructSuite.scala | 2 +-
.../datasources/binaryfile/BinaryFileFormatSuite.scala | 2 +-
.../spark/sql/execution/datasources/csv/CSVSuite.scala | 4 ++--
.../jdbc/connection/ConnectionProviderSuiteBase.scala | 2 +-
.../sql/execution/datasources/orc/OrcFilterSuite.scala | 2 +-
.../sql/execution/datasources/orc/OrcV1FilterSuite.scala | 2 +-
.../parquet/ParquetAvroCompatibilitySuite.scala | 2 +-
.../datasources/parquet/ParquetCompatibilityTest.scala | 2 +-
.../parquet/ParquetCompressionCodecPrecedenceSuite.scala | 2 +-
.../datasources/parquet/ParquetEncodingSuite.scala | 2 +-
.../datasources/parquet/ParquetFieldIdIOSuite.scala | 2 +-
.../datasources/parquet/ParquetFieldIdSchemaSuite.scala | 2 +-
.../execution/datasources/parquet/ParquetIOSuite.scala | 2 +-
.../datasources/parquet/ParquetRowIndexSuite.scala | 2 +-
.../sql/execution/datasources/parquet/ParquetTest.scala | 2 +-
.../datasources/parquet/ParquetVectorizedSuite.scala | 2 +-
.../sql/execution/datasources/v2/FileTableSuite.scala | 2 +-
.../execution/datasources/v2/V2SessionCatalogSuite.scala | 2 +-
.../spark/sql/execution/datasources/xml/XmlSuite.scala | 2 +-
.../xml/parsers/StaxXmlParserUtilsSuite.scala | 2 +-
.../sql/execution/python/BatchEvalPythonExecSuite.scala | 2 +-
.../streaming/sources/RateStreamProviderSuite.scala | 2 +-
.../streaming/sources/TextSocketStreamSuite.scala | 2 +-
.../sql/execution/streaming/state/MemoryStateStore.scala | 2 +-
.../state/RocksDBStateStoreIntegrationSuite.scala | 4 ++--
.../sql/execution/streaming/state/StateStoreSuite.scala | 2 +-
.../apache/spark/sql/execution/ui/UISeleniumSuite.scala | 2 +-
.../sql/execution/vectorized/ColumnarBatchSuite.scala | 2 +-
.../test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala | 2 +-
.../scala/org/apache/spark/sql/jdbc/JDBCWriteSuite.scala | 2 +-
.../spark/sql/sources/ExternalCommandRunnerSuite.scala | 2 +-
.../apache/spark/sql/streaming/FileStreamSinkSuite.scala | 2 +-
.../spark/sql/streaming/ReportSinkMetricsSuite.scala | 2 +-
.../sql/streaming/StreamingQueryListenerSuite.scala | 2 +-
.../streaming/StreamingQueryStatusAndProgressSuite.scala | 2 +-
.../sql/streaming/continuous/EpochCoordinatorSuite.scala | 2 +-
.../spark/sql/test/DataFrameReaderWriterSuite.scala | 2 +-
.../scala/org/apache/spark/sql/test/SQLTestUtils.scala | 2 +-
.../protobuf/sql/KVStoreProtobufSerializerSuite.scala | 2 +-
.../apache/spark/sql/hive/thriftserver/RowSetUtils.scala | 2 +-
.../thriftserver/SparkExecuteStatementOperation.scala | 2 +-
.../sql/hive/thriftserver/SparkGetColumnsOperation.scala | 4 ++--
.../hive/thriftserver/SparkGetFunctionsOperation.scala | 4 ++--
.../sql/hive/thriftserver/SparkGetTablesOperation.scala | 4 ++--
.../spark/sql/hive/thriftserver/SparkSQLCLIDriver.scala | 2 +-
.../spark/sql/hive/thriftserver/SparkSQLCLIService.scala | 2 +-
.../spark/sql/hive/thriftserver/SparkSQLDriver.scala | 2 +-
.../hive/thriftserver/ui/HiveThriftServer2Listener.scala | 2 +-
.../apache/spark/sql/hive/thriftserver/CliSuite.scala | 2 +-
.../sql/hive/thriftserver/HiveSessionImplSuite.scala | 2 +-
.../sql/hive/thriftserver/HiveThriftServer2Suites.scala | 2 +-
.../spark/sql/hive/thriftserver/SharedThriftServer.scala | 2 +-
.../scala/org/apache/spark/sql/hive/HiveInspectors.scala | 2 +-
.../main/scala/org/apache/spark/sql/hive/HiveShim.scala | 2 +-
.../main/scala/org/apache/spark/sql/hive/HiveUtils.scala | 2 +-
.../scala/org/apache/spark/sql/hive/TableReader.scala | 2 +-
.../apache/spark/sql/hive/client/HiveClientImpl.scala | 2 +-
.../org/apache/spark/sql/hive/client/HiveShim.scala | 2 +-
.../apache/spark/sql/hive/execution/HiveFileFormat.scala | 2 +-
.../apache/spark/sql/hive/execution/HiveOptions.scala | 2 +-
.../hive/execution/HiveScriptTransformationExec.scala | 2 +-
.../spark/sql/hive/execution/HiveTableScanExec.scala | 2 +-
.../org/apache/spark/sql/hive/hiveUDFEvaluators.scala | 2 +-
.../main/scala/org/apache/spark/sql/hive/hiveUDFs.scala | 2 +-
.../org/apache/spark/sql/hive/orc/OrcFileFormat.scala | 2 +-
.../apache/spark/sql/hive/CompressionCodecSuite.scala | 2 +-
.../apache/spark/sql/hive/HiveUserDefinedTypeSuite.scala | 2 +-
.../apache/spark/sql/hive/execution/HiveUDAFSuite.scala | 2 +-
.../apache/spark/sql/hive/execution/HiveUDFSuite.scala | 2 +-
.../apache/spark/sql/hive/execution/PruningSuite.scala | 2 +-
.../scala/org/apache/spark/sql/hive/test/TestHive.scala | 2 +-
.../spark/streaming/api/java/JavaDStreamLike.scala | 2 +-
.../spark/streaming/api/java/JavaPairDStream.scala | 2 +-
.../spark/streaming/api/java/JavaStreamingContext.scala | 2 +-
.../api/java/JavaStreamingListenerWrapper.scala | 2 +-
.../spark/streaming/api/python/PythonDStream.scala | 2 +-
.../org/apache/spark/streaming/receiver/Receiver.scala | 2 +-
.../streaming/receiver/ReceiverSupervisorImpl.scala | 2 +-
.../apache/spark/streaming/scheduler/JobScheduler.scala | 2 +-
.../spark/streaming/scheduler/ReceivedBlockTracker.scala | 2 +-
.../streaming/ui/StreamingJobProgressListener.scala | 2 +-
.../spark/streaming/util/BatchedWriteAheadLog.scala | 2 +-
.../spark/streaming/util/FileBasedWriteAheadLog.scala | 2 +-
.../org/apache/spark/streaming/CheckpointSuite.scala | 2 +-
.../org/apache/spark/streaming/InputStreamsSuite.scala | 2 +-
.../scala/org/apache/spark/streaming/JavaTestUtils.scala | 2 +-
.../org/apache/spark/streaming/MapWithStateSuite.scala | 2 +-
.../org/apache/spark/streaming/MasterFailureTest.scala | 2 +-
.../apache/spark/streaming/StreamingListenerSuite.scala | 2 +-
.../scala/org/apache/spark/streaming/TestSuiteBase.scala | 2 +-
.../api/java/JavaStreamingListenerWrapperSuite.scala | 2 +-
.../spark/streaming/receiver/BlockGeneratorSuite.scala | 2 +-
.../spark/streaming/util/RecurringTimerSuite.scala | 2 +-
.../apache/spark/streaming/util/WriteAheadLogSuite.scala | 2 +-
657 files changed, 702 insertions(+), 702 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
