GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4900
[FLINK-7666] Close TimeService after closing operators.
R @aljoscha
**(The sections below can be removed for hotfixes of typos)**
## What is the purpose of the change
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4838
R @aljoscha
---
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4838
[FLINK-7826][QS] Add support for all types of state to the QS Client.
## What is the purpose of the change
As the JIRA describes, it makes the queryable state client able to query
all types
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4821
Merging this.
---
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4821
[FLINK-7835][cep] Fix duplicate() in NFASerializer.
R @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-nfa-serializer-bug
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4814
[FLINK-7788][QS] Allows to specify a range of ports for the QS proxy.
## What is the purpose of the change
The queryable state client proxy can now take a port range as argument
so
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4778
[FLINK-7770][FLINK-7769][Queryable State] Refactor the Queryable State
Client.
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4654
Hi @zjureel ! Thanks for the work!
This can be a temporary fix, but I was thinking more of a long term one
where there is no limit.
The problems that I can find with such temporary
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4646
I see. Thanks @zentol.
So +1 to merge from me.
---
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4645#discussion_r137209983
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -77,14 +77,10 @@
private static final ObjectMapper
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4645#discussion_r137210136
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java ---
@@ -159,24 +155,17 @@ public void shutdown(Time timeout
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4644#discussion_r137198747
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java
---
@@ -104,8 +105,8 @@ protected void initChannel(SocketChannel
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4331
I think you can merge it @dawidwys .
I was following the evolution of this PR and I think it looks good ;) .
Thanks for the work both @yestinchen and @dawidwys !
---
If your project is set up
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4611
Changes LGTM @zentol !
When Travis gives a green light, feel free to merge!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4569
Thanks a lot @tillrohrmann ! This is a pretty useful API addition.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4569#discussion_r134686921
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerResponse.java
---
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apache
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4523
LGTM, merging this
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4523
@dianfu I will have a look tomorrow! Thanks for the work btw ;)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4550
I agree that this is a change that we agreed upon. My only point is that we
have to communicate it also in the ML. Probably with a thread that points to
this JIRA and the PR and mentions this issue
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4550
From a brief check, I see that this also removed backwards compatibility
also for 1.2 for the CEP library. The reason is that the CEP library in Flink
1.2 was the same as in Flink 1.1 (no upgrade
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895649
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132898814
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -340,6 +362,65 @@ public void resetNFAChanged
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132896369
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/TimeoutKeyedCEPPatternOperator.java
---
@@ -42,20 +43,21 @@
private
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132896183
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -120,13 +121,16
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895590
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132896299
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/KeyedCEPPatternOperator.java
---
@@ -42,28 +43,29 @@
private static
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132894559
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -96,7 +97,8 @@
} else
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132897107
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -158,9 +158,9 @@
private boolean nfaChanged
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895822
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132896150
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -120,13 +121,16
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132894611
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -117,9 +119,11 @@
private Map
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895583
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895143
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -150,6 +160,29 @@ long getWindowTime
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895280
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -150,6 +160,29 @@ long getWindowTime
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895639
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132895977
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4418
@dianfu Changes look good. +1 to merge
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4487
[FLINK-7379] [qs] Remove HighAvailabilityServices from QS client
constructor.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink qs
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4418
Hi @dianfu and @dawidwys. This PR is actually broken.
The reason is that the `comparator` in the
`AbstractKeyedCEPPatternOperator` is not `serializable` so when Flink tries to
ship the job
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4406
@dawidwys The changes look good! I checked with `oneOrMore()` and
`zeroOrMore()` to see if we prematurely clean up the state and it seems to be
ok.
+1 to merge.
---
If your project is set up
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4406
@dawidwys I will have a look later today!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/4225
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4225
@aljoscha thanks for the review, I updated the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r125007394
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/query/AbstractQueryableStateITCase.java
---
@@ -534,33 +537,66 @@ public Integer getKey(Tuple2
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r125007122
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/query/AbstractQueryableStateITCase.java
---
@@ -234,38 +239,28 @@ public Integer getKey(Tuple2
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r125006493
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateClient.java
---
@@ -267,6 +293,177 @@ public void shutDown
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r125006417
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java
---
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the Apache
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4225
[FLINK-7044] [queryable-st] Allow to specify namespace and descriptor in
the query.
R @aljoscha
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4153
Hi @dianfu and @dawidwys .
I think that we should stick to the current API as:
1) a new API will raise serious backwards compatibility concerns,
2) people have already started
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
Hi @wuchong . I am not an expert in Janino and how it works but I do not
think you need Janino's classloader at any point. Using the `open()` of the
`CEPOperator` you just need to compile the code
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
@wuchong Yes this is what I had in mind. Could you tell me which class is
not found?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4195#discussion_r124500395
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -270,10 +270,12 @@ private void
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
@dianfu So this is a plan that can work to avoid having to generate the
code of the `IterativeCondition` every time. This came also after discussion
with @fhueske who also explained me how things
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
@dianfu and I also include @wuchong on this as these two are related.
The way I see it is that by not serializing the condition and the states,
you are trying to gain some speed, especially
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
Hi @dianfu . Thanks for updating the PR.
I left some comments on the related JIRA
(https://issues.apache.org/jira/browse/FLINK-6983) and the related
https://issues.apache.org/jira/browse/FLINK
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4143
LGTM. +1 to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4172
Hi @dianfu , this branch seems to be broken. Most of the migration tests
fail when you run them locally. I will keep on checking out the branch, just to
see the general idea of the change because
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4145
Hi @wuchong ! Nice work!
I have some changes to propose in the code itself, but before moving on
with this, I have some questions about the need of the change.
For the second, I have
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4165
Hi @dawidwys !
This branch seems to be broken (does not compile). In the `Pattern` class,
the newly introduced:
`public Pattern<T, F> where(SimpleCondition condition) ` and `
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123715144
--- Diff: docs/dev/libs/cep.md ---
@@ -547,18 +579,30 @@ pattern.where(event => ... /* some condition */)
or(condit
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123715389
--- Diff: docs/dev/libs/cep.md ---
@@ -334,6 +334,20 @@ pattern.where(event => ... /* some condition
*/).or(event => ... /* or con
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123714098
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/UntilConditionITCase.java
---
@@ -0,0 +1,427 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123710396
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -186,6 +193,24 @@ public Quantifier getQuantifier
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123713960
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -514,25 +524,46 @@ private void
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4143#discussion_r123715235
--- Diff: docs/dev/libs/cep.md ---
@@ -409,11 +423,28 @@ pattern.where(new IterativeCondition() {
});
{% endhighlight
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4143
Thanks a lot @dawidwys ! I will have a look.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4143
Hi @dawidwys ! Thanks for the work.
Could you also update the documentation?
This will also help the review process.
---
If your project is set up for it, you can reply to this email and have
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4132
After an offline discussion with @dianfu , we decided to close this PR and
merge this change with https://github.com/apache/flink/pull/4121/ as it is more
relevant there.
---
If your project is set
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4084
Thanks @dawidwys ! I will let travis have another go on the rebased version
and then merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4084
[FLINK-6772] [cep] Fix ordering (by timestamp) of matched events.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-fix-ordering
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4059
@tzulitai yes I will ;)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4041#discussion_r120362519
--- Diff: docs/dev/libs/cep.md ---
@@ -98,48 +128,105 @@ val result: DataStream[Alert] =
patternStream.select(createAlert(_))
-Note
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4059
Hi @tzulitai ! Thanks for testing also this.
The problem with the `CEP` failing test for `1.3` while passing for `1.2`
is that the semantics of the `followedBy()` changed between `1.2
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4059
@aljoscha yes we have already discussed offline with @tzulitai .
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4041#discussion_r120303532
--- Diff: docs/dev/libs/cep.md ---
@@ -98,48 +128,105 @@ val result: DataStream[Alert] =
patternStream.select(createAlert(_))
-Note
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4041
Thanks a lot @dawidwys for having a detailed look at it! I will integrate
your comments and then merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/4041
Thanks a lot for the thorough review @tzulitai ! I will address your
comments and then merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4041#discussion_r119596846
--- Diff: docs/dev/libs/cep.md ---
@@ -874,3 +1141,19 @@ val alerts = patternStream.select(createAlert(_)))
{% endhighlight
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/4041
[FLINK-6198] [cep] Update CEP documentation.
R @tzulitai @dawidwys
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-doc
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3963
@dawidwys merged this. Could you close the PR and the related JIRA?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2937
Hi @DmytroShkvyra ! Great to hear that you want to contribute to Flink!
To see the features that are pending, I would suggest to have a look at the
JIRAs that have CEP as component
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3963#discussion_r118297586
--- Diff:
flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/conditions/Context.scala
---
@@ -0,0 +1,33 @@
+/*
+ * Licensed
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3963#discussion_r118051044
--- Diff:
flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala
---
@@ -296,25 +294,94 @@ class PatternStream[T
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3963#discussion_r117989704
--- Diff:
flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala
---
@@ -296,25 +294,94 @@ class PatternStream[T
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3963#discussion_r117985885
--- Diff:
flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/package.scala
---
@@ -40,7 +44,11 @@ package object scala
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3961
Hi @dawidwys ! Your understanding is correct in the sense that it does not
leverage to the fullest the fact of keys being returned in order. The reason is
that this is valid only in RocksDB state
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3961
The re-ordering is just to verify that at watermark time, we actually order
by event-time.
On May 22, 2017 2:57 PM, "Aljoscha Krettek" <notificati...@github.c
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3961
[FLINK-6656] [cep] Change element PriorityQueue to MapState.
This is to leverage the fact that RocksDB already returns the
keys sorted. So now elements, instead of being stores in a PQ
and all
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2937
Thanks a lot @chermenin ! The same comment also holds for the branching
patterns PR. The PR is outdated but the issue is still valid. So if you ever
want to work on that, let us know!
---
If your
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2937
Hi @chermenin .
And sorry for the really late reply. As you may have noticed the CEP
library has been significantly enriched for the 1.3 version with a bunch of
cool new features
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3945#discussion_r117477471
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -930,6 +930,7 @@ public void serialize(NFA record, DataOutputView
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3945
[FLINK-6634] [cep] NFASerializer serializes ComputationState counter.
Before the recently introduces `NFASerializer` was not serializing the
`counter` of the `ComputationState`. This could result
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3938
Merging this!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/3938
[FLINK-6624] [cep] Fix SharedBuffer#hashCode().
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kl0u/flink cep-hash
Alternatively you can review
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3909
Merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3872
Merged.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3872
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user kl0u closed the pull request at:
https://github.com/apache/flink/pull/3909
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3927
@dawidwys thanks a lot for the work! I merged it on the master and the 1.3
release. Could you close this PR and the related JIRA?
---
If your project is set up for it, you can reply to this email
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3820
Merged this. Could you close the PR and the related JIRA?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have
301 - 400 of 952 matches
Mail list logo
