[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123471#comment-15123471
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on the pull request:
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-176754489
You identified the right classes and methods for the fix, but the place
within the method is not correct. Let me explain the issue.
In the common case as for
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1562
Enhance Partitioned State and use it in WindowOperator
The commits in this are self-contained. The first one enhances the
partitioned state such that it can be used by the WindowOperator. The
Stephan Ewen created FLINK-3303:
---
Summary: Move all non-batch specific classes in flink-java to
flink-core
Key: FLINK-3303
URL: https://issues.apache.org/jira/browse/FLINK-3303
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123577#comment-15123577
]
Jeyhun Karimov commented on FLINK-1509:
---
I will give a try to this problem
> Streaming Group Reduce
Sebastian Klemke created FLINK-3304:
---
Summary: AvroOutputFormat.setSchema() doesn't work in yarn-cluster
mode
Key: FLINK-3304
URL: https://issues.apache.org/jira/browse/FLINK-3304
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2184:
Assignee: Fabian Hueske
> Cannot get last element with maxBy/minBy
>
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2184:
-
Assignee: Jeyhun Karimov
> Cannot get last element with maxBy/minBy
>
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-2184:
-
Assignee: (was: Fabian Hueske)
> Cannot get last element with maxBy/minBy
>
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123473#comment-15123473
]
Fabian Hueske commented on FLINK-2184:
--
Hi [~jeyhunkarimov], sure. Thanks for picking the issue up.
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123469#comment-15123469
]
Jeyhun Karimov commented on FLINK-2184:
---
If no one is working on this issue, I can give a try
>
[
https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123589#comment-15123589
]
Greg Hogan commented on FLINK-3302:
---
Hi, Pieter! I had filed FLINK-3263 about a week ago with a similar
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123348#comment-15123348
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123401#comment-15123401
]
ASF GitHub Bot commented on FLINK-3300:
---
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1561#issuecomment-176723782
Test failures unrelated to the changes. Yarn tests pass in this build:
https://travis-ci.org/apache/flink/jobs/105645193
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123438#comment-15123438
]
ASF GitHub Bot commented on FLINK-3300:
---
Github user tillrohrmann commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1561#issuecomment-176737933
As far as I can tell the changes look good to me. Good work @mxm :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123338#comment-15123338
]
ASF GitHub Bot commented on FLINK-3300:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1561
[FLINK-3300] fix concurrency bug in YarnJobManager
Adds message passing between Hadoop's async resource manager client and
the YarnJobManager actor.
It helps to view the diff with ignored
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-176693988
Updated the PR
---
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
Github user stefanobaghino commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-176700143
It works, I'll be pushing the code in a few minutes. If everything looks
good I can move on to the other examples. Thank you all the precious feedback
provided
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123359#comment-15123359
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123326#comment-15123326
]
Stephan Ewen commented on FLINK-3300:
-
+1 for the actor messages. That would be the cleanest approach!
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123463#comment-15123463
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123461#comment-15123461
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1553#discussion_r51259067
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java
---
@@ -102,36 +107,72 @@ public
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1553#discussion_r51259080
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java
---
@@ -66,30 +70,62 @@ public SingleInputPlanNode
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123391#comment-15123391
]
Jeyhun Karimov commented on FLINK-3089:
---
If nobody works on this issue, I would like to give a try.
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123416#comment-15123416
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user twalthr commented on the pull request:
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-176727999
+1 for 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
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov updated FLINK-3089:
--
Comment: was deleted
(was: If nobody works on this issue, I would like to give a try.)
>
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123267#comment-15123267
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123279#comment-15123279
]
Till Rohrmann commented on FLINK-2678:
--
It should work for arbitrary dimensional arrays and not only
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123289#comment-15123289
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user fhueske commented on the pull request:
Pieter Hameete created FLINK-3302:
-
Summary: Save Taskmanager Metrics per Job
Key: FLINK-3302
URL: https://issues.apache.org/jira/browse/FLINK-3302
Project: Flink
Issue Type: Wish
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1536#issuecomment-176675459
Thanks for the update!
+1 using case classes in the Scala example. Can you also check if we can
directly read the CSV file into the case classes (not sure if that
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123294#comment-15123294
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user twalthr commented on the pull request:
Github user twalthr commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-176676353
Except for the comments it looks very good.
---
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
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/1559#discussion_r51241130
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala
---
@@ -41,21 +44,13 @@ class
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123284#comment-15123284
]
Maximilian Michels commented on FLINK-3300:
---
Thanks for reporting. Quick fix would be to just
Github user ramkrish86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/1560#discussion_r51240892
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java
---
@@ -177,21 +177,19
[
https://issues.apache.org/jira/browse/FLINK-3301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123251#comment-15123251
]
ASF GitHub Bot commented on FLINK-3301:
---
Github user ramkrish86 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123260#comment-15123260
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user twalthr commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123314#comment-15123314
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1559#discussion_r51245443
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/java/table/JavaBatchTranslator.scala
---
@@ -41,21 +44,13 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1559#discussion_r51245496
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetRel.scala
---
@@ -0,0 +1,33 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123269#comment-15123269
]
Till Rohrmann commented on FLINK-3300:
--
+1 for actor messages
> Concurrency Bug in Yarn JobManager
>
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123316#comment-15123316
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske commented on a diff in the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1486#issuecomment-176839542
@ajaybhat Do you have any updates on this PR?
---
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-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123648#comment-15123648
]
ASF GitHub Bot commented on FLINK-2445:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123693#comment-15123693
]
ASF GitHub Bot commented on FLINK-2522:
---
Github user aljoscha commented on the pull request:
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1523#issuecomment-176858076
New commit which passes FLINK_SSH_OPTS to pdsh.
Also, some sample timings starting and stopping an AWS cluster of various
sizes, with ssh and pdsh comparable
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123744#comment-15123744
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123718#comment-15123718
]
ASF GitHub Bot commented on FLINK-3161:
---
Github user greghogan commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned FLINK-1509:
-
Assignee: Jeyhun Karimov
> Streaming Group Reduce Combiner
>
[
https://issues.apache.org/jira/browse/FLINK-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeyhun Karimov reassigned FLINK-2390:
-
Assignee: Jeyhun Karimov
> Replace iteration timeout with algorithm for detecting
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1500#issuecomment-176839108
@tillrohrmann do you have any comments on @chiwanpark's updates?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-176839873
@mjsax What is the status on this PR? Can it be closed since the feature in
Storm will be implemented another way?
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123686#comment-15123686
]
ASF GitHub Bot commented on FLINK-3150:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1446#issuecomment-176845053
What's the state of this? Who do we need it? Is it still valid with the
(planned) reworking of Yarn/Mesos integration?
---
If your project is set up for it, you can
Github user greghogan commented on the pull request:
https://github.com/apache/flink/pull/1523#issuecomment-176853645
New commit that passes FLINK_SSH_OPTS to pdsh.
64 x c4.large
0m4.210s0m4.181s
0m4.203s0m4.283s
0m4.262s0m4.196s
0m13.969s
[
https://issues.apache.org/jira/browse/FLINK-2935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123644#comment-15123644
]
ASF GitHub Bot commented on FLINK-2935:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1491#issuecomment-176839361
@ajaybhat Do you have any updates on this PR?
---
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-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123646#comment-15123646
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1429#issuecomment-176845490
@twalthr Is this in the calcite branch now? Can this PR then be closed?
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Stephan Ewen created FLINK-3305:
---
Summary: Remove JavaKaffee serializer util
Key: FLINK-3305
URL: https://issues.apache.org/jira/browse/FLINK-3305
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123651#comment-15123651
]
ASF GitHub Bot commented on FLINK-1870:
---
Github user aljoscha commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1561#issuecomment-176838676
Thanks for the review @tillrohrmann. Going to merge this soon as it is a
release critical fix.
---
If your project is set up for it, you can reply to this email and have
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1514#issuecomment-176838607
Are there any objections to merging this? I think the arguments on mailing
list/jira sounded reasonable and you probably know this part of Flink best,
@vasia.
---
[
https://issues.apache.org/jira/browse/FLINK-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123641#comment-15123641
]
ASF GitHub Bot commented on FLINK-3300:
---
Github user mxm commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123689#comment-15123689
]
ASF GitHub Bot commented on FLINK-3097:
---
Github user aljoscha commented on the pull request:
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1412#issuecomment-176847731
@nikste Any updates on 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
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-176869415
Hi @wangyangjun,
sorry for the long wait but I think we can get this PR in after some
modifications. I'd like to change the API a bit to separate it from the other
[
https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123809#comment-15123809
]
ASF GitHub Bot commented on FLINK-3109:
---
Github user aljoscha commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123857#comment-15123857
]
Pieter Hameete commented on FLINK-3302:
---
Hi Greg,
nice, I did not see your ticket, but good to see
[
https://issues.apache.org/jira/browse/FLINK-3302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123857#comment-15123857
]
Pieter Hameete edited comment on FLINK-3302 at 1/29/16 5:44 PM:
Hi Greg,
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1559#issuecomment-176891835
Yes, @fhueske , i saw you rewrite the DataSetRelNodes on scala, i would
continue my work based on your PR.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123896#comment-15123896
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user ChengXiangLi commented on the pull request:
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/1556#issuecomment-176894471
Thanks for the comments, i would create a new PR based on Fabian's work.
Besides, @twalthr , what's the scope of your code generation, previous Table
API code
[
https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124398#comment-15124398
]
ASF GitHub Bot commented on FLINK-3109:
---
Github user wangyangjun commented on the pull request:
Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-177007794
Hello @aljoscha ,
As I mentioned in last comment, I will reimplement it with [Guava
[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124736#comment-15124736
]
ASF GitHub Bot commented on FLINK-1870:
---
Github user mjsax commented on the pull request:
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1563#issuecomment-177088061
With the `RollingHDFSSink` this functionality is not needed any more and as
you suggested apparently was a misleading implmentation anyway. I like your not
to the
Márton Balassi created FLINK-3307:
-
Summary: RMQSourceTest failure
Key: FLINK-3307
URL: https://issues.apache.org/jira/browse/FLINK-3307
Project: Flink
Issue Type: Bug
Components:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1480
---
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-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124797#comment-15124797
]
Chesnay Schepler commented on FLINK-3307:
-
i would assume that FLINK-3301 is related.
>
Github user mjsax commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-177069344
I would like to keep this open, until
[FLINK-2721](https://issues.apache.org/jira/browse/FLINK-2721) is merged. To
make sure, we do not need this -- for this case, we can
Github user ramkrish86 commented on the pull request:
https://github.com/apache/flink/pull/1553#issuecomment-177080713
Thank you very much for the feedback. Let me try to understand this thing
better and update the PR sooner. I will reach out here in case of any questions
or doubts
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124790#comment-15124790
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user mbalassi commented on the pull request:
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-177094172
I think exposing the feature through the API similarly to the way join
strategies are exposed is the way to properly make this feature available for
users. I would
[
https://issues.apache.org/jira/browse/FLINK-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124755#comment-15124755
]
ASF GitHub Bot commented on FLINK-3179:
---
Github user ramkrish86 commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124777#comment-15124777
]
ASF GitHub Bot commented on FLINK-3296:
---
Github user mbalassi commented on the pull request:
Github user fhueske closed the pull request at:
https://github.com/apache/flink/pull/1559
---
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-3225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124250#comment-15124250
]
ASF GitHub Bot commented on FLINK-3225:
---
Github user fhueske closed the pull request at:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/1564
[FLINK-3160] [web-dashboard] Aggregate operator statistics by TaskManager
Adds a new per-job tab displaying task statistics aggregated by TaskManager
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124267#comment-15124267
]
ASF GitHub Bot commented on FLINK-3160:
---
GitHub user greghogan opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124273#comment-15124273
]
Greg Hogan commented on FLINK-3160:
---
This commit I just pushed does use two tabs called "Tasks"
Github user wangyangjun commented on the pull request:
https://github.com/apache/flink/pull/1527#issuecomment-176912402
Hello, @aljoscha ,
Thanks for your comment and suggestion. I will update the API. During my
benchmark tests of timeJoin, the feature of this implementation is
[
https://issues.apache.org/jira/browse/FLINK-3109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15123979#comment-15123979
]
ASF GitHub Bot commented on FLINK-3109:
---
Github user wangyangjun commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124194#comment-15124194
]
ASF GitHub Bot commented on FLINK-3296:
---
GitHub user rmetzger opened a pull request:
1 - 100 of 103 matches
Mail list logo
