[ https://issues.apache.org/jira/browse/FLINK-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Stephan Ewen resolved FLINK-8945. --------------------------------- Resolution: Fixed Assignee: Kailash Hassan Dayanand Fix Version/s: 1.5.0 Fixed in - 1.5.0 via 7763f7f680fec162e27855f792760bcc3820b799 - 1.6.0 via cb60fd29e7e46f8015587e9be7ad88f2368fe85a > Allow customization of the KinesisProxy > --------------------------------------- > > Key: FLINK-8945 > URL: https://issues.apache.org/jira/browse/FLINK-8945 > Project: Flink > Issue Type: Improvement > Reporter: Kailash Hassan Dayanand > Assignee: Kailash Hassan Dayanand > Priority: Minor > Fix For: 1.5.0 > > > Currently the KinesisProxy interface here: > [https://github.com/apache/flink/blob/310f3de62e52f1f977c217d918cc5aac79b87277/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java#L125] > has a private constructor. This restricts extending the class and prevents > customizations on shard discovery. I am proposing to change this to protected. > While the creating a new implementation of KinesisProxyInterface is possible, > I would like to continue to use implementation of getRecords and > getShardIterator. > This will be a temporary workaround till FLINK-8944 is submitted. -- This message was sent by Atlassian JIRA (v7.6.3#76005)