Skip to content

Commit 9166ce8

Browse files
committed
chore: null exception on date
1 parent 292dea8 commit 9166ce8

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

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

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,11 @@ class MySqlSourceCdcTemporalConverter : RelationalColumnCustomConverter {
119119

120120
override val partialConverters: List<PartialConverter> =
121121
listOf(
122-
NullFallThrough,
122+
PartialConverter {
123+
if (it == null || it == 0) {
124+
Converted("")
125+
} else NoConversion
126+
},
123127
PartialConverter {
124128
if (it is LocalDate) {
125129
Converted(it.format(LocalDateCodec.formatter))

0 commit comments

Comments
 (0)