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)