[hotfix] Relax condition for argument count

The argument count doesn't actually need to be a ConstantArgumentCount. This condition is unnecessarily restrictive.
is · Sep 17, 2021 · cd08b4b · cd08b4b
1 parent 4090a06
commit cd08b4b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/.../java/org/apache/flink/table/types/inference/strategies/SubsequenceInputTypeStrategy.java b/.../java/org/apache/flink/table/types/inference/strategies/SubsequenceInputTypeStrategy.java
@@ -245,9 +245,7 @@ public SubsequenceStrategyBuilder subsequence(InputTypeStrategy inputTypeStrateg
  * arguments must not be defined.
  */
  public InputTypeStrategy finishWithVarying(InputTypeStrategy inputTypeStrategy) {
- Preconditions.checkArgument(
- inputTypeStrategy.getArgumentCount() instanceof ConstantArgumentCount);
- ArgumentCount strategyArgumentCount = inputTypeStrategy.getArgumentCount();
+ final ArgumentCount strategyArgumentCount = inputTypeStrategy.getArgumentCount();
  strategyArgumentCount
  .getMaxCount()
  .ifPresent(
@@ -256,7 +254,7 @@ public InputTypeStrategy finishWithVarying(InputTypeStrategy inputTypeStrategy)
  "The maximum number of arguments must not be defined.");
  });
  argumentsSplits.add(new ArgumentsSplit(currentPos, null, inputTypeStrategy));
- int minCount = currentPos + strategyArgumentCount.getMinCount().orElse(0);
+ final int minCount = currentPos + strategyArgumentCount.getMinCount().orElse(0);
  return new SubsequenceInputTypeStrategy(
  argumentsSplits, ConstantArgumentCount.from(minCount));
  }