Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/417#issuecomment-74930615
Since the IOManager add shutdown hook to clean up the files, should
IOManagerAsync#isProperlyShutDown need to call super.isProperlyShutDown ?
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326429#comment-14326429
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on a diff in the pull request:
https://github.com/apache/flink/pull/417#discussion_r24931138
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/IOManager.java
---
@@ -52,26 +57,88 @@
/**
* Constructs a n
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326411#comment-14326411
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user hsaputra commented on a diff in
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/417
[FLINK-1483] IOManager puts temp files in dedicated directory and cleans up
on shutdown
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Step
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326399#comment-14326399
]
ASF GitHub Bot commented on FLINK-1483:
---
GitHub user StephanEwen opened a pull reque
GitHub user hsaputra opened a pull request:
https://github.com/apache/flink/pull/416
Remove extra space after open parenthesis in InstanceConnectionInfo#toString
Small update to remove extra space after open parenthesis in
InstanceConnectionInfo#toString to be consistent with other
[
https://issues.apache.org/jira/browse/FLINK-1444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326240#comment-14326240
]
ASF GitHub Bot commented on FLINK-1444:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/379#issuecomment-74908763
@rmetzger thanks for the review.
Will merge tomorrow if nobody raises a flag.
---
If your project is set up for it, you can reply to this email and have your
reply app
[
https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326234#comment-14326234
]
ASF GitHub Bot commented on FLINK-1461:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/381#issuecomment-74908224
any further comment 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 project does not ha
Till Rohrmann created FLINK-1583:
Summary: TaskManager reregistration in case of a restart
Key: FLINK-1583
URL: https://issues.apache.org/jira/browse/FLINK-1583
Project: Flink
Issue Type: Bug
Márton Balassi created FLINK-1582:
-
Summary: SocketStream gets stuck when socket closes
Key: FLINK-1582
URL: https://issues.apache.org/jira/browse/FLINK-1582
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326196#comment-14326196
]
Fay Beligianni edited comment on FLINK-1421 at 2/18/15 5:13 PM:
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fay Beligianni updated FLINK-1421:
--
Comment: was deleted
(was: Hey Stefan,
Thank you very much for the response! Indeed that was t
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fay Beligianni updated FLINK-1421:
--
Comment: was deleted
(was: Hey Stefan,
Thank you very much for the response! Indeed that was t
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326196#comment-14326196
]
Fay Beligianni commented on FLINK-1421:
---
Hey Stefan,
Thank you very much for the res
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326193#comment-14326193
]
Fay Beligianni commented on FLINK-1421:
---
We already tried that workaround for testin
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1582:
--
Labels: starter (was: )
> SocketStream gets stuck when socket closes
>
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326189#comment-14326189
]
Fay Beligianni commented on FLINK-1421:
---
Hey Stefan,
Thank you very much for the r
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326190#comment-14326190
]
Fay Beligianni commented on FLINK-1421:
---
Hey Stefan,
Thank you very much for the r
Till Rohrmann created FLINK-1581:
Summary: Configure DeathWatch parameters properly
Key: FLINK-1581
URL: https://issues.apache.org/jira/browse/FLINK-1581
Project: Flink
Issue Type: Bug
Till Rohrmann created FLINK-1580:
Summary: Cleanup TaskManager initialization logic
Key: FLINK-1580
URL: https://issues.apache.org/jira/browse/FLINK-1580
Project: Flink
Issue Type: Bug
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/411#issuecomment-74895705
Cool. Then I think the change is 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 pr
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326147#comment-14326147
]
ASF GitHub Bot commented on FLINK-1466:
---
Github user rmetzger commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/411#issuecomment-74894556
@rmetzger Thanks for the feedback.
Added support for complex types to the Flink tuple mode and tested it on a
local cluster setup.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-1466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326134#comment-14326134
]
ASF GitHub Bot commented on FLINK-1466:
---
Github user fhueske commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-1567:
-
Assignee: Robert Metzger
> Add option to switch between Avro and Kryo serialization for G
[
https://issues.apache.org/jira/browse/FLINK-1567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326054#comment-14326054
]
Robert Metzger commented on FLINK-1567:
---
Resolved for 0.9 in master in
http://git-w
[
https://issues.apache.org/jira/browse/FLINK-1391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1391.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved for 0.9 into master with
http://git-wip-
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1417.
---
Resolution: Fixed
Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/354efec0
>
[
https://issues.apache.org/jira/browse/FLINK-1392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1392.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved for 0.9 in master with commit:
http://gi
[
https://issues.apache.org/jira/browse/FLINK-1395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-1395.
---
Resolution: Fixed
Fix Version/s: 0.9
Resolved for master 0.9 in
http://git-wip-us.apac
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14326043#comment-14326043
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/393
---
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-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325974#comment-14325974
]
Robert Metzger commented on FLINK-1388:
---
- The {{DataSet.internalWriteAsCsv}} curren
[
https://issues.apache.org/jira/browse/FLINK-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325971#comment-14325971
]
Robert Metzger commented on FLINK-1388:
---
Yes, adding additional tests is always good
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-1201.
Resolution: Implemented
> Graph API for Flink
>
>
> Key: FLINK
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325918#comment-14325918
]
Vasia Kalavri commented on FLINK-1201:
--
sure, I'll close it :)
> Graph API for Flink
[
https://issues.apache.org/jira/browse/FLINK-1201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325885#comment-14325885
]
Stephan Ewen commented on FLINK-1201:
-
I think we can close this, now that Gelly is in
[
https://issues.apache.org/jira/browse/FLINK-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1578.
-
Resolution: Fixed
Fixed via cfce493feb70a49d2722dc2a0d79f845f7e0461a
> Overhaul BLOB manager
> --
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74867033
Merging it 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 this feat
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325864#comment-14325864
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-74864911
Very good idea.
+1 from my side
---
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-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325851#comment-14325851
]
Robert Metzger commented on FLINK-1579:
---
We have to investigate on that:
http://had
[
https://issues.apache.org/jira/browse/FLINK-1579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325847#comment-14325847
]
Stephan Ewen commented on FLINK-1579:
-
How much is there in terms of Hadoop History se
Robert Metzger created FLINK-1579:
-
Summary: Create a Flink History Server
Key: FLINK-1579
URL: https://issues.apache.org/jira/browse/FLINK-1579
Project: Flink
Issue Type: New Feature
Aff
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325823#comment-14325823
]
Stephan Ewen commented on FLINK-1421:
-
My guess is that the Samoa adapter (specificall
[
https://issues.apache.org/jira/browse/FLINK-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325820#comment-14325820
]
ASF GitHub Bot commented on FLINK-1555:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/415
[FLINK-1555] Add serializer hierarchy debug util
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink1555
Alternatively you can
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325808#comment-14325808
]
Márton Balassi commented on FLINK-1421:
---
When your program is distributed one of the
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325807#comment-14325807
]
Márton Balassi commented on FLINK-1421:
---
When your program is distributed one of the
[
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi updated FLINK-1421:
--
Comment: was deleted
(was: When your program is distributed one of the workers does not have
He
[
https://issues.apache.org/jira/browse/FLINK-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1548.
-
Resolution: Fixed
Assignee: Stephan Ewen
Resolved through mailing list discussion (see archi
[
https://issues.apache.org/jira/browse/FLINK-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325769#comment-14325769
]
Martin Kiefer edited comment on FLINK-1552 at 2/18/15 11:47 AM:
[
https://issues.apache.org/jira/browse/FLINK-1552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325769#comment-14325769
]
Martin Kiefer commented on FLINK-1552:
--
I worked on Approximate Maximum Weight Watchi
[
https://issues.apache.org/jira/browse/FLINK-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1562.
-
Resolution: Duplicate
Subsumed by[FLINK-1578]
> Introduce retries for fetching data from the BLOB
[
https://issues.apache.org/jira/browse/FLINK-1564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1564.
-
Resolution: Duplicate
Duplicate of [FLINK-1578]
> Make sure BLOB client downloads files only once
[
https://issues.apache.org/jira/browse/FLINK-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325760#comment-14325760
]
ASF GitHub Bot commented on FLINK-1561:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1561.
-
Resolution: Fixed
Fixed via a8c99d5a8fc6a700a670da5443d9a808ac5eaaa0
> Improve build server robus
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/412
---
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-1578:
---
Summary: Overhaul BLOB manager
Key: FLINK-1578
URL: https://issues.apache.org/jira/browse/FLINK-1578
Project: Flink
Issue Type: Bug
Components: JobMa
[
https://issues.apache.org/jira/browse/FLINK-1566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1566.
---
Resolution: Fixed
> WindowIntegrationTest fails
> ---
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325705#comment-14325705
]
ASF GitHub Bot commented on FLINK-947:
--
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/405#issuecomment-74845397
To me, `flink-expressions` sounds much better than `linq` and it mitigates
the risk of law suites :)
---
If your project is set up for it, you can reply to this email and hav
[
https://issues.apache.org/jira/browse/FLINK-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325695#comment-14325695
]
Ufuk Celebi commented on FLINK-1577:
{code}
10:56:40,161 ERROR org.apache.flink.runtim
Ufuk Celebi created FLINK-1577:
--
Summary: Misleading error messages when cancelling tasks
Key: FLINK-1577
URL: https://issues.apache.org/jira/browse/FLINK-1577
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325693#comment-14325693
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74843995
Yes. First we need to understand why exactly the performance is so poor.
Maybe its an issue we can "easily" fix.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325691#comment-14325691
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74843783
Yes please, go ahead. But if our Pojo stuff is really that slow we should
think about how to improve that or remove it alltogether.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325686#comment-14325686
]
ASF GitHub Bot commented on FLINK-947:
--
Github user aljoscha commented on the pull req
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/405#issuecomment-74842606
Yeah, I'm not sure about linq as well. I like the name but realise that it
might be problematic. What do the others think. I could call it
"flink-expressions".
I
[
https://issues.apache.org/jira/browse/FLINK-1573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-1573:
--
Fix Version/s: (was: pre-apache)
> Add per-job metrics to flink.
> -
[
https://issues.apache.org/jira/browse/FLINK-1575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger closed FLINK-1575.
-
Resolution: Invalid
The issue is caused by one of my changes (dependency conflict).
I'm closing it
[
https://issues.apache.org/jira/browse/FLINK-1417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325629#comment-14325629
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/393#issuecomment-74833886
I would like to merge this pull request soon.
@aljoscha, do you agree that we can investigate the performance for the
PojoComparator also when the change is merged?
[
https://issues.apache.org/jira/browse/FLINK-947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325617#comment-14325617
]
ASF GitHub Bot commented on FLINK-947:
--
Github user rmetzger commented on the pull req
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/405#issuecomment-74832989
One more thing, the maven module is called "flink-linq". Are we certain
that we can use the name LINQ without problems here?
---
If your project is set up for it, you ca
79 matches
Mail list logo