GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2228
[FLINK-4170][kinesis-connector] Simplify Kinesis connecter config keys to
be less overly verbose
Changes included with this PR:
1) Separate consumer & producer config keys into 2 classes:
`Con
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372468#comment-15372468
]
ASF GitHub Bot commented on FLINK-4170:
---
GitHub user tzulitai opened a pull request:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2227
Hi @skidder, I like the add, I think serious users will definitely need
this.
One thing I'm concerned about is how `CONFIG_AWS_REGION` and
`CONFIG_AWS_ENDPOINT` should co-exist in the confi
[
https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372492#comment-15372492
]
ASF GitHub Bot commented on FLINK-4197:
---
Github user tzulitai commented on the issue
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/1947
No. They are currently only accessible via JMX or a system supported by a
reporter. They are not available in the Dashboard, this will be worked on for
1.2 .
You could write a reporter that l
[
https://issues.apache.org/jira/browse/FLINK-1502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372495#comment-15372495
]
ASF GitHub Bot commented on FLINK-1502:
---
Github user zentol commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2228
We should probably also merge https://github.com/apache/flink/pull/2227
before this one, to reduce effort on rebasing.
---
If your project is set up for it, you can reply to this email and have you
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372501#comment-15372501
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user tzulitai commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2225
---
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-4191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372507#comment-15372507
]
ASF GitHub Bot commented on FLINK-4191:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4191.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/662b4586
>
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2071
Sry, I forgot to merge it. Will do now.
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372513#comment-15372513
]
ASF GitHub Bot commented on FLINK-4018:
---
Github user rmetzger commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2071
---
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-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4018.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/f0387aca
>
[
https://issues.apache.org/jira/browse/FLINK-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372515#comment-15372515
]
ASF GitHub Bot commented on FLINK-4018:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372521#comment-15372521
]
Robert Metzger commented on FLINK-3516:
---
And again https://s3.amazonaws.com/archive.
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2071
No problem, thank you!
---
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 s
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2228
Rebasing on merge of https://github.com/apache/flink/pull/2071 ..
---
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-4018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372558#comment-15372558
]
ASF GitHub Bot commented on FLINK-4018:
---
Github user tzulitai commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372559#comment-15372559
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user tzulitai commented on the issue
Till Rohrmann created FLINK-4198:
Summary: Replace
org.apache.flink.streaming.api.windowing.time.Time with
org.apache.flink.api.common.time.Time
Key: FLINK-4198
URL: https://issues.apache.org/jira/browse/FLINK-41
[
https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372563#comment-15372563
]
Ufuk Celebi commented on FLINK-3516:
OK, I will look into this. I didn't do it until n
[
https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372570#comment-15372570
]
Stephan Ewen commented on FLINK-4193:
-
One of the crash reports looks like it could be
Kostas Kloudas created FLINK-4199:
-
Summary: Wrong client behavior when submitting job to non-existing
cluster
Key: FLINK-4199
URL: https://issues.apache.org/jira/browse/FLINK-4199
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4199:
--
Description:
Trying to submit a job jar from the client to a non-existing cluster gives the
fol
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/2229
[hotfix][docs] Add note about Kinesis producer limitations
While testing the Kinesis connector @uce and I found out that data is not
written in-order with the Kinesis producer.
I'm now mentioni
[
https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372606#comment-15372606
]
Robert Metzger commented on FLINK-4015:
---
What's the throughput of the Kafka producer
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2209
Thanks @rmetzger. I would merge it today if there are no objections.
---
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 do
[
https://issues.apache.org/jira/browse/FLINK-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372621#comment-15372621
]
ASF GitHub Bot commented on FLINK-4111:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372624#comment-15372624
]
ASF GitHub Bot commented on FLINK-3916:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2197
I would like to merge this if there are no objections. It is a very
important improvement.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-4193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372638#comment-15372638
]
Gyula Fora commented on FLINK-4193:
---
I can probably try a different GC later but I have
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372649#comment-15372649
]
Josh Forman-Gornall commented on FLINK-4190:
Ah yeah that's a good point! I'll
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2229
+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, or if the fea
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2228#discussion_r70413349
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372655#comment-15372655
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user uce commented on a diff in the
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2229#discussion_r70413125
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -240,8 +239,9 @@ consumer when calling this API can also be modified by
using the other keys pref
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2228
I think this is an improvement over the current state.
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372658#comment-15372658
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user uce commented on the issue:
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2229#discussion_r70414090
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -240,8 +239,9 @@ consumer when calling this API can also be modified by
using the other keys pref
[
https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372665#comment-15372665
]
Sebastian Klemke commented on FLINK-4015:
-
No, synchronous wouldn't be fast enough
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2229#discussion_r70423762
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -240,8 +239,9 @@ consumer when calling this API can also be modified by
using the other keys pref
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2229
---
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
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2183
Changes look good to me. Thanks for your contribution @zentol. Will be
merging this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372825#comment-15372825
]
ASF GitHub Bot commented on FLINK-4123:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4199:
--
Component/s: Client
> Wrong client behavior when submitting job to non-existing cluster
> --
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4199:
--
Description:
Trying to submit a job jar from the client to a non-existing cluster gives the
fol
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-4199:
--
Description:
Trying to submit a job jar from the client to a non-existing cluster gives the
fol
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/2227
Thanks for the comment, @tzulitai !
I have not had any problems with testing Flink against a local Kinesalite
instance where the Region (required by Flink) is set to `us-east-1` and the
endp
[
https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372835#comment-15372835
]
ASF GitHub Bot commented on FLINK-4197:
---
Github user skidder commented on the issue:
Stefan Richter created FLINK-4200:
-
Summary: Kafka consumers should log the offset from which they
restore
Key: FLINK-4200
URL: https://issues.apache.org/jira/browse/FLINK-4200
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372843#comment-15372843
]
Stephan Ewen commented on FLINK-4034:
-
Okay, I see the issue. May make sense then to c
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2192
Good idea in general.
I would use variables for all versions used more than once. For example,
where ever `io.netty::netty` is used in version 3.x, it should probably refer
to a variable whic
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/2230
[FLINK-4200] [Kafka Connector] Kafka consumers logs the offset from wâ¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StefanRRichter/f
[
https://issues.apache.org/jira/browse/FLINK-4200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372860#comment-15372860
]
ASF GitHub Bot commented on FLINK-4200:
---
GitHub user StefanRRichter opened a pull re
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2228#discussion_r70437664
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372874#comment-15372874
]
Till Rohrmann commented on FLINK-4006:
--
Thanks for spotting this issue [~bowen.zheng]
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372875#comment-15372875
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user tzulitai commented on a diff in
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2197
Merging...
---
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
[
https://issues.apache.org/jira/browse/FLINK-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372887#comment-15372887
]
ASF GitHub Bot commented on FLINK-3916:
---
Github user twalthr commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2227
@skidder I see, thank you for your explanation. If it's a familiar behavior
(with respect to AWS / Kinesis users) to completely override the region when
setting the endpoint regardless of the origin
[
https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372892#comment-15372892
]
ASF GitHub Bot commented on FLINK-4197:
---
Github user tzulitai commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2197
---
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-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372895#comment-15372895
]
ASF GitHub Bot commented on FLINK-3916:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-4006:
Assignee: Till Rohrmann
> ExecutionGraph.restartStrategy field can't be serialized
> --
[
https://issues.apache.org/jira/browse/FLINK-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-4006.
Resolution: Fixed
Fixed via cc9ee2cc37ed0c7a7f9b0c50cf5edca63e289e1a
> ExecutionGraph.restartStrate
[
https://issues.apache.org/jira/browse/FLINK-3916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-3916.
-
Resolution: Fixed
Fix Version/s: 1.1.0
Fixed in 1b327f1ae7d078e22700729524e374b449b0f209.
[
https://issues.apache.org/jira/browse/FLINK-4190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372902#comment-15372902
]
Josh Forman-Gornall commented on FLINK-4190:
I've made those changes to my bra
[
https://issues.apache.org/jira/browse/FLINK-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372903#comment-15372903
]
ASF GitHub Bot commented on FLINK-4111:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2209
Merging...
---
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
[
https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372920#comment-15372920
]
ASF GitHub Bot commented on FLINK-4170:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2228#discussion_r70443267
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/ConsumerConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter updated FLINK-4150:
--
Description:
Submitting a job in Yarn with HA can lead to the following exception:
{code}
org.a
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372930#comment-15372930
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user StephanEwen commented on the is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2209
---
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-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372932#comment-15372932
]
ASF GitHub Bot commented on FLINK-4111:
---
Github user asfgit closed the pull request
Stefan Richter created FLINK-4201:
-
Summary: Checkpoints for jobs in non-terminal state (e.g.
suspended) get deleted
Key: FLINK-4201
URL: https://issues.apache.org/jira/browse/FLINK-4201
Project: Flin
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2226
Is it important that the metric reporter projects do not depend on
"flink-core"? If not, the the entire MetricRegistry could stay in flink-core,
and there would be no need to the MetricConfig obj
Till Rohrmann created FLINK-4202:
Summary: Add JM metric which shows the restart duration
Key: FLINK-4202
URL: https://issues.apache.org/jira/browse/FLINK-4202
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372941#comment-15372941
]
ASF GitHub Bot commented on FLINK-4197:
---
Github user skidder commented on the issue:
Github user skidder commented on the issue:
https://github.com/apache/flink/pull/2227
@tzulitai definitely, I'll add an explanation of the config setting in the
docs shortly.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as wel
[
https://issues.apache.org/jira/browse/FLINK-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4111.
-
Resolution: Fixed
Fixed in 508965e69cfb99724b69f1e5dc59e5f5d5a70315.
> Flink Table & SQL doesn't
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2226
you are correct that the MetricRegistry could remain in flink-core.
However, you would still need the new MetricConfig due to the MetricReporter.
---
If your project is set up for it, you can reply t
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372942#comment-15372942
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user zentol commented on the issue:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2202#discussion_r70448543
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -19,12 +19,16 @@
package org.apache.flink.cep.nfa;
[
https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372952#comment-15372952
]
ASF GitHub Bot commented on FLINK-4149:
---
Github user tillrohrmann commented on a dif
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2226
Could the `MetricReporter` stay in `flink-core`as well, or does that void
the separation of dependencies.
You can probably use the Java `Properties` object as a configuration
object. Sav
[
https://issues.apache.org/jira/browse/FLINK-4192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372955#comment-15372955
]
ASF GitHub Bot commented on FLINK-4192:
---
Github user StephanEwen commented on the is
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2202#discussion_r70449634
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -454,4 +458,126 @@ static String generateStateName(final Strin
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2202#discussion_r70449753
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -454,4 +458,126 @@ static String generateStateName(final Strin
[
https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372959#comment-15372959
]
ASF GitHub Bot commented on FLINK-4149:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372960#comment-15372960
]
ASF GitHub Bot commented on FLINK-4149:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372951#comment-15372951
]
Kostas Kloudas commented on FLINK-4199:
---
Another related issue is that a similar mis
[
https://issues.apache.org/jira/browse/FLINK-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372963#comment-15372963
]
ASF GitHub Bot commented on FLINK-4149:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2202#discussion_r70450213
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -454,4 +458,126 @@ static String generateStateName(final Strin
[
https://issues.apache.org/jira/browse/FLINK-3713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372973#comment-15372973
]
ASF GitHub Bot commented on FLINK-3713:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2083
If there are no objections, I would like to merge 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
[
https://issues.apache.org/jira/browse/FLINK-4067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372972#comment-15372972
]
ASF GitHub Bot commented on FLINK-4067:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2194
If there are no objections, I would like to merge 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
1 - 100 of 173 matches
Mail list logo
