Re: [DISCUSS] FLIP-90: Support SQL 2016-2017 JSON functions in Flink SQL

Thanks a lot for the update. +1 to start a vote. On Tue, Dec 31, 2019 at 2:38 PM Forward Xu wrote: > Hi Jark, Hequn, > > I have updated the documentation. > > Best, > > Forward > > Forward Xu 于2019年12月29日周日 下午4:01写道： > > > Hi Jark, Hequn, > > > > Thank you very much, Introducing new `TableSymbo

[jira] [Created] (FLINK-15445) JDBC Table Source didn't work for Types with precision (or/and scale)

Zhenghua Gao created FLINK-15445: Summary: JDBC Table Source didn't work for Types with precision (or/and scale) Key: FLINK-15445 URL: https://issues.apache.org/jira/browse/FLINK-15445 Project: Flink

[VOTE] FLIP-90: Support SQL 2016-2017 JSON functions in Flink SQL

Hi all, I'd like to start the vote of FLIP-90 [1] since that we have reached an agreement on the design in the discussion thread [2]. This vote will be open for at least 72 hours. Unless there is an objection, I will try to close it by January 3, 2020 08:00 UTC if we have received sufficient vote

[jira] [Created] (FLINK-15446) Improve "Connect to External Systems" documentation page

Jark Wu created FLINK-15446: --- Summary: Improve "Connect to External Systems" documentation page Key: FLINK-15446 URL: https://issues.apache.org/jira/browse/FLINK-15446 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-15447) Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp"

Victor Wong created FLINK-15447: --- Summary: Change "java.io.tmpdir" of JM/TM on Yarn to "{{PWD}}/tmp" Key: FLINK-15447 URL: https://issues.apache.org/jira/browse/FLINK-15447 Project: Flink Is

[jira] [Created] (FLINK-15448) Make "ResourceID#toString" more descriptive

Victor Wong created FLINK-15448: --- Summary: Make "ResourceID#toString" more descriptive Key: FLINK-15448 URL: https://issues.apache.org/jira/browse/FLINK-15448 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-15449) Retain lost task managers on Flink UI

Victor Wong created FLINK-15449: --- Summary: Retain lost task managers on Flink UI Key: FLINK-15449 URL: https://issues.apache.org/jira/browse/FLINK-15449 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15450) Add kafka topic information to Kafka source

Victor Wong created FLINK-15450: --- Summary: Add kafka topic information to Kafka source Key: FLINK-15450 URL: https://issues.apache.org/jira/browse/FLINK-15450 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-15451) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure

Congxian Qiu(klion26) created FLINK-15451: - Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure Key: FLINK-15451 URL: https://issues.apache.org/jira/browse/FLINK-15451

How to get kafka record's timestamp in job

In kafka010, ConsumerRecord has a field named timestamp. It is encapsulated in Kafka010Fetcher. How can I get the timestamp when I write a flink job? Thank you very much.