[
https://issues.apache.org/jira/browse/BEAM-6201?focusedWorklogId=173657&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-173657
]
ASF GitHub Bot logged work on BEAM-6201:
----------------------------------------
Author: ASF GitHub Bot
Created on: 10/Dec/18 15:42
Start Date: 10/Dec/18 15:42
Worklog Time Spent: 10m
Work Description: lgajowy commented on issue #7238: [BEAM-6201] Data
insertion pipeline
URL: https://github.com/apache/beam/pull/7238#issuecomment-445861153
I'm aware of https://github.com/apache/beam/pull/6637/ that adds a periodic,
streaming impulse source. However, this is Flink only solution (at least for
now).
Until we have a generic solution for streaming sources that works on
portable pipelines we can use the Data Insertion Pipeline if we have no other
options. WDYT?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 173657)
Time Spent: 20m (was: 10m)
> Provide a "Data insertion pipeline" for Python suites
> -----------------------------------------------------
>
> Key: BEAM-6201
> URL: https://issues.apache.org/jira/browse/BEAM-6201
> Project: Beam
> Issue Type: Sub-task
> Components: testing
> Reporter: Lukasz Gajowy
> Assignee: Lukasz Gajowy
> Priority: Trivial
> Time Spent: 20m
> Remaining Estimate: 0h
>
> We can provide a special pipeline that simply writes synthetic data to a
> PubSub topic. Then this data can be read from a subscription in a streaming
> test (eg. in python SDK tests or others).
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
