[jira] [Created] (FLINK-7558) Improve SQL ValidationException message.

sunjincheng created FLINK-7558: -- Summary: Improve SQL ValidationException message. Key: FLINK-7558 URL: https://issues.apache.org/jira/browse/FLINK-7558 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7557) Fix typo for s3a config in AWS deployment documentation

Wei-Che Wei created FLINK-7557: -- Summary: Fix typo for s3a config in AWS deployment documentation Key: FLINK-7557 URL: https://issues.apache.org/jira/browse/FLINK-7557 Project: Flink Issue

RE: Sync Flink

Hi Aljoscha, Since you answered the question you definitely can answer the bonus. I’ll be grateful if you explain why using watermarks as you showed in notion of time cant help here. Thanks. From: Aljoscha Krettek-2 [via Apache Flink Mailing List archive.]

[jira] [Created] (FLINK-7556) Fix fetch size configurable in JDBCInputFormat for MySQL Driver

Nycholas de Oliveira e Oliveira created FLINK-7556: -- Summary: Fix fetch size configurable in JDBCInputFormat for MySQL Driver Key: FLINK-7556 URL: https://issues.apache.org/jira/browse/FLINK-7556

[jira] [Created] (FLINK-7554) Add a testing RuntimeContext to test utilities

Timo Walther created FLINK-7554: --- Summary: Add a testing RuntimeContext to test utilities Key: FLINK-7554 URL: https://issues.apache.org/jira/browse/FLINK-7554 Project: Flink Issue Type: New

[jira] [Created] (FLINK-7553) Use new SinkFunction interface in FlinkKafkaProducer010

Aljoscha Krettek created FLINK-7553: --- Summary: Use new SinkFunction interface in FlinkKafkaProducer010 Key: FLINK-7553 URL: https://issues.apache.org/jira/browse/FLINK-7553 Project: Flink

[jira] [Created] (FLINK-7552) Extend SinkFunction interface with SinkContext

Aljoscha Krettek created FLINK-7552: --- Summary: Extend SinkFunction interface with SinkContext Key: FLINK-7552 URL: https://issues.apache.org/jira/browse/FLINK-7552 Project: Flink Issue

[jira] [Created] (FLINK-7551) Add VERSION to the REST urls.

Kostas Kloudas created FLINK-7551: - Summary: Add VERSION to the REST urls. Key: FLINK-7551 URL: https://issues.apache.org/jira/browse/FLINK-7551 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7550) Give names to REST client/server for clearer logging.

Kostas Kloudas created FLINK-7550: - Summary: Give names to REST client/server for clearer logging. Key: FLINK-7550 URL: https://issues.apache.org/jira/browse/FLINK-7550 Project: Flink Issue

[jira] [Created] (FLINK-7549) CEP - Pattern not discovered if source streaming is very fast

Paolo Rendano created FLINK-7549: Summary: CEP - Pattern not discovered if source streaming is very fast Key: FLINK-7549 URL: https://issues.apache.org/jira/browse/FLINK-7549 Project: Flink

Re: "Unable to find registrar for hdfs" on Flink cluster

By the way, this kind of question should go on the user mailing list IMHO. Thanks Regards JB On 08/29/2017 08:59 AM, P. Ramanjaneya Reddy wrote: Hi All, build jar file from the beam quickstart. while run the jar on Flinkcluster got below error.? anybody got this error? Could you please help

"Unable to find registrar for hdfs" on Flink cluster

Hi All, build jar file from the beam quickstart. while run the jar on Flinkcluster got below error.? anybody got this error? Could you please help how to resolve this? root1@master:~/NAI/Tools/flink-1.3.0$ *bin/flink run -c org.apache.beam.examples.WordCount