Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/1305#issuecomment-156809400
I have updated the description, and ran some more cluster tests without any
issues.
It would be good if you all could do a second round of reviews please.
---
GitHub user smarthi opened a pull request:
https://github.com/apache/flink/pull/1356
FLINK-3013: Incorrect package declaration in
GellyScalaAPICompletenessTest.scala
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/smarthi/flink
[
https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006008#comment-15006008
]
ASF GitHub Bot commented on FLINK-3013:
---
GitHub user smarthi opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi reassigned FLINK-3013:
Assignee: Suneel Marthi
> Incorrect package declaration in
[
https://issues.apache.org/jira/browse/FLINK-2765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2765:
--
Description:
Currently 0.98.11 is used:
{code}
0.98.11-hadoop2
{code}
Stable release for
jun aoki created FLINK-3012:
---
Summary: Refactor boilerplate code of while and if statements in
DataSourceTask
Key: FLINK-3012
URL: https://issues.apache.org/jira/browse/FLINK-3012
Project: Flink
GitHub user jaoki opened a pull request:
https://github.com/apache/flink/pull/1355
[FLINK-3012] Refactor boilerplate code in DataSourceTask
Refactor repetitive and boilerplate code of while and if statements in
DataSourceTask
The previous if and else nest and to control the
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15005990#comment-15005990
]
ASF GitHub Bot commented on FLINK-3012:
---
GitHub user jaoki opened a pull request:
Ted Yu created FLINK-3014:
-
Summary: Return code from InputStream#read() should be checked in
PythonStreamer#sendBroadCastVariables
Key: FLINK-3014
URL: https://issues.apache.org/jira/browse/FLINK-3014
[
https://issues.apache.org/jira/browse/FLINK-3014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-3014:
---
Assignee: Chesnay Schepler
> Return code from InputStream#read() should be checked
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006087#comment-15006087
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006094#comment-15006094
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user zentol commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1355#issuecomment-156869041
I'm not too fond of the new version either and feel like this code bit
doesn't really need more clarity, simply because it isn't a lot of code.
Using a counter
[
https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006160#comment-15006160
]
ASF GitHub Bot commented on FLINK-2956:
---
Github user gallenvara commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006051#comment-15006051
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user StephanEwen commented on the pull request:
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1355#issuecomment-156859098
Thanks for the interest in helping us maintain clear code.
I think actually that the original code was easier than the code with
counter checks. Further
Github user jaoki commented on the pull request:
https://github.com/apache/flink/pull/1355#issuecomment-156867821
@StephanEwen , thank you for your feedback. Looping with an int variable is
clearly wrong in Flink's use case, and I can change to long, but, I'd like to
hear more of
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/1349#issuecomment-156902819
@gallenvara Yes, exactly right.
---
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-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006192#comment-15006192
]
ASF GitHub Bot commented on FLINK-2956:
---
Github user chiwanpark commented on the pull request:
Stephan Ewen created FLINK-3015:
---
Summary: Bring Features Web Page up to speed
Key: FLINK-3015
URL: https://issues.apache.org/jira/browse/FLINK-3015
Project: Flink
Issue Type: Improvement
Github user gallenvara commented on the pull request:
https://github.com/apache/flink/pull/1349#issuecomment-156890933
Hi, @chiwanpark . Thanks for your review. I'm not very clear about your
first suggestion. Do you mean that we should remove type description when to
create a new
Slim Baltagi created FLINK-3016:
---
Summary: Update Flink roadmap
Key: FLINK-3016
URL: https://issues.apache.org/jira/browse/FLINK-3016
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi reassigned FLINK-3017:
Assignee: Suneel Marthi
> Broken 'Slots' link on Streaming Programming Guide
>
GitHub user smarthi opened a pull request:
https://github.com/apache/flink/pull/1357
Flink-3017: Fix broken 'Slots' link on Streaming Guide.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/smarthi/flink Flink-3017
Alternatively
Suneel Marthi created FLINK-3017:
Summary: Broken link 'Slots' on Streaming Programming Guide
Key: FLINK-3017
URL: https://issues.apache.org/jira/browse/FLINK-3017
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi updated FLINK-3017:
-
Summary: Broken 'Slots' link on Streaming Programming Guide (was: Broken
link 'Slots' on
[
https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006224#comment-15006224
]
Suneel Marthi commented on FLINK-3017:
--
Fix available via PR#1357
[
https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suneel Marthi resolved FLINK-3017.
--
Resolution: Fixed
> Broken 'Slots' link on Streaming Programming Guide
>
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006303#comment-15006303
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki closed the pull request at:
Github user jaoki closed the pull request at:
https://github.com/apache/flink/pull/1355
---
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
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15006302#comment-15006302
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki commented on the pull request:
Github user jaoki commented on the pull request:
https://github.com/apache/flink/pull/1355#issuecomment-156946307
Thank you for your input. @zentol ! Withdrawing 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
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jun aoki resolved FLINK-3012.
-
Resolution: Won't Fix
> Refactor boilerplate code of while and if statements in DataSourceTask
>
[
https://issues.apache.org/jira/browse/FLINK-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-2914:
--
Description:
{code}
case CONNECTION_SUSPENDED:
LOG.warn("ZooKeeper connection SUSPENDED.
Suneel Marthi created FLINK-3013:
Summary: Incorrect package declaration in
GellyScalaAPICompletenessTest.scala
Key: FLINK-3013
URL: https://issues.apache.org/jira/browse/FLINK-3013
Project: Flink
35 matches
Mail list logo
