[
https://issues.apache.org/jira/browse/FLINK-6575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069609#comment-16069609
]
ASF GitHub Bot commented on FLINK-6575:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-6575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069610#comment-16069610
]
ASF GitHub Bot commented on FLINK-6575:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069611#comment-16069611
]
mingleizhang commented on FLINK-7047:
-
Chesnay Schepler is great. Actually, I did not
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3776
@Rucongzhang ok, understood. I agree that in general the current
`AbstractYarnClusterDescriptor` has poor separation of concerns, as is a bit
hard to write contained tests. We should remember to add
[
https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069621#comment-16069621
]
ASF GitHub Bot commented on FLINK-6376:
---
Github user tzulitai commented on the issue
Github user Rucongzhang commented on the issue:
https://github.com/apache/flink/pull/3776
@tzulitai ,ok,Thanks a lot!
---
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
[
https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069627#comment-16069627
]
ASF GitHub Bot commented on FLINK-6376:
---
Github user Rucongzhang commented on the is
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3891
I ran the tests repeatedly and analyzed why they failed. For these i
determined the cause to be hdfs.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
[
https://issues.apache.org/jira/browse/FLINK-6575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069628#comment-16069628
]
ASF GitHub Bot commented on FLINK-6575:
---
Github user zentol commented on the issue:
Github user ch33hau commented on the issue:
https://github.com/apache/flink/pull/2761
@fhueske Sorry for the problems you have raised, I can see the painful now,
I will avoid the same mistake.
Thanks for your time I really appreciate it.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069632#comment-16069632
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user ch33hau commented on the issue:
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/3915#discussion_r124977924
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java
---
@@ -128,6 +13
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069634#comment-16069634
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user zjureel commented on a diff in
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4206
Hmm, this is disturbing. Locally it works for me always. I have rewritten
test so that it should be less prone to intermittent failures (longer reading
from Kafka timeout). Hopefully that will solv
[
https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069657#comment-16069657
]
ASF GitHub Bot commented on FLINK-6996:
---
Github user pnowojski commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069667#comment-16069667
]
Till Rohrmann commented on FLINK-7047:
--
I like the idea. +1 for the changes. This cou
[
https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069669#comment-16069669
]
ASF GitHub Bot commented on FLINK-4022:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3746
(please ignore the batch of commits. I'm just using this branch for an
overall Travis run before committing the batch; personal accounts get time-outs
too constantly)
---
If your project is set up
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2761
No worries :-)
---
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
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069671#comment-16069671
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069688#comment-16069688
]
Chesnay Schepler edited comment on FLINK-7047 at 6/30/17 8:23 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069688#comment-16069688
]
Chesnay Schepler commented on FLINK-7047:
-
WIth a split repo we could make the tes
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069688#comment-16069688
]
Chesnay Schepler edited comment on FLINK-7047 at 6/30/17 8:23 AM:
--
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124988636
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/fun/SqlStdOperatorTable.java
---
@@ -1900,7 +1900,7 @@ public void unparse(
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069696#comment-16069696
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124990474
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala
---
@@ -349,6 +350,14 @@ class RelTimeIn
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069707#comment-16069707
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124990940
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala
---
@@ -349,6 +350,14 @@ class RelTimeIn
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069711#comment-16069711
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r124991860
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala
---
@@ -54,34 +56,75 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069718#comment-16069718
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/3984
---
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 is enab
[
https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069756#comment-16069756
]
ASF GitHub Bot commented on FLINK-6710:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6710.
---
Resolution: Fixed
1.4: d7d10a130bf7a1856e5ab17ac354f3f2fc4d2f55
> Remove twitter-inputformat
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4231
[FLINK-6695] Activate strict checkstyle for flink-contrib
This PR moves the checkstyle plugin declaration into the flink-contrib pom.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069760#comment-16069760
]
ASF GitHub Bot commented on FLINK-6695:
---
GitHub user zentol opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4232
[FLINK-7041] Deserialize StateBackend from JobCheckpointingSettings with
user classloader
R: @tzulitai
CC: @StephanEwen I noticed that the state backend that is in the
configuration is n
[
https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069762#comment-16069762
]
ASF GitHub Bot commented on FLINK-7041:
---
GitHub user aljoscha opened a pull request:
Usman Younas created FLINK-7050:
---
Summary: RFC Compliant CSV Parser for Table Source
Key: FLINK-7050
URL: https://issues.apache.org/jira/browse/FLINK-7050
Project: Flink
Issue Type: Improvement
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r125000171
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateClient.java
---
@@ -267,6 +293,177 @@ public void shutDown() {
}
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r124999617
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/query/AbstractQueryableStateITCase.java
---
@@ -534,33 +537,66 @@ public Integer getKey(Tuple2 va
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r124998338
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateClient.java
---
@@ -157,10 +168,16 @@ public QueryableStateClient(
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r124998957
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/VoidNamespaceTypeInfo.java
---
@@ -0,0 +1,102 @@
+/*
+ * Licensed to the Apach
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4225#discussion_r124999382
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/query/AbstractQueryableStateITCase.java
---
@@ -234,38 +239,28 @@ public Integer getKey(Tuple2 va
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069779#comment-16069779
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069783#comment-16069783
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069782#comment-16069782
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069781#comment-16069781
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069780#comment-16069780
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user aljoscha commented on a diff in
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4232
Thanks for the quick fix @aljoscha!
Regarding tests:
Can we also have another test that verifies `JobGraphs` containing custom
`StateBackend`s or `StateBackends` with custom classes can
[
https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069793#comment-16069793
]
ASF GitHub Bot commented on FLINK-7041:
---
Github user tzulitai commented on the issue
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r125002758
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala
---
@@ -349,6 +350,14 @@ class RelTimeIn
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069797#comment-16069797
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r125003073
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala
---
@@ -54,34 +56,75 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069799#comment-16069799
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r125003218
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/calcite/sql/fun/SqlGroupFunction.java
---
@@ -50,7 +50,8 @@
* GROUP BY HOP(rowtime, INT
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069801#comment-16069801
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4232
Ah scratch that, perhaps the `CheckpointSettingsSerializableTest` is
sufficient.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If y
[
https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069803#comment-16069803
]
ASF GitHub Bot commented on FLINK-7041:
---
Github user tzulitai commented on the issue
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/4199#discussion_r125004836
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowStartEndPropertiesRule.scala
---
@@ -54,34 +56,75 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069817#comment-16069817
]
ASF GitHub Bot commented on FLINK-6584:
---
Github user twalthr commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4232#discussion_r125004426
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java
---
@@ -223,19 +223,21 @@ public static ExecutionG
[
https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069822#comment-16069822
]
ASF GitHub Bot commented on FLINK-7041:
---
Github user tzulitai commented on a diff in
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 So
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() {
}
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069827#comment-16069827
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069829#comment-16069829
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user kl0u commented on a diff in the
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 value)
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069832#comment-16069832
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user kl0u commented on a diff in the
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 value)
[
https://issues.apache.org/jira/browse/FLINK-7044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069834#comment-16069834
]
ASF GitHub Bot commented on FLINK-7044:
---
Github user kl0u commented on a diff in the
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3915
@tzulitai Thank you for your suggestion. I think move the conversion
between date and offset to `KafkaConsumerThread` is really a good idea. I have
fixed the NPE in test case, and move the conversion
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069846#comment-16069846
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user zjureel commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/4229
Hi, @tzulitai I have updated the code. Please check whether it should add
more ?
---
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 dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125005837
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
---
@@ -153,9 +153,8 @@ public int hashCode() {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125005984
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -455,6 +548,76 @@ private void addStopStateToLo
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125012573
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java
---
@@ -0,0 +1,807 @@
+/*
+ * Licensed to the Apache So
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125005892
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/TimesRangeITCase.java
---
@@ -92,6 +92,57 @@ public boolean filter(Event value)
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125010592
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java
---
@@ -0,0 +1,807 @@
+/*
+ * Licensed to the Apache So
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125005277
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -430,6 +431,54 @@ public Quantifier getQuantifier() {
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069904#comment-16069904
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069909#comment-16069909
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069906#comment-16069906
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069899#comment-16069899
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069903#comment-16069903
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069901#comment-16069901
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069907#comment-16069907
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069896#comment-16069896
]
ASF GitHub Bot commented on FLINK-7038:
---
Github user zhangminglei commented on the i
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069905#comment-16069905
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069898#comment-16069898
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069897#comment-16069897
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r124999092
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -455,6 +548,76 @@ private void addStopStateToLo
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069908#comment-16069908
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r124994181
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFAStateNameHandler.java
---
@@ -55,6 +55,11 @@ public void checkNameUn
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125009258
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java
---
@@ -0,0 +1,807 @@
+/*
+ * Licensed to the Apache So
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125005796
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -366,8 +366,9 @@ public Quantifier getQuantifier() {
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125012236
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java
---
@@ -0,0 +1,807 @@
+/*
+ * Licensed to the Apache So
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4153#discussion_r125009695
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/nfa/GroupITCase.java
---
@@ -0,0 +1,807 @@
+/*
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069900#comment-16069900
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069902#comment-16069902
]
ASF GitHub Bot commented on FLINK-6927:
---
Github user dawidwys commented on a diff in
1 - 100 of 216 matches
Mail list logo
