[jira] [Created] (FLINK-11230) Sum of FlinkSql after two table union all.The value is too large.
jiwei created FLINK-11230: - Summary: Sum of FlinkSql after two table union all.The value is too large. Key: FLINK-11230 URL: https://issues.apache.org/jira/browse/FLINK-11230 Project: Flink Issue Type: Bug Components: Table API SQL Affects Versions: 1.7.0 Reporter: jiwei SELECT k AS KEY, SUM(p) AS pv FROM ( SELECT tumble_start(stime, INTERVAL '1' minute) AS k , COUNT(*) AS p FROM flink_test1 GROUP BY tumble(stime, INTERVAL '1' minute) UNION ALL SELECT tumble_start(stime, INTERVAL '1' minute) AS k , COUNT(*) AS p FROM flink_test2 GROUP BY tumble(stime, INTERVAL '1' minute) ) t GROUP BY k The Result of executing this sql is about 7000 per minute.But the result is 60 per minute for per table.Is there an error in your SQL statement? -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-11229) Support ScalarFunction for the where/filter clause.
vinoyang created FLINK-11229: Summary: Support ScalarFunction for the where/filter clause. Key: FLINK-11229 URL: https://issues.apache.org/jira/browse/FLINK-11229 Project: Flink Issue Type: Sub-task Components: Table API SQL Reporter: vinoyang Assignee: vinoyang Currently, the where/filter clause only supports expressions, and we can enhance its extensibility by letting it support scalar functions. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Created] (FLINK-11228) Flink web UI can not read stdout logs
wxmimperio created FLINK-11228: -- Summary: Flink web UI can not read stdout logs Key: FLINK-11228 URL: https://issues.apache.org/jira/browse/FLINK-11228 Project: Flink Issue Type: Bug Components: Web Client Affects Versions: 1.7.1 Reporter: wxmimperio Attachments: image-2018-12-28-18-58-41-111.png, image-2018-12-28-19-00-17-652.png I start flink as local cluster. $ tar xzf flink-*.tgz $ cd flink-1.6.1 $ ./bin/start-cluster.sh # Start Flink I createRemoteEnvironment to submit a remote job and job run successful. However when I read stdout log from web ui, I find nothing. I can find logs on linux server. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
Re: [ANNOUNCE] Apache Flink 1.5.6 released
Thanks a lot for being our release manager Thomas. Great work! Also thanks to the community for making this release possible. Cheers, Till On Thu, Dec 27, 2018 at 2:58 AM Jeff Zhang wrote: > Thanks Thomas. It's nice to have a more stable flink 1.5.x > > vino yang 于2018年12月27日周四 上午9:43写道： > >> Thomas, thanks for being a release manager. >> And Thanks for the whole community. >> I think the release of Flink 1.5.6 makes sense for many users who are >> currently unable to upgrade major versions. >> >> Best, >> Vino >> >> jincheng sun 于2018年12月27日周四 上午8:00写道： >> >>> Thanks a lot for being our release manager Thomas. >>> Thanks a lot for made this release possible! >>> >>> Cheers, >>> Jincheng >>> >>> Thomas Weise 于2018年12月27日周四 上午4:03写道： >>> The Apache Flink community is very happy to announce the release of Apache Flink 1.5.6, which is the final bugfix release for the Apache Flink 1.5 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming applications. The release is available for download at: https://flink.apache.org/downloads.html Please check out the release blog post for an overview of the improvements for this bugfix release: https://flink.apache.org/news/2018/12/22/release-1.5.6.html The full release notes are available in Jira: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12344315 We would like to thank all contributors of the Apache Flink community who made this release possible! Regards, Thomas >>> > > -- > Best Regards > > Jeff Zhang >
