[ https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
guoxin updated FLINK-30612: --------------------------- Priority: Blocker (was: Major) > ObjectArrayConverter is not thread-safe,raised by reuseArray、reuseWriter > ------------------------------------------------------------------------ > > Key: FLINK-30612 > URL: https://issues.apache.org/jira/browse/FLINK-30612 > Project: Flink > Issue Type: Bug > Affects Versions: 1.12.2 > Reporter: guoxin > Priority: Blocker > > data clutter in multi-threaded environment. > by design? > or , how do i use it in multi-thread env? > {code:java} > package org.apache.flink.table.data.util; > public class DataFormatConverters{ > .... > public static final class ObjectArrayConverter<T> extends > DataFormatConverter<ArrayData, T[]>{ > .... > // it's not thread-safe > private transient BinaryArrayData reuseArray; > private transient BinaryArrayWriter reuseWriter; > .... > } > .... > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)