[
https://issues.apache.org/jira/browse/FLINK-30612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
guoxin updated FLINK-30612:
---------------------------
Description:
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}
was:
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}
> 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: Major
>
> 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)
