You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Matěj Novotný (JIRA)" <ji...@apache.org> on 2019/05/15 15:31:00 UTC
[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work
in event classes inside streams.
[ https://issues.apache.org/jira/browse/FLINK-12303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840509#comment-16840509 ]
Matěj Novotný commented on FLINK-12303:
---------------------------------------
[~aljoscha] I would say that You don't see the bug. My test is ment to just demonstrate it. I am not collecting timestamps to the object in my real app.
The issue is that classes containing lambdas does not pass thru stream in Scala 2.12.
I have added test with case class what does not contain any lambda to demonstrate correctness of my test. It does pass.
> Scala 2.12 lambdas does not work in event classes inside streams.
> -----------------------------------------------------------------
>
> Key: FLINK-12303
> URL: https://issues.apache.org/jira/browse/FLINK-12303
> Project: Flink
> Issue Type: Bug
> Components: API / DataStream, API / Scala
> Affects Versions: 1.7.2
> Environment: Scala 2.11/2.12, Oracle Java 1.8.0_172
> Reporter: Matěj Novotný
> Priority: Major
>
> When you use lambdas inside event classes used in streams it does work in Scala 2.11. It stoped working in Scala 2.12. It does compile but does not process any data and does not throw any exception. I would expect that it would not compile in case I have used some not supported field in event class or I would throw some exception at least.
>
> For more detail check my demonstration repo, please: [https://github.com/matej-novotny/flink-lambda-bug]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)