Github user qmlmoon commented on the pull request:
https://github.com/apache/flink/pull/424#issuecomment-75197699
As a user I would expect the system could carry on quickly after server
socket is reinitiated. A large limit of exponentially increase may lead to
potential long wait and
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328633#comment-14328633
]
ASF GitHub Bot commented on FLINK-1582:
---
Github user qmlmoon commented on the pull r
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328583#comment-14328583
]
Andra Lungu commented on FLINK-1587:
Hi Carsten,
Nice catch.
You can add the test h
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu reassigned FLINK-1587:
--
Assignee: Andra Lungu
> coGroup throws NoSuchElementException on iterator.next()
>
[
https://issues.apache.org/jira/browse/FLINK-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andra Lungu updated FLINK-1587:
---
Assignee: (was: Andra Lungu)
> coGroup throws NoSuchElementException on iterator.next()
>
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328532#comment-14328532
]
ASF GitHub Bot commented on FLINK-1582:
---
Github user chiwanpark commented on the pul
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/424#issuecomment-75186840
+1 for exponentially increasing wait time
---
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-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Carsten Brandt updated FLINK-1587:
--
Description:
I am receiving the following exception when running a simple job that extracts
out
Carsten Brandt created FLINK-1587:
-
Summary: coGroup throws NoSuchElementException on iterator.next()
Key: FLINK-1587
URL: https://issues.apache.org/jira/browse/FLINK-1587
Project: Flink
Issu
Gyula Fora created FLINK-1586:
-
Summary: Add support for iteration visualization for Streaming
programs
Key: FLINK-1586
URL: https://issues.apache.org/jira/browse/FLINK-1586
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328231#comment-14328231
]
ASF GitHub Bot commented on FLINK-1582:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/424#issuecomment-75153547
Thanks for quickly picking out the issue. Looks good to me I might modify
it to exponentially increase wait time until a limit instead of constant 5
seconds. What do you
[
https://issues.apache.org/jira/browse/FLINK-1576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri updated FLINK-1576:
-
Assignee: Daniel Bali
> Change the Gelly examples to be consistent with the other Flink examples
>
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328027#comment-14328027
]
ASF GitHub Bot commented on FLINK-1584:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328028#comment-14328028
]
ASF GitHub Bot commented on FLINK-1556:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/425
---
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/422
---
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/423
---
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-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14328029#comment-14328029
]
ASF GitHub Bot commented on FLINK-1484:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/419
---
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-1556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327812#comment-14327812
]
ASF GitHub Bot commented on FLINK-1556:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/422#issuecomment-75102524
Looks good, will merge this as well...
---
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
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/425#issuecomment-75100102
shouldn't it also be plural for Task Managers (since they're 4 :P)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
GitHub user chiwanpark opened a pull request:
https://github.com/apache/flink/pull/426
[FLINK-1512] Add CsvReader for reading into POJOs.
This PR contains following changes.
* `CsvInputFormat` and `ScalaCsvInputFormat` can receive POJO type as
generic parameter
* Add `p
[
https://issues.apache.org/jira/browse/FLINK-1512?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327776#comment-14327776
]
ASF GitHub Bot commented on FLINK-1512:
---
GitHub user chiwanpark opened a pull reques
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327772#comment-14327772
]
ASF GitHub Bot commented on FLINK-1584:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/419#issuecomment-75097617
Looks good, will merge 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 project does
[
https://issues.apache.org/jira/browse/FLINK-1484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327759#comment-14327759
]
ASF GitHub Bot commented on FLINK-1484:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/423#issuecomment-75096035
Rebased the PR on the pending PR #422
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/425#issuecomment-75094489
Looks good, thanks, I'll merge it
---
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
GitHub user cebe opened a pull request:
https://github.com/apache/flink/pull/425
Small UI css class fix
Height of information bullets was not equal due to text break.
before:
 library for improving
the performance
GitHub user balidani opened a pull request:
https://github.com/apache/flink/pull/420
Added Local Clustering Coefficient Example (Help needed)
Hi!
I closed https://github.com/apache/flink/pull/400 and created this instead,
because the commit history was messed up.
I
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75055735
Thanks Ufuk. That is really helpful.
On Thu, Feb 19, 2015 at 2:14 PM, Stephan Ewen
wrote:
> Nice, thanks!
>
> â
> Reply to this ema
[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327431#comment-14327431
]
ASF GitHub Bot commented on FLINK-1528:
---
Github user balidani closed the pull reques
Github user balidani closed the pull request at:
https://github.com/apache/flink/pull/400
---
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-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327407#comment-14327407
]
Stephan Ewen commented on FLINK-1585:
-
I have an upcoming patch...
> Fix computation
Stephan Ewen created FLINK-1585:
---
Summary: Fix computation of TaskManager memory for Mini Cluster
(tests)
Key: FLINK-1585
URL: https://issues.apache.org/jira/browse/FLINK-1585
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327396#comment-14327396
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user cebe commented on the pull requ
Github user cebe commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75051739
:+1:
---
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 w
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75049700
Nice, thanks!
---
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
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75049539
OK, I've set it to our main repo and the forks of: @tillrohrmann,
@rmetzger, @StephanEwen, and my own.
---
If your project is set up for it, you can reply to this email and h
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75049005
Great Ufuk. Could you enable it for my repo?
On Thu, Feb 19, 2015 at 12:42 PM, Ufuk Celebi
wrote:
> Added some documentation here:
> https://
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75039103
Should I add some committer fork repos to the configuration to allow
uploading of log files there as well? Currently, it only uploads logs of builds
for apache/flink.
---
If
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75038691
Added some documentation here:
https://cwiki.apache.org/confluence/display/FLINK/Travis+log+output
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327286#comment-14327286
]
ASF GitHub Bot commented on FLINK-1584:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/419
[FLINK-1584] Fixes TaskManagerFailsITCase
Fixes TaskManagerFailsITCase by replacing the ```TestingCluster``` with a
```ForkableFlinkMiniCluster``` and by increasing the death watch timeouts.
Y
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75035273
OK, rebased and fixed a remaining issue with the help of @rmetzger.
With the current version, all builds of apache/flink will be logged to file
and uploaded to S3.
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-1483.
-
Resolution: Fixed
Fix Version/s: 0.8
0.9
Assignee: Stephan Ewen
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327244#comment-14327244
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user martinkiefer commented on the p
Github user martinkiefer commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75032757
Done
---
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
enable
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327236#comment-14327236
]
ASF GitHub Bot commented on FLINK-1584:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/418#issuecomment-75031616
Does not seem to fix the issue.
---
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 n
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327237#comment-14327237
]
ASF GitHub Bot commented on FLINK-1584:
---
Github user tillrohrmann closed the pull re
Github user tillrohrmann closed the pull request at:
https://github.com/apache/flink/pull/418
---
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
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/370#issuecomment-75030486
okay, I will the remove the chained combiner.
I'm curious though, the issue description specifically mentions the
AllGroupReduce greatly benefiting from a chained v
[
https://issues.apache.org/jira/browse/FLINK-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327233#comment-14327233
]
ASF GitHub Bot commented on FLINK-785:
--
Github user zentol commented on the pull reque
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/418
[FLINK-1584] Fixes TaskManagerFailsITCase
Fixes ```TaskManagerFailsITCase``` by replacing the TestingCluster with a
ForkableFlinkMiniCluster.
You can merge this pull request into a Git reposito
[
https://issues.apache.org/jira/browse/FLINK-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327226#comment-14327226
]
ASF GitHub Bot commented on FLINK-1584:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327217#comment-14327217
]
ASF GitHub Bot commented on FLINK-1521:
---
Github user zentol commented on the pull re
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75029446
Oh, one minor thing.. Could you prefix your commits with "[FLINK-1515]
[gelly]" ? Thanks!
---
If your project is set up for it, you can reply to this email and have your
re
[
https://issues.apache.org/jira/browse/FLINK-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327219#comment-14327219
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user vasia commented on the pull req
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/392#issuecomment-75029399
Alright, I`m closing this PR then.
---
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
[
https://issues.apache.org/jira/browse/FLINK-1521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327218#comment-14327218
]
ASF GitHub Bot commented on FLINK-1521:
---
Github user zentol closed the pull request
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/392
---
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-1515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327214#comment-14327214
]
ASF GitHub Bot commented on FLINK-1515:
---
Github user vasia commented on the pull req
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/402#issuecomment-75029078
Thanks a lot @martinkiefer! +1 to merge from me :)
---
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-1584:
Summary: Spurious failure of TaskManagerFailsITCase
Key: FLINK-1584
URL: https://issues.apache.org/jira/browse/FLINK-1584
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327159#comment-14327159
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/417
---
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/416
---
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-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327158#comment-14327158
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user StephanEwen commented on the pu
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/417#issuecomment-75021578
Actually, `IOManagerAsync#isProperlyShutDown` already calls the superclass
method:
```
return isShutdown.get() && readersShutDown && writersShutDown &&
super.i
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/416#issuecomment-75019775
:+1: 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 this featur
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/416#issuecomment-75019393
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
enabl
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/417#issuecomment-75019114
Good comments. I address them and merge this.
The tests that fail are not related to this change (there is an instability
in the TaskManager tests currently)
[
https://issues.apache.org/jira/browse/FLINK-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14327146#comment-14327146
]
ASF GitHub Bot commented on FLINK-1483:
---
Github user StephanEwen commented on the pu
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/407#issuecomment-75018451
Much needed feature.
+1
---
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
88 matches
Mail list logo
