Flink SQL is treating all values as string. Therefore, it needs to be casted for specific rules. It is currenly using straing CASTs which can throw exceptions and restart the whole piplines.
Instead TRY_Casts should be used which return NULL in case that the cast was not successful
Flink SQL is treating all values as string. Therefore, it needs to be casted for specific rules. It is currenly using straing CASTs which can throw exceptions and restart the whole piplines. Instead TRY_Casts should be used which return NULL in case that the cast was not successful