[ 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:44 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 (X) state/RocksDB.scala (X) state/RocksDBFileManager.scala (X) state/RocksDBLoader.scala (X) state/RocksDBMemoryManager.scala (X) state/RocksDBStateStoreProvider.scala (X) state/StateSchemaCompatibilityChecker.scala (X) state/StateStore.scala (X) state/StateStoreChangelog.scala (X) state/StateStoreCoordinator.scala (X) state/StreamingSessionWindowStateManager.scala (X) 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 (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 (X) 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