[
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 9:04 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
(X) StreamExecution.scala
(X) WatermarkTracker.scala
(X) continuous/ContinuousExecution.scala
(X) continuous/ContinuousQueuedDataReader.scala
(X) continuous/ContinuousWriteRDD.scala
(X) continuous/EpochCoordinator.scala
(X) continuous/WriteToContinuousDataSourceExec.scala
(X) sources/RateStreamMicroBatchStream.scala
(X) 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:
(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
(X) StreamExecution.scala
(X) 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
