This is an automated email from the ASF dual-hosted git repository.
gengliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
from 9a1fc112677f [SPARK-47871][SQL] Oracle: Map TimestampType to TIMESTAMP
WITH LOCAL TIME ZONE
add 6919febfcc87 [SPARK-47594] Connector module: Migrate logInfo with
variables to structured logging framework
No new revisions were added by this update.
Summary of changes:
.../scala/org/apache/spark/internal/LogKey.scala | 36 +++++++++++++++++++++-
.../org/apache/spark/sql/avro/AvroUtils.scala | 7 +++--
.../execution/ExecuteGrpcResponseSender.scala | 33 +++++++++++---------
.../execution/ExecuteResponseObserver.scala | 19 +++++++-----
.../sql/connect/planner/SparkConnectPlanner.scala | 7 +++--
.../planner/StreamingForeachBatchHelper.scala | 20 ++++++++----
.../planner/StreamingQueryListenerHelper.scala | 7 +++--
.../sql/connect/service/LoggingInterceptor.scala | 9 ++++--
.../spark/sql/connect/service/SessionHolder.scala | 15 ++++++---
.../service/SparkConnectExecutionManager.scala | 17 ++++++----
.../sql/connect/service/SparkConnectServer.scala | 7 +++--
.../sql/connect/service/SparkConnectService.scala | 5 +--
.../service/SparkConnectSessionManager.scala | 11 +++++--
.../service/SparkConnectStreamingQueryCache.scala | 26 +++++++++++-----
.../spark/sql/connect/utils/ErrorUtils.scala | 4 +--
.../sql/kafka010/KafkaBatchPartitionReader.scala | 14 ++++++---
.../spark/sql/kafka010/KafkaContinuousStream.scala | 4 +--
.../spark/sql/kafka010/KafkaMicroBatchStream.scala | 4 +--
.../sql/kafka010/KafkaOffsetReaderAdmin.scala | 4 +--
.../sql/kafka010/KafkaOffsetReaderConsumer.scala | 4 +--
.../apache/spark/sql/kafka010/KafkaRelation.scala | 7 +++--
.../org/apache/spark/sql/kafka010/KafkaSink.scala | 5 +--
.../apache/spark/sql/kafka010/KafkaSource.scala | 11 ++++---
.../apache/spark/sql/kafka010/KafkaSourceRDD.scala | 6 ++--
.../sql/kafka010/consumer/KafkaDataConsumer.scala | 13 +++++---
.../kafka010/producer/CachedKafkaProducer.scala | 5 +--
.../apache/spark/sql/kafka010/KafkaTestUtils.scala | 10 +++---
.../kafka010/DirectKafkaInputDStream.scala | 9 ++++--
.../streaming/kafka010/KafkaDataConsumer.scala | 18 ++++++-----
.../apache/spark/streaming/kafka010/KafkaRDD.scala | 12 +++++---
.../spark/streaming/kinesis/KinesisReceiver.scala | 7 +++--
.../streaming/kinesis/KinesisRecordProcessor.scala | 12 +++++---
.../executor/profiler/ExecutorJVMProfiler.scala | 5 +--
.../executor/profiler/ExecutorProfilerPlugin.scala | 6 ++--
.../scala/org/apache/spark/deploy/Client.scala | 6 ++--
.../spark/deploy/yarn/ApplicationMaster.scala | 4 +--
.../scheduler/cluster/YarnSchedulerBackend.scala | 6 ++--
37 files changed, 257 insertions(+), 138 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
