Github user kiszk commented on the issue:

    https://github.com/apache/spark/pull/19730
  
    Working for this. I met another problem. [This 
code](https://github.com/kiszk/spark/blob/83fef403b92a96a13421901d161a0df5e6a6d7b3/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Cast.scala#L855)
 creates a lot of global variable.  
    Since `UTF8String.IntWrapper` can be reused, I am writing the following 
code.
    ```
          val wrapper = "intWrapper"
          if (!ctx.mutableStates.exists(s => s._1 == wrapper)) {
            ctx.addMutableState("UTF8String.IntWrapper", wrapper,
              s"$wrapper = new UTF8String.IntWrapper();")
          }
    ```


---

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to