{"action":"opened","issue":{"url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/issues/10766","repository_url":"https://api.github.com/repos/ballerina-platform/ballerina-lang","labels_url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/issues/10766/labels{/name}","comments_url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/issues/10766/comments","events_url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/issues/10766/events","html_url":"https://github.com/ballerina-platform/ballerina-lang/issues/10766","id":368576993,"node_id":"MDU6SXNzdWUzNjg1NzY5OTM=","number":10766,"title":"Ballerina Stream join does not work without 'on' condition","user":{"login":"mohanvive","id":7523274,"node_id":"MDQ6VXNlcjc1MjMyNzQ=","avatar_url":"https://avatars0.githubusercontent.com/u/7523274?v=4","gravatar_id":"","url":"https://api.github.com/users/mohanvive","html_url":"https://github.com/mohanvive","followers_url":"https://api.github.com/users/mohanvive/followers","following_url":"https://api.github.com/users/mohanvive/following{/other_user}","gists_url":"https://api.github.com/users/mohanvive/gists{/gist_id}","starred_url":"https://api.github.com/users/mohanvive/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mohanvive/subscriptions","organizations_url":"https://api.github.com/users/mohanvive/orgs","repos_url":"https://api.github.com/users/mohanvive/repos","events_url":"https://api.github.com/users/mohanvive/events{/privacy}","received_events_url":"https://api.github.com/users/mohanvive/received_events","type":"User","site_admin":false},"labels":[{"id":927339469,"node_id":"MDU6TGFiZWw5MjczMzk0Njk=","url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/labels/Component/Streams","name":"Component/Streams","color":"006b75","default":false},{"id":684576328,"node_id":"MDU6TGFiZWw2ODQ1NzYzMjg=","url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/labels/Severity/Critical","name":"Severity/Critical","color":"b60205","default":false},{"id":684576167,"node_id":"MDU6TGFiZWw2ODQ1NzYxNjc=","url":"https://api.github.com/repos/ballerina-platform/ballerina-lang/labels/Type/Bug","name":"Type/Bug","color":"1d76db","default":false}],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":0,"created_at":"2018-10-10T09:35:54Z","updated_at":"2018-10-10T09:35:54Z","closed_at":null,"author_association":"CONTRIBUTOR","body":"**Description:**\r\n$subject\r\n\r\n**Steps to reproduce:**\r\nPlease consider below query. \r\n\r\n```\r\nforever {\r\n        from stockStream window lengthWindow(1)\r\n        join twitterStream window lengthWindow(1)\r\n        select stockStream.symbol as symbol, twitterStream.tweet as tweet, stockStream.price as price\r\n        => (StockWithPrice[] emp) {\r\n            foreach e in emp {\r\n                stockWithPriceStream.publish(e);\r\n            }\r\n        }\r\n    }\r\n```\r\nIt result with below error,\r\n\r\njava.lang.IllegalStateException: Compilation Failed:\r\nERROR: .::streamingv2-join-test.bal:52:9:: extraneous input 'select'\r\nERROR: .::streamingv2-join-test.bal:52:16:: mismatched input 'stockStream'. expecting {'as', 'on', 'where'}\r\nERROR: .::streamingv2-join-test.bal:52:35:: extraneous input 'as'\r\nERROR: .::streamingv2-join-test.bal:53:35:: missing token '=' before '{'\r\nERROR: .::streamingv2-join-test.bal:54:21:: missing token '(' before 'e'\r\nERROR: .::streamingv2-join-test.bal:54:23:: mismatched input 'in'. expecting {'but', '.', ',', ')', '[', '?', '+', '-', '*', '/', '%', '!', '==', '!=', '>', '<', '>=', '<=', '&&', '||', '&', '^', '@', '...', '|', '?:', '..<'}\r\n\r\n\r\n\tat org.ballerinalang.launcher.util.BRunUtil.invokeFunction(BRunUtil.java:201)\r\n\tat org.ballerinalang.launcher.util.BRunUtil.invoke(BRunUtil.java:187)\r\n\tat org.ballerinalang.launcher.util.BRunUtil.invoke(BRunUtil.java:247)\r\n\tat org.ballerinalang.test.streaming.BallerinaStreamsV2JoinTest.testStreamJoinQuery(BallerinaStreamsV2JoinTest.java:50)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n\tat java.lang.reflect.Method.invoke(Method.java:497)\r\n\tat org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:124)\r\n\tat org.testng.internal.Invoker.invokeMethod(Invoker.java:571)\r\n\tat org.testng.internal.Invoker.invokeTestMethod(Invoker.java:707)\r\n\tat org.testng.internal.Invoker.invokeTestMethods(Invoker.java:979)\r\n\tat org.testng.internal.TestMethodWorker.invokeTestMethods(TestMethodWorker.java:125)\r\n\tat org.testng.internal.TestMethodWorker.run(TestMethodWorker.java:109)\r\n\tat org.testng.TestRunner.privateRun(TestRunner.java:648)\r\n\tat org.testng.TestRunner.run(TestRunner.java:505)\r\n\tat org.testng.SuiteRunner.runTest(SuiteRunner.java:455)\r\n\tat org.testng.SuiteRunner.runSequentially(SuiteRunner.java:450)\r\n\tat org.testng.SuiteRunner.privateRun(SuiteRunner.java:415)\r\n\tat org.testng.SuiteRunner.run(SuiteRunner.java:364)\r\n\tat org.testng.SuiteRunnerWorker.runSuite(SuiteRunnerWorker.java:52)\r\n\tat org.testng.SuiteRunnerWorker.run(SuiteRunnerWorker.java:84)\r\n\tat org.testng.TestNG.runSuitesSequentially(TestNG.java:1187)\r\n\tat org.testng.TestNG.runSuitesLocally(TestNG.java:1116)\r\n\tat org.testng.TestNG.runSuites(TestNG.java:1028)\r\n\tat org.testng.TestNG.run(TestNG.java:996)\r\n\tat org.testng.IDEARemoteTestNG.run(IDEARemoteTestNG.java:72)\r\n\tat org.testng.RemoteTestNGStarter.main(RemoteTestNGStarter.java:127)\r\n\r\n**Suggested Assignees (optional):**\r\n@gimantha @grainier @mohanvive \r\n"}}
{"actor":{"display_login":"mohanvive"}}