Apply suggestions from code review

HeartSaVioR · web-flow · commit 00f5341de53f · 2026-02-11T16:12:46.000+09:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateEncoder.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/RocksDBStateEncoder.scala
@@ -1722,7 +1722,7 @@ object TimestampKeyStateEncoder {
 
   def finalKeySchema(keySchema: StructType): StructType = {
     StructType(keySchema.fields)
-      .add(name = "__event_time", dataType = LongType, nullable = false)
+      .add(name = INTERNAL_TIMESTAMP_COLUMN_NAME, dataType = LongType, nullable = false)
   }
 
   def getByteBufferForBigEndianLong(): ByteBuffer = {

Original file line number	Diff line number	Diff line change
`@@ -1722,7 +1722,7 @@ object TimestampKeyStateEncoder {`
`1722`	`1722`
`1723`	`1723`	`def finalKeySchema(keySchema: StructType): StructType = {`
`1724`	`1724`	`StructType(keySchema.fields)`
`1725`		`- .add(name = "__event_time", dataType = LongType, nullable = false)`
	`1725`	`+ .add(name = INTERNAL_TIMESTAMP_COLUMN_NAME, dataType = LongType, nullable = false)`
`1726`	`1726`	`}`
`1727`	`1727`
`1728`	`1728`	`def getByteBufferForBigEndianLong(): ByteBuffer = {`