[
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)
