[
https://issues.apache.org/jira/browse/FLINK-34353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814061#comment-17814061
]
xuyang commented on FLINK-34353:
--------------------------------
I'll try to fix it.
> A strange exception will be thrown if minibatch size is not set while using
> mini-batch join
> -------------------------------------------------------------------------------------------
>
> Key: FLINK-34353
> URL: https://issues.apache.org/jira/browse/FLINK-34353
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.19.0
> Reporter: xuyang
> Priority: Major
> Fix For: 1.19.0
>
>
> {code:java}
> java.lang.IllegalArgumentException: maxCount must be greater than 0
> at
> org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
> at
> org.apache.flink.table.runtime.operators.bundle.trigger.CountCoBundleTrigger.<init>(CountCoBundleTrigger.java:34)
> at
> org.apache.flink.table.planner.plan.utils.MinibatchUtil.createMiniBatchCoTrigger(MinibatchUtil.java:61)
> at
> org.apache.flink.table.planner.plan.nodes.exec.stream.StreamExecJoin.translateToPlanInternal(StreamExecJoin.java:231)
> at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:168)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner.$anonfun$translateToPlan$1(StreamPlanner.scala:85)
> at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> at scala.collection.Iterator.foreach(Iterator.scala:937) at
> scala.collection.Iterator.foreach$(Iterator.scala:937) at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425) at
> scala.collection.IterableLike.foreach(IterableLike.scala:70) at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69) at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54) at
> scala.collection.TraversableLike.map(TraversableLike.scala:233) at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226) at
> scala.collection.AbstractTraversable.map(Traversable.scala:104) at
> org.apache.flink.table.planner.delegation.StreamPlanner.translateToPlan(StreamPlanner.scala:84)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.getExplainGraphs(PlannerBase.scala:537)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner.explain(StreamPlanner.scala:103)
> at
> org.apache.flink.table.planner.delegation.StreamPlanner.explain(StreamPlanner.scala:51)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.explainInternal(TableEnvironmentImpl.java:697)
> at
> org.apache.flink.table.api.internal.TableImpl.explain(TableImpl.java:482)
> at org.apache.flink.table.api.Explainable.explain(Explainable.java:40) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
