[
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)
