You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dawid Wysakowicz (Jira)" <ji...@apache.org> on 2020/05/20 12:34:00 UTC
[jira] [Closed] (FLINK-15947) Finish moving scala expression DSL to
flink-table-api-scala
[ https://issues.apache.org/jira/browse/FLINK-15947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz closed FLINK-15947.
------------------------------------
Fix Version/s: (was: 1.12.0)
1.11.0
Release Note:
Due to various issues with packages {{org.apache.flink.table.api.scala/java}} all classes from those packages were relocated. Moreover the scala expressions were moved to org.apache.flink.table.api as anounced in Flink 1.9.
If you used one of
* {{org.apache.flink.table.api.java.StreamTableEnvironment}}
* {{org.apache.flink.table.api.scala.StreamTableEnvironment}}
* {{org.apache.flink.table.api.java.BatchTableEnvironment}}
* {{org.apache.flink.table.api.scala.BatchTableEnvironment}}
and you do not convert to/from DataStream switch to:
* {{org.apache.flink.table.api.TableEnvironment}}
If you do convert to/from DataStream/DataSet change your imports to one of:
* {{org.apache.flink.table.api.bridge.java.StreamTableEnvironment}}
* {{org.apache.flink.table.api.bridge.scala.StreamTableEnvironment}}
* {{org.apache.flink.table.api.bridge.java.BatchTableEnvironment}}
* {{org.apache.flink.table.api.bridge.scala.BatchTableEnvironment}}
For the Scala expressions use the import:
{{org.apache.flink.table.api._}} instead of {{org.apache.flink.table.api.bridge.scala._}}
additionally if you use Scala's implicit conversions to/from DataStream/DataSet import
{{org.apache.flink.table.api.bridge.scala._}} instead of {{org.apache.flink.table.api.scala._}}
Resolution: Fixed
Implemented in
master: 5f0183fe79d10ac36101f60f2589062a39630f96 4e56ca11fb275c72f4a70f8dd12ff71dc12983d3
1.11: 194b85b42749b03c5f1e79b5ae4377ab7230df36 87a0358deb51cf55f455d0dd4cfd6bf8690b2e2e
> Finish moving scala expression DSL to flink-table-api-scala
> -----------------------------------------------------------
>
> Key: FLINK-15947
> URL: https://issues.apache.org/jira/browse/FLINK-15947
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Reporter: Dawid Wysakowicz
> Assignee: Dawid Wysakowicz
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.11.0
>
>
> FLINK-13045 performed the first step of moving implicit conversions to a long term package object. It also added release notes so that users have time to adapt to the changes.
> Now that it's two releases since that time, we can finish moving all the intended conversions.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)