Zhanchun Zhang created FLINK-16919:
--------------------------------------
Summary: Parameter 'jobName' not used in BatchTableEnvUtil
Key: FLINK-16919
URL: https://issues.apache.org/jira/browse/FLINK-16919
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Zhanchun Zhang
{code:java}
def collect[T](
tEnv: TableEnvironment,
table: Table,
sink: CollectTableSink[T],
jobName: Option[String]): Seq[T] = { // jobName was not used
val typeSerializer = fromDataTypeToLegacyInfo(sink.getConsumedDataType)
.asInstanceOf[TypeInformation[T]]
.createSerializer(tEnv.asInstanceOf[TableEnvironmentImpl]
.getPlanner.asInstanceOf[PlannerBase].getExecEnv.getConfig)
val id = new AbstractID().toString
sink.init(typeSerializer.asInstanceOf[TypeSerializer[T]], id)
val sinkName = UUID.randomUUID().toString
tEnv.registerTableSink(sinkName, sink)
tEnv.insertInto(s"`$sinkName`", table)
val res = tEnv.execute(jobName.getOrElse("test"))
val accResult: JArrayList[Array[Byte]] = res.getAccumulatorResult(id)
SerializedListAccumulator.deserializeList(accResult, typeSerializer)
}
{code}
Just shown as the code, parameter 'jobName' not used.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
