[
https://issues.apache.org/jira/browse/GOBBLIN-236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hung Tran updated GOBBLIN-236:
------------------------------
Description:
Add a ControlMessage injector as a RecordStreamProcessor.
A ControlMessageInjector inspects an incoming record and can inject
ControlMessages based on the content of the incoming record.
One use case for this is the injection of MetadataUpdateControlMessages when
the latest schema has been updated to trigger the update of the schema used by
other constructs downstream from the ControlMessageInjector.
Long running jobs are more likely to encounter issues due to the schema being
updated after the start of the job.
was:Add a way to inject control messages in the record stream.
> Add a ControlMessage injector as a RecordStreamProcessor
> --------------------------------------------------------
>
> Key: GOBBLIN-236
> URL: https://issues.apache.org/jira/browse/GOBBLIN-236
> Project: Apache Gobblin
> Issue Type: Task
> Reporter: Hung Tran
> Assignee: Hung Tran
>
> Add a ControlMessage injector as a RecordStreamProcessor.
> A ControlMessageInjector inspects an incoming record and can inject
> ControlMessages based on the content of the incoming record.
> One use case for this is the injection of MetadataUpdateControlMessages when
> the latest schema has been updated to trigger the update of the schema used
> by other constructs downstream from the ControlMessageInjector.
> Long running jobs are more likely to encounter issues due to the schema being
> updated after the start of the job.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
