[
https://issues.apache.org/jira/browse/FLINK-20135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235826#comment-17235826
]
Shuiqiang Chen commented on FLINK-20135:
----------------------------------------
Thank you for creating this ticket.
I have finished testing the following APIs for Python DataStream API, all of
them work as expected under normal condition and throw exceptions with invalid
inputs:
|get_name|
|name|
|uid|
|set_uid_hash|
|set_parallelism|
|set_max_parallelism|
|get_type|
|get_execution_environment|
|get_execution_config|
|force_non_parallel|
|set_buffer_timeout|
|start_new_chain|
|disable_chaining|
|slot_sharing_group|
|map|
|flat_map|
|key_by|
|filter|
|union|
|connect|
|shuffle|
|project|
|rescale|
|broadcast|
|print|
I would test the following API as soon as possible：
|rebalance|
|forward|
|process|
|assign_timestamp_and_watermark|
|partition_custom|
|add_sink|
All these APIs have documented respectively.
* [|https://issues.apache.org/jira/secure/AddComment!default.jspa?id=13340263]
> Test Python DataStream API
> --------------------------
>
> Key: FLINK-20135
> URL: https://issues.apache.org/jira/browse/FLINK-20135
> Project: Flink
> Issue Type: Task
> Components: API / Python
> Affects Versions: 1.12.0
> Reporter: Dian Fu
> Assignee: Shuiqiang Chen
> Priority: Critical
> Fix For: 1.12.0
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
