flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Till Rohrmann (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-6085) flink as micro service
Date Thu, 23 Mar 2017 14:13:41 GMT

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

Till Rohrmann commented on FLINK-6085:
--------------------------------------

Isn't it already possible to build such a tracking system within the user code by adding the
respective field to the payload? That way the user can also define how tracking ids are handled
in case of aggregations and windows.

> flink as micro service
> ----------------------
>
>                 Key: FLINK-6085
>                 URL: https://issues.apache.org/jira/browse/FLINK-6085
>             Project: Flink
>          Issue Type: Improvement
>          Components: DataStream API, JobManager
>            Reporter: Chen Qin
>            Priority: Minor
>
> Track discussion around run flink as a micro service, includes but not limited to 
> - RPC (web service endpoint) source
>   as web service endpoint accept RPC call, ingest to the streaming job(only one)
> - callback mechanism 
> - task assignment should honor deployment group (web tier hosts should be isolated from
rest of task assignment)



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message