You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Michael (JIRA)" <ji...@apache.org> on 2019/04/23 09:05:00 UTC
[jira] [Updated] (FLINK-12300) Unused Import warning with
DataStream[Seq[...]]
[ https://issues.apache.org/jira/browse/FLINK-12300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Michael updated FLINK-12300:
----------------------------
Description:
There is a regression in Flink 1.8.0 compared to 1.7.2 using Scala...
When enabling unused import warnings in *build.sbt*:
{code:scala}
scalacOptions ++= Seq("-Xfatal-warnings", "-Ywarn-unused-import")
{code}
...and compiling a file with this content:
{code:scala}
package com.example.unusedimportissue
import org.apache.flink.streaming.api.scala._
object ExampleSeqDataStream {
def doubleElement(numbers: DataStream[Int]): DataStream[Seq[Int]] = {
numbers.map(x => Seq(x, x))
}
}
{code}
Then with Flink 1.8.0 this compile issue happens (while with Flink 1.7.2 everything compiles fine):
{noformat}
[error] /path/to/com/example/unusedimportissue/example.scala:1:0: Unused import
[error] package com.example.unusedimportissue
[error] ^
{noformat}
If the result type {{DataStream[Seq[Int]]}} is replaced by {{DataStream[Int]}}, then this issue does not occur, so it is related to the {{Seq[...]}} type.
Maybe a Flink macro is generating an import that is not used, resulting in this error?
was:
There is a regression in Flink 1.8.0 compared to 1.7.2 using Scala...
When enabling unused import warnings in *build.sbt*:
{code:java}
scalacOptions ++= Seq("-Xfatal-warnings", "-Ywarn-unused-import")
{code}
...and compiling a file with this content:
{code:java}
package com.example.unusedimportissue
import org.apache.flink.streaming.api.scala._
object ExampleSeqDataStream {
def doubleElement(numbers: DataStream[Int]): DataStream[Seq[Int]] = {
numbers.map(x => Seq(x, x))
}
}
{code}
Then with Flink 1.8.0 this compile issue happens (while with Flink 1.7.2 everything compiles fine):
{noformat}
[error] /path/to/com/example/unusedimportissue/example.scala:1:0: Unused import
[error] package com.example.unusedimportissue
[error] ^
{noformat}
If the result type {{DataStream[Seq[Int]]}} is replaced by {{DataStream[Int]}}, then this issue does not occur, so it is related to the {{Seq[...]}} type.
Maybe a Flink macro is generating an import that is not used, resulting in this error?
> Unused Import warning with DataStream[Seq[...]]
> -----------------------------------------------
>
> Key: FLINK-12300
> URL: https://issues.apache.org/jira/browse/FLINK-12300
> Project: Flink
> Issue Type: Bug
> Components: API / Scala
> Affects Versions: 1.8.0
> Reporter: Michael
> Priority: Major
>
> There is a regression in Flink 1.8.0 compared to 1.7.2 using Scala...
> When enabling unused import warnings in *build.sbt*:
> {code:scala}
> scalacOptions ++= Seq("-Xfatal-warnings", "-Ywarn-unused-import")
> {code}
> ...and compiling a file with this content:
> {code:scala}
> package com.example.unusedimportissue
> import org.apache.flink.streaming.api.scala._
> object ExampleSeqDataStream {
> def doubleElement(numbers: DataStream[Int]): DataStream[Seq[Int]] = {
> numbers.map(x => Seq(x, x))
> }
> }
> {code}
> Then with Flink 1.8.0 this compile issue happens (while with Flink 1.7.2 everything compiles fine):
> {noformat}
> [error] /path/to/com/example/unusedimportissue/example.scala:1:0: Unused import
> [error] package com.example.unusedimportissue
> [error] ^
> {noformat}
> If the result type {{DataStream[Seq[Int]]}} is replaced by {{DataStream[Int]}}, then this issue does not occur, so it is related to the {{Seq[...]}} type.
> Maybe a Flink macro is generating an import that is not used, resulting in this error?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)