[ https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
guoxin updated FLINK-30612: --------------------------- Component/s: Table SQL / API Table SQL / Runtime > 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 > Components: Table SQL / API, Table SQL / Runtime > 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; > .... > private ArrayData toBinaryArray(T[] value){ > // not thread-safe > } > .... > } > .... > } > {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)