[GitHub] flink pull request #4238: [FLINK-7057][blob] move BLOB ref-counting from Lib...

2017-07-04 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4238#discussion_r125404358 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobCache.java --- @@ -107,146 +133,268 @@ public BlobCache( this.n

[jira] [Commented] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073226#comment-16073226 ] ASF GitHub Bot commented on FLINK-7057: --- Github user NicoK commented on a diff in th

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-04 Thread uce
Github user uce commented on the issue: https://github.com/apache/flink/pull/4213 Just ran into this as well. This was so annoying. Thank you very much for the fix... I spent an hour assuming it was a problem on my side. Merging now... --- If your project is set up for it, you can re

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073231#comment-16073231 ] ASF GitHub Bot commented on FLINK-7032: --- Github user uce commented on the issue:

[GitHub] flink pull request #4213: [FLINK-7032] Overwrite inherited properties from p...

2017-07-04 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4213 --- 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 enab

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073235#comment-16073235 ] ASF GitHub Bot commented on FLINK-7032: --- Github user asfgit closed the pull request

[jira] [Commented] (FLINK-6995) Add a warning to outdated documentation

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073237#comment-16073237 ] mingleizhang commented on FLINK-6995: - [~alpinegizmo] I will create another JIRA for w

[GitHub] flink issue #4244: [docs]Added missing "more" word to programming-model docs...

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4244 @Adebski thanks for the fix. Yes I think this qualifies as a trivial fix and doesn't require a JIRA. For these kind of fixes we usually prefix the commit message with a `[hotfix]`. LGTM,

[jira] [Closed] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-07-04 Thread Ufuk Celebi (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi closed FLINK-7032. -- Resolution: Fixed Fix Version/s: 1.3.2 1.4.0 Fixed in 5f4296e (release-1.3), d

[GitHub] flink issue #4229: [FLINK-7038] [docs] Correct misused term to KeyedStream

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4229 LGTM, merging .. --- 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

[GitHub] flink pull request #4238: [FLINK-7057][blob] move BLOB ref-counting from Lib...

2017-07-04 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4238#discussion_r125406639 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobServerLibraryManager.java --- @@ -0,0 +1,55 @@ +/* + * Licen

[jira] [Commented] (FLINK-7038) Several misused "KeyedDataStream" term in docs and Javadocs

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073243#comment-16073243 ] ASF GitHub Bot commented on FLINK-7038: --- Github user tzulitai commented on the issue

[jira] [Commented] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073244#comment-16073244 ] ASF GitHub Bot commented on FLINK-7057: --- Github user NicoK commented on a diff in th

[GitHub] flink issue #4213: [FLINK-7032] Overwrite inherited properties from parent p...

2017-07-04 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4213 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 feature enabled and wishes so, or if the f

[jira] [Commented] (FLINK-7032) Intellij is constantly changing language level of sub projects back to 1.6

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073248#comment-16073248 ] ASF GitHub Bot commented on FLINK-7032: --- Github user pnowojski commented on the issu

[jira] [Created] (FLINK-7094) Update outdated doc release 1.2 to latest stable release 1.3

2017-07-04 Thread mingleizhang (JIRA)
mingleizhang created FLINK-7094: --- Summary: Update outdated doc release 1.2 to latest stable release 1.3 Key: FLINK-7094 URL: https://issues.apache.org/jira/browse/FLINK-7094 Project: Flink Iss

[jira] [Updated] (FLINK-7094) Update outdated doc release 1.2 to latest stable release 1.3

2017-07-04 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang updated FLINK-7094: Issue Type: Sub-task (was: Bug) Parent: FLINK-6995 > Update outdated doc release 1.2 to lat

[GitHub] flink pull request #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarant...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4206#discussion_r125411227 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java --- @@ -172,6 +1

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073276#comment-16073276 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarant...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4206#discussion_r125411707 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java --- @@ -172,6 +1

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073280#comment-16073280 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on a diff in

[GitHub] flink pull request #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarant...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4206#discussion_r125411974 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironment.java --- @@ -80,6 +82,

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073283#comment-16073283 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on a diff in

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073284#comment-16073284 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarantee at-l...

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4206 Thanks for the fixups @pnowojski! I have some final minor comments, other than that this LGTM. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[GitHub] flink issue #4220: [FLINK-6665] Pass a ScheduledExecutorService to the Resta...

2017-07-04 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4220 @tillrohrmann Thank you for your review, I have remove `restart(ExecutionGraph executionGraph)`, and use `ScheduledExecutor` instead of `ScheduledExecutorService` you metioned. Thanks --- If your

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073299#comment-16073299 ] ASF GitHub Bot commented on FLINK-6665: --- Github user zjureel commented on the issue:

[GitHub] flink pull request #4251: [FLINK-7093] [tm] Send SlotReport as part of the h...

2017-07-04 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4251 [FLINK-7093] [tm] Send SlotReport as part of the heartbeat payload to the ResourceManager The TaskManager sends the SlotReport as part of the heartbeat payload to the ResourceManager. That

[jira] [Commented] (FLINK-7093) Send SlotReport as part of the heartbeat payload to the RM

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073306#comment-16073306 ] ASF GitHub Bot commented on FLINK-7093: --- GitHub user tillrohrmann opened a pull requ

[jira] [Assigned] (FLINK-7074) Add entry point for TaskManagerRunner

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7074: Assignee: Till Rohrmann > Add entry point for TaskManagerRunner > -

[jira] [Updated] (FLINK-7074) Add entry point for TaskManagerRunner

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7074: - Labels: flip-6 (was: ) > Add entry point for TaskManagerRunner >

[GitHub] flink issue #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarantee at-l...

2017-07-04 Thread pnowojski
Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4206 @tzulitai applied changes. --- 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 wi

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073313#comment-16073313 ] ASF GitHub Bot commented on FLINK-6996: --- Github user pnowojski commented on the issu

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073315#comment-16073315 ] ASF GitHub Bot commented on FLINK-6996: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarant...

2017-07-04 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/4206#discussion_r125416757 --- Diff: flink-connectors/flink-connector-kafka-base/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaProducerTestBase.java --- @@ -172,6 +

[GitHub] flink issue #4184: [FLINK-6310] Use lock object for synchronization

2017-07-04 Thread zjureel
Github user zjureel commented on the issue: https://github.com/apache/flink/pull/4184 @aljoscha Thank you for merging it, I will close it, 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

[GitHub] flink pull request #4184: [FLINK-6310] Use lock object for synchronization

2017-07-04 Thread zjureel
Github user zjureel closed the pull request at: https://github.com/apache/flink/pull/4184 --- 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

[jira] [Commented] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073323#comment-16073323 ] ASF GitHub Bot commented on FLINK-6310: --- Github user zjureel commented on the issue:

[jira] [Commented] (FLINK-6310) LocalExecutor#endSession() uses wrong lock for synchronization

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073325#comment-16073325 ] ASF GitHub Bot commented on FLINK-6310: --- Github user zjureel closed the pull request

[GitHub] flink issue #4130: [FLINK-6773] [checkpoint] Introduce compression (snappy) ...

2017-07-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4130 Thanks for the review @tillrohrmann! I will address your comments and proceed with merging. --- If your project is set up for it, you can reply to this email and have your reply appear on Git

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073331#comment-16073331 ] ASF GitHub Bot commented on FLINK-6773: --- Github user StefanRRichter commented on the

[jira] [Updated] (FLINK-7094) Update outdated doc release 1.2 to latest stable release 1.3

2017-07-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-7094: -- Component/s: Documentation > Update outdated doc release 1.2 to latest stable release 1.3 >

[GitHub] flink pull request #4130: [FLINK-6773] [checkpoint] Introduce compression (s...

2017-07-04 Thread StefanRRichter
Github user StefanRRichter closed the pull request at: https://github.com/apache/flink/pull/4130 --- 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

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073334#comment-16073334 ] ASF GitHub Bot commented on FLINK-6773: --- Github user StefanRRichter closed the pull

[GitHub] flink issue #4130: [FLINK-6773] [checkpoint] Introduce compression (snappy) ...

2017-07-04 Thread StefanRRichter
Github user StefanRRichter commented on the issue: https://github.com/apache/flink/pull/4130 Merged in 5171513a3c. --- 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 wis

[GitHub] flink issue #4241: [FLINK-7015] [streaming] separate OperatorConfig from Str...

2017-07-04 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/4241 Also, for actually doing the changes I suggest separate steps, i.e. separate commits. With possibly separate PRs to make reviewing easier and to make the changes more isolated: - Rename `S

[jira] [Commented] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073335#comment-16073335 ] ASF GitHub Bot commented on FLINK-6773: --- Github user StefanRRichter commented on the

[jira] [Commented] (FLINK-7015) Separate OperatorConfig from StreamConfig

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073336#comment-16073336 ] ASF GitHub Bot commented on FLINK-7015: --- Github user aljoscha commented on the issue

[jira] [Closed] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-07-04 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-6773. - Resolution: Implemented Merged in 5171513a3c. Documentation in 41806ba681. > Use compression (e.g

[GitHub] flink issue #4249: [FLINK-7070] Use properly built custom jar in ScalaShellI...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4249 merging. --- 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 fea

[jira] [Commented] (FLINK-7070) Rework ScalaShellITCase#testSubmissionOfExternalLibraryStream

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073344#comment-16073344 ] ASF GitHub Bot commented on FLINK-7070: --- Github user zentol commented on the issue:

[GitHub] flink issue #4249: [FLINK-7070] Use properly built custom jar in ScalaShellI...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4249 +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 wishes so, or if the feature

[jira] [Commented] (FLINK-7070) Rework ScalaShellITCase#testSubmissionOfExternalLibraryStream

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073345#comment-16073345 ] ASF GitHub Bot commented on FLINK-7070: --- Github user zentol commented on the issue:

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125423153 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig priva

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073356#comment-16073356 ] ASF GitHub Bot commented on FLINK-6649: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125423783 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073358#comment-16073358 ] ASF GitHub Bot commented on FLINK-6649: --- Github user sunjincheng121 commented on a d

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

2017-07-04 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125424099 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[jira] [Commented] (FLINK-6649) Improve Non-window group aggregate with configurable `earlyFire`.

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073361#comment-16073361 ] ASF GitHub Bot commented on FLINK-6649: --- Github user sunjincheng121 commented on a d

[jira] [Commented] (FLINK-6880) Activate checkstyle for runtime/iterative

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073382#comment-16073382 ] ASF GitHub Bot commented on FLINK-6880: --- Github user zentol commented on the issue:

[GitHub] flink issue #4098: [FLINK-6880] [runtime] Activate checkstyle for runtime/it...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4098 merging. --- 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 fea

[jira] [Commented] (FLINK-6877) Activate checkstyle for runtime/security

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073384#comment-16073384 ] ASF GitHub Bot commented on FLINK-6877: --- Github user zentol commented on the issue:

[GitHub] flink issue #4095: [FLINK-6877] [runtime] Activate checkstyle for runtime/se...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4095 merging. --- 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 fea

[jira] [Commented] (FLINK-6821) Activate checkstyle for runtime/fs

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073387#comment-16073387 ] ASF GitHub Bot commented on FLINK-6821: --- Github user zentol commented on the issue:

[GitHub] flink issue #4063: [FLINK-6821] Activate checkstyle for runtime/fs

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4063 merging. --- 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 fea

[GitHub] flink pull request #4064: [FLINK-6822] Activate checkstyle for runtime/pluga...

2017-07-04 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/4064#discussion_r125429424 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/plugable/ReusingDeserializationDelegate.java --- @@ -16,33 +16,31 @@ * limitations under

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073389#comment-16073389 ] ASF GitHub Bot commented on FLINK-6822: --- Github user zentol commented on a diff in t

[GitHub] flink issue #4222: [FLINK-7039] [build] Increase forkCountTestPackage for su...

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4222 merging. --- 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 fea

[GitHub] flink pull request #4238: [FLINK-7057][blob] move BLOB ref-counting from Lib...

2017-07-04 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4238#discussion_r125430028 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -162,105 +164,116 @@ static File initStorageDirectory(String storage

[jira] [Commented] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073391#comment-16073391 ] ASF GitHub Bot commented on FLINK-7057: --- Github user NicoK commented on a diff in th

[jira] [Commented] (FLINK-7039) Increase forkCountTestPackage for sudo-enabled TravisCI

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073390#comment-16073390 ] ASF GitHub Bot commented on FLINK-7039: --- Github user zentol commented on the issue:

[GitHub] flink pull request #4238: [FLINK-7057][blob] move BLOB ref-counting from Lib...

2017-07-04 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4238#discussion_r125430786 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java --- @@ -477,97 +406,96 @@ else if (contentAddressable == CONTENT

[jira] [Commented] (FLINK-7057) move BLOB ref-counting from LibraryCacheManager to BlobCache

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073394#comment-16073394 ] ASF GitHub Bot commented on FLINK-7057: --- Github user NicoK commented on a diff in th

[GitHub] flink issue #4068: [FLINK-6823] Activate checkstyle for runtime/broadcast

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4068 @greghogan fixed. --- 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 i

[jira] [Commented] (FLINK-6823) Activate checkstyle for runtime/broadcast

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073404#comment-16073404 ] ASF GitHub Bot commented on FLINK-6823: --- Github user zentol commented on the issue:

[GitHub] flink issue #4064: [FLINK-6822] Activate checkstyle for runtime/plugable

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4064 @greghogan fixed. --- 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 i

[GitHub] flink issue #4065: [FLINK-6826] Activate checkstyle for runtime/net

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4065 merging. --- 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 fea

[jira] [Commented] (FLINK-6822) Activate checkstyle for runtime/plugable

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073406#comment-16073406 ] ASF GitHub Bot commented on FLINK-6822: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-6826) Activate checkstyle for runtime/net

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073407#comment-16073407 ] ASF GitHub Bot commented on FLINK-6826: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-6991) Inaccessible link under Gelly document

2017-07-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-6991: --- Component/s: Project Website > Inaccessible link under Gelly document > --

[jira] [Created] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2017-07-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7095: Summary: Add proper command line parsing tool to TaskManagerRunner.main Key: FLINK-7095 URL: https://issues.apache.org/jira/browse/FLINK-7095 Project: Flink

[jira] [Updated] (FLINK-7095) Add proper command line parsing tool to TaskManagerRunner.main

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7095: - Priority: Minor (was: Major) > Add proper command line parsing tool to TaskManagerRunner.main > -

[jira] [Resolved] (FLINK-6991) Inaccessible link under Gelly document

2017-07-04 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-6991. Resolution: Fixed Fixed for asf-site via 7b21e3ed77faf66e61e50f522a5b910217699690.

[jira] [Commented] (FLINK-6665) Pass a ScheduledExecutorService to the RestartStrategy

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073437#comment-16073437 ] ASF GitHub Bot commented on FLINK-6665: --- Github user StephanEwen commented on the is

[jira] [Created] (FLINK-7096) Adapt start-up scripts to start Flip-6 cluster

2017-07-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7096: Summary: Adapt start-up scripts to start Flip-6 cluster Key: FLINK-7096 URL: https://issues.apache.org/jira/browse/FLINK-7096 Project: Flink Issue Type: Bug

[GitHub] flink issue #4220: [FLINK-6665] Pass a ScheduledExecutorService to the Resta...

2017-07-04 Thread StephanEwen
Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4220 We have to also consider anther aspect: Changing this from a synchronous call to an asynchronous callback makes new types of races possible, against which we need to guard. We need to ma

[jira] [Created] (FLINK-7097) Start TaskExecutor via start-up script

2017-07-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7097: Summary: Start TaskExecutor via start-up script Key: FLINK-7097 URL: https://issues.apache.org/jira/browse/FLINK-7097 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-7096) Adapt start-up scripts to start Flip-6 cluster

2017-07-04 Thread Till Rohrmann (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7096: - Labels: flip-6 (was: ) > Adapt start-up scripts to start Flip-6 cluster > ---

[jira] [Created] (FLINK-7098) Start standalone cluster entry point via start-up script

2017-07-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7098: Summary: Start standalone cluster entry point via start-up script Key: FLINK-7098 URL: https://issues.apache.org/jira/browse/FLINK-7098 Project: Flink Issue

[GitHub] flink issue #4206: [FLINK-6996] FlinkKafkaProducer010 doesn't guarantee at-l...

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4206 LGTM, merging 👍 --- 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,

[jira] [Commented] (FLINK-6996) FlinkKafkaProducer010 doesn't guarantee at-least-once semantic

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073441#comment-16073441 ] ASF GitHub Bot commented on FLINK-6996: --- Github user tzulitai commented on the issue

[GitHub] flink issue #4232: [FLINK-7041] Deserialize StateBackend from JobCheckpointi...

2017-07-04 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/4232 Thanks for the fixups @aljoscha :-D The last Travis run was successful, the test name rename should not affect anything. Merging this .. --- If your project is set up for it, you can reply

[jira] [Commented] (FLINK-7041) Deserialize StateBackend from JobCheckpointingSettings with user classloader

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073448#comment-16073448 ] ASF GitHub Bot commented on FLINK-7041: --- Github user tzulitai commented on the issue

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125445059 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -117,12 +11

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125445000 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -117,12 +11

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125445183 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -117,12 +11

[GitHub] flink pull request #4228: Flink-7035 Automatically identify AWS Region, simp...

2017-07-04 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/4228#discussion_r125445109 --- Diff: docs/dev/connectors/kinesis.md --- @@ -72,12 +72,80 @@ Before consuming data from Kinesis streams, make sure that all streams are creat

[GitHub] flink issue #3583: [FLINK-6043] [web] Display exception timestamp

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/3583 @tillrohrmann Thanks for the review, will add the null check to `failGlobal` and merge it. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as we

[jira] [Commented] (FLINK-6043) Display time when exceptions/root cause of failure happened

2017-07-04 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16073476#comment-16073476 ] ASF GitHub Bot commented on FLINK-6043: --- Github user zentol commented on the issue:

[GitHub] flink issue #4146: [FLINK-6008][blob] collection of BlobServer improvements

2017-07-04 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/4146 merging, --- 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 fea

  1   2   3   4   >