[jira] [Created] (FLINK-15420) Cast string to timestamp will loose precision

2019-12-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15420: Summary: Cast string to timestamp will loose precision Key: FLINK-15420 URL: https://issues.apache.org/jira/browse/FLINK-15420 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15421) GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp

2019-12-26 Thread Benchao Li (Jira)
Benchao Li created FLINK-15421: -- Summary: GroupAggsHandler throws java.time.LocalDateTime cannot be cast to java.sql.Timestamp Key: FLINK-15421 URL: https://issues.apache.org/jira/browse/FLINK-15421 Proj

[jira] [Created] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

2019-12-26 Thread Kaibo Zhou (Jira)
Kaibo Zhou created FLINK-15419: -- Summary: Validate SQL syntax not need to depend on connector jar Key: FLINK-15419 URL: https://issues.apache.org/jira/browse/FLINK-15419 Project: Flink Issue Typ

[jira] [Created] (FLINK-15418) StreamExecMatchRule not set FlinkRelDistribution

2019-12-26 Thread Benchao Li (Jira)
Benchao Li created FLINK-15418: -- Summary: StreamExecMatchRule not set FlinkRelDistribution Key: FLINK-15418 URL: https://issues.apache.org/jira/browse/FLINK-15418 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15417) Remove the docker volume or mount when starting Mesos e2e cluster

2019-12-26 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-15417: -- Summary: Remove the docker volume or mount when starting Mesos e2e cluster Key: FLINK-15417 URL: https://issues.apache.org/jira/browse/FLINK-15417 Project: Flink

[jira] [Created] (FLINK-15416) Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel

2019-12-26 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-15416: - Summary: Add Retry Mechanism for PartitionRequestClientFactory.ConnectingChannel Key: FLINK-15416 URL: https://issues.apache.org/jira/browse/FLINK-15416 Project: Fl

[jira] [Created] (FLINK-15415) Flink machine node memory is consumed quickly, but the heap has not changed

2019-12-26 Thread hiliuxg (Jira)
hiliuxg created FLINK-15415: --- Summary: Flink machine node memory is consumed quickly, but the heap has not changed Key: FLINK-15415 URL: https://issues.apache.org/jira/browse/FLINK-15415 Project: Flink

[jira] [Created] (FLINK-15414) KafkaITCase#prepare failed in travis

2019-12-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-15414: --- Summary: KafkaITCase#prepare failed in travis Key: FLINK-15414 URL: https://issues.apache.org/jira/browse/FLINK-15414 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-15413) ScalarOperatorsTest failed in travis

2019-12-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-15413: --- Summary: ScalarOperatorsTest failed in travis Key: FLINK-15413 URL: https://issues.apache.org/jira/browse/FLINK-15413 Project: Flink Issue Type: Bug Componen

[jira] [Created] (FLINK-15412) LocalExecutorITCase#testParameterizedTypes failed in travis

2019-12-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-15412: --- Summary: LocalExecutorITCase#testParameterizedTypes failed in travis Key: FLINK-15412 URL: https://issues.apache.org/jira/browse/FLINK-15412 Project: Flink Issue Type

Re: [DISCUSS] FLIP-85: Delayed Job Graph Generation

2019-12-26 Thread Peter Huang
Hi Yang, I can't agree more. The effort definitely needs to align with the final goal of FLIP-73. I am thinking about whether we can achieve the goal with two phases. 1) Phase I As the CLiFrontend will not be depreciated soon. We can still use the deployMode flag there, pass the program info thro

[jira] [Created] (FLINK-15411) HiveCatalog can't prune partition on DATE/TIMESTAMP columns

2019-12-26 Thread Bowen Li (Jira)
Bowen Li created FLINK-15411: Summary: HiveCatalog can't prune partition on DATE/TIMESTAMP columns Key: FLINK-15411 URL: https://issues.apache.org/jira/browse/FLINK-15411 Project: Flink Issue Ty

[jira] [Created] (FLINK-15410) Solace JCSMP connectors

2019-12-26 Thread Leonid Ilyevsky (Jira)
Leonid Ilyevsky created FLINK-15410: --- Summary: Solace JCSMP connectors Key: FLINK-15410 URL: https://issues.apache.org/jira/browse/FLINK-15410 Project: Flink Issue Type: Improvement

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

2019-12-26 Thread Hequn Cheng
Hi Jark & ForwardXu, The design doc looks very nice! Only some minor feedback from my side. As calcite has already implemented the JSON functions, I would suppose the semantics and implementation are right for SQL. For TableAPI, I think the most important is to keep align with the SQL(which has

[jira] [Created] (FLINK-15409) Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement

2019-12-26 Thread hailong wang (Jira)
hailong wang created FLINK-15409: Summary: Add semicolon to WindowJoinUtil#generateJoinFunction '$collectorTerm.collect($joinedRow)' statement Key: FLINK-15409 URL: https://issues.apache.org/jira/browse/FLINK-1540

[jira] [Created] (FLINK-15408) Interval join support no equi-condition

2019-12-26 Thread hailong wang (Jira)
hailong wang created FLINK-15408: Summary: Interval join support no equi-condition Key: FLINK-15408 URL: https://issues.apache.org/jira/browse/FLINK-15408 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-15407) Add document to explain how to write a table with PK

2019-12-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15407: Summary: Add document to explain how to write a table with PK Key: FLINK-15407 URL: https://issues.apache.org/jira/browse/FLINK-15407 Project: Flink Issue Ty

[jira] [Created] (FLINK-15406) The savepoint is writted by "State Processor API" can't be restore by map or flatmap

2019-12-26 Thread Darcy Lin (Jira)
Darcy Lin created FLINK-15406: - Summary: The savepoint is writted by "State Processor API" can't be restore by map or flatmap Key: FLINK-15406 URL: https://issues.apache.org/jira/browse/FLINK-15406 Projec

[jira] [Created] (FLINK-15405) Make Yarn staging directory configurable

2019-12-26 Thread Yang Wang (Jira)
Yang Wang created FLINK-15405: - Summary: Make Yarn staging directory configurable Key: FLINK-15405 URL: https://issues.apache.org/jira/browse/FLINK-15405 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15404) How to insert hive table for different catalog

2019-12-26 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-15404: - Summary: How to insert hive table for different catalog Key: FLINK-15404 URL: https://issues.apache.org/jira/browse/FLINK-15404 Project: Flink Issue Type: Wish

[jira] [Created] (FLINK-15403) 'State Migration end-to-end test from 1.6' is unstable on travis.

2019-12-26 Thread Xintong Song (Jira)
Xintong Song created FLINK-15403: Summary: 'State Migration end-to-end test from 1.6' is unstable on travis. Key: FLINK-15403 URL: https://issues.apache.org/jira/browse/FLINK-15403 Project: Flink

[jira] [Created] (FLINK-15402) Add disable quote character feature for serializing row to csv format

2019-12-26 Thread Peng (Jira)
Peng created FLINK-15402: Summary: Add disable quote character feature for serializing row to csv format Key: FLINK-15402 URL: https://issues.apache.org/jira/browse/FLINK-15402 Project: Flink Issue

[jira] [Created] (FLINK-15401) Planner should set sink field names to setKeyFields of upsert sink

2019-12-26 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-15401: Summary: Planner should set sink field names to setKeyFields of upsert sink Key: FLINK-15401 URL: https://issues.apache.org/jira/browse/FLINK-15401 Project: Flink

[jira] [Created] (FLINK-15400) elasticsearch sink support dynamic index.

2019-12-26 Thread ouyangwulin (Jira)
ouyangwulin created FLINK-15400: --- Summary: elasticsearch sink support dynamic index. Key: FLINK-15400 URL: https://issues.apache.org/jira/browse/FLINK-15400 Project: Flink Issue Type: New Featu

[jira] [Created] (FLINK-15399) Join with a LookupableTableSource：java.lang.RuntimeException: while converting XXXX Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type

2019-12-26 Thread Rockey Cui (Jira)
Rockey Cui created FLINK-15399: -- Summary: Join with a LookupableTableSource：java.lang.RuntimeException: while converting Caused by: java.lang.AssertionError: Field ordinal 26 is invalid for type Key: FLINK-15399