[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429207#comment-15429207
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2369
Left a few comments on some high-level design choices for a first review.
Mostly on `FlinkKafkaProducer010`, I wonder if there are other better
possibilities over there?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429202#comment-15429202
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75572263
--- Diff: docs/apis/streaming/connectors/kafka.md ---
@@ -291,3 +301,35 @@ higher value.
There is currently no transactional producer for Kafka, so Flink
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429201#comment-15429201
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75572212
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429183#comment-15429183
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75571478
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429179#comment-15429179
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75571320
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429144#comment-15429144
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75569873
--- Diff:
flink-streaming-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429127#comment-15429127
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2369#discussion_r75569347
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java
---
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-3211.
Resolution: Resolved
> Add AWS Kinesis streaming connector
> ---
[
https://issues.apache.org/jira/browse/FLINK-4195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4195:
---
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-3211)
> Dedic
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4194:
---
Summary: Implement isEndOfStream() for KinesisDeserializationSchema (was:
KinesisDese
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4194:
---
Description:
**Original JIRA title: KinesisDeserializationSchema.isEndOfStream() is ne
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4194:
---
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-3211)
> Kines
[
https://issues.apache.org/jira/browse/FLINK-3983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-3983:
---
Issue Type: Improvement (was: Sub-task)
Parent: (was: FLINK-3211)
> Allow
[
https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-3924:
---
Issue Type: Task (was: Sub-task)
Parent: (was: FLINK-3211)
> Remove proto
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15429114#comment-15429114
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
Closing this now ...
Remaining is
Ted Yu created FLINK-4437:
-
Summary: Lock evasion around lastTriggeredCheckpoint may lead to
lost updates to related fields
Key: FLINK-4437
URL: https://issues.apache.org/jira/browse/FLINK-4437
Project: Flink
Ted Yu created FLINK-4436:
-
Summary: Unclosed DataOutputBuffer in Utils#setTokensFor()
Key: FLINK-4436
URL: https://issues.apache.org/jira/browse/FLINK-4436
Project: Flink
Issue Type: Bug
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2390
---
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-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428926#comment-15428926
]
ASF GitHub Bot commented on FLINK-4355:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2395
[FLINK-4355] [cluster management] Add tests for the TaskManager ->
ResourceManager registration.
This adds the missing tests for [FLINK-4355].
It makes use of the testing RPC service su
[
https://issues.apache.org/jira/browse/FLINK-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428924#comment-15428924
]
ASF GitHub Bot commented on FLINK-4434:
---
GitHub user StephanEwen opened a pull reque
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/2394
[FLINK-4434] [rpc] Add a testing RPC service.
Adds an RPC Service implementation for testing. This RPC service acts as a
replacement for the regular RPC service for cases where tests need to ret
GitHub user thvasilo opened a pull request:
https://github.com/apache/flink/pull/2393
[trivial] Fix typo in dosctring
There is a small typo in the getBufferTimeout docstring, this fixes it.
Talked with @tillrohrmann about whether it's worth it to open a PR for
something lik
Stephan Ewen created FLINK-4435:
---
Summary: Replace Guava's VisibleForTesting annotation with Flink's
annotation
Key: FLINK-4435
URL: https://issues.apache.org/jira/browse/FLINK-4435
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4431.
---
> Introduce a "VisibleForTesting" annotation
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4431.
-
Done via 59eb4332f31204b118fe95d56bcf3893ae705866
> Introduce a "VisibleForTesting" annotation
>
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428909#comment-15428909
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4434:
Description:
I suggest to add a simple testing RPC service that allows to register mock
gateways un
Stephan Ewen created FLINK-4434:
---
Summary: Add a testing RPC service
Key: FLINK-4434
URL: https://issues.apache.org/jira/browse/FLINK-4434
Project: Flink
Issue Type: Sub-task
Componen
[
https://issues.apache.org/jira/browse/FLINK-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4403.
---
> RPC proxy classloading should use Flink class' classloader
> ---
[
https://issues.apache.org/jira/browse/FLINK-4403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4403.
-
Resolution: Fixed
Merged to flip-6 branch in b7259d617bbb080e486ae91aaf3d9b24addb352c
> RPC proxy
[
https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428884#comment-15428884
]
Stephan Ewen commented on FLINK-4377:
-
[FLINK-4399] should fix this.
> akka.remote.Ov
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428878#comment-15428878
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428877#comment-15428877
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2390
@ramkrish86 Only some project are API projects and need annotations. Other
internal projects have no stability annotations.
---
If your project is set up for it, you can reply to this email and
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2390
I would merge this and file for a followup issue to replace the Guava
annotations and add a checkstyle rule.
---
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-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428874#comment-15428874
]
Stephan Ewen commented on FLINK-4433:
-
Let's tackle those as independent issues. I thi
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428862#comment-15428862
]
Sunny T commented on FLINK-4422:
Okay, Thanks for the clarification.
> Convert all time i
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428858#comment-15428858
]
Stephan Ewen commented on FLINK-4422:
-
It goes through the entire Flink codebase.
> C
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428734#comment-15428734
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2367
@tillrohrmann Thank you for the very detailed review. I do appreciate it.
I agree with your suggestions and I'll try to improve the code and write
documentation in the next couple of days.
A
[
https://issues.apache.org/jira/browse/FLINK-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428696#comment-15428696
]
ASF GitHub Bot commented on FLINK-3866:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2289
@fhueske Thank you for your review!
Could you please merge it? I don't have write permissions.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428695#comment-15428695
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issu
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/2244
@twalthr Could you review this one more time?
---
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 feat
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428681#comment-15428681
]
Maximilian Michels commented on FLINK-3710:
---
Seems like this is not really possi
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428588#comment-15428588
]
Maximilian Michels commented on FLINK-3710:
---
Thank you for the reminder, I'll lo
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428584#comment-15428584
]
Scott Kidder commented on FLINK-4341:
-
FYI, I've confirmed that explicitly setting the
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428567#comment-15428567
]
Elias Levy commented on FLINK-3710:
---
As of 1.1.0 this is still broken.
> ScalaDocs for
[
https://issues.apache.org/jira/browse/FLINK-3222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3222:
--
Description:
Here is related code:
{code}
result = 31 * result + (int) (subTaskStats.length ^ (subTaskStats.
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4433:
--
Description:
With the addition of continuous file monitoring, apart from the
{{StreamSource}} a
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4433:
--
Description:
With the addition of continuous file monitoring, apart from the
{{StreamSource}} a
[
https://issues.apache.org/jira/browse/FLINK-3801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3801:
--
Description:
Currently yoda-time 2.5 is used which was very old.
We should upgrade to 2.9.3
was:
Currently
[
https://issues.apache.org/jira/browse/FLINK-3734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3734:
--
Description:
{code}
DataInputView in = inputState.getState(getUserCodeClassloader());
final long nextEv
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428459#comment-15428459
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the iss
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2342
@uce
Thanks. No problem. I can wait.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ramkrishna.s.vasudevan reassigned FLINK-4417:
-
Assignee: ramkrishna.s.vasudevan
> Checkpoints should be subsumed by Chec
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428450#comment-15428450
]
ramkrishna.s.vasudevan commented on FLINK-4417:
---
Thank you. Will start with
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428447#comment-15428447
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2367
Thanks for your contribution and apologies for the late review @mushketyk.
I think your implementation goes into the right direction and I really like the
testing.
I think what we still
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428408#comment-15428408
]
Sunny T commented on FLINK-4422:
I have a question: This change has to be done in *flink-c
Kostas Kloudas created FLINK-4433:
-
Summary: Refactor the StreamSource.
Key: FLINK-4433
URL: https://issues.apache.org/jira/browse/FLINK-4433
Project: Flink
Issue Type: Bug
Report
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/2305
Are there strong reasons to use `apply` for `DataStream` and `with` for
`DataSet`? Could we deprecate the `apply` so that users having switched to
`with` will not lose API compatibility with 2.0?
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428402#comment-15428402
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428397#comment-15428397
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user aljoscha commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2355
---
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 aljoscha commented on the issue:
https://github.com/apache/flink/pull/2355
I merged it. Thanks for your work! ð
---
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
en
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2333
---
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-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sunny T reassigned FLINK-4422:
--
Assignee: Sunny T
> Convert all time interval measurements to System.nanoTime()
> -
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428394#comment-15428394
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428395#comment-15428395
]
Sunny T commented on FLINK-4422:
Okay cool. I would like to take this up.
Assigning this
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek resolved FLINK-4282.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in
https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428393#comment-15428393
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428380#comment-15428380
]
Maximilian Michels commented on FLINK-4426:
---
The {{ZooKeeperSaslClient}} is not
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2313
I've made the last changes concerning the lazy reconstruction of the class
loader we discussed. Rebased to master. Should be good to go now.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428361#comment-15428361
]
ASF GitHub Bot commented on FLINK-4273:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428349#comment-15428349
]
ASF GitHub Bot commented on FLINK-4402:
---
Github user nssalian commented on the issue
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2382
Thank you @rmetzger and @zentol
---
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 a
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428300#comment-15428300
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75496232
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java
---
@@ -129,6 +141,23 @@ public Time getWindowTime() {
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428296#comment-15428296
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75495772
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/State.java ---
@@ -38,10 +40,16 @@
private final String name;
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428294#comment-15428294
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75495601
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java
---
@@ -202,7 +203,8 @@ public void prune(long pruningTimes
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428290#comment-15428290
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75495021
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -300,17 +311,21 @@ public int hashCode() {
Robert Metzger created FLINK-4432:
-
Summary: (YARN) JobManager web port is no longer available in
configuration page in web interface
Key: FLINK-4432
URL: https://issues.apache.org/jira/browse/FLINK-4432
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75494363
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -133,9 +134,13 @@ public void addState(final State state) {
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428286#comment-15428286
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2367#discussion_r75491739
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -243,8 +252,7 @@ public int hashCode() {
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-4402.
---
Resolution: Resolved
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/3be9a285
[
https://issues.apache.org/jira/browse/FLINK-4402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15428275#comment-15428275
]
ASF GitHub Bot commented on FLINK-4402:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2382
---
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
1 - 100 of 304 matches
Mail list logo
