This closes #4115
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2b4a6b5d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2b4a6b5d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2b4a6b5d Branch: refs/heads/tez-runner Commit: 2b4a6b5d5cb455fe73971fde4caa7d1446cd55aa Parents: acfab89 92b3a9a Author: James Xu <xumingmi...@gmail.com> Authored: Mon Nov 13 14:42:08 2017 +0800 Committer: James Xu <xumingmi...@gmail.com> Committed: Mon Nov 13 14:42:08 2017 +0800 ---------------------------------------------------------------------- .../sql/meta/provider/kafka/BeamKafkaTable.java | 39 +++++++++++++++----- 1 file changed, 30 insertions(+), 9 deletions(-) ----------------------------------------------------------------------
