[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429202#comment-15429202
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429201#comment-15429201
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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=15429183#comment-15429183
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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=15429179#comment-15429179
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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=15429144#comment-15429144
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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=15429127#comment-15429127
]
ASF GitHub Bot commented on FLINK-4035:
---
Github user tzulitai commented on a diff in the pull
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)
>
[
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:
[
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
[
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)
>
[
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)
>
[
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
[
https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15429114#comment-15429114
]
Tzu-Li (Gordon) Tai commented on FLINK-3211:
Closing this now ...
Remaining issues will be
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428926#comment-15428926
]
ASF GitHub Bot commented on FLINK-4355:
---
GitHub user StephanEwen opened a pull request:
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
[
https://issues.apache.org/jira/browse/FLINK-4434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428924#comment-15428924
]
ASF GitHub Bot commented on FLINK-4434:
---
GitHub user StephanEwen opened a pull request:
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
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
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=15428909#comment-15428909
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user asfgit closed the pull request at:
[
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
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428884#comment-15428884
]
Stephan Ewen commented on FLINK-4377:
-
[FLINK-4399] should fix this.
>
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428878#comment-15428878
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428877#comment-15428877
]
ASF GitHub Bot commented on FLINK-4431:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428874#comment-15428874
]
Stephan Ewen commented on FLINK-4433:
-
Let's tackle those as independent issues. I think for some of
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428862#comment-15428862
]
Sunny T commented on FLINK-4422:
Okay, Thanks for the clarification.
> Convert all time interval
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428858#comment-15428858
]
Stephan Ewen commented on FLINK-4422:
-
It goes through the entire Flink codebase.
> Convert all time
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428734#comment-15428734
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user mushketyk commented on the issue:
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.
[
https://issues.apache.org/jira/browse/FLINK-3866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428696#comment-15428696
]
ASF GitHub Bot commented on FLINK-3866:
---
Github user mushketyk commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428695#comment-15428695
]
ASF GitHub Bot commented on FLINK-3874:
---
Github user mushketyk commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428681#comment-15428681
]
Maximilian Michels commented on FLINK-3710:
---
Seems like this is not really possible with
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428588#comment-15428588
]
Maximilian Michels commented on FLINK-3710:
---
Thank you for the reminder, I'll look into it.
>
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428584#comment-15428584
]
Scott Kidder commented on FLINK-4341:
-
FYI, I've confirmed that explicitly setting the parallelism on
[
https://issues.apache.org/jira/browse/FLINK-3710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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 ^
[
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}}
[
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}}
[
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
[
https://issues.apache.org/jira/browse/FLINK-4253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428459#comment-15428459
]
ASF GitHub Bot commented on FLINK-4253:
---
Github user ramkrish86 commented on the issue:
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428450#comment-15428450
]
ramkrishna.s.vasudevan commented on FLINK-4417:
---
Thank you. Will start with this early next
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428447#comment-15428447
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428408#comment-15428408
]
Sunny T commented on FLINK-4422:
I have a question: This change has to be done in *flink-core* project or
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
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=15428402#comment-15428402
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
[
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=15428394#comment-15428394
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428395#comment-15428395
]
Sunny T commented on FLINK-4422:
Okay cool. I would like to take this up.
Assigning this to myself.
>
[
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://issues.apache.org/jira/browse/FLINK-4282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428393#comment-15428393
]
ASF GitHub Bot commented on FLINK-4282:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428380#comment-15428380
]
Maximilian Michels commented on FLINK-4426:
---
The {{ZooKeeperSaslClient}} is not provided with
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=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=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
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428300#comment-15428300
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a diff in the pull
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=15428296#comment-15428296
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a diff in the pull
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=15428294#comment-15428294
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15428290#comment-15428290
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a diff in the pull
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=15428286#comment-15428286
]
ASF GitHub Bot commented on FLINK-3703:
---
Github user tillrohrmann commented on a diff in the pull
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=15428275#comment-15428275
]
ASF GitHub Bot commented on FLINK-4402:
---
Github user asfgit closed the pull request at:
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
1 - 100 of 305 matches
Mail list logo
