[
https://issues.apache.org/jira/browse/FLINK-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321741#comment-14321741
]
ASF GitHub Bot commented on FLINK-1549:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/397
[FLINK-1549] Adds proper exception handling to YarnJobManager
Adds proper exception handling to ```YarnJobManager``` by catching the
thrown exceptions and sending a
```StopYarnSession(FinalAppl
Till Rohrmann created FLINK-1549:
Summary: Add proper exception handling for YarnJobManager
Key: FLINK-1549
URL: https://issues.apache.org/jira/browse/FLINK-1549
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321725#comment-14321725
]
Till Rohrmann commented on FLINK-1546:
--
Apparently, the specified file is wrong and t
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/395#issuecomment-74393323
+1 for merging asap. It's an improvement on both semantics and performance
prospects for windowing.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1179.
---
Resolution: Fixed
Fix Version/s: 0.9
Thank you Chiwan for implementing this!
The issue
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321676#comment-14321676
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/374
---
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
[
https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321661#comment-14321661
]
Robert Metzger commented on FLINK-1546:
---
Indeed. The uncaught exception doesn't caus
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/394#issuecomment-74388302
No worries, thanks for replying to my concern =)
---
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 p
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321658#comment-14321658
]
ASF GitHub Bot commented on FLINK-1543:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321654#comment-14321654
]
Till Rohrmann commented on FLINK-1547:
--
This is not so surprising. I just looked into
[
https://issues.apache.org/jira/browse/FLINK-1539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1539:
--
Affects Version/s: 0.9
> Runtime context not initialized when running streaming PojoExample
> --
[
https://issues.apache.org/jira/browse/FLINK-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321649#comment-14321649
]
Till Rohrmann commented on FLINK-1546:
--
The problem with the uncaught exception in th
[
https://issues.apache.org/jira/browse/FLINK-1179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321646#comment-14321646
]
ASF GitHub Bot commented on FLINK-1179:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/374#issuecomment-74387918
Merging this now ...
https://github.com/rmetzger/flink/compare/FLINK-1179
---
If your project is set up for it, you can reply to this email and have your
reply appe
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321645#comment-14321645
]
Robert Metzger commented on FLINK-1388:
---
How about {{org.apache.flink.api.java.funct
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321642#comment-14321642
]
Adnan Khan commented on FLINK-1388:
---
Okay thanks, that sounds good.
Also - Where should
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321635#comment-14321635
]
Robert Metzger commented on FLINK-1388:
---
Yes, for private fields you need to make th
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321633#comment-14321633
]
Adnan Khan commented on FLINK-1388:
---
Hey Timo,
So the rules for defining a POJO accordi
[
https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321631#comment-14321631
]
Robert Metzger commented on FLINK-1547:
---
The AM stopped due to: https://issues.apach
[
https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321626#comment-14321626
]
Till Rohrmann commented on FLINK-1547:
--
The default behaviour was changed to stopping
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321608#comment-14321608
]
Till Rohrmann commented on FLINK-1543:
--
You're totally right Henry. I'll be more pati
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321600#comment-14321600
]
ASF GitHub Bot commented on FLINK-1543:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321601#comment-14321601
]
ASF GitHub Bot commented on FLINK-1543:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/394#issuecomment-74385078
@hsaputra, sorry I did not see your comments before I committed the PR. I
started merging it yesterday but it always failed because of some minor issues
on Travis. Th
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/394#discussion_r24716021
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskManagerTest.java
---
@@ -486,7 +489,8 @@ protected void run() {
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321587#comment-14321587
]
Henry Saputra commented on FLINK-1543:
--
This is example I was talking about committer
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321583#comment-14321583
]
ASF GitHub Bot commented on FLINK-1543:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/394#issuecomment-74384108
@tillrohrmann I had concern about style and question about value about
parameter passed.
Would be nice to address those before committing.
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321565#comment-14321565
]
ASF GitHub Bot commented on FLINK-1543:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1508.
Resolution: Fixed
Fixed in 1583dcfc7bdcd31ba5e951835fc1d4ca60a23948
> Remove AkkaUtils.ask to encou
[
https://issues.apache.org/jira/browse/FLINK-1543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann closed FLINK-1543.
Resolution: Fixed
Fixed in 589b539c5acdd25f53ef6c9a453198a960ba93d5
> Proper exception handling in
[
https://issues.apache.org/jira/browse/FLINK-1508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321564#comment-14321564
]
ASF GitHub Bot commented on FLINK-1508:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/394
---
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/384
---
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
Stephan Ewen created FLINK-1548:
---
Summary: [DISCUSS] Make Scala implicit parameters explicit in the
runtime
Key: FLINK-1548
URL: https://issues.apache.org/jira/browse/FLINK-1548
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321551#comment-14321551
]
Stephan Ewen commented on FLINK-1547:
-
I agree, we should also deactivate the restart
Robert Metzger created FLINK-1547:
-
Summary: Disable automated ApplicationMaster restart
Key: FLINK-1547
URL: https://issues.apache.org/jira/browse/FLINK-1547
Project: Flink
Issue Type: Bug
Robert Metzger created FLINK-1546:
-
Summary: Failed job causes JobManager to shutdown due to uncatched
WebFrontend exception
Key: FLINK-1546
URL: https://issues.apache.org/jira/browse/FLINK-1546
Proje
[
https://issues.apache.org/jira/browse/FLINK-1531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321520#comment-14321520
]
Johannes commented on FLINK-1531:
-
Thanks for the info [~StephanEwen]
Makes sense to me an
Till Rohrmann created FLINK-1545:
Summary: Spurious failure of
AsynchronousFileIOChannelsTest.testExceptionForwardsToClose
Key: FLINK-1545
URL: https://issues.apache.org/jira/browse/FLINK-1545
Project
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14321297#comment-14321297
]
ASF GitHub Bot commented on FLINK-1521:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/392#issuecomment-74367347
The problem here I think that an error caused by the reusing mapper could
be very hard to detect. So some users might have it but they don't realise.
For streaming
44 matches
Mail list logo
