[jira] [Created] (FLINK-4885) Improve the Elasticsearch configuration flexibility

2016-10-21 Thread Mike Dias (JIRA)
Mike Dias created FLINK-4885: Summary: Improve the Elasticsearch configuration flexibility Key: FLINK-4885 URL: https://issues.apache.org/jira/browse/FLINK-4885 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-4884) Eagerly Store MergingWindowSet in State in WindowOperator

2016-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4884: --- Summary: Eagerly Store MergingWindowSet in State in WindowOperator Key: FLINK-4884 URL: https://issues.apache.org/jira/browse/FLINK-4884 Project: Flink

Re: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Aljoscha Krettek
Hi, the problem is that EvictingWindowOperator uses StreamRecordSerializer to serialise the contents of the windows. This does not serialise timestamps so when the objects are deserialised from RocksDB they all have Long.MIN_VALUE as timestamp. The evictor in the program therefore always evicts all

RE: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Ovidiu Cristian Marcu
Hi I have the latest source code Master. I think the refactoring you were doing on State Backend gives this issue, unless the example is not supposed to work With rocksdb. At some point collected records's values are null, giving the error.. What do you think? Best, Ovidiu -Original Mess

Re: [FLINK-2118] Table API fails on composite filter conditions

2016-10-21 Thread Fabian Hueske
Hi Alexander, I agree and will close the issue. Thanks for looking into this! Best, Fabian 2016-10-21 16:37 GMT+02:00 Alexander Shoshin : > Hi everybody. > > I propose to close this issue: > https://issues.apache.org/jira/browse/FLINK-2118 > as "not a bug", because we can't change scala behavio

[jira] [Created] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

2016-10-21 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-4883: - Summary: Prevent UDFs implementations through Scala singleton objects Key: FLINK-4883 URL: https://issues.apache.org/jira/browse/FLINK-4883 Project: Flink

[FLINK-2118] Table API fails on composite filter conditions

2016-10-21 Thread Alexander Shoshin
Hi everybody. I propose to close this issue: https://issues.apache.org/jira/browse/FLINK-2118 as "not a bug", because we can't change scala behavior. Or we just can add some comments to "filter" and "where" functions about the need of using brackets in such cases. What do you think about it?

[jira] [Created] (FLINK-4882) Cleanup throws exception clause in HighAvailabilityServices

2016-10-21 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4882: Summary: Cleanup throws exception clause in HighAvailabilityServices Key: FLINK-4882 URL: https://issues.apache.org/jira/browse/FLINK-4882 Project: Flink Is

[DISCUSS] FLIP-13: Consistent Processing with Loops

2016-10-21 Thread Paris Carbone
Hello everyone, Loops in Apache Flink have a good potential to become a much more powerful thing in future version of Apache Flink. There is generally high demand to make them usable and first of all production-ready for upcoming releases. As a first commitment we would like to propose FLIP-13

[jira] [Created] (FLINK-4881) Docker: Remove dependency on shared volumes

2016-10-21 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-4881: - Summary: Docker: Remove dependency on shared volumes Key: FLINK-4881 URL: https://issues.apache.org/jira/browse/FLINK-4881 Project: Flink Issue Typ

Re: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Till Rohrmann
Hi Ovidiu, which version of Flink are you using? Cheers, Till On Thu, Oct 20, 2016 at 6:38 PM, Ovidiu Cristian Marcu < ovidiu.cristian.ma...@huawei.com> wrote: > Could you check the following issue on master? > > When running this example org.apache.flink.streaming.examples.windowing. > TopSpee

[jira] [Created] (FLINK-4880) FlinkML - Implement Feature hashing (Data pre-processing)

2016-10-21 Thread Thomas FOURNIER (JIRA)
Thomas FOURNIER created FLINK-4880: -- Summary: FlinkML - Implement Feature hashing (Data pre-processing) Key: FLINK-4880 URL: https://issues.apache.org/jira/browse/FLINK-4880 Project: Flink I

[FLINK-4832] Count/Sum 0 elements

2016-10-21 Thread Anton Mushin
Hi everybody, Could you explain issue https://issues.apache.org/jira/browse/FLINK-4832, please? Simple, I chose another option for resolve this issue, unlike as described in issue description In the `org.apache.flink.api.common.operators.base.MapOperatorBase#executeOnCollections` I added next

[jira] [Created] (FLINK-4879) class KafkaTableSource should be public just like KafkaTableSink

2016-10-21 Thread yuemeng (JIRA)
yuemeng created FLINK-4879: -- Summary: class KafkaTableSource should be public just like KafkaTableSink Key: FLINK-4879 URL: https://issues.apache.org/jira/browse/FLINK-4879 Project: Flink Issue Typ

RE: [FLINK-3035] Redis as State Backend

2016-10-21 Thread Ovidiu Cristian Marcu
Hi I missed your reply, thank you for feedback. Agree with 1, that will be possible only with Ramcloud. It is clear the second point. A short question: if you checkpoint the operator's state in hdfs I assume that on failure you are restarting the operator's tasks on other nodes, is that possible

[jira] [Created] (FLINK-4878) ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable

2016-10-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4878: - Summary: ReduceTaskExternalITCase.testMultiLevelMergeCombiningReduceTask test instable Key: FLINK-4878 URL: https://issues.apache.org/jira/browse/FLINK-4878 Project

[jira] [Created] (FLINK-4877) Refactorings around FLINK-3674 (User Function Timers)

2016-10-21 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-4877: --- Summary: Refactorings around FLINK-3674 (User Function Timers) Key: FLINK-4877 URL: https://issues.apache.org/jira/browse/FLINK-4877 Project: Flink Iss

Re: Implicit class RichExecutionEnvironment - Can't use MlUtils.readLibSVM(path) in QUickStart guide

2016-10-21 Thread Theodore Vasiloudis
Oh, sorry just noticed the error. You should be calling env.readLibSVMFile, the implicit class pimps the ExecutionEnvironment, the MLUtils.readLibSVM still requires the env as an argument. On Fri, Oct 21, 2016 at 10:22 AM, Theodore Vasiloudis < theodoros.vasilou...@gmail.com> wrote: > I've copy p

[jira] [Created] (FLINK-4876) Allow web interface to be bound to a specific ip/interface/inetHost

2016-10-21 Thread Bram Vogelaar (JIRA)
Bram Vogelaar created FLINK-4876: Summary: Allow web interface to be bound to a specific ip/interface/inetHost Key: FLINK-4876 URL: https://issues.apache.org/jira/browse/FLINK-4876 Project: Flink

Re: Implicit class RichExecutionEnvironment - Can't use MlUtils.readLibSVM(path) in QUickStart guide

2016-10-21 Thread Theodore Vasiloudis
I've copy pasted your code to an example and it compiles fine. Are you sure your project imports are done correctly? Here's the sbt file I'm using: resolvers in ThisBuild ++= Seq("Apache Development Snapshot Repository" at "https://repository.apache.org/content/repositories/snapshots/";, Resolv

[jira] [Created] (FLINK-4875) operator name not correctly inferred

2016-10-21 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-4875: --- Summary: operator name not correctly inferred Key: FLINK-4875 URL: https://issues.apache.org/jira/browse/FLINK-4875 Project: Flink Issue Type: Bug