[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 T

[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: Flink

[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] [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] [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: Ta

[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: Bu

[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] [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 I

[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] [Created] (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)
brucewoo created FLINK-8281: --- Summary: org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable Key: FLINK-8281 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-8280) Enable checkstyle for org.apache.flink.runtime.blob

2017-12-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8280: -- Summary: Enable checkstyle for org.apache.flink.runtime.blob Key: FLINK-8280 URL: https://issues.apache.org/jira/browse/FLINK-8280 Project: Flink Issue Type: Imp

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

2017-12-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-8279: -- Summary: Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories Key: FLINK-8279 URL: https://issues.apache.org/jira/browse/FLINK-8279 Project:

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

2017-12-18 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8278: Summary: Scala examples in Metric documentation do not compile Key: FLINK-8278 URL: https://issues.apache.org/jira/browse/FLINK-8278 Project: Flink Issue Typ

[jira] [Created] (FLINK-8277) Optimize code generation by using local references

2017-12-18 Thread Timo Walther (JIRA)
Timo Walther created FLINK-8277: --- Summary: Optimize code generation by using local references Key: FLINK-8277 URL: https://issues.apache.org/jira/browse/FLINK-8277 Project: Flink Issue Type: Im

Re: how to assign jira task to myself ?

2017-12-18 Thread Tzu-Li (Gordon) Tai
Hi, Welcome to the Flink community, contributions are always welcome! Could you let us know your JIRA ids, so someone can assign appropriate permissions for you? After that, you can freely assign open and unassigned tasks to yourself to work on. Best, Gordon On 18 December 2017 at 1:02:26 AM,

Re: how to assign jira task to myself ?

2017-12-18 Thread Renjie Liu
+1, I want to implement some of the features and just don't know how to assign a task to me. On Sat, Dec 16, 2017 at 12:59 PM Lynch Lee wrote: > hi, team , > > could someone tell me how to assign a jira task to myself or assign me a > special permission ?? > > > Lynch Lee -- Liu, Renjie Softwa

[jira] [Created] (FLINK-8276) Annotation for Kafka connector

2017-12-18 Thread mingleizhang (JIRA)
mingleizhang created FLINK-8276: --- Summary: Annotation for Kafka connector Key: FLINK-8276 URL: https://issues.apache.org/jira/browse/FLINK-8276 Project: Flink Issue Type: Sub-task R