Hi,
这是 changgelog 里的一个bug[1], 在1.11.1和master上已经修复,1.11.1社区已经在准备中了。

Best,
Leonard Xu
[1] https://issues.apache.org/jira/browse/FLINK-18461 
<https://issues.apache.org/jira/browse/FLINK-18461>

> 在 2020年7月13日,16:20,曹武 <[email protected]> 写道:
> 
> log4j:WARN No appenders could be found for logger
> (org.apache.flink.table.module.ModuleManager).
> log4j:WARN Please initialize the log4j system properly.
> Exception in thread "main" org.apache.flink.table.api.TableException:
> Provided trait [BEFORE_AND_AFTER] can't satisfy required trait
> [ONLY_UPDATE_AFTER]. This is a bug in planner, please file an issue. 
> Current node is TableSourceScan(table=[[default_catalog, default_database,
> ddd]], fields=[id, age])
>       at
> org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.$anonfun$visitChildren$2(FlinkChangelogModeInferenceProgram.scala:626)
>       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.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.visitChildren(FlinkChangelogModeInferenceProgram.scala:614)
>       at
> org.apache.flink.table.planner.plan.optimize.program.FlinkChangelogModeInferenceProgram$SatisfyUpdateKindTraitVisitor.$anonfun$visitSink$1(FlinkChangelogModeInferenceProgram.scala:690)
>       at
> scala.collection.TraversableLike.$anonfun$flatMap$1(TraversableLike.scala:240)
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

回复