Hi all,
Integrating SQL with CEP seems like a really nice idea. Unfortunately I had
time just for a brief look at the design doc, but it looks really cool and
thorough. Also will have a second run tomorrow and will try to provide more
comments. Anyway will be glad to help pushing the initiative fo
Hi Dian & Jark,
I checked out your prototype code, but it didn't pass the CEPITCase test in
the flink-table component.
It turns out that in the `MatchCodeGenerator.scala` file, line 74 should
use `${classOf[IterativeCondition.Context[_]].getCanonicalName}` instead of
`${classOf[IterativeCondition.
I’ve just merged the last blockers for 1.3.1. IMO, the release process for
1.3.1 is ready for kick off.
On 8 June 2017 at 10:32:47 AM, Aljoscha Krettek (aljos...@apache.org) wrote:
Yes, there is a workaround, as mentioned in the other thread:
https://lists.apache.org/thread.html/eb7e256146fbe0
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
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
Compo
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 c
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
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
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
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
Issu
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 reposi
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: Improveme
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
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
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 Typ
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 detail,
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 som
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
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 Typ
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
Com
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
Com
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
> >
> >
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
Components:
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
Components
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
Components:
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
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
27 matches
Mail list logo
