[
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
> -
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 your
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006303#comment-15006303
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki closed the pull request a
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006302#comment-15006302
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki commented on the pull req
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 enabl
[
https://issues.apache.org/jira/browse/FLINK-3017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006224#comment-15006224
]
Suneel Marthi commented on FLINK-3017:
--
Fix available via PR#1357
https://github.com
[
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
> ---
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
[
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
>
[
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 Streamin
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:
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
Components
[
https://issues.apache.org/jira/browse/FLINK-2956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006192#comment-15006192
]
ASF GitHub Bot commented on FLINK-2956:
---
Github user chiwanpark commented on the pul
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&focusedCommentId=15006160#comment-15006160
]
ASF GitHub Bot commented on FLINK-2956:
---
Github user gallenvara commented on the pul
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 gene
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006094#comment-15006094
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user zentol commented on the pull re
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 a
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006087#comment-15006087
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user jaoki commented on the pull req
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 this
[
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 in
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
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006051#comment-15006051
]
ASF GitHub Bot commented on FLINK-3012:
---
Github user StephanEwen commented on the pu
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 more
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
Projec
[
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 GellyScalaAPICompletenessTest.sc
[
https://issues.apache.org/jira/browse/FLINK-3013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15006008#comment-15006008
]
ASF GitHub Bot commented on FLINK-3013:
---
GitHub user smarthi opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-3012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15005990#comment-15005990
]
ASF GitHub Bot commented on FLINK-3012:
---
GitHub user jaoki opened a pull request:
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
I
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 timi
[
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 hadoop-
[
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. Chang
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.
---
I
35 matches
Mail list logo
