[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704402#comment-14704402
]
Suminda Dharmasena commented on FLINK-2366:
---
Looks good. Once this gets merged w
[
https://issues.apache.org/jira/browse/FLINK-2468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reopened FLINK-2468:
Observed another failure.
https://travis-ci.org/apache/flink/jobs/76396571
> StreamCheckpointingITCase
[
https://issues.apache.org/jira/browse/FLINK-2549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704244#comment-14704244
]
Chengxiang Li commented on FLINK-2549:
--
The basic idea of implementation is as follow
Chengxiang Li created FLINK-2549:
Summary: Add topK operator for DataSet
Key: FLINK-2549
URL: https://issues.apache.org/jira/browse/FLINK-2549
Project: Flink
Issue Type: New Feature
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132871675
Was there a specific reason to not generate fresh environments in the first
place? Or was it just to minimize object creations?
Here's what I propose though: S
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704229#comment-14704229
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704214#comment-14704214
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user ChengXiangLi commented on the p
Github user ChengXiangLi commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-132864761
Thanks for the detail explanation, @tillrohrmann . As the owner of this
issue, make it work correctly and efficiently is my top desire, so i would
never say no to a
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14704151#comment-14704151
]
ASF GitHub Bot commented on FLINK-2540:
---
GitHub user uce opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/1036
[FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union
inputs
The DataExchangeMode of union nodes was not respected when translating an
OptimizedPlan to a JobGraph. This could resu
[
https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703841#comment-14703841
]
Chesnay Schepler edited comment on FLINK-2541 at 8/19/15 10:20 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-2541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703841#comment-14703841
]
Chesnay Schepler commented on FLINK-2541:
-
I did some digging and found the follow
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703445#comment-14703445
]
Min Jiang commented on FLINK-2089:
--
I re-ran today and directed to a result log file. On
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703425#comment-14703425
]
Min Jiang commented on FLINK-2089:
--
I re-ran today and directed to a result log file. On
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703423#comment-14703423
]
Gabor Gevay commented on FLINK-2548:
{quote}
Actually, the second co-group is not a re
[
https://issues.apache.org/jira/browse/FLINK-2448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703405#comment-14703405
]
ASF GitHub Bot commented on FLINK-2448:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1031#issuecomment-132704210
A call to clear cache files does not hurt, but let's fix the
MultipleProgramsTest base to produce fresh ExecutionEnvironments in its
factory, rather than repeatedly
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703401#comment-14703401
]
Stephan Ewen commented on FLINK-2548:
-
I like the idea of improving this, but it is pr
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/949#issuecomment-132692640
Sorry for the late review @ChengXiangLi. I finished it now and the PR looks
really good.
There is only one thing I would like to change before merging it. T
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703347#comment-14703347
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-2548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703337#comment-14703337
]
Stephan Ewen commented on FLINK-2548:
-
Actually, the second co-group is not a real co-
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-2398.
---
Resolution: Fixed
> Decouple StreamGraph Building from the API
> -
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-2398:
Fix Version/s: 0.10
> Decouple StreamGraph Building from the API
> -
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reopened FLINK-2398:
-
Reopening to change "Fix Versions"
> Decouple StreamGraph Building from the API
> ---
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-2398.
---
Resolution: Fixed
Implemented in bac21bf5d77c8e15c608ecbf006d29e7af1dd68a
> Decouple StreamGr
[
https://issues.apache.org/jira/browse/FLINK-2514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-2514.
---
Resolution: Fixed
Fixed in bac21bf5d77c8e15c608ecbf006d29e7af1dd68a
> Local and Remote enviro
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703318#comment-14703318
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user aljoscha commented on the pull
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/988
---
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 ena
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703319#comment-14703319
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user aljoscha closed the pull reques
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-132689802
Manually merged
---
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 featur
Gabor Gevay created FLINK-2548:
--
Summary: VertexCentricIteration should avoid doing a coGroup with
the edges and the solution set
Key: FLINK-2548
URL: https://issues.apache.org/jira/browse/FLINK-2548
Pro
[
https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703303#comment-14703303
]
Aljoscha Krettek commented on FLINK-2506:
-
OK, bad news first: I got it to work. I
[
https://issues.apache.org/jira/browse/FLINK-1901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703211#comment-14703211
]
ASF GitHub Bot commented on FLINK-1901:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/949#discussion_r37429899
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/operators/util/PoissonSampler.java
---
@@ -0,0 +1,109 @@
+/*
+ * Licensed to the A
[
https://issues.apache.org/jira/browse/FLINK-2540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703114#comment-14703114
]
Ufuk Celebi commented on FLINK-2540:
Debugging this. It is not a bug in the local buff
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-132622278
I think this looks reasonable.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703108#comment-14703108
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user StephanEwen commented on the pu
Andra Lungu created FLINK-2546:
--
Summary: The webclient does not allow users to save the execution
plan
Key: FLINK-2546
URL: https://issues.apache.org/jira/browse/FLINK-2546
Project: Flink
Issu
Stephan Ewen created FLINK-2547:
---
Summary: Provide Cluster Status Info
Key: FLINK-2547
URL: https://issues.apache.org/jira/browse/FLINK-2547
Project: Flink
Issue Type: Sub-task
Compon
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703065#comment-14703065
]
Ufuk Celebi commented on FLINK-2089:
At the moment, the only way I can reproduce a sim
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703063#comment-14703063
]
Ufuk Celebi commented on FLINK-2089:
Can you send me the complete logs? The email addr
[
https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703057#comment-14703057
]
Stephan Ewen commented on FLINK-2528:
-
I have seen before that the canceling tests are
[
https://issues.apache.org/jira/browse/FLINK-2506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703055#comment-14703055
]
Aljoscha Krettek commented on FLINK-2506:
-
I started looking into this. I'm curren
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703052#comment-14703052
]
Till Rohrmann commented on FLINK-2366:
--
Great to hear [~sirinath19...@gmail.com] :-)
[
https://issues.apache.org/jira/browse/FLINK-2286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-2286.
-
Resolution: Fixed
Fix Version/s: 0.10
Via 143ec4f & 67087de.
> Window ParallelMerge someti
[
https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel updated FLINK-2528:
---
Summary: DriverTestBase tests fail spuriously (was: MatchTaskTest failure)
> DriverTestBase tests fai
[
https://issues.apache.org/jira/browse/FLINK-2528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14703015#comment-14703015
]
Sachin Goel commented on FLINK-2528:
Three failures so far. Always due to TaskCancelTh
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702989#comment-14702989
]
Suminda Dharmasena edited comment on FLINK-2366 at 8/19/15 1:17 PM:
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702989#comment-14702989
]
Suminda Dharmasena commented on FLINK-2366:
---
If you can give a simple SPI to cod
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702981#comment-14702981
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-132585797
I also updated the documentation to reflect the changes in shipping
strategies/partitioning.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-2398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702963#comment-14702963
]
ASF GitHub Bot commented on FLINK-2398:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-132582717
What I did is basically adding every operator to the list of "sinks". When
`execute` is called the translation starts from every operator, which is ok,
since an operator
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702892#comment-14702892
]
Till Rohrmann commented on FLINK-2366:
--
Do you mind taking the lead for the alternati
[
https://issues.apache.org/jira/browse/FLINK-2030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702881#comment-14702881
]
ASF GitHub Bot commented on FLINK-2030:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132554412
Updated the title and description for both.
I hope I can get these two in with today's commits since there are no more
issues. I need both of these to finalize
Github user thvasilo commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132552269
Sounds good, just make sure to update the title and description of both PRs
to reflect the current state
---
If your project is set up for it, you can reply to this em
Github user ankurcha commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-132529165
Thanks all for the comments. I am out for MesosCon and work this week. I'll
try to address the feedback and push some changes later this weekend.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702813#comment-14702813
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user ankurcha commented on the pull
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132512002
Okay. Done.
I will modify the `createContinuousHistogram` to use `DataStats` in #1032,
since that is going to be merged after this anyway.
---
If your proje
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702769#comment-14702769
]
Suminda Dharmasena commented on FLINK-2366:
---
Provide SPI so you can just plug th
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702761#comment-14702761
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-132508921
Add tests for retry 10 times and 0.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project do
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1016#issuecomment-132504227
Very nice, Till. I will rebase my changes for FLINK-2354 on this. Your
description in this PR and the docs were already very helpful in this regard.
I got delayed la
[
https://issues.apache.org/jira/browse/FLINK-2291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702742#comment-14702742
]
ASF GitHub Bot commented on FLINK-2291:
---
Github user uce commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-1984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702739#comment-14702739
]
ASF GitHub Bot commented on FLINK-1984:
---
Github user uce commented on the pull reque
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/948#issuecomment-132503290
Sorry for not getting back on time @ankurcha. Robert did a good review in
the meantime. Thanks!
---
If your project is set up for it, you can reply to this email and have yo
Github user PieterJanVanAeken commented on the pull request:
https://github.com/apache/flink/pull/1033#issuecomment-132502725
**EDIT:** I tried the approach above, and technically it works. But when I
create a GraphAlgorithm[Long,Long,Long] in Scala, it does not work on a Java
Graph[L
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702716#comment-14702716
]
Ufuk Celebi commented on FLINK-2089:
Thanks for researching the existing issues and re
[
https://issues.apache.org/jira/browse/FLINK-2089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reopened FLINK-2089:
> "Buffer recycled" IllegalStateException during cancelling
> --
Github user PieterJanVanAeken commented on the pull request:
https://github.com/apache/flink/pull/1033#issuecomment-132495162
Fixed the style issues.
At this point in time, it is not possible to run Scala-based graph
algorithms from inside the Java API. Do you think this woul
[
https://issues.apache.org/jira/browse/FLINK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702709#comment-14702709
]
ASF GitHub Bot commented on FLINK-2379:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/861#issuecomment-132494738
Good! But because there is another issue (FLINK-2379) covered the
column-wise statistics, I think that spliting them would be better.
---
If your project is set up fo
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/861#discussion_r37390659
--- Diff: docs/libs/ml/statistics.md ---
@@ -0,0 +1,98 @@
+---
+mathjax: include
+htmlTitle: FlinkML - Statistics
+title: FlinkML - Statistic
[
https://issues.apache.org/jira/browse/FLINK-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702684#comment-14702684
]
Ufuk Celebi commented on FLINK-2366:
+1 to what Stephan said.
Both Till and I have pu
[
https://issues.apache.org/jira/browse/FLINK-2537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702673#comment-14702673
]
chenliang commented on FLINK-2537:
--
any comments?
i will go ahead to raise a PR for resol
[
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702669#comment-14702669
]
ASF GitHub Bot commented on FLINK-2077:
---
Github user gallenvara commented on the pul
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1035#issuecomment-132482759
Hi, @zentol .Thanks for your review.
Remove two methods : hashCode() and compareTo()
---
If your project is set up for it, you can reply to this email and have yo
[
https://issues.apache.org/jira/browse/FLINK-2077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14702656#comment-14702656
]
ASF GitHub Bot commented on FLINK-2077:
---
Github user zentol commented on the pull re
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1035#issuecomment-132481210
The changes i see are:
* removed hashCode()
* moved makeQualified to a new file as a static method
* reordered the remaining methods in Path
is that ab
80 matches
Mail list logo
