This is an automated email from the ASF dual-hosted git repository. kurt pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 56f275c [FLINK-21927][table-planner-blink] Resolve ExpressionReducer compile fail when running long term (#15354) 56f275c is described below commit 56f275c989933bfdb06c9a85117b14a53464c1f7 Author: xmarker <592577...@qq.com> AuthorDate: Fri Apr 2 09:01:12 2021 +0800 [FLINK-21927][table-planner-blink] Resolve ExpressionReducer compile fail when running long term (#15354) This commit replaces CodeGenUtils#nameCounter from AtomicInteger to AtomicLong to resolve Integer overflow issue --- .../scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala index c2a822e..b7b3a37 100644 --- a/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala +++ b/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala @@ -20,7 +20,7 @@ package org.apache.flink.table.planner.codegen import java.lang.reflect.Method import java.lang.{Boolean => JBoolean, Byte => JByte, Double => JDouble, Float => JFloat, Integer => JInt, Long => JLong, Object => JObject, Short => JShort} -import java.util.concurrent.atomic.AtomicInteger +import java.util.concurrent.atomic.AtomicLong import org.apache.flink.api.common.ExecutionConfig import org.apache.flink.api.common.functions.RuntimeContext @@ -116,7 +116,7 @@ object CodeGenUtils { // ---------------------------------------------------------------------------------------- - private val nameCounter = new AtomicInteger + private val nameCounter = new AtomicLong def newName(name: String): String = { s"$name$$${nameCounter.getAndIncrement}"