Shu Li Zheng created FLINK-15579:
------------------------------------
Summary: Can not use jdbc connector on Blink batch mode
Key: FLINK-15579
URL: https://issues.apache.org/jira/browse/FLINK-15579
Project: Flink
Issue Type: Bug
Reporter: Shu Li Zheng
Because JDBCTableSourceSinkFactory.createStreamTableSink() create
JDBCUpsertTableSink. But BatchExecSink can not work with UpsertStreamTableSink.
{code:scala}
override protected def translateToPlanInternal(
planner: BatchPlanner): Transformation[Any] = {
val resultTransformation = sink match {
case _: RetractStreamTableSink[T] | _: UpsertStreamTableSink[T] =>
throw new TableException("RetractStreamTableSink and
UpsertStreamTableSink is not" +
" supported in Batch environment.")
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
