[jira] [Created] (FLINK-15579) Can not use jdbc connector on Blink batch mode

[Shang Yuanchun (Jira)]

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)