[
https://issues.apache.org/jira/browse/FLINK-27824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17543900#comment-17543900
]
Dian Fu commented on FLINK-27824:
---------------------------------
[~billrao] Would you like to take this issue?
> Implement Pyflink KeyedSchema
> -----------------------------
>
> Key: FLINK-27824
> URL: https://issues.apache.org/jira/browse/FLINK-27824
> Project: Flink
> Issue Type: Improvement
> Components: API / Python
> Reporter: Zixuan Rao
> Priority: Minor
> Original Estimate: 20h
> Remaining Estimate: 20h
>
> This issue is to implement KeyedSchema for pyflink. Currently, only keyless
> schema is supported. This prevents me from emitting keyed kafka entries to
> datastream kafka connector. I plan to implement this on my own.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
