java.sql.BatchUpdateException: String or binary data would be truncated in table 'NOTE_NLP', column 'snippet'.

[dvellanki]

Hi Andrew,

Can you help share some pointers on the following exception?

Caused by: org.apache.flink.runtime.operators.chaining.ExceptionInChainedStubException: Exception in chained task 'FlatMap (FlatMap at Write Records to OHDSI OMOP CDM note_nlp Table via JDBC/ParDo(Anonymous)/ParMultiDo(Anonymous).output)'
at org.apache.flink.runtime.operators.chaining.ChainedFlatMapDriver.collect(ChainedFlatMapDriver.java:81)
at org.apache.flink.runtime.operators.util.metrics.CountingCollector.collect(CountingCollector.java:35)
at org.apache.beam.runners.flink.translation.functions.FlinkDoFnFunction$DoFnOutputManager.output(FlinkDoFnFunction.java:221)
at org.apache.beam.runners.core.SimpleDoFnRunner.outputWindowedValue(SimpleDoFnRunner.java:275)
at org.apache.beam.runners.core.SimpleDoFnRunner.access$900(SimpleDoFnRunner.java:85)
at org.apache.beam.runners.core.SimpleDoFnRunner$DoFnFinishBundleArgumentProvider$Context.output(SimpleDoFnRunner.java:333)
at org.apache.beam.runners.core.SimpleDoFnRunner$DoFnFinishBundleArgumentProvider$Context.output(SimpleDoFnRunner.java:328)
at org.apache.beam.sdk.io.jdbc.JdbcIO$1.finish(JdbcIO.java:1772)
Caused by: org.apache.beam.sdk.util.UserCodeException: java.sql.BatchUpdateException: String or binary data would be truncated in table 'NOTE_NLP', column 'snippet'.

I did check the table structure and the datatypes and limits are as per the OMOP standard.