[
https://issues.apache.org/jira/browse/FLINK-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121106#comment-16121106
]
ASF GitHub Bot commented on FLINK-7406:
---
GitHub user zhijiangW opened a pull request:
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/4509
[FLINK-7406][network] Implement Netty receiver incoming pipeline for
credit-based
## What is the purpose of the change
Currently `PartitionRequestClientHandler` receives and reads
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Blocker (was: Critical)
> Assumption of partition id strict contiguity is
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121099#comment-16121099
]
Tzu-Li (Gordon) Tai commented on FLINK-7407:
[~aljoscha] this information isn't independently
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121094#comment-16121094
]
Aljoscha Krettek commented on FLINK-7407:
-
[~tzulitai] Should we make this a blocker, because it
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7407:
--
Assignee: Tzu-Li (Gordon) Tai
> Assumption of partition id strict contiguity
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Description:
In the Kafka Consumer's {{AbstractPartitionDiscoverer}}, for partition
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Priority: Critical (was: Major)
> Assumption of partition id strict contiguity is
[
https://issues.apache.org/jira/browse/FLINK-7407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7407:
---
Affects Version/s: 1.4.0
> Assumption of partition id strict contiguity is too naive
Tzu-Li (Gordon) Tai created FLINK-7407:
--
Summary: Assumption of partition id strict contiguity is too naive
in Kafka consumer's AbstractPartitionDiscoverer
Key: FLINK-7407
URL:
[
https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16121011#comment-16121011
]
ASF GitHub Bot commented on FLINK-7368:
---
Github user asdf2014 commented on a diff in the pull
Github user asdf2014 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4472#discussion_r132358492
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/metrics/MetricStore.java
---
@@ -24,8 +24,8 @@
import org.slf4j.Logger;
zhijiang created FLINK-7406:
---
Summary: Implement Netty receiver incoming pipeline for
credit-based
Key: FLINK-7406
URL: https://issues.apache.org/jira/browse/FLINK-7406
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120997#comment-16120997
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user dbrinegar commented on the issue:
Github user dbrinegar commented on the issue:
https://github.com/apache/flink/pull/4188
Totally understand! Busy here too. Let me know what you decide to do and
I'll try to chip in.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-6787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120955#comment-16120955
]
ASF GitHub Bot commented on FLINK-6787:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4500
@zentol I have created this PR to fix
[https://issues.apache.org/jira/browse/FLINK-6787](https://issues.apache.org/jira/browse/FLINK-6787),
could you please have a look when you're free, thanks :)
Github user yestinchen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132349108
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,276 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120938#comment-16120938
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff in the pull
Github user yestinchen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132348950
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java
---
@@ -150,6 +160,59 @@ long getWindowTime() {
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120936#comment-16120936
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user yestinchen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120928#comment-16120928
]
Jark Wu edited comment on FLINK-7398 at 8/10/17 1:52 AM:
-
[~wheat9] how do you
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120928#comment-16120928
]
Jark Wu commented on FLINK-7398:
[~wheat9] how do you want to fix it?
> Table API operators/UDFs must
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120885#comment-16120885
]
Michael Fong commented on FLINK-6805:
-
Thanks for your comment, [~Zentol],
I see the point of
[
https://issues.apache.org/jira/browse/FLINK-7278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120845#comment-16120845
]
Zhenzhong Xu commented on FLINK-7278:
-
[~trohrm...@apache.org] unfortunately, we don't have logs for
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120818#comment-16120818
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user rangadi commented on the issue:
Github user rangadi commented on the issue:
https://github.com/apache/flink/pull/4239
> Hmmm, are you sure about this thing? That would mean that Kafka doesn't
support transactional parallel writes from two different process, which would
be very strange. Could you point to a source
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120713#comment-16120713
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
Writing records in state would be very costly. It is only a "last resort"
solution.
> That would imply exactly-once consumers can not read past that
transaction as long as it is open
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120703#comment-16120703
]
ASF GitHub Bot commented on FLINK-7405:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4508
Make sense
---
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-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120701#comment-16120701
]
ASF GitHub Bot commented on FLINK-7405:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4508
this way all exceptions are being cutoff, please add a separate catch block
for socket timeout exceptions.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Summary: Reduce spamming warning logging from DatadogHttpReporter (was:
Reduce excessive warning logging
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120664#comment-16120664
]
ASF GitHub Bot commented on FLINK-7405:
---
GitHub user bowenli86 opened a pull request:
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/4508
[FLINK-7405][metrics] Reduce excessive warning logging from
DatadogHttpReporter
## What is the purpose of the change
DatadogHttpReporter is logging too much when there's a connection
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Component/s: Metrics
> Reduce excessive warning logging from DatadogHttpReporter
>
[
https://issues.apache.org/jira/browse/FLINK-7405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-7405:
Description:
DatadogHttpReporter is logging too much when there's a connection timeout, and
we need to
[
https://issues.apache.org/jira/browse/FLINK-6281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120659#comment-16120659
]
ASF GitHub Bot commented on FLINK-6281:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3712
Thanks @fhueske ! Updated the PR to address the comments.
---
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
Bowen Li created FLINK-7405:
---
Summary: Reduce excessive warning logging from DatadogHttpReporter
Key: FLINK-7405
URL: https://issues.apache.org/jira/browse/FLINK-7405
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rong Rong reassigned FLINK-7357:
Assignee: Rong Rong (was: Haohui Mai)
> HOP_START() HOP_END() does not work when using HAVING
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120536#comment-16120536
]
Haohui Mai commented on FLINK-7398:
---
Good catch!
I think we can fix it for once but I'm more worried
[
https://issues.apache.org/jira/browse/FLINK-7398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-7398:
-
Assignee: Haohui Mai
> Table API operators/UDFs must not store Logger
>
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120511#comment-16120511
]
Haohui Mai commented on FLINK-7357:
---
I haven't started yet. Please go ahead.
> HOP_START() HOP_END()
[
https://issues.apache.org/jira/browse/FLINK-7357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120483#comment-16120483
]
Rong Rong commented on FLINK-7357:
--
Seems like the logical plan generated from Having inserts another
[
https://issues.apache.org/jira/browse/FLINK-7367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120319#comment-16120319
]
ASF GitHub Bot commented on FLINK-7367:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4473
@tzulitai @aljoscha Let me know if this PR looks good. Thanks!
---
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
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120249#comment-16120249
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user rangadi commented on the issue:
Github user rangadi commented on the issue:
https://github.com/apache/flink/pull/4239
May be an extra shuffle to make small batches could help. Another option is
to buffer all the records in state and write them all inside commit(). But not
sure how costly it is to save all the
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120145#comment-16120145
]
Xingcan Cui commented on FLINK-7245:
I have made some minor changes, which can be found at
[
https://issues.apache.org/jira/browse/FLINK-7372?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120143#comment-16120143
]
ASF GitHub Bot commented on FLINK-7372:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4483
+1, 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. If your project does not have this feature
enabled and wishes
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7395:
Priority: Major (was: Blocker)
> NumBytesOut metric in RecordWriter call synchronized
[
https://issues.apache.org/jira/browse/FLINK-7404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120102#comment-16120102
]
ASF GitHub Bot commented on FLINK-7404:
---
GitHub user fhueske opened a pull request:
GitHub user fhueske opened a pull request:
https://github.com/apache/flink/pull/4507
[FLINK-7404] [table] Generate code for non-equi join conditions only.
## What is the purpose of the change
Generate code only for non-equi join conditions for Table API / SQL batch
joins.
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120091#comment-16120091
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4504
@twalthr noticed it and found it odd that we acquire a lock for doing
metrics stuff, and asked me whether it is correct.
Since we try to keep the overhead of metrics as low as possible not
Fabian Hueske created FLINK-7404:
Summary: Table API batch join code-gen's equi-join conditions
Key: FLINK-7404
URL: https://issues.apache.org/jira/browse/FLINK-7404
Project: Flink
Issue
Timo Walther created FLINK-7403:
---
Summary: Remove expandLocalRef() before code generation
Key: FLINK-7403
URL: https://issues.apache.org/jira/browse/FLINK-7403
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6805:
Fix Version/s: 1.4.0
> Flink Cassandra connector dependency on Netty disagrees with Flink
>
[
https://issues.apache.org/jira/browse/FLINK-7395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120044#comment-16120044
]
ASF GitHub Bot commented on FLINK-7395:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4504
@zentol what is the root cause for this change? I see that this is marked
as a blocker bug. Was this reported or discussed on the mailing list?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120018#comment-16120018
]
Chesnay Schepler commented on FLINK-6805:
-
Since the cassandra connector jar doesn't contain netty
[
https://issues.apache.org/jira/browse/FLINK-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16120012#comment-16120012
]
ASF GitHub Bot commented on FLINK-7400:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/4506
[FLINK-7400][cluster] fix off-heap limits set to conservatively in cluster
environments
## What is the purpose of the change
Inside `ContaineredTaskManagerParameters`, since #3648, the
[
https://issues.apache.org/jira/browse/FLINK-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7400:
---
Summary: off-heap limits set to conservatively in cluster environments
(was: off-heap limits set to
[
https://issues.apache.org/jira/browse/FLINK-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-7400:
---
Component/s: Mesos
Cluster Management
> off-heap limits set to conservatively in
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119982#comment-16119982
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4492
Thanks for testing things on yarn/HA.
As for the web monitor options, I do see the point of not coupling new
options to the jobmanager. However, I think it's a bad idea to have some be
tied
[
https://issues.apache.org/jira/browse/FLINK-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119981#comment-16119981
]
Nico Kruber commented on FLINK-7316:
After changing to off-heap network buffers, we are hit by
[
https://issues.apache.org/jira/browse/FLINK-6805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119971#comment-16119971
]
Michael Fong commented on FLINK-6805:
-
All other flink libraries depends on 4.0.27, except
[
https://issues.apache.org/jira/browse/FLINK-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119970#comment-16119970
]
Nico Kruber commented on FLINK-7400:
Please note that this affects (at least) all (batch) programs
Ted Yu created FLINK-7402:
-
Summary: Ineffective null check in NettyMessage#write()
Key: FLINK-7402
URL: https://issues.apache.org/jira/browse/FLINK-7402
Project: Flink
Issue Type: Bug
Nico Kruber created FLINK-7401:
--
Summary: EnvironmentInformation.getMaxJvmHeapMemory does not
return the value given via -Xmx
Key: FLINK-7401
URL: https://issues.apache.org/jira/browse/FLINK-7401
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/commit/fca8caea70cb5b76d4d45bdac438d8e3c3fd3315#commitcomment-23558079
In flink-shaded-hadoop/flink-shaded-hadoop2/pom.xml:
In flink-shaded-hadoop/flink-shaded-hadoop2/pom.xml on line 113:
[
https://issues.apache.org/jira/browse/FLINK-7381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119933#comment-16119933
]
ASF GitHub Bot commented on FLINK-7381:
---
Github user tillrohrmann commented on the issue:
Nico Kruber created FLINK-7400:
--
Summary: off-heap limits set to conservatively in yarn
Key: FLINK-7400
URL: https://issues.apache.org/jira/browse/FLINK-7400
Project: Flink
Issue Type: Bug
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4492
I did the additional tests running Flink on Yarn with and without HA and
the web frontend worked.
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-7399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119895#comment-16119895
]
ASF GitHub Bot commented on FLINK-7399:
---
GitHub user zentol opened a pull request:
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4505
[FLINK-7399] [checkstyle] Forbid imports from org.codehaus.jackson
## What is the purpose of the change
Flink uses `com.fasterxml.jackson` but pulls in the codehaus version from
various
Chesnay Schepler created FLINK-7399:
---
Summary: Add checkstyle rule to forbid codehaus jackson imports
Key: FLINK-7399
URL: https://issues.apache.org/jira/browse/FLINK-7399
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119882#comment-16119882
]
ASF GitHub Bot commented on FLINK-7009:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4188
Sorry that it's taking so long for me to response, I'm completely swamped
with issues at the moment.
I will take another deeper look when i finally find time to try this out,
but from what
Aljoscha Krettek created FLINK-7398:
---
Summary: Table API operators/UDFs must not store Logger
Key: FLINK-7398
URL: https://issues.apache.org/jira/browse/FLINK-7398
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119873#comment-16119873
]
Steve Loughran commented on FLINK-7365:
---
There's a special log you can turn off to slience all
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132134129
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,276 @@
+/*
+ * Licensed to
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132176196
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,276 @@
+/*
+ * Licensed to
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132174353
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java
---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132175333
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java
---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132175179
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java
---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119867#comment-16119867
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119869#comment-16119869
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132175418
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java
---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119853#comment-16119853
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132175365
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/AfterMatchSkipITCase.java
---
@@ -0,0 +1,431 @@
+/*
+ * Licensed to the
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4331#discussion_r132166853
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -322,6 +336,64 @@ public void resetNFAChanged() {
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119860#comment-16119860
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119861#comment-16119861
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16119864#comment-16119864
]
ASF GitHub Bot commented on FLINK-7169:
---
Github user dawidwys commented on a diff in the pull
1 - 100 of 239 matches
Mail list logo
