[
https://issues.apache.org/jira/browse/FLINK-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14047605#comment-14047605
]
Aljoscha Krettek commented on FLINK-990:
----------------------------------------
Why did you only add the {{applyHints}} call in line 108 in CompilerHints.scala
and not in the other methods where {{addCardinality}} is called?
Also, the system is a mess there because the way the annotations and hints are
handled here is from a time when the system used annotations to specify those
hints and did not really provide an API. This stuff will have to be reworked to
bring the scala interface up to speed with the java interface.
> Scala API: Compiler Hints are not forwarded
> -------------------------------------------
>
> Key: FLINK-990
> URL: https://issues.apache.org/jira/browse/FLINK-990
> Project: Flink
> Issue Type: Bug
> Reporter: Till Rohrmann
> Assignee: Till Rohrmann
>
> The Scala API contains functions such as preserve, observe, neglect,
> uniqueKey etc. which can be used to specify compiler hints. However, they are
> not forwarded to the compiler. Thus an operation:
> DataSet[A] ds = input.map{ x=> x}
> ds.preserve(x=>x, y=>y)
> which should say that the fields stay constant, does not have an effect.
--
This message was sent by Atlassian JIRA
(v6.2#6252)