Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1079#issuecomment-139129112
@jamescao Yes, I think the part (including tests) related with
`HCatInputFormat` should be removed.
---
If your project is set up for it, you can reply to this email
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1112#issuecomment-139127959
Looks good to merge.
---
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 thi
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14738247#comment-14738247
]
ASF GitHub Bot commented on FLINK-2645:
---
Github user chiwanpark commented on the pul
Henry Saputra created FLINK-2650:
Summary: Fix broken link in the Table API doc
Key: FLINK-2650
URL: https://issues.apache.org/jira/browse/FLINK-2650
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14738098#comment-14738098
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user HuangWHWHW commented on the pul
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1077#issuecomment-139106600
Hi, sorry for reply late.
The file `SocketTextStreamFunction.java` has been changed recently.
Can you update the code and squash your commits into one for the C
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14738091#comment-14738091
]
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-139104928
I removed the toString() method and change the lock to `private final
SerializableObject lock`.
---
If your project is set up for it, you can reply to this email and
Github user HuangWHWHW commented on the pull request:
https://github.com/apache/flink/pull/1030#issuecomment-139101747
Sorry for careless.
I forget to change the git global user.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-2536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14738058#comment-14738058
]
ASF GitHub Bot commented on FLINK-2536:
---
Github user HuangWHWHW commented on the pul
Github user jamescao commented on the pull request:
https://github.com/apache/flink/pull/1064#issuecomment-139085352
@twalthr : sorry I missed your message, this pr is reopened in
https://github.com/apache/flink/pull/1079
I didn't check this closed page. I should have continued
Github user jamescao commented on the pull request:
https://github.com/apache/flink/pull/1079#issuecomment-139079494
@chiwanpark
Thanks for all you comments! I will fix them in subsequent commits. There
is also a bug fix for HcatInputformat in this pr, do you think that part shoul
Ted Yu created FLINK-2649:
-
Summary: Potential resource leak in JarHelper#unjar()
Key: FLINK-2649
URL: https://issues.apache.org/jira/browse/FLINK-2649
Project: Flink
Issue Type: Bug
Repo
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737528#comment-14737528
]
Aljoscha Krettek commented on FLINK-2600:
-
Sure :D
> Failing ElasticsearchSinkITC
[
https://issues.apache.org/jira/browse/FLINK-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2619.
---
> Some Scala Tests not being executed by Maven
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2619.
-
Resolution: Fixed
Fix Version/s: 0.10
Fixed via c9edd9a88ab20bc314470fb3eb7da4c643dd7d57 an
[
https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2003.
---
> Building on some encrypted filesystems leads to "File name too long" error
> ---
[
https://issues.apache.org/jira/browse/FLINK-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2638.
---
> Add @SafeVarargs to the environment.fromElements(...) method
> -
[
https://issues.apache.org/jira/browse/FLINK-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2638.
-
Resolution: Fixed
Fixed via d0502e4fb9338c6ed44a2c0a925aa2f60ebeb7f2
> Add @SafeVarargs to the en
[
https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737342#comment-14737342
]
ASF GitHub Bot commented on FLINK-2003:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2648.
-
Resolution: Fixed
Assignee: Stephan Ewen
Fix Version/s: 0.10
Fixed via 361947d6c54
[
https://issues.apache.org/jira/browse/FLINK-2648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-2648.
---
> CombineTaskTest.testCancelCombineTaskSorting
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737340#comment-14737340
]
ASF GitHub Bot commented on FLINK-2619:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737341#comment-14737341
]
ASF GitHub Bot commented on FLINK-2638:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-2003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-2003.
-
Resolution: Fixed
Assignee: Theodore Vasiloudis
Fix Version/s: 0.10
Documentation
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1103
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1109
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1100
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737285#comment-14737285
]
ASF GitHub Bot commented on FLINK-2645:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1112#issuecomment-138988378
Looks good, modulo the one inline comment.
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737280#comment-14737280
]
ASF GitHub Bot commented on FLINK-2645:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1112#discussion_r39073704
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java
---
@@ -922,19 +922,18 @@ public boolean updateState(Ta
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737204#comment-14737204
]
ASF GitHub Bot commented on FLINK-2645:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1112#issuecomment-138976625
Thanks for the review. I've since extended this pull request. Upon failure
to deserialize the final task accumulator results, we now fail `Executions` and
forward the Except
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1097#discussion_r39068191
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/utils/RequiredParameter.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licensed to the Apache Softw
[
https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737196#comment-14737196
]
ASF GitHub Bot commented on FLINK-2017:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737193#comment-14737193
]
Sachin Goel commented on FLINK-2600:
But this is a test stability issue though. Maybe
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737182#comment-14737182
]
Aljoscha Krettek commented on FLINK-2600:
-
I don't think that's anything that we c
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737166#comment-14737166
]
Sachin Goel edited comment on FLINK-2600 at 9/9/15 4:47 PM:
Ob
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737168#comment-14737168
]
Matthias J. Sax commented on FLINK-2586:
Thanks for reporting. Can be resolved aft
[
https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel reopened FLINK-2600:
Observed a failure just now: Here's the build log:
https://s3.amazonaws.com/archive.travis-ci.org/jobs/
[
https://issues.apache.org/jira/browse/FLINK-2586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737135#comment-14737135
]
Sachin Goel commented on FLINK-2586:
Observed the same failure albeit on a different t
[
https://issues.apache.org/jira/browse/FLINK-2612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sachin Goel updated FLINK-2612:
---
Description:
{{testTaskManagerRegistrationAtReelectedLeader}} fails with the following
exception:
{co
Sachin Goel created FLINK-2648:
--
Summary: CombineTaskTest.testCancelCombineTaskSorting
Key: FLINK-2648
URL: https://issues.apache.org/jira/browse/FLINK-2648
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737082#comment-14737082
]
ASF GitHub Bot commented on FLINK-2408:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/941#issuecomment-138956199
Do this PR need modification? It seems good to merge.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. I
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737071#comment-14737071
]
ASF GitHub Bot commented on FLINK-1737:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1078#issuecomment-138954598
Looks good to me except some minor issues (including things @rmetzger
said). But there is no JIRA issue covered this PR. We should create JIRA issue
first.
---
If y
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1078#discussion_r39059950
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/DenseVector.scala
---
@@ -102,6 +102,38 @@ case class DenseVector(
}
[
https://issues.apache.org/jira/browse/FLINK-2595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2595:
--
Description:
Here is related code:
{code}
try {
new JarF
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737064#comment-14737064
]
ASF GitHub Bot commented on FLINK-1737:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737054#comment-14737054
]
ASF GitHub Bot commented on FLINK-2645:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1112#issuecomment-138950226
LGTM
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled a
Stephan Ewen created FLINK-2647:
---
Summary: Stream operators need to differentiate between close()
and dispose()
Key: FLINK-2647
URL: https://issues.apache.org/jira/browse/FLINK-2647
Project: Flink
Stephan Ewen created FLINK-2646:
---
Summary: Rich functions should provide a method
"closeAfterFailure()"
Key: FLINK-2646
URL: https://issues.apache.org/jira/browse/FLINK-2646
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737012#comment-14737012
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14737013#comment-14737013
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/605
---
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 enabl
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1094
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1090#issuecomment-138942223
Should we bundle the utility into a JAR like the other examples? If so, we
need to adjust the `pom.xml` file in flink-examples.
---
If your project is set up for it, you ca
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-2493.
Resolution: Implemented
Fix Version/s: 0.10
Fixed by bbddda776a21124d665ade95dfbf7642b81988fc
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1090#issuecomment-138940821
Yes, this failed check is unrelated to your changes.
---
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 fhueske commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-138939760
Thanks @tammymendt for the PR and the last fixes. Sorry that it took us so
long to merge it :-/
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736999#comment-14736999
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved FLINK-1297.
---
Resolution: Implemented
Assignee: Tamara (was: Alexander Alexandrov)
Implemente
[
https://issues.apache.org/jira/browse/FLINK-1297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736985#comment-14736985
]
ASF GitHub Bot commented on FLINK-1297:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/605#issuecomment-138937490
Looks good. Merging this 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 your project does not have th
[
https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736955#comment-14736955
]
Hilmi Yildirim commented on FLINK-2624:
---
I have implemented checkpointing for Rabbit
[
https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736937#comment-14736937
]
ASF GitHub Bot commented on FLINK-2617:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/#issuecomment-138928137
+1 Looks good to merge
---
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 thi
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1083#issuecomment-138926576
Aha. I had only searched Jira for any existing work on this. Anyways, I'm
assuming you'll be rebasing the same PR after session management is in. I'm
quite intere
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736929#comment-14736929
]
ASF GitHub Bot commented on FLINK-1730:
---
Github user sachingoel0101 commented on the
[
https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-1674.
Resolution: Fixed
Fix Version/s: 0.10
Tests implemented with 0a005700dd5ad1ed7bb8f3c7f9079f03
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1103#issuecomment-138922680
Testing my patch, then merging 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 projec
[
https://issues.apache.org/jira/browse/FLINK-2493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736922#comment-14736922
]
ASF GitHub Bot commented on FLINK-2493:
---
Github user fhueske commented on the pull r
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/671#issuecomment-138923637
I actually like this. Can you rebase to master, and maybe change one name:
`CheckpointCommittingTask` --> `CheckpointCompleteNotifiyee` or
`CheckpointComplete
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1094#issuecomment-138923580
@chenliang613, thanks for the PR!
I'll check it and merge it if everything is fine.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736920#comment-14736920
]
ASF GitHub Bot commented on FLINK-1730:
---
Github user mxm commented on the pull reque
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1083#issuecomment-138923111
@sachingoel0101 I've opened a pull request some time ago to backtrack
intermediate results on the network layer and then "backtrack" them during
scheduling time: #640. At th
[
https://issues.apache.org/jira/browse/FLINK-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736918#comment-14736918
]
ASF GitHub Bot commented on FLINK-2619:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736914#comment-14736914
]
Fabian Hueske commented on FLINK-1674:
--
[~vimalk78] It's all good. Thanks!
> Add tes
[
https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736912#comment-14736912
]
ASF GitHub Bot commented on FLINK-1674:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1091
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736904#comment-14736904
]
ASF GitHub Bot commented on FLINK-1730:
---
Github user sachingoel0101 commented on the
Github user sachingoel0101 commented on the pull request:
https://github.com/apache/flink/pull/1083#issuecomment-138921118
Great! One step closer. Would love to see this feature soon. :)
---
If your project is set up for it, you can reply to this email and have your
reply appear on Gi
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1083#issuecomment-138918787
@sachingoel0101 No need to apologize. It is just that you probably worked
for quite a bit on this, and it is sad that this work is lost.
@mxm is merging the
[
https://issues.apache.org/jira/browse/FLINK-1730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736901#comment-14736901
]
ASF GitHub Bot commented on FLINK-1730:
---
Github user StephanEwen commented on the pu
[
https://issues.apache.org/jira/browse/FLINK-2638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736890#comment-14736890
]
ASF GitHub Bot commented on FLINK-2638:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1109#issuecomment-138918211
Yes, has been bugging me as well. Will merge this then...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as w
[
https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736876#comment-14736876
]
Vimal commented on FLINK-1674:
--
thanks!
does it still need to be assigned to me
> Add test w
[
https://issues.apache.org/jira/browse/FLINK-1745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736856#comment-14736856
]
ASF GitHub Bot commented on FLINK-1745:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/696#issuecomment-138912233
Update the implementation to use priority queue.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If you
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/754#issuecomment-138910462
Why not add it now and have one more step done towards batch scheduling?
Wouldn't it be duplicate work if this PR is put aside now and the internals
change?
B
[
https://issues.apache.org/jira/browse/FLINK-2119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736844#comment-14736844
]
ASF GitHub Bot commented on FLINK-2119:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736836#comment-14736836
]
ASF GitHub Bot commented on FLINK-2645:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1112
[FLINK-2645][jobmanager] forward exceptions when merging final accumlator
results
- fix forwarding
- add test case
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14736835#comment-14736835
]
ASF GitHub Bot commented on FLINK-1674:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1091#issuecomment-138908967
@vimalk78, thanks for the PR!
Looks good to me, will merge this.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
Maximilian Michels created FLINK-2645:
-
Summary: Accumulator exceptions are not properly forwarded
Key: FLINK-2645
URL: https://issues.apache.org/jira/browse/FLINK-2645
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-2645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels reassigned FLINK-2645:
-
Assignee: Maximilian Michels
> Accumulator exceptions are not properly forwarded
1 - 100 of 271 matches
Mail list logo
