[jira] [Created] (FLINK-6237) support RAND and RAND_INTEGER on SQL

godfrey he created FLINK-6237: - Summary: support RAND and RAND_INTEGER on SQL Key: FLINK-6237 URL: https://issues.apache.org/jira/browse/FLINK-6237 Project: Flink Issue Type: New Feature

Re: Machine Learning on Flink - Next steps

Hi, all I prefer online learning than offline training. Offline learning is the basic ability. I think ML in Flink, the more obvious advantage is streaming process. One suggestion is that FLinkML can define some API to support tensor-flow, mxnet and other ps framework, like apache beam’s mode.

Re: Machine Learning on Flink - Next steps

Hi, all I prefer online learning than offline training. Offline learning is the basic ability. I think ML in Flink, the more obvious advantage is streaming process. One suggestion is that FLinkML can define some API to support tensor-flow, mxnet and other ps framework, like apache beam’s mode.

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

I don't know what is best to do, but I think releasing 1.2.1 with potentially more bugs than 1.2.0 is not a good option. I suspect a good workaround for FLINK-6188 is setting the parallelism manually for operators that can't cope with the default

Re: [DISCUSS] Project build time and possible restructuring

Hi Grey, No, I still think we should split the repos. But it makes the whole thing a bit easier, because we don't need to introduce Jenkins at the same time. If we do the change, I'm going to ask Travis to extend the limit for all forks of the Flink repo? (Hope that's possible). Here is how it

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

You mean reverting the changes around FLINK-5808 [1]? This is what introduced the follow-up FLINK-6188 [2]. [1] https://issues.apache.org/jira/browse/FLINK-5808 [2]https://issues.apache.org/jira/browse/FLINK-6188 On Fri, Mar 31, 2017, at 19:10, Robert Metzger wrote: > I think reverting

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

I think reverting FLINK-6188 for the 1.2 branch might be a good idea. FLINK-6188 introduced two new bugs, so undoing the FLINK-6188 fix will lead only to one known bug in 1.2.1, instead of an uncertain number of issues. So 1.2.1 is not going to be worse than 1.2.0 The fix will hopefully make it

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

I merged the fix for FLINK-6044 to the release-1.2 and release-1.1 branch. 2017-03-31 15:02 GMT+02:00 Fabian Hueske : > We should also backport the fix for FLINK-6044 to Flink 1.2.1. > > I'll take care of that. > > 2017-03-30 18:50 GMT+02:00 Aljoscha Krettek

Re: [DISCUSS] Project build time and possible restructuring

Thanks for pursuing this Robert. I appreciate their receptiveness to increasing the time and memory limits but we’ll still be bound by the old limits for our personal repos. Does this change any of the proposed actions for splitting the repo? Has anyone looked into why we see many jobs timeout

[jira] [Created] (FLINK-6236) Savepoint page needs to include web console possibility

Rami created FLINK-6236: --- Summary: Savepoint page needs to include web console possibility Key: FLINK-6236 URL: https://issues.apache.org/jira/browse/FLINK-6236 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6235) Broken link in documentation

Rami created FLINK-6235: --- Summary: Broken link in documentation Key: FLINK-6235 URL: https://issues.apache.org/jira/browse/FLINK-6235 Project: Flink Issue Type: Bug Components:

Re: [DISCUSS] Project build time and possible restructuring

Good news :) A few weeks ago, I got an email from travis asking for feedback. I filled out the form and said, that the 50 minutes build time limit is a showstopper for us. And now, a few weeks later they got back to me and told me that they have increased the build time for "apache/flink" to 120

Re: Machine Learning on Flink - Next steps

Thank you,. I vote for: 1) Offline learning with the batch API 2) Low-latency prediction serving -> Online learning In details: 1) Without ML Flink can never become the de-facto streaming engine. 2) Flink is a part of production ecosystem, and production systems require ML support. a.

Re: [VOTE] Release Apache Flink 1.2.1 (RC1)

We should also backport the fix for FLINK-6044 to Flink 1.2.1. I'll take care of that. 2017-03-30 18:50 GMT+02:00 Aljoscha Krettek : > https://issues.apache.org/jira/browse/FLINK-6188 turns out to be a bit > more involved, see my comments on the PR: >

[jira] [Created] (FLINK-6234) HTTP/HTTPS WebServer Extension

Abey Sam Alex created FLINK-6234: Summary: HTTP/HTTPS WebServer Extension Key: FLINK-6234 URL: https://issues.apache.org/jira/browse/FLINK-6234 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

hongyuhong created FLINK-6233: - Summary: Support rowtime inner equi-join between two streams in the SQL API Key: FLINK-6233 URL: https://issues.apache.org/jira/browse/FLINK-6233 Project: Flink

[jira] [Created] (FLINK-6232) Support proctime inner equi-join between two streams in the SQL API

hongyuhong created FLINK-6232: - Summary: Support proctime inner equi-join between two streams in the SQL API Key: FLINK-6232 URL: https://issues.apache.org/jira/browse/FLINK-6232 Project: Flink

[jira] [Created] (FLINK-6231) completed PendingCheckpoint not release state caused oom

Chao Zhao created FLINK-6231: Summary: completed PendingCheckpoint not release state caused oom Key: FLINK-6231 URL: https://issues.apache.org/jira/browse/FLINK-6231 Project: Flink Issue Type:

[jira] [Created] (FLINK-6230) Make mmap size configurable

Chesnay Schepler created FLINK-6230: --- Summary: Make mmap size configurable Key: FLINK-6230 URL: https://issues.apache.org/jira/browse/FLINK-6230 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6229) Rework setup of PythonPlanBinder/operators

Chesnay Schepler created FLINK-6229: --- Summary: Rework setup of PythonPlanBinder/operators Key: FLINK-6229 URL: https://issues.apache.org/jira/browse/FLINK-6229 Project: Flink Issue Type:

[jira] [Created] (FLINK-6228) Integrating the OVER windows in the Table API

sunjincheng created FLINK-6228: -- Summary: Integrating the OVER windows in the Table API Key: FLINK-6228 URL: https://issues.apache.org/jira/browse/FLINK-6228 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

zhijiang created FLINK-6227: --- Summary: Introduce the DataConsumptionException for downstream task failure Key: FLINK-6227 URL: https://issues.apache.org/jira/browse/FLINK-6227 Project: Flink

[jira] [Created] (FLINK-6226) ScalarFunction and TableFunction do not support parameters of byte, short and float

Zhuoluo Yang created FLINK-6226: --- Summary: ScalarFunction and TableFunction do not support parameters of byte, short and float Key: FLINK-6226 URL: https://issues.apache.org/jira/browse/FLINK-6226

Re: [Bug]Question about StreamExecutionEnvironment.createRemoteEnvironment

Thanks a lot :-) On Fri, Mar 31, 2017 at 2:59 AM, canbinzheng <2056268...@qq.com> wrote: > Hi, I have opened an issue for the probelm > https://issues.apache.org/jira/browse/FLINK-6224 > > > > -- > View this message in context: http://apache-flink-mailing- >