guoxin created FLINK-30612:
------------------------------

             Summary: 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


data clutter in multi-threaded environment.
{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)

Reply via email to