{"action":"created","issue":{"url":"https://api.github.com/repos/confluentinc/ksql/issues/1564","repository_url":"https://api.github.com/repos/confluentinc/ksql","labels_url":"https://api.github.com/repos/confluentinc/ksql/issues/1564/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/ksql/issues/1564/comments","events_url":"https://api.github.com/repos/confluentinc/ksql/issues/1564/events","html_url":"https://github.com/confluentinc/ksql/issues/1564","id":340030013,"node_id":"MDU6SXNzdWUzNDAwMzAwMTM=","number":1564,"title":"KSQL stream-to-stream join creates union of all columns when using * on first stream","user":{"login":"IDispose","id":379719,"node_id":"MDQ6VXNlcjM3OTcxOQ==","avatar_url":"https://avatars0.githubusercontent.com/u/379719?v=4","gravatar_id":"","url":"https://api.github.com/users/IDispose","html_url":"https://github.com/IDispose","followers_url":"https://api.github.com/users/IDispose/followers","following_url":"https://api.github.com/users/IDispose/following{/other_user}","gists_url":"https://api.github.com/users/IDispose/gists{/gist_id}","starred_url":"https://api.github.com/users/IDispose/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/IDispose/subscriptions","organizations_url":"https://api.github.com/users/IDispose/orgs","repos_url":"https://api.github.com/users/IDispose/repos","events_url":"https://api.github.com/users/IDispose/events{/privacy}","received_events_url":"https://api.github.com/users/IDispose/received_events","type":"User","site_admin":false},"labels":[{"id":860305701,"node_id":"MDU6TGFiZWw4NjAzMDU3MDE=","url":"https://api.github.com/repos/confluentinc/ksql/labels/awaiting%20info","name":"awaiting info","color":"ffe13d","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2018-07-10T22:33:10Z","updated_at":"2018-07-18T12:06:33Z","closed_at":null,"author_association":"NONE","body":"ksql stream-to-stream join seems to produce a union of columns from both streams even when only specific columns from stream2 are selected.\r\n\r\n```\r\nCREATE STREAM my_stream AS\r\n  SELECT a.col_a1, a.col_a2, b.col_b1, b.col_b2\r\n  FROM table_a AS a\r\n  INNER JOIN table_b AS b WITHIN 1 SECOND\r\n  ON a.p_key = b.p_key\r\n```\r\n\r\nproduces the stream with the right set of desired columns. However,\r\n\r\n```\r\nCREATE STREAM my_stream AS\r\n  SELECT a.*, b.col_b1, b.col_c2\r\n  FROM table_a AS a\r\n  INNER JOIN table_b AS b WITHIN 1 SECOND\r\n  ON a.p_key = b.p_key\r\n```\r\n\r\nproduces a stream with a union of all columns from both `table_a` and `table_b` like so\r\n\r\n```\r\nName                 : MY_STREAM\r\n Field               | Type\r\n--------------------------------------------------\r\nROWTIME              | BIGINT           (system)\r\n ROWKEY              | VARCHAR(STRING)  (system)\r\n A_ROWTIME           | BIGINT\r\n A_ROWKEY            | VARCHAR(STRING)\r\n A_P_KEY             | VARCHAR(STRING)\r\n A_COL_A1            | VARCHAR(STRING)\r\n A_COL_A2            | VARCHAR(STRING)\r\n A_COL_A3            | VARCHAR(STRING)\r\n A_WINDOW_SIZE       | BIGINT\r\n A_WINDOW_START      | BIGINT\r\n A_WINDOW_END        | BIGINT\r\n B_ROWTIME           | BIGINT\r\n B_ROWKEY            | VARCHAR(STRING)\r\n B_P_KEY             | VARCHAR(STRING)\r\n B_COL_B1            | VARCHAR(STRING)\r\n B_COL_B2            | VARCHAR(STRING)\r\n B_COL_B3            | VARCHAR(STRING)\r\n B_WINDOW_SIZE       | BIGINT\r\n B_WINDOW_START      | BIGINT\r\n B_WINDOW_END        | BIGINT\r\n```\r\n\r\n"},"comment":{"url":"https://api.github.com/repos/confluentinc/ksql/issues/comments/405908036","html_url":"https://github.com/confluentinc/ksql/issues/1564#issuecomment-405908036","issue_url":"https://api.github.com/repos/confluentinc/ksql/issues/1564","id":405908036,"node_id":"MDEyOklzc3VlQ29tbWVudDQwNTkwODAzNg==","user":{"login":"IDispose","id":379719,"node_id":"MDQ6VXNlcjM3OTcxOQ==","avatar_url":"https://avatars0.githubusercontent.com/u/379719?v=4","gravatar_id":"","url":"https://api.github.com/users/IDispose","html_url":"https://github.com/IDispose","followers_url":"https://api.github.com/users/IDispose/followers","following_url":"https://api.github.com/users/IDispose/following{/other_user}","gists_url":"https://api.github.com/users/IDispose/gists{/gist_id}","starred_url":"https://api.github.com/users/IDispose/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/IDispose/subscriptions","organizations_url":"https://api.github.com/users/IDispose/orgs","repos_url":"https://api.github.com/users/IDispose/repos","events_url":"https://api.github.com/users/IDispose/events{/privacy}","received_events_url":"https://api.github.com/users/IDispose/received_events","type":"User","site_admin":false},"created_at":"2018-07-18T12:06:33Z","updated_at":"2018-07-18T12:06:33Z","author_association":"NONE","body":"@miguno yes, that's correct. Sorry for the typo."}}
{"actor":{"display_login":"IDispose"}}