Skip to content

Commit 292dea8

Browse files
committed
fix: minor change
1 parent 5fe7d49 commit 292dea8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte-integrations/connectors/source-mysql/src/main/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceCdcTemporalConverter.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -183,7 +183,7 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
183183
if (it is ZonedDateTime) {
184184
if (serverTimezone != "UTC") {
185185
val offsetDateTime = Instant.parse(it.toInstant().toString()).atZone(ZoneId.of(serverTimezone)).toLocalDateTime()
186-
val formattedValue = offsetDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSSSSS"))
186+
val formattedValue = offsetDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSSSSS"))
187187
Converted(formattedValue)
188188
}else {
189189
val offsetDateTime: OffsetDateTime = it.toOffsetDateTime()

0 commit comments

Comments
 (0)