[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448024#comment-15448024
]
Jark Wu edited comment on FLINK-4469 at 8/30/16 4:51 AM:
-
Agree with that. Using a
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448024#comment-15448024
]
Jark Wu commented on FLINK-4469:
Agree with that. Using a collector will be more user-friendly and can
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2305
Hi @aljoscha @StephanEwen , this issue has been blocked for some days. It
would be great, if you can have a look again ?
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448012#comment-15448012
]
ASF GitHub Bot commented on FLINK-4271:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15448004#comment-15448004
]
ramkrishna.s.vasudevan commented on FLINK-4484:
---
I can help out in the sub tasks too,
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447911#comment-15447911
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on the issue:
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2400
@mxm , I have created the FLINK-4505 for TaskExecutorFactory issue. As you
mentioned, it should be an abstract class and provide an abstract method maybe
called
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447907#comment-15447907
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user wangzhijiang999 commented on the issue:
Github user wangzhijiang999 commented on the issue:
https://github.com/apache/flink/pull/2400
@mxm, I already push my changes and solve the conflicts based on the new
flip-6 branch.
---
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-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447903#comment-15447903
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2102
Thanks @twalthr . This issue is more complex than I expected before. I will
try to update this PR in next days.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447770#comment-15447770
]
Wenlong Lyu commented on FLINK-4375:
the definition will be split into special interaction
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wenlong Lyu closed FLINK-4375.
--
Resolution: Invalid
> Introduce rpc protocols implemented by job manager
>
[
https://issues.apache.org/jira/browse/FLINK-2247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447477#comment-15447477
]
Neelesh Srinivas Salian commented on FLINK-2247:
Hi [~tvas], please let me know if this is
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447356#comment-15447356
]
Neelesh Srinivas Salian commented on FLINK-3999:
Thank you [~ggevay]. Will post a PR this
[
https://issues.apache.org/jira/browse/FLINK-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446747#comment-15446747
]
ASF GitHub Bot commented on FLINK-4245:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2418
Well this won't be pretty. The problem lies with the "name" check we have
to do since we mustn't modify the underlying map, since it belongs to the
metric groups.
As you showed in your
[
https://issues.apache.org/jira/browse/FLINK-4531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4531.
---
> Thread.stop() is deprecated
> ---
>
> Key: FLINK-4531
>
[
https://issues.apache.org/jira/browse/FLINK-4531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-4531.
-
Resolution: Won't Fix
> Thread.stop() is deprecated
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446540#comment-15446540
]
ASF GitHub Bot commented on FLINK-4528:
---
Github user tillrohrmann commented on the issue:
Ted Yu created FLINK-4531:
-
Summary: Thread.stop() is deprecated
Key: FLINK-4531
URL: https://issues.apache.org/jira/browse/FLINK-4531
Project: Flink
Issue Type: Bug
Reporter: Ted Yu
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446448#comment-15446448
]
ASF GitHub Bot commented on FLINK-4528:
---
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/2436#discussion_r76645756
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutorToResourceManagerConnection.java
---
@@ -93,22 +94,24 @@
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446425#comment-15446425
]
ASF GitHub Bot commented on FLINK-4528:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2436
I am not sure I agree with this change.
There are cases when another class logically belongs to the RPC endpoint
(such as a connection utility). Being able to access the RPC execution
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446421#comment-15446421
]
ASF GitHub Bot commented on FLINK-4528:
---
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/2436#discussion_r76643397
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rpc/taskexecutor/TaskExecutorToResourceManagerConnection.java
---
@@ -93,22 +94,24 @@
[
https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446417#comment-15446417
]
ASF GitHub Bot commented on FLINK-3950:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2374
---
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-4361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446392#comment-15446392
]
Till Rohrmann commented on FLINK-4361:
--
I'm not sure whether it's worth the effort to actually
[
https://issues.apache.org/jira/browse/FLINK-4436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-4436:
--
Description:
{code}
DataOutputBuffer dob = new DataOutputBuffer();
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2423
---
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-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446324#comment-15446324
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user gheo21 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-4495.
---
Resolution: Duplicate
Fix Version/s: 1.1.2
1.2.0
Should be
[
https://issues.apache.org/jira/browse/FLINK-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4526.
-
Resolution: Fixed
master: 31c88a564a8eda263aedada0da671357d1a6f524
release-1.1:
[
https://issues.apache.org/jira/browse/FLINK-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-4488.
-
Resolution: Fixed
master: 87114cd2aaf78de2114d1ea4ab7bd2b57494d716
release-1.1:
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-4486.
---
Resolution: Fixed
master: ab1df63c3fd419c23631f3b55b506e6fdf3cb72f
release-1.1:
[
https://issues.apache.org/jira/browse/FLINK-4488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446320#comment-15446320
]
ASF GitHub Bot commented on FLINK-4488:
---
Github user asfgit closed the pull request at:
Github user gheo21 commented on the issue:
https://github.com/apache/flink/pull/2397
@StephanEwen pull request updated, please have a look!
---
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
[
https://issues.apache.org/jira/browse/FLINK-4486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446322#comment-15446322
]
ASF GitHub Bot commented on FLINK-4486:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446321#comment-15446321
]
ASF GitHub Bot commented on FLINK-4526:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2437
---
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 asfgit closed the pull request at:
https://github.com/apache/flink/pull/2419
---
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-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-4525.
---
> Drop the "eager split pre-assignment" code paths
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-4525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-4525.
-
Resolution: Fixed
Fixed via 578e80e3c161601d22760ef2ea0e52e6ae963786
> Drop the "eager split
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446231#comment-15446231
]
Maximilian Michels commented on FLINK-4485:
---
Thanks for the update. That's very important
[
https://issues.apache.org/jira/browse/FLINK-4055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446226#comment-15446226
]
Till Rohrmann commented on FLINK-4055:
--
It happened again:
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446201#comment-15446201
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on the issue:
Till Rohrmann created FLINK-4530:
Summary: Generalize TaskExecutorToResourceManagerConnection to be
reusable
Key: FLINK-4530
URL: https://issues.apache.org/jira/browse/FLINK-4530
Project: Flink
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2315
Thank you so much for your contribution @EronWright! Looking forward to see
the Mesos integration in Flink grow :)
---
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-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446195#comment-15446195
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2315
---
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-4439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446162#comment-15446162
]
ASF GitHub Bot commented on FLINK-4439:
---
Github user gheo21 commented on the issue:
Github user gheo21 commented on the issue:
https://github.com/apache/flink/pull/2397
@StephanEwen I will submit shortly an update then you can take a look.
Thanks!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446154#comment-15446154
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2434
I had comments about introducing an interface for the asynchronous excepts,
other than that and @rmetzger's comment this looks good. I like the addition of
the `TimeProviderTest`. ð
---
If
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446151#comment-15446151
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r76625434
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java
---
@@ -98,7 +99,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446144#comment-15446144
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r76624854
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultTimeServiceProvider.java
---
@@ -28,15 +31,22 @@
*/
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446140#comment-15446140
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r76624448
--- Diff:
flink-streaming-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/testutils/MockRuntimeContext.java
---
[
https://issues.apache.org/jira/browse/FLINK-4485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446104#comment-15446104
]
Niels Basjes commented on FLINK-4485:
-
I didn't change that setting.
In the web UI I see only the last
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446101#comment-15446101
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2315
Fixing the errors and trying to rebase your changes on top of the latest
master 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
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446098#comment-15446098
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user mxm commented on a diff in the pull request:
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/2315#discussion_r76621116
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/ContaineredJobManager.scala
---
@@ -0,0 +1,172 @@
+/*
--- End diff --
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2432
I think a check for the interval to be lower than 5 minutes is sufficient.
Setting the limit to 4.5 min seems to be a bit too strict. You never know if
some advanced users want to cover a very
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446086#comment-15446086
]
ASF GitHub Bot commented on FLINK-4514:
---
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/2432#discussion_r76620194
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
[
https://issues.apache.org/jira/browse/FLINK-4529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446064#comment-15446064
]
ASF GitHub Bot commented on FLINK-4529:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2438
[FLINK-4529] [flip-6] Move TaskExecutor, JobMaster and ResourceManager out
of the rpc package
The TaskExecutor, the JobMaster and the ResourceManager were still
contained in the rpc
[
https://issues.apache.org/jira/browse/FLINK-4527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446061#comment-15446061
]
Ivan Mushketyk commented on FLINK-4527:
---
Hi [~StephanEwen],
Does this mean that accumulators are
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446048#comment-15446048
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2432#discussion_r76617364
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
---
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446044#comment-15446044
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2432
The latest commit sets the check to be less than 5 minutes.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446040#comment-15446040
]
ASF GitHub Bot commented on FLINK-4363:
---
Github user mxm commented on the issue:
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2400
@wangzhijiang999 Could you port your changes to the new flip-6 branch? We
can then go ahead and merge this PR.
---
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-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446003#comment-15446003
]
ASF GitHub Bot commented on FLINK-4526:
---
GitHub user mxm opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15446017#comment-15446017
]
ASF GitHub Bot commented on FLINK-4514:
---
Github user rmetzger commented on the issue:
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2433
Thank you for the fix. Will merge it.
---
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
Till Rohrmann created FLINK-4529:
Summary: Move JobMaster, TaskExecutor and ResourceManager out of
the rpc package
Key: FLINK-4529
URL: https://issues.apache.org/jira/browse/FLINK-4529
Project: Flink
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2433
---
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 mxm opened a pull request:
https://github.com/apache/flink/pull/2437
[FLINK-4526][yarn] remove redundant proxy messages
Merging this with #2423 with #2419.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2031
Hi @mans2singh,
I'm happy to hear that you are interested in contributing the code to Bahir.
You can just fork the bahir-flink repo and create a folder similar to the
existing
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445995#comment-15445995
]
ASF GitHub Bot commented on FLINK-3967:
---
Github user rmetzger commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2102
@wuchong I have added symbols recently. So functions like `TRIM` are now
called correctly. If you like you could update this PR.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-4528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445976#comment-15445976
]
ASF GitHub Bot commented on FLINK-4528:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445978#comment-15445978
]
Robert Metzger commented on FLINK-4496:
---
What's the reasoning behind this change?
> Refactor the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2436
[FLINK-4528] [rpc] Marks main thread execution methods in RpcEndpoint as
protected
The main thread execution methods should not be exposed to the outside
world of the `RpcEndpoint`, because
[
https://issues.apache.org/jira/browse/FLINK-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445974#comment-15445974
]
ASF GitHub Bot commented on FLINK-4068:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445966#comment-15445966
]
ASF GitHub Bot commented on FLINK-4496:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2434#discussion_r76612209
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/DefaultTimeServiceProvider.java
---
@@ -57,4 +67,49 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4420.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 1f17886198eb67c8fdb53b96098ebb812029b3ba.
[
https://issues.apache.org/jira/browse/FLINK-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445958#comment-15445958
]
ASF GitHub Bot commented on FLINK-4420:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2384
---
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-4420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15445933#comment-15445933
]
ASF GitHub Bot commented on FLINK-4420:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2384
Thanks @wuchong. The PR looks good. I will 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
Stephan Ewen created FLINK-4527:
---
Summary: Drop the "flinkAccumulators" from the Execution
Key: FLINK-4527
URL: https://issues.apache.org/jira/browse/FLINK-4527
Project: Flink
Issue Type:
1 - 100 of 207 matches
Mail list logo
