[jira] [Created] (FLINK-16919) Parameter 'jobName' not used in BatchTableEnvUtil

[Shang Yuanchun (Jira)]

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)