[jira] [Created] (FLINK-6906) TumblingProcessingTimeWindows can't set offset parameter to a negative value

2017-06-12 Thread bmnouwq (JIRA)
bmnouwq created FLINK-6906: -- Summary: TumblingProcessingTimeWindows can't set offset parameter to a negative value Key: FLINK-6906 URL: https://issues.apache.org/jira/browse/FLINK-6906 Project: Flink

[jira] [Created] (FLINK-6905) Support for zeroOrMore to CEP's pattern API

2017-06-12 Thread Dian Fu (JIRA)
Dian Fu created FLINK-6905: -- Summary: Support for zeroOrMore to CEP's pattern API Key: FLINK-6905 URL: https://issues.apache.org/jira/browse/FLINK-6905 Project: Flink Issue Type: Bug

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

2017-06-12 Thread Dian Fu
Hi Fabian, We have evaluated the missing features of Flink CEP roughly, it should not be quite difficult to support them. Kostas, Dawid, what's your thought? For supporting MATCH_RECOGNIZE, do you think we could create the JIRAs and start to work right now or we should wait until the release of

[jira] [Created] (FLINK-6904) Support for quantifier range to CEP's pattern API

2017-06-12 Thread Dian Fu (JIRA)
Dian Fu created FLINK-6904: -- Summary: Support for quantifier range to CEP's pattern API Key: FLINK-6904 URL: https://issues.apache.org/jira/browse/FLINK-6904 Project: Flink Issue Type: Bug

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

2017-06-12 Thread Fabian Hueske
Hi Jark, Thanks for updating the design doc and sharing your prototype! I didn't look at the code in detail, but the fact that it is less than 1k LOC is very promising. It seems that most of the complex CEP logic can be reused :-) Adding a dependency on flink-cep should be fine, IMO. It is a very

[jira] [Created] (FLINK-6903) Activate checkstyle for runtime/akka

2017-06-12 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-6903: - Summary: Activate checkstyle for runtime/akka Key: FLINK-6903 URL: https://issues.apache.org/jira/browse/FLINK-6903 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6902) Activate strict checkstyle for flink-streaming-scala

2017-06-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6902: --- Summary: Activate strict checkstyle for flink-streaming-scala Key: FLINK-6902 URL: https://issues.apache.org/jira/browse/FLINK-6902 Project: Flink

Re: [DISCUSS] Removal of twitter-inputformat

2017-06-12 Thread sblackmon
Hello, Apache Streams (incubating) maintains and publishes json-schemas and jackson-compatible POJOs for Twitter and other popular third-party APIs. http://streams.apache.org/site/0.5.1-incubating-SNAPSHOT/streams-project/streams-contrib/streams-provider-twitter/index.html We also have a

[jira] [Created] (FLINK-6901) Flip checkstyle configuration files

2017-06-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6901: --- Summary: Flip checkstyle configuration files Key: FLINK-6901 URL: https://issues.apache.org/jira/browse/FLINK-6901 Project: Flink Issue Type:

[jira] [Created] (FLINK-6900) Limit size of indiivual components in DropwizardReporter

2017-06-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6900: --- Summary: Limit size of indiivual components in DropwizardReporter Key: FLINK-6900 URL: https://issues.apache.org/jira/browse/FLINK-6900 Project: Flink

[jira] [Created] (FLINK-6899) Wrong state array size in NestedMapsStateTable

2017-06-12 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-6899: Summary: Wrong state array size in NestedMapsStateTable Key: FLINK-6899 URL: https://issues.apache.org/jira/browse/FLINK-6899 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6898) Limit size of operator component in metric name

2017-06-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6898: --- Summary: Limit size of operator component in metric name Key: FLINK-6898 URL: https://issues.apache.org/jira/browse/FLINK-6898 Project: Flink Issue

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

2017-06-12 Thread Jark Wu
Hi guys, Good news! We have made a prototype for integrating CEP and SQL. See this link https://github.com/apache/flink/compare/master...wuchong:cep-on-sql?expand=1 You can check CepITCase to try the simple CQL example. Meanwhile, we updated our design doc with additional implementation

Re: [DISCUSS] Removal of twitter-inputformat

2017-06-12 Thread Aljoscha Krettek
Bumpety-bump. I would be in favour or removing this: - It can be implemented as a MapFunction parser after a TextInputFormat - Additions, changes, fixes that happen on TextInputFormat are not reflected to SimpleTweetInputFormat - SimpleTweetInput format overrides nextRecord(), which is not

[jira] [Created] (FLINK-6897) Re-add support for Java 8 lambdas.

2017-06-12 Thread Kostas Kloudas (JIRA)
Kostas Kloudas created FLINK-6897: - Summary: Re-add support for Java 8 lambdas. Key: FLINK-6897 URL: https://issues.apache.org/jira/browse/FLINK-6897 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-6896) Creating a table from a POJO and use table sink to output fail

2017-06-12 Thread Mark You (JIRA)
Mark You created FLINK-6896: --- Summary: Creating a table from a POJO and use table sink to output fail Key: FLINK-6896 URL: https://issues.apache.org/jira/browse/FLINK-6896 Project: Flink Issue

[jira] [Created] (FLINK-6895) Add STR_TO_DATE supported in SQL

2017-06-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6895: -- Summary: Add STR_TO_DATE supported in SQL Key: FLINK-6895 URL: https://issues.apache.org/jira/browse/FLINK-6895 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6894) Add DATE_FORMAT supported in SQL

2017-06-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6894: -- Summary: Add DATE_FORMAT supported in SQL Key: FLINK-6894 URL: https://issues.apache.org/jira/browse/FLINK-6894 Project: Flink Issue Type: Sub-task

Re: Elasticsearch 5 connector maven artifact

2017-06-12 Thread Nico Kruber
This is among the fixes for 1.3.1 see https://issues.apache.org/jira/browse/FLINK-6812 Nico On Friday, 9 June 2017 08:57:39 CEST Dawid Wysakowicz wrote: > Hi devs, > > I tried using flink-connector-elasticsearch5_2.10 dependency: > > > > > > org.apache.flink > > > >

[jira] [Created] (FLINK-6893) Add BIN supported in SQL

2017-06-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6893: -- Summary: Add BIN supported in SQL Key: FLINK-6893 URL: https://issues.apache.org/jira/browse/FLINK-6893 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6892) Add LPAD supported in SQL

2017-06-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6892: -- Summary: Add LPAD supported in SQL Key: FLINK-6892 URL: https://issues.apache.org/jira/browse/FLINK-6892 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6891) Add LOG supported in SQL

2017-06-12 Thread sunjincheng (JIRA)
sunjincheng created FLINK-6891: -- Summary: Add LOG supported in SQL Key: FLINK-6891 URL: https://issues.apache.org/jira/browse/FLINK-6891 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6890) flink-dist Jar contains non-shaded Guava dependencies (built with Maven 3.0.5)

2017-06-12 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6890: -- Summary: flink-dist Jar contains non-shaded Guava dependencies (built with Maven 3.0.5) Key: FLINK-6890 URL: https://issues.apache.org/jira/browse/FLINK-6890

[jira] [Created] (FLINK-6889) Improve Path parsing for Windows paths with scheme

2017-06-12 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6889: --- Summary: Improve Path parsing for Windows paths with scheme Key: FLINK-6889 URL: https://issues.apache.org/jira/browse/FLINK-6889 Project: Flink Issue