[jira] [Created] (FLINK-7572) Improve TableSchema ValidationException message.

2017-09-03 Thread sunjincheng (JIRA)
sunjincheng created FLINK-7572:
--

 Summary: Improve TableSchema ValidationException message.
 Key: FLINK-7572
 URL: https://issues.apache.org/jira/browse/FLINK-7572
 Project: Flink
  Issue Type: Improvement
Reporter: sunjincheng
Assignee: sunjincheng


When sql is very complicated(e.g.: more than 100+ tables), the following 
exception information is very confusing:
{code}
org.apache.flink.table.api.TableException: Table column names must be unique. 
at org.apache.flink.table.api.TableSchema.(TableSchema.scala:36)
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)


Quick start guide

2017-09-03 Thread Michael Fong
Hi,

I was following the quick start guide on official documents

,
and I came cross a line that caused a bit confusion.
$ tail -f log/flink-*-jobmanager-*.out

It is said the wordcount program would print output to that output file.
However, when I run the code locally (mater branch, on IDE). I found the
output in taskmanager-*.out instead.

==> log/flink--*taskmanager*-0-out <==
ddd : 1
ccc : 1
bbb : 2
abc : 2
aba : 1
aab : 1
ddd : 1
aaa : 1
abca : 1
abac : 6


Is it an intended behavior in logic, or a typo in the document? Thanks in
advance.

Regards,