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
[
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/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-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
[
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-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.
> -
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-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/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-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 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=14325693#comment-14325693
]
ASF GitHub Bot commented on FLINK-1417:
---
Github user rmetzger commented on the pull
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-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
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-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:
[
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:
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
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
[
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
[
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-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-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-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-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-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-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-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
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-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:
[
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
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-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
[
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
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-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 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-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1578.
-
Resolution: Fixed
Fixed via cfce493feb70a49d2722dc2a0d79f845f7e0461a
> Overhaul BLOB manager
> --
[
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-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:all-tabpanel
]
Vasia Kalavri closed FLINK-1201.
Resolution: Implemented
> Graph API for Flink
>
>
> Key: FLINK
[
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-1388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14325974#comment-14325974
]
Robert Metzger commented on FLINK-1388:
---
- The {{DataSet.internalWriteAsCsv}} curren
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-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
[
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-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-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-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-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-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-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
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=14326147#comment-14326147
]
ASF GitHub Bot commented on FLINK-1466:
---
Github user rmetzger commented on the pull
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
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
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
[
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
[
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-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=14326193#comment-14326193
]
Fay Beligianni commented on FLINK-1421:
---
We already tried that workaround for testin
[
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: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 edited comment on FLINK-1421 at 2/18/15 5:13 PM:
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
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
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
[
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/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-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 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-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 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=14326411#comment-14326411
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user hsaputra commented on a diff in
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=14326429#comment-14326429
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user hsaputra commented on the pull
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
79 matches
Mail list logo
