[GitHub] flink issue #4926: [FLINK-7951] Load YarnConfiguration with default Hadoop c...

2017-12-18 Thread djh4230
Github user djh4230 commented on the issue: https://github.com/apache/flink/pull/4926 Does that mean it's not a issue? But the issue still happened in flink-1.4.How can i fix the issue? ---

[jira] [Commented] (FLINK-7951) YarnApplicationMaster does not load HDFSConfiguration

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296279#comment-16296279 ] ASF GitHub Bot commented on FLINK-7951: --- Github user djh4230 commented on the issue:

[jira] [Commented] (FLINK-8260) Document API of Kafka 0.11 Producer

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296200#comment-16296200 ] ASF GitHub Bot commented on FLINK-8260: --- GitHub user tzulitai opened a pull request:

[GitHub] flink issue #5178: [hotfix] Fix typo in TestableKinesisDataFetcher

2017-12-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5178 +1, thanks for the fix. Merging this ... ---

[GitHub] flink pull request #5179: [FLINK-8260/8287] [kafka] Bunch of improvements to...

2017-12-18 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5179 [FLINK-8260/8287] [kafka] Bunch of improvements to Kafka producer Javadocs / document ## What is the purpose of the change This PR collects several improvements to the

[jira] [Comment Edited] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

2017-12-18 Thread jia liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296123#comment-16296123 ] jia liu edited comment on FLINK-8248 at 12/19/17 3:29 AM: -- It happened again,

[jira] [Reopened] (FLINK-8248) RocksDB state backend Checkpointing is not working with KeyedCEP in 1.4

2017-12-18 Thread jia liu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jia liu reopened FLINK-8248: It happened again, I've read the source code. Found that may be a bug at

[GitHub] flink issue #5171: [FLINK-8271][Kinesis connector] upgrade from deprecated c...

2017-12-18 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5171 No, those classes have been deprecated in AWS SDK 1.11.171. ---

[jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296107#comment-16296107 ] ASF GitHub Bot commented on FLINK-8271: --- Github user bowenli86 commented on the issue:

[jira] [Comment Edited] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes

2017-12-18 Thread dongxiao.yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296073#comment-16296073 ] dongxiao.yang edited comment on FLINK-8270 at 12/19/17 2:56 AM: Yes , the

[jira] [Commented] (FLINK-8270) TaskManagers do not use correct local path for shipped Keytab files in Yarn deployment modes

2017-12-18 Thread dongxiao.yang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296073#comment-16296073 ] dongxiao.yang commented on FLINK-8270: -- Yes , the PR should fixes the problem correctly .So can i

[jira] [Created] (FLINK-8290) Modify clientId to groupId in flink-connector-kafka-0.8

2017-12-18 Thread xymaqingxiang (JIRA)
xymaqingxiang created FLINK-8290: Summary: Modify clientId to groupId in flink-connector-kafka-0.8 Key: FLINK-8290 URL: https://issues.apache.org/jira/browse/FLINK-8290 Project: Flink Issue

[jira] [Updated] (FLINK-8288) Register the web interface url to yarn for yarn job mode

2017-12-18 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu updated FLINK-8288: Affects Version/s: 1.5.0 > Register the web interface url to yarn for yarn job mode >

[jira] [Updated] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-18 Thread shuai.xu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shuai.xu updated FLINK-8289: Affects Version/s: 1.5.0 > The RestServerEndpoint should return the address with real ip when >

[jira] [Created] (FLINK-8289) The RestServerEndpoint should return the address with real ip when getRestAdddress

2017-12-18 Thread shuai.xu (JIRA)
shuai.xu created FLINK-8289: --- Summary: The RestServerEndpoint should return the address with real ip when getRestAdddress Key: FLINK-8289 URL: https://issues.apache.org/jira/browse/FLINK-8289 Project:

[jira] [Closed] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread brucewoo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] brucewoo closed FLINK-8281. --- Resolution: Not A Problem Fix Version/s: 1.4.0 >

[jira] [Created] (FLINK-8288) Register the web interface url to yarn for yarn job mode

2017-12-18 Thread shuai.xu (JIRA)
shuai.xu created FLINK-8288: --- Summary: Register the web interface url to yarn for yarn job mode Key: FLINK-8288 URL: https://issues.apache.org/jira/browse/FLINK-8288 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread brucewoo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] brucewoo updated FLINK-8281: http://www.apache.org/dyn/closer.lua/flink/flink-1.4.0/flink-1.4.0-bin-hadoop27-scala_2.11.tgz >

[GitHub] flink pull request #5178: [hotfix] Fix typo in TestableKinesisDataFetcher

2017-12-18 Thread casidiablo
GitHub user casidiablo opened a pull request: https://github.com/apache/flink/pull/5178 [hotfix] Fix typo in TestableKinesisDataFetcher You can merge this pull request into a Git repository by running: $ git pull https://github.com/casidiablo/flink hotfix/typo-gst

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

2017-12-18 Thread Cristian (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295892#comment-16295892 ] Cristian commented on FLINK-8162: - I will try to test and push a PR soon. > Kinesis Connector to report

[jira] [Created] (FLINK-8287) Flink Kafka Producer docs should clearly state what partitioner is used by default

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-8287: -- Summary: Flink Kafka Producer docs should clearly state what partitioner is used by default Key: FLINK-8287 URL: https://issues.apache.org/jira/browse/FLINK-8287

[jira] [Commented] (FLINK-8162) Kinesis Connector to report millisBehindLatest metric

2017-12-18 Thread Furruska (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295843#comment-16295843 ] Furruska commented on FLINK-8162: - Can you share your fork with me? I'm interested in this but haven't

[jira] [Commented] (FLINK-8271) upgrade from deprecated classes to AmazonKinesis

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295816#comment-16295816 ] ASF GitHub Bot commented on FLINK-8271: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5171: [FLINK-8271][Kinesis connector] upgrade from deprecated c...

2017-12-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5171 Without the SDK upgrade, the API actually isn't yet deprecated yet, right? It is only deprecated in a newer SDK version. If so, I would prefer to not merge this until we actually try to

[jira] [Comment Edited] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295806#comment-16295806 ] Stefan Richter edited comment on FLINK-8281 at 12/18/17 10:58 PM: -- Hi, I

[jira] [Commented] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread Stefan Richter (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295806#comment-16295806 ] Stefan Richter commented on FLINK-8281: --- Hi, I had a look at your stacktraces and something seems

[jira] [Commented] (FLINK-3720) Add warm starts for models

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295735#comment-16295735 ] ASF GitHub Bot commented on FLINK-3720: --- Github user rawkintrevo commented on the issue:

[jira] [Commented] (FLINK-3720) Add warm starts for models

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295736#comment-16295736 ] ASF GitHub Bot commented on FLINK-3720: --- Github user rawkintrevo closed the pull request at:

[GitHub] flink pull request #1875: [FLINK-3742][ml][wip] Add Multilayer Perceptron

2017-12-18 Thread rawkintrevo
Github user rawkintrevo closed the pull request at: https://github.com/apache/flink/pull/1875 ---

[GitHub] flink pull request #1865: [FLINK-3720][ml][wip] Add Warm Starts for Iterativ...

2017-12-18 Thread rawkintrevo
Github user rawkintrevo closed the pull request at: https://github.com/apache/flink/pull/1865 ---

[jira] [Commented] (FLINK-3742) Add Multi Layer Perceptron Predictor

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295734#comment-16295734 ] ASF GitHub Bot commented on FLINK-3742: --- Github user rawkintrevo closed the pull request at:

[jira] [Commented] (FLINK-3742) Add Multi Layer Perceptron Predictor

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295733#comment-16295733 ] ASF GitHub Bot commented on FLINK-3742: --- Github user rawkintrevo commented on the issue:

[GitHub] flink issue #1865: [FLINK-3720][ml][wip] Add Warm Starts for Iterative Solve...

2017-12-18 Thread rawkintrevo
Github user rawkintrevo commented on the issue: https://github.com/apache/flink/pull/1865 closing this ---

[GitHub] flink issue #1875: [FLINK-3742][ml][wip] Add Multilayer Perceptron

2017-12-18 Thread rawkintrevo
Github user rawkintrevo commented on the issue: https://github.com/apache/flink/pull/1875 closing this ---

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295697#comment-16295697 ] ASF GitHub Bot commented on FLINK-8116: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5121: [FLINK-8116] Stale comments referring to Checkpointed int...

2017-12-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5121 Thanks @ankitiitb1069 @ggevay for the work and review. The changes LGTM, minus my comment. I'll address my comments while merging this ... ---

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295695#comment-16295695 ] ASF GitHub Bot commented on FLINK-8116: --- Github user tzulitai commented on a diff in the pull

[jira] [Commented] (FLINK-8116) Stale comments referring to Checkpointed interface

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295694#comment-16295694 ] ASF GitHub Bot commented on FLINK-8116: --- Github user tzulitai commented on a diff in the pull

[GitHub] flink pull request #5121: [FLINK-8116] Stale comments referring to Checkpoin...

2017-12-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5121#discussion_r157606329 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java --- @@ -61,9 +61,9 @@ *

[GitHub] flink pull request #5121: [FLINK-8116] Stale comments referring to Checkpoin...

2017-12-18 Thread tzulitai
Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5121#discussion_r157606375 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java --- @@ -61,9 +61,9 @@ *

[jira] [Comment Edited] (FLINK-7860) Support YARN proxy user in Flink (impersonation)

2017-12-18 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295656#comment-16295656 ] Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:11 PM: - Hi

[jira] [Created] (FLINK-8286) Investigate Flink-Yarn-Kerberos integration for flip-6

2017-12-18 Thread Shuyi Chen (JIRA)
Shuyi Chen created FLINK-8286: - Summary: Investigate Flink-Yarn-Kerberos integration for flip-6 Key: FLINK-8286 URL: https://issues.apache.org/jira/browse/FLINK-8286 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-7860) Support YARN proxy user in Flink (impersonation)

2017-12-18 Thread Shuyi Chen (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294694#comment-16294694 ] Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:01 PM: - I am proposing

[jira] [Comment Edited] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8285 at 12/18/17 7:26 PM: --

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518 ] Tzu-Li (Gordon) Tai commented on FLINK-8285: Ah, sorry, I somehow was thinking of the

[jira] [Comment Edited] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518 ] Tzu-Li (Gordon) Tai edited comment on FLINK-8285 at 12/18/17 7:24 PM: --

[jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295515#comment-16295515 ] ASF GitHub Bot commented on FLINK-8275: --- Github user EronWright commented on the issue:

[GitHub] flink issue #5172: [FLINK-8275] [Security] fix keytab local path in YarnTask...

2017-12-18 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5172 This PR probably fixes the problem, but it would be good to address the deeper problem that the code is confusing. At least we could add some commentary to the code. The specific problems, in

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Julio Biason (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295507#comment-16295507 ] Julio Biason commented on FLINK-8285: - [~tzulitai] Yeah, it's not relevant, because there is no

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Julio Biason (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295496#comment-16295496 ] Julio Biason commented on FLINK-8285: - [~tzulitai] Actually, it is relevant: It could completely

[jira] [Commented] (FLINK-8275) Flink YARN deployment with Kerberos enabled not working

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295493#comment-16295493 ] ASF GitHub Bot commented on FLINK-8275: --- Github user tzulitai commented on the issue:

[GitHub] flink issue #5172: [FLINK-8275] [Security] fix keytab local path in YarnTask...

2017-12-18 Thread tzulitai
Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5172 @suez1224 keep in mind, that contribution PRs should initially have one commit with the commit message appropriately set (the title of the PR would be a good commit message for your case). ---

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295484#comment-16295484 ] Tzu-Li (Gordon) Tai commented on FLINK-8285: [~JBiason] just as a side note irrelevant to this

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Julio Biason (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295479#comment-16295479 ] Julio Biason commented on FLINK-8285: - Well, I was expecting to use the DataStreamUtils.colect to

[jira] [Commented] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295463#comment-16295463 ] Tzu-Li (Gordon) Tai commented on FLINK-8285: I'm not knowledgable of the full context here,

[jira] [Updated] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Julio Biason (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Julio Biason updated FLINK-8285: Description: In the docs about

[jira] [Created] (FLINK-8285) Iterator Data Sink doesn't mention required module

2017-12-18 Thread Julio Biason (JIRA)
Julio Biason created FLINK-8285: --- Summary: Iterator Data Sink doesn't mention required module Key: FLINK-8285 URL: https://issues.apache.org/jira/browse/FLINK-8285 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8240) Create unified interfaces to configure and instatiate TableSources

2017-12-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295353#comment-16295353 ] Timo Walther commented on FLINK-8240: - Hi everyone, I think we don't need a design document for it

[GitHub] flink issue #5176: [FLINK-8279][blob] fall back to TaskManager temp director...

2017-12-18 Thread EronWright
Github user EronWright commented on the issue: https://github.com/apache/flink/pull/5176 @NicoK was this PR a response to an actual issue, and did it resolve it? Do I understand correctly that this will cause the JM (blob server) to use `taskmanager.tmp.dirs`? In addition

[jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295317#comment-16295317 ] ASF GitHub Bot commented on FLINK-8279: --- Github user EronWright commented on the issue:

[jira] [Commented] (FLINK-6065) Make TransportClient for ES5 pluggable

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295316#comment-16295316 ] ASF GitHub Bot commented on FLINK-6065: --- Github user sschaef closed the pull request at:

[GitHub] flink pull request #3934: [FLINK-6065] Add initClient method to Elasticsearc...

2017-12-18 Thread sschaef
Github user sschaef closed the pull request at: https://github.com/apache/flink/pull/3934 ---

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295303#comment-16295303 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295299#comment-16295299 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295305#comment-16295305 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295300#comment-16295300 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295307#comment-16295307 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295301#comment-16295301 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295306#comment-16295306 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295304#comment-16295304 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295308#comment-16295308 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[jira] [Commented] (FLINK-7468) Implement sender backlog logic for credit-based

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295302#comment-16295302 ] ASF GitHub Bot commented on FLINK-7468: --- Github user NicoK commented on a diff in the pull request:

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157544965 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java --- @@ -161,6 +172,29 @@ public boolean

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157548033 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java --- @@ -52,6 +54,10 @@ /** Flag

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157540910 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java --- @@ -47,7 +48,14 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157539147 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -239,6 +261,10 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157538061 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartitionTest.java --- @@ -103,16 +104,35 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157548895 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java --- @@ -77,6 +78,10 @@ /** Flag

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157541024 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SubpartitionTestBase.java --- @@ -62,7 +70,14 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157545208 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java --- @@ -237,6 +243,29 @@ public boolean

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157538818 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java --- @@ -181,10 +182,27 @@ public void

[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

2017-12-18 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4559#discussion_r157544794 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java --- @@ -99,6 +82,23 @@ protected Throwable

[jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295290#comment-16295290 ] ASF GitHub Bot commented on FLINK-8279: --- Github user EronWright commented on a diff in the pull

[GitHub] flink pull request #5176: [FLINK-8279][blob] fall back to TaskManager temp d...

2017-12-18 Thread EronWright
Github user EronWright commented on a diff in the pull request: https://github.com/apache/flink/pull/5176#discussion_r157548338 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java --- @@ -127,21 +132,31 @@ private static BlobStoreService

[jira] [Updated] (FLINK-8281) org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable

2017-12-18 Thread Gary Yao (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-8281: Description: {noformat} org.apache.flink.streaming.runtime.tasks.AsynchronousException:

[jira] [Assigned] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

2017-12-18 Thread Tzu-Li (Gordon) Tai (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-8283: -- Assignee: Tzu-Li (Gordon) Tai > FlinkKafkaConsumerBase failing on Travis with

[jira] [Created] (FLINK-8284) Custom metrics not being exposed for Prometheus

2017-12-18 Thread Julio Biason (JIRA)
Julio Biason created FLINK-8284: --- Summary: Custom metrics not being exposed for Prometheus Key: FLINK-8284 URL: https://issues.apache.org/jira/browse/FLINK-8284 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

2017-12-18 Thread Nico Kruber (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-8283: --- Labels: test-stability (was: ) > FlinkKafkaConsumerBase failing on Travis with no output in 10min >

[jira] [Created] (FLINK-8283) FlinkKafkaConsumerBase failing on Travis with no output in 10min

2017-12-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8283: -- Summary: FlinkKafkaConsumerBase failing on Travis with no output in 10min Key: FLINK-8283 URL: https://issues.apache.org/jira/browse/FLINK-8283 Project: Flink

[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295207#comment-16295207 ] Timo Walther commented on FLINK-8282: - I don't know if this is needed. Actually, the {{transform()}}

[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295193#comment-16295193 ] Xingcan Cui commented on FLINK-8282: Hi [~twalthr], thanks for this ticket. I just wonder whether we

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295132#comment-16295132 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL closed the pull request at:

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

2017-12-18 Thread GJL
Github user GJL closed the pull request at: https://github.com/apache/flink/pull/5168 ---

[jira] [Created] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8282: --- Summary: Transformation with TwoInputStreamOperator fails Key: FLINK-8282 URL: https://issues.apache.org/jira/browse/FLINK-8282 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-8282) Transformation with TwoInputStreamOperator fails

2017-12-18 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-8282: Affects Version/s: 1.4.0 > Transformation with TwoInputStreamOperator fails >

[jira] [Commented] (FLINK-7495) AbstractUdfStreamOperator#initializeState() should be called in AsyncWaitOperator#initializeState()

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295128#comment-16295128 ] ASF GitHub Bot commented on FLINK-7495: --- Github user PedroMrChaves commented on the issue:

[GitHub] flink issue #4621: [FLINK-7495] Call to AbstractUdfStreamOperator#initialize...

2017-12-18 Thread PedroMrChaves
Github user PedroMrChaves commented on the issue: https://github.com/apache/flink/pull/4621 This change needs to also be added to previous versions. I'm using version 1.3.2 and realised that the initializeState(..) function was not being called. ---

[jira] [Commented] (FLINK-8278) Scala examples in Metric documentation do not compile

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295027#comment-16295027 ] ASF GitHub Bot commented on FLINK-8278: --- GitHub user xccui opened a pull request:

[GitHub] flink pull request #5177: [FLINK-8278] [doc] Fix the private member init pro...

2017-12-18 Thread xccui
GitHub user xccui opened a pull request: https://github.com/apache/flink/pull/5177 [FLINK-8278] [doc] Fix the private member init problem for Scala examples in docs ## What is the purpose of the change This PR fixes the improper initialization problem for Scala private

[jira] [Commented] (FLINK-8234) Cache JobExecutionResult from finished JobManagerRunners

2017-12-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295011#comment-16295011 ] ASF GitHub Bot commented on FLINK-8234: --- Github user GJL commented on a diff in the pull request:

  1   2   >