[jira] [Created] (FLINK-4598) Support NULLIF in Table API

2016-09-07 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4598: -- Summary: Support NULLIF in Table API Key: FLINK-4598 URL: https://issues.apache.org/jira/browse/FLINK-4598 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-4597) Improve Scalar Function section in Table API documentation

2016-09-07 Thread Jark Wu (JIRA)
Jark Wu created FLINK-4597: -- Summary: Improve Scalar Function section in Table API documentation Key: FLINK-4597 URL: https://issues.apache.org/jira/browse/FLINK-4597 Project: Flink Issue Type: Impr

Re: Re: [DISCUSS] how choose Scala and Java

2016-09-07 Thread Fabian Hueske
The Java and Scala APIs are organized in different Maven modules and the Scala APIs are based on the respective Java API. The benefit of this design is to keep Scala dependencies out of the Java APIs which is requested by many users. The Java and Scala counterparts of the DataSet and DataStream AP

Re: release-1.1.2 does not exist on github

2016-09-07 Thread Robert Metzger
Hi Alex, the problem is that the tag has not been created for the release. I'll add it. On Wed, Sep 7, 2016 at 11:09 PM, Alexander Pivovarov wrote: > Hi Everyone > > I noticed that release-1.1.2 does not exist on github > https://github.com/apache/flink/releases > > Regards > Alex >

[jira] [Created] (FLINK-4596) Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml

2016-09-07 Thread Nagarjun Guraja (JIRA)
Nagarjun Guraja created FLINK-4596: -- Summary: Class not found exception when RESTART_STRATEGY is configured with fully qualified class name in the yaml Key: FLINK-4596 URL: https://issues.apache.org/jira/browse/F

Re:Re: [DISCUSS] how choose Scala and Java

2016-09-07 Thread 时某人
Hi, Till, Thanks for your clear reply. In fact the API of Java and Scala are not coordinating. User are easy confused by the Same class name of Java/Scala API such as `StreamExecutionEnvironment`. Since Scala can do almost what Java can, Why not use Scala only? Kafka's API looks good. https

[jira] [Created] (FLINK-4595) Close FileOutputStream in ParameterTool

2016-09-07 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4595: -- Summary: Close FileOutputStream in ParameterTool Key: FLINK-4595 URL: https://issues.apache.org/jira/browse/FLINK-4595 Project: Flink Issue Type:

release-1.1.2 does not exist on github

2016-09-07 Thread Alexander Pivovarov
Hi Everyone I noticed that release-1.1.2 does not exist on github https://github.com/apache/flink/releases Regards Alex

[jira] [Created] (FLINK-4594) Validate lower bound in MathUtils.checkedDownCast

2016-09-07 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-4594: - Summary: Validate lower bound in MathUtils.checkedDownCast Key: FLINK-4594 URL: https://issues.apache.org/jira/browse/FLINK-4594 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4593) Fix PageRank algorithm example

2016-09-07 Thread Alexander Pivovarov (JIRA)
Alexander Pivovarov created FLINK-4593: -- Summary: Fix PageRank algorithm example Key: FLINK-4593 URL: https://issues.apache.org/jira/browse/FLINK-4593 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4592) Fix flaky test ScalarFunctionsTest.testCurrentTimePoint

2016-09-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4592: --- Summary: Fix flaky test ScalarFunctionsTest.testCurrentTimePoint Key: FLINK-4592 URL: https://issues.apache.org/jira/browse/FLINK-4592 Project: Flink Issue Typ

[jira] [Created] (FLINK-4591) Select star does not work with grouping

2016-09-07 Thread Timo Walther (JIRA)
Timo Walther created FLINK-4591: --- Summary: Select star does not work with grouping Key: FLINK-4591 URL: https://issues.apache.org/jira/browse/FLINK-4591 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4590) Some Table API tests are failing when debug lvl is set to DEBUG

2016-09-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4590: - Summary: Some Table API tests are failing when debug lvl is set to DEBUG Key: FLINK-4590 URL: https://issues.apache.org/jira/browse/FLINK-4590 Project: Flink

[jira] [Created] (FLINK-4589) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4589: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4589 URL: https://issues.apache.org/jira/browse/FLINK-4589 Project: Flink Issue

[jira] [Created] (FLINK-4588) Fix Merging of Covering Window in MergingWindowSet

2016-09-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4588: --- Summary: Fix Merging of Covering Window in MergingWindowSet Key: FLINK-4588 URL: https://issues.apache.org/jira/browse/FLINK-4588 Project: Flink Issue

Re: [DISCUSS] FLIP-11: Table API Stream Aggregations

2016-09-07 Thread Jark Wu
Hi Fabian, Thanks for sharing your ideas. They all make sense to me. Regarding to reassigning timestamp, I do not have an use case. I come up with this because DataStream has a TimestampAssigner :) +1 for this FLIP. - Jark Wu > 在 2016年9月7日,下午2:59,Fabian Hueske 写道: > > Hi, > > thanks fo

Re: Assign tasks from JIRA

2016-09-07 Thread Fabian Hueske
Hi Kirill, welcome to the Flink community! I gave your JIRA account Contributor permissions for the FLINK JIRA. You should now be able to assign tasks to yourself. Best, Fabian 2016-09-07 9:46 GMT+02:00 Kirill Morozov : > Hello folks! > > I am novice in community, but I want to

Assign tasks from JIRA

2016-09-07 Thread Kirill Morozov
Hello folks! I am novice in community, but I want to participate in community process. How I can assign https://issues.apache.org/jira/browse/FLINK-4506 to me? Best regards, Kirill Morozov EPAM mailto:kirill_moro...@epam.com

Re: [DISCUSS] how choose Scala and Java

2016-09-07 Thread Till Rohrmann
I think you're referring to the implementation of some of Flink's modules, right? If that is the case, then the rule of thumb is that we want to use Java for the low level runtime implementations. For the API implementations it is a case to case decision. The Scala API, for example is of course im