{"action":"created","issue":{"url":"https://api.github.com/repos/apache/beam/issues/7226","repository_url":"https://api.github.com/repos/apache/beam","labels_url":"https://api.github.com/repos/apache/beam/issues/7226/labels{/name}","comments_url":"https://api.github.com/repos/apache/beam/issues/7226/comments","events_url":"https://api.github.com/repos/apache/beam/issues/7226/events","html_url":"https://github.com/apache/beam/pull/7226","id":388658193,"node_id":"MDExOlB1bGxSZXF1ZXN0MjM2ODcwNTU0","number":7226,"title":"[BEAM-6188] Unbouded synthetic source","user":{"login":"lgajowy","id":1932045,"node_id":"MDQ6VXNlcjE5MzIwNDU=","avatar_url":"https://avatars3.githubusercontent.com/u/1932045?v=4","gravatar_id":"","url":"https://api.github.com/users/lgajowy","html_url":"https://github.com/lgajowy","followers_url":"https://api.github.com/users/lgajowy/followers","following_url":"https://api.github.com/users/lgajowy/following{/other_user}","gists_url":"https://api.github.com/users/lgajowy/gists{/gist_id}","starred_url":"https://api.github.com/users/lgajowy/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lgajowy/subscriptions","organizations_url":"https://api.github.com/users/lgajowy/orgs","repos_url":"https://api.github.com/users/lgajowy/repos","events_url":"https://api.github.com/users/lgajowy/events{/privacy}","received_events_url":"https://api.github.com/users/lgajowy/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":14,"created_at":"2018-12-07T13:37:36Z","updated_at":"2019-01-02T21:02:28Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/apache/beam/pulls/7226","html_url":"https://github.com/apache/beam/pull/7226","diff_url":"https://github.com/apache/beam/pull/7226.diff","patch_url":"https://github.com/apache/beam/pull/7226.patch"},"body":"Provides UnboundedSyntheticSource, some necessary refactoring and enables it in java load tests.\r\n\r\nKey points: \r\n - watermark is based on next elements prediction. Please see SyntheticWatermark class to find out how.\r\n - Checkpoints consist of start and end position for a bundle \r\n - splitting and delays are applied the same way as in Bounded source\r\n\r\nStreaming tests are not stopped automatically (yet). I decided to implement this in a separate contribution.\r\n\r\n@pabloem could you take a look?\r\n\r\n------------------------\r\n\r\nFollow this checklist to help us incorporate your contribution quickly and easily:\r\n\r\n - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue.\r\n - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf).\r\n\r\nIt will help us expedite review of your Pull Request if you tag someone (e.g. `@username`) to look at it.\r\n\r\nPost-Commit Tests Status (on master branch)\r\n------------------------------------------------------------------------------------------------\r\n\r\nLang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark\r\n--- | --- | --- | --- | --- | --- | --- | ---\r\nGo | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Go_GradleBuild/lastCompletedBuild/) | --- | --- | --- | --- | --- | ---\r\nJava | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_GradleBuild/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Gradle/lastCompletedBuild/) [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza_Gradle/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark_Gradle/lastCompletedBuild/)\r\nPython | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_Verify/lastCompletedBuild/) | --- | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/) </br> [![Build Status](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Py_ValCont/lastCompletedBuild/) | [![Build Status](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/badge/icon)](https://builds.apache.org/job/beam_PostCommit_Python_VR_Flink/lastCompletedBuild/) | --- | --- | ---\r\n\r\n\r\n\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/apache/beam/issues/comments/450983943","html_url":"https://github.com/apache/beam/pull/7226#issuecomment-450983943","issue_url":"https://api.github.com/repos/apache/beam/issues/7226","id":450983943,"node_id":"MDEyOklzc3VlQ29tbWVudDQ1MDk4Mzk0Mw==","user":{"login":"pabloem","id":1301740,"node_id":"MDQ6VXNlcjEzMDE3NDA=","avatar_url":"https://avatars2.githubusercontent.com/u/1301740?v=4","gravatar_id":"","url":"https://api.github.com/users/pabloem","html_url":"https://github.com/pabloem","followers_url":"https://api.github.com/users/pabloem/followers","following_url":"https://api.github.com/users/pabloem/following{/other_user}","gists_url":"https://api.github.com/users/pabloem/gists{/gist_id}","starred_url":"https://api.github.com/users/pabloem/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/pabloem/subscriptions","organizations_url":"https://api.github.com/users/pabloem/orgs","repos_url":"https://api.github.com/users/pabloem/repos","events_url":"https://api.github.com/users/pabloem/events{/privacy}","received_events_url":"https://api.github.com/users/pabloem/received_events","type":"User","site_admin":false},"created_at":"2019-01-02T21:02:28Z","updated_at":"2019-01-02T21:02:28Z","author_association":"MEMBER","body":"@dpmills @reuvenlax \r\nare you guys able to speak to this?\r\nBy using the approach outlined in [this comment](https://github.com/apache/beam/pull/7226#discussion_r243346489), Lukazs is seeing [these errors](https://github.com/apache/beam/pull/7226#issuecomment-449409277) on dataflow.\r\n\r\nWe'd greatly appreciate your feedback."}}
{"actor":{"display_login":"pabloem"}}