[ 
https://issues.apache.org/jira/browse/FLINK-14635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968495#comment-16968495
 ] 

Stephan Ewen commented on FLINK-14635:
--------------------------------------

The main issue is that records coming from the Flink Kinesis connector are of 
the relocated {{GetRecordsResult}} type, which means one cannot work with them 
unless referring to the relocated type which does however not work in the IDE.

The solution would be to have a utility in the Kinesis Connector that collects 
the records as Strings to avoid dealing with the relocated types.

[~t...@apache.org] what do you think about this?


> Don't use relocated imports in Kinesis End-2-End Tests
> ------------------------------------------------------
>
>                 Key: FLINK-14635
>                 URL: https://issues.apache.org/jira/browse/FLINK-14635
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kinesis
>    Affects Versions: 1.9.1
>            Reporter: Stephan Ewen
>            Assignee: Stephan Ewen
>            Priority: Major
>             Fix For: 1.10.0
>
>
> Using relocated imports in {{KinesisPubsubClient}} makes it not possible to 
> build the code in the IDE any more.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to