Márton Balassi created FLINK-1767:
-
Summary: StreamExecutionEnvironment's execute should return
JobExecutionResult
Key: FLINK-1767
URL: https://issues.apache.org/jira/browse/FLINK-1767
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-1710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374836#comment-14374836
]
Aljoscha Krettek commented on FLINK-1710:
-
It would not be too major, I think.
>
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/484#issuecomment-84575241
No problem, thanks for the contribution. Cherry-picked and squashed your
commits. I've decided to make three changes:
1. The output was not necessarily flushed up
[
https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374852#comment-14374852
]
ASF GitHub Bot commented on FLINK-1688:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/474#issuecomment-84575589
@gaborhermann, @rmetzger wwhat is the status of this PR? Some of the code
is already in, other parts are missing. Is the code considered ready?
---
If your project is se
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/508#issuecomment-84576440
Nice, thanks for also updating the minor details.
`GroupedWindowBufferStreamOperator` is a bit long of a name for my taste, but
other than LGTM. :)
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374858#comment-14374858
]
ASF GitHub Bot commented on FLINK-1655:
---
Github user mbalassi commented on the pull
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-84591515
Other than this, it looks good.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374888#comment-14374888
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-84591454
1 sec seems to be little to frequent until we make this very efficient. I
would put it around 3-5 sec.
---
If your project is set up for it, you can reply to this email an
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374889#comment-14374889
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user gyfora commented on the pull re
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/508#issuecomment-84592099
I personally don't like the sound of all these class names too much. It
seems to be too redundant and too long in most cases. I know the ...Invokables
weren't so much bette
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374890#comment-14374890
]
ASF GitHub Bot commented on FLINK-1655:
---
Github user gyfora commented on the pull re
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-84596628
:+1: nice
Another thing, while you are at it. What about changing the compaction
timeout. It is currently set to 2 x interval which might be an overkill for b
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374894#comment-14374894
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user senorcarbone commented on the p
[
https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374895#comment-14374895
]
Gyula Fora commented on FLINK-1763:
---
I wonder if we should do the same thing with the So
[
https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14374911#comment-14374911
]
ASF GitHub Bot commented on FLINK-1763:
---
GitHub user gyfora opened a pull request:
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/513
[FLINK-1763] [streaming] Remove cancel from SinkFunction
In addition, always calls the close method of the functions even if it was
cancelled.
You can merge this pull request into a Git repository by
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-84633164
@gyfora: Changed default checkpoint interval to 5 secs.
@senorcarbone: Thanks for the reminder on that. I do not have a really nice
idea for the compaction inter
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375016#comment-14375016
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user mbalassi commented on the pull
Sibao Hong created FLINK-1768:
-
Summary: Fix the bug of BlobServerConnection's LOG.
Key: FLINK-1768
URL: https://issues.apache.org/jira/browse/FLINK-1768
Project: Flink
Issue Type: Bug
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/514
[FLINK-1768]Fix the bug of BlobServerConnection's LOG.
The LOG in class of BlobServerConnection should be created by classloader
of BlobServerConnection.class
You can merge this pull request in
[
https://issues.apache.org/jira/browse/FLINK-1768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375044#comment-14375044
]
ASF GitHub Bot commented on FLINK-1768:
---
GitHub user matadorhong opened a pull reque
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/515
Rename the variable 'contentAdressable' to 'contentAddressable'
Rename the variable 'contentAdressable' to 'contentAddressable' in order to
better understanding.
You can merge this pull request
[
https://issues.apache.org/jira/browse/FLINK-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375076#comment-14375076
]
ASF GitHub Bot commented on FLINK-1763:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375078#comment-14375078
]
ASF GitHub Bot commented on FLINK-1688:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375077#comment-14375077
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/506
---
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/513
---
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/484
---
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-1763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1763.
-
Resolution: Implemented
Implemented via 35f3416
> Remove "cancel" from streaming SinkFunction
> -
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1756.
---
Resolution: Implemented
Implemented via 2842e2f
> Rename Stream Monitoring to Stream Checkpo
[
https://issues.apache.org/jira/browse/FLINK-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1688.
---
Resolution: Implemented
Fix Version/s: 0.9
Client version implemented via a3bc785 and 1
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/506#issuecomment-84687727
Change looks good.
I miss some javadocs on the user facing methods ;)
---
If your project is set up for it, you can reply to this email and have your
reply appear on
[
https://issues.apache.org/jira/browse/FLINK-1756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375136#comment-14375136
]
ASF GitHub Bot commented on FLINK-1756:
---
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375152#comment-14375152
]
Henry Saputra commented on FLINK-1693:
--
Will help working on this if no one pick it u
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay reassigned FLINK-1767:
--
Assignee: Gabor Gevay
> StreamExecutionEnvironment's execute should return JobExecutionResult
>
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/516
[FLINK-1767] [streaming] Make StreamExecutionEnvironment return
JobExecutionResult
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ggevay/flink J
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375182#comment-14375182
]
ASF GitHub Bot commented on FLINK-1767:
---
GitHub user ggevay opened a pull request:
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/516#issuecomment-84741309
Could give more description about how you go about with the PR?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375250#comment-14375250
]
ASF GitHub Bot commented on FLINK-1767:
---
Github user hsaputra commented on the pull
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/516#issuecomment-84741359
Will help review if more description about the direction of the patch
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitH
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375251#comment-14375251
]
ASF GitHub Bot commented on FLINK-1767:
---
Github user hsaputra commented on the pull
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/516#issuecomment-84743663
Yes, sorry for not providing a description.
I changed the return type of StreamExecutionEnvironment.execute() from void
to JobExecutionResult, and then added return stat
[
https://issues.apache.org/jira/browse/FLINK-1767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14375261#comment-14375261
]
ASF GitHub Bot commented on FLINK-1767:
---
Github user ggevay commented on the pull re
45 matches
Mail list logo
