{"action":"created","issue":{"url":"https://api.github.com/repos/apache/spark/issues/21199","repository_url":"https://api.github.com/repos/apache/spark","labels_url":"https://api.github.com/repos/apache/spark/issues/21199/labels{/name}","comments_url":"https://api.github.com/repos/apache/spark/issues/21199/comments","events_url":"https://api.github.com/repos/apache/spark/issues/21199/events","html_url":"https://github.com/apache/spark/pull/21199","id":319048339,"node_id":"MDExOlB1bGxSZXF1ZXN0MTg1MDc0Mjc3","number":21199,"title":"[SPARK-24127][SS] Continuous text socket source","user":{"login":"arunmahadevan","id":6792890,"node_id":"MDQ6VXNlcjY3OTI4OTA=","avatar_url":"https://avatars0.githubusercontent.com/u/6792890?v=4","gravatar_id":"","url":"https://api.github.com/users/arunmahadevan","html_url":"https://github.com/arunmahadevan","followers_url":"https://api.github.com/users/arunmahadevan/followers","following_url":"https://api.github.com/users/arunmahadevan/following{/other_user}","gists_url":"https://api.github.com/users/arunmahadevan/gists{/gist_id}","starred_url":"https://api.github.com/users/arunmahadevan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/arunmahadevan/subscriptions","organizations_url":"https://api.github.com/users/arunmahadevan/orgs","repos_url":"https://api.github.com/users/arunmahadevan/repos","events_url":"https://api.github.com/users/arunmahadevan/events{/privacy}","received_events_url":"https://api.github.com/users/arunmahadevan/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":25,"created_at":"2018-04-30T21:50:58Z","updated_at":"2018-08-02T03:58:28Z","closed_at":null,"author_association":"CONTRIBUTOR","pull_request":{"url":"https://api.github.com/repos/apache/spark/pulls/21199","html_url":"https://github.com/apache/spark/pull/21199","diff_url":"https://github.com/apache/spark/pull/21199.diff","patch_url":"https://github.com/apache/spark/pull/21199.patch"},"body":"## What changes were proposed in this pull request?\r\n\r\nSupport for text socket stream in spark structured streaming \"continuous\" mode. This is roughly based on the idea of ContinuousMemoryStream where the executor queries the data from driver over an RPC endpoint.\r\n\r\nThis makes it possible to create Structured streaming continuous pipeline to ingest data via \"nc\" and run examples.\r\n\r\n## How was this patch tested?\r\n\r\nUnit test and ran spark examples in structured streaming continuous mode.\r\n\r\nPlease review http://spark.apache.org/contributing.html before opening a pull request.\r\n"},"comment":{"url":"https://api.github.com/repos/apache/spark/issues/comments/409798222","html_url":"https://github.com/apache/spark/pull/21199#issuecomment-409798222","issue_url":"https://api.github.com/repos/apache/spark/issues/21199","id":409798222,"node_id":"MDEyOklzc3VlQ29tbWVudDQwOTc5ODIyMg==","user":{"login":"SparkQA","id":8108735,"node_id":"MDQ6VXNlcjgxMDg3MzU=","avatar_url":"https://avatars1.githubusercontent.com/u/8108735?v=4","gravatar_id":"","url":"https://api.github.com/users/SparkQA","html_url":"https://github.com/SparkQA","followers_url":"https://api.github.com/users/SparkQA/followers","following_url":"https://api.github.com/users/SparkQA/following{/other_user}","gists_url":"https://api.github.com/users/SparkQA/gists{/gist_id}","starred_url":"https://api.github.com/users/SparkQA/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/SparkQA/subscriptions","organizations_url":"https://api.github.com/users/SparkQA/orgs","repos_url":"https://api.github.com/users/SparkQA/repos","events_url":"https://api.github.com/users/SparkQA/events{/privacy}","received_events_url":"https://api.github.com/users/SparkQA/received_events","type":"User","site_admin":false},"created_at":"2018-08-02T03:58:28Z","updated_at":"2018-08-02T03:58:28Z","author_association":"NONE","body":"**[Test build #93939 has started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/93939/testReport)** for PR 21199 at commit [`f4a39d9`](https://github.com/apache/spark/commit/f4a39d9ebae2d6f6ae59caf3140310b17e75b602)."}}
{"actor":{"display_login":"SparkQA"}}