[
https://issues.apache.org/jira/browse/SPARK-47597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840213#comment-17840213
]
Daniel edited comment on SPARK-47597 at 4/23/24 8:27 PM:
---------------------------------------------------------
spark$ grep logInfo sql/core/src/main/* -R | cut -d ':' -f 1 | sort -u
Under sql/core/src/main/scala/org/apache/spark/sql/execution/streaming:
(X) AsyncProgressTrackingMicroBatchExecution.scala
(X) CheckpointFileManager.scala
(X) CompactibleFileStreamLog.scala
(X) FileStreamSink.scala
(X) FileStreamSinkLog.scala
(X) FileStreamSource.scala
(X) HDFSMetadataLog.scala
(X) IncrementalExecution.scala
(X) ManifestFileCommitProtocol.scala
(X) MetadataLogFileIndex.scala
(X) MicroBatchExecution.scala
(X) ProgressReporter.scala
(X) ResolveWriteToStream.scala
StreamExecution.scala
WatermarkTracker.scala
continuous/ContinuousExecution.scala
continuous/ContinuousQueuedDataReader.scala
continuous/ContinuousWriteRDD.scala
continuous/EpochCoordinator.scala
continuous/WriteToContinuousDataSourceExec.scala
sources/RateStreamMicroBatchStream.scala
state/HDFSBackedStateStoreProvider.scala
state/RocksDB.scala
state/RocksDBFileManager.scala
state/RocksDBLoader.scala
state/RocksDBMemoryManager.scala
state/RocksDBStateStoreProvider.scala
state/StateSchemaCompatibilityChecker.scala
state/StateStore.scala
state/StateStoreChangelog.scala
state/StateStoreCoordinator.scala
state/StreamingSessionWindowStateManager.scala
state/SymmetricHashJoinStateManager.scala
was (Author: JIRAUSER285772):
spark$ grep logInfo sql/core/src/main/* -R | cut -d ':' -f 1 | sort -u
Under sql/core/src/main/scala/org/apache/spark/sql/execution/streaming:
AsyncProgressTrackingMicroBatchExecution.scala
CheckpointFileManager.scala
CompactibleFileStreamLog.scala
FileStreamSink.scala
FileStreamSinkLog.scala
FileStreamSource.scala
HDFSMetadataLog.scala
IncrementalExecution.scala
ManifestFileCommitProtocol.scala
MetadataLogFileIndex.scala
MicroBatchExecution.scala
ProgressReporter.scala
ResolveWriteToStream.scala
StreamExecution.scala
WatermarkTracker.scala
continuous/ContinuousExecution.scala
continuous/ContinuousQueuedDataReader.scala
continuous/ContinuousWriteRDD.scala
continuous/EpochCoordinator.scala
continuous/WriteToContinuousDataSourceExec.scala
sources/RateStreamMicroBatchStream.scala
state/HDFSBackedStateStoreProvider.scala
state/RocksDB.scala
state/RocksDBFileManager.scala
state/RocksDBLoader.scala
state/RocksDBMemoryManager.scala
state/RocksDBStateStoreProvider.scala
state/StateSchemaCompatibilityChecker.scala
state/StateStore.scala
state/StateStoreChangelog.scala
state/StateStoreCoordinator.scala
state/StreamingSessionWindowStateManager.scala
state/SymmetricHashJoinStateManager.scala
> Streaming: Migrate logInfo with variables to structured logging framework
> -------------------------------------------------------------------------
>
> Key: SPARK-47597
> URL: https://issues.apache.org/jira/browse/SPARK-47597
> Project: Spark
> Issue Type: Sub-task
> Components: Spark Core
> Affects Versions: 4.0.0
> Reporter: Gengliang Wang
> Priority: Major
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
