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

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:

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

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.

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

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

release-1.1.2 does not exist on github

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

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

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

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

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

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

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

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

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

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 写道： >

Re: Assign tasks from JIRA

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

Assign tasks from JIRA

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

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

[DISCUSS] how choose Scala and Java

Scala and Java mixed in the module. Some Flink API indeed make someone confused. What is rule about the current Scala and Java API at the first implement time? Thanks