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}"
