Till Rohrmann created FLINK-8392:
Summary: Simplify termination future completion
Key: FLINK-8392
URL: https://issues.apache.org/jira/browse/FLINK-8392
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318827#comment-16318827
]
ASF GitHub Bot commented on FLINK-4816:
---
Github user StephanEwen commented on the issue:
Till Rohrmann created FLINK-8393:
Summary: Reconnect to last known JobMaster when connection is lost
Key: FLINK-8393
URL: https://issues.apache.org/jira/browse/FLINK-8393
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-8394:
--
Issue Type: Test (was: Bug)
> Lack of synchronization accessing expectedRecord in ReceiverThread#shutdown
>
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319170#comment-16319170
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319021#comment-16319021
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-6951.
---
Resolution: Invalid
Not a problem anymore
> Incompatible versions of httpcomponents jars for Flink kinesis
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319049#comment-16319049
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5239
Thanks for going through the general design @StephanEwen ! As we discussed,
I agree with your first point. For the second point about RocksDB, this PR
already contains an optimized way to
[
https://issues.apache.org/jira/browse/FLINK-8393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319051#comment-16319051
]
ASF GitHub Bot commented on FLINK-8393:
---
GitHub user tillrohrmann opened a pull request:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160524740
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -150,16 +126,13 @@
*/
private boolean
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318999#comment-16318999
]
Julio Biason commented on FLINK-8284:
-
I swear to ${deity} that it didn't work. Restarted the project
[
https://issues.apache.org/jira/browse/FLINK-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julio Biason closed FLINK-8284.
---
Resolution: Invalid
> Custom metrics not being exposed for Prometheus
>
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4150
Thanks for confirming. I'll close this ticket and PR
---
Ted Yu created FLINK-8394:
-
Summary: Lack of synchronization accessing expectedRecord in
ReceiverThread#shutdown
Key: FLINK-8394
URL: https://issues.apache.org/jira/browse/FLINK-8394
Project: Flink
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160523676
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/AndFilterFunction.java
---
@@ -1,55 +0,0 @@
-/*
- * Licensed to the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5267
[FLINK-8393] [flip6] Reconnect to last known JobMaster when connection is
lost
## What is the purpose of the change
Reconnect to the last known location of a lost `JobMaster`
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319158#comment-16319158
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on a diff in the pull
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5266
[FLINK-8392] [rpc] Let termination future be completed by
AkkaRpcActor#postStop
## What is the purpose of the change
Revert the changes introduced by FLINK-7754. An RpcEndpoint's
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318879#comment-16318879
]
ASF GitHub Bot commented on FLINK-5982:
---
Github user asfgit closed the pull request at:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5262
Fails only with the now fixed "duplicate entry" error in `flink-mesos`, so
looks like this is fine.
---
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318760#comment-16318760
]
ASF GitHub Bot commented on FLINK-7475:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4963
@StefanRRichter Thanks! I will
---
[
https://issues.apache.org/jira/browse/FLINK-8082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318906#comment-16318906
]
ASF GitHub Bot commented on FLINK-8082:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318754#comment-16318754
]
ASF GitHub Bot commented on FLINK-8392:
---
GitHub user tillrohrmann opened a pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3633
---
[
https://issues.apache.org/jira/browse/FLINK-8350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318819#comment-16318819
]
Stephan Ewen commented on FLINK-8350:
-
{{io.tmp.dirs}} is fine with me. Please keep the
[
https://issues.apache.org/jira/browse/FLINK-8350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318834#comment-16318834
]
Chesnay Schepler commented on FLINK-8350:
-
I'm not so sure about making {{taskmanager.tmp.dirs}} a
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318974#comment-16318974
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4828
I think this approach is not yet sufficient. There can be various reasons
why a failure in DEPLOY happens, failed checkpoint restore is only one of the
reasons.
This also adds some
[
https://issues.apache.org/jira/browse/FLINK-8360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318913#comment-16318913
]
ASF GitHub Bot commented on FLINK-8360:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r160492829
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointStreamFactory.java
---
@@ -43,9 +44,9 @@ CheckpointStateOutputStream
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5239
I did a peer review and walk through the code.
Overall, the design look good, +1 for that!
Some comments:
- I would argue to change the way that these recovery options are
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160413762
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -359,12 +359,17 @@ class
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318456#comment-16318456
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160413930
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -145,6
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318461#comment-16318461
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318470#comment-16318470
]
ASF GitHub Bot commented on FLINK-8352:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5264
---
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160416641
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/SetOperatorsITCase.scala
---
@@ -278,7 +278,14 @@
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318475#comment-16318475
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user sunjincheng121 commented on a diff in the pull
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5256
---
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160419117
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/SetOperatorsITCase.scala
---
@@ -278,7 +278,14 @@
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318487#comment-16318487
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user sunjincheng121 commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160420917
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/JoinITCase.scala
---
@@ -254,7 +254,7 @@ class JoinITCase(
Github user casidiablo commented on the issue:
https://github.com/apache/flink/pull/4150
This actually worked for me. I ran it on EMR 5.10, compiling the kinesis
connector from the release-1.3 branch (since EMR provides Flink 1.3)
---
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318500#comment-16318500
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user casidiablo commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160421752
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/SetOperatorsITCase.scala
---
@@ -278,7 +278,14 @@ class
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318457#comment-16318457
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mohammad Abareghi updated FLINK-8354:
-
Priority: Major (was: Minor)
> Flink Kafka connector ignores Kafka message headers
>
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5241#discussion_r160414914
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/batch/sql/JoinITCase.scala
---
@@ -254,7 +254,7 @@ class
[
https://issues.apache.org/jira/browse/FLINK-8385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318478#comment-16318478
]
ASF GitHub Bot commented on FLINK-8385:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318495#comment-16318495
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318501#comment-16318501
]
ASF GitHub Bot commented on FLINK-8325:
---
Github user fhueske commented on a diff in the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/commit/a03cdfabe6eab48509b42a6831a21e488b9c3e80#commitcomment-26740277
In .travis.yml:
In .travis.yml on line 93:
So far, each profile had a different cache identifier. That way profiles
Nico Kruber created FLINK-8395:
--
Summary: Create (derived) sliced Buffer class
Key: FLINK-8395
URL: https://issues.apache.org/jira/browse/FLINK-8395
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wei-Che Wei closed FLINK-5982.
--
Resolution: Done
Fix Version/s: 1.5.0
> Refactor AbstractInvokable and StatefulTask
>
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/3633
Thanks a lot for doing these work. Nice to see this PR be merged. =)
---
[
https://issues.apache.org/jira/browse/FLINK-5982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319532#comment-16319532
]
ASF GitHub Bot commented on FLINK-5982:
---
Github user tony810430 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-6004:
--
Assignee: Tzu-Li (Gordon) Tai (was: ChungChe Lai)
> Allow
[
https://issues.apache.org/jira/browse/FLINK-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319572#comment-16319572
]
Tzu-Li (Gordon) Tai commented on FLINK-6004:
Since there's been quite a while since this issue
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319441#comment-16319441
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user tzulitai commented on the issue:
Shuyi Chen created FLINK-8397:
-
Summary: Support ROW type in CassandraOutputFormat
Key: FLINK-8397
URL: https://issues.apache.org/jira/browse/FLINK-8397
Project: Flink
Issue Type: Improvement
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4150
@casidiablo did you mean that without applying this PR's patch, the current
master worked for you? Or you had to apply this patch in order for it to work?
---
Github user casidiablo commented on the issue:
https://github.com/apache/flink/pull/4150
Since EMR only supports Flink 1.3 I had to checkout release-1.3 and compile
the connector from there. Then I was getting this `Socket not created by this
factory` error.
I then patched
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319445#comment-16319445
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user casidiablo commented on the issue:
Nico Kruber created FLINK-8396:
--
Summary: Create (derived) duplicate Buffer class
Key: FLINK-8396
URL: https://issues.apache.org/jira/browse/FLINK-8396
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-8395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8395:
---
Description: In order to pass sub-regions of a single buffer separately, we
require a sliced Buffer
[
https://issues.apache.org/jira/browse/FLINK-8396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8396:
---
Description: In order to pass a single buffer to netty multiple times, we
require a duplicate Buffer
Github user tony810430 commented on the issue:
https://github.com/apache/flink/pull/4828
Hi @StephanEwen
Let me conclude your comment and clarify some questions in my mind.
1. The original design treated all failures in DEPLOY as restore failure.
That is not fair because
[
https://issues.apache.org/jira/browse/FLINK-4816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319632#comment-16319632
]
ASF GitHub Bot commented on FLINK-4816:
---
Github user tony810430 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318221#comment-16318221
]
ASF GitHub Bot commented on FLINK-8381:
---
Github user twalthr commented on the issue:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5186#discussion_r160368484
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/JobClusterEntrypoint.java
---
@@ -132,6 +122,16 @@ protected void
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/5257
Thanks for your feedback @fhueske. I hope I could address all your
comments. I will merge this now...
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5257
---
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-8381.
-
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed in 1.5:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160372500
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -150,16 +126,13 @@
*/
private boolean
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318239#comment-16318239
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng closed FLINK-7578.
--
Resolution: Fixed
fixed by FLINK-7490
> WindowStream should support rich AggregateFunction
>
[
https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318220#comment-16318220
]
ASF GitHub Bot commented on FLINK-8288:
---
Github user NicoK commented on a diff in the pull request:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160375193
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/AndFilterFunction.java
---
@@ -1,55 +0,0 @@
-/*
- * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317975#comment-16317975
]
sunjincheng commented on FLINK-7578:
Hi [~hequn8128] May be the issue is fixed by
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4890
---
[
https://issues.apache.org/jira/browse/FLINK-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317992#comment-16317992
]
ASF GitHub Bot commented on FLINK-7903:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317993#comment-16317993
]
ASF GitHub Bot commented on FLINK-7904:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7903.
Resolution: Fixed
Fixed via 2d97cc1873b71b237e827d843cd5bd6d40f86d9c
> Add Flip6 build profile
>
[
https://issues.apache.org/jira/browse/FLINK-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7909.
Resolution: Fixed
Fix Version/s: 1.5.0
Fixed via
b90210e3712a54ad85a33dfc308a03e0c4a2a250
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4889
---
[
https://issues.apache.org/jira/browse/FLINK-7904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-7904.
Resolution: Fixed
Fixed via a03cdfabe6eab48509b42a6831a21e488b9c3e80
> Enable Flip6 build profile
[
https://issues.apache.org/jira/browse/FLINK-7909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16317989#comment-16317989
]
ASF GitHub Bot commented on FLINK-7909:
---
Github user asfgit closed the pull request at:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5261#discussion_r160349800
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -52,6 +55,10 @@
/** Flag
Fabian Hueske created FLINK-8391:
Summary: Improve dependency documentation for queryable state
Key: FLINK-8391
URL: https://issues.apache.org/jira/browse/FLINK-8391
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318166#comment-16318166
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4552#discussion_r160361957
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
---
@@ -88,6 +93,35 @@ public void run() {
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160349688
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -150,16 +126,13 @@
*/
private boolean
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318198#comment-16318198
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user pnowojski commented on a diff in the pull
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4587#discussion_r160363378
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/AndFilterFunction.java
---
@@ -1,55 +0,0 @@
-/*
- * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318199#comment-16318199
]
ASF GitHub Bot commented on FLINK-7511:
---
Github user pnowojski commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318225#comment-16318225
]
ASF GitHub Bot commented on FLINK-8381:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16318232#comment-16318232
]
ASF GitHub Bot commented on FLINK-7456:
---
Github user zhijiangW commented on a diff in the pull
1 - 100 of 236 matches
Mail list logo
