[jira] [Updated] (FLINK-20570) The `NOTE` tip style is different from the others in process_function page.

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20570: Fix Version/s: 1.12.1 1.13.0 > The `NOTE` tip style is different from the others in pro

[jira] [Assigned] (FLINK-20570) The `NOTE` tip style is different from the others in process_function page.

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20570: --- Assignee: shizhengchao > The `NOTE` tip style is different from the others in process_function page

[jira] [Updated] (FLINK-20556) Compile exception when using Scala package object as POJO

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20556: Summary: Compile exception when using Scala package object as POJO (was: org.apache.flink.api.common.Inv

[jira] [Commented] (FLINK-20556) Compile exception when using Scala package object as POJO

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247824#comment-17247824 ] Jark Wu commented on FLINK-20556: - Hi [~zzh...@gmail.com], currently, Flink SQL doesn't

[jira] [Updated] (FLINK-20556) Compile exception when using Scala package object as POJO

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20556: Component/s: (was: Client / Job Submission) (was: API / Scala) > Compile exceptio

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20576: Component/s: Table SQL / Ecosystem Connectors / Hive > Flink Temporal Join Hive Dim Error

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20576: Fix Version/s: 1.13.0 > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Closed] (FLINK-20577) Flink Temporal Join Hive Dim Error

2020-12-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20577. --- Resolution: Duplicate > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Commented] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250816#comment-17250816 ] Jark Wu commented on FLINK-19880: - The problem lies in the {{JsonRowFormatFactory#suppor

[jira] [Updated] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Labels: starter (was: flink-json format.ignore-parse-errors) > flink-json The validation and incoming par

[jira] [Updated] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Component/s: Table SQL / Ecosystem > flink-json The validation and incoming parameters do not match >

[jira] [Updated] (FLINK-20582) Fix typos in `CREATE Statements` docs

2020-12-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20582: Component/s: Table SQL / Ecosystem > Fix typos in `CREATE Statements` docs > -

[jira] [Commented] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251035#comment-17251035 ] Jark Wu commented on FLINK-20386: - Feel free to create subtasks. [~873925...@qq.com] >

[jira] [Assigned] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19905: --- Assignee: jiawen xiao > The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in > J

[jira] [Updated] (FLINK-20607) a wrong example in udfs page.

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20607: Component/s: Table SQL / API > a wrong example in udfs page. > - > >

[jira] [Closed] (FLINK-20607) a wrong example in udfs page.

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20607. --- Fix Version/s: 1.12.1 1.13.0 Assignee: shizhengchao Resolution: Fixed Fix

[jira] [Updated] (FLINK-20590) flink sql support hive dynamic configuration

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20590: Component/s: Connectors / Hive > flink sql support hive dynamic configuration > -

[jira] [Updated] (FLINK-20590) flink sql support hive dynamic configuration

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20590: Fix Version/s: (was: 1.12.1) (was: 1.13.0) > flink sql support hive dynamic co

[jira] [Updated] (FLINK-20590) flink sql support hive dynamic configuration

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20590: Issue Type: New Feature (was: Improvement) > flink sql support hive dynamic configuration >

[jira] [Commented] (FLINK-20590) flink sql support hive dynamic configuration

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251045#comment-17251045 ] Jark Wu commented on FLINK-20590: - I think this should be considered when hive dialect i

[jira] [Commented] (FLINK-18578) Add rejecting checkpoint logic in source

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251046#comment-17251046 ] Jark Wu commented on FLINK-18578: - I don't know whether this feature is planed in the ne

[jira] [Commented] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251051#comment-17251051 ] Jark Wu commented on FLINK-20562: - Before starting the work, we need to discuss the synt

[jira] [Assigned] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19880: --- Assignee: Xiao Cai > flink-json The validation and incoming parameters do not match > -

[jira] [Commented] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251055#comment-17251055 ] Jark Wu commented on FLINK-19880: - What value do you suggest to return? IIUC, returning

[jira] [Updated] (FLINK-20583) Support to define the data range of decimal types in datagen table source connector

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20583: Fix Version/s: (was: 1.12.1) > Support to define the data range of decimal types in datagen table sour

[jira] [Commented] (FLINK-20583) Support to define the data range of decimal types in datagen table source connector

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251066#comment-17251066 ] Jark Wu commented on FLINK-20583: - cc [~danny0405], could you help to check whether this

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251079#comment-17251079 ] Jark Wu commented on FLINK-19146: - [~badqiu], I tried your SQL in 1.12.0, and it works w

[jira] [Commented] (FLINK-19146) createMiniBatchTrigger() use OR ,table.exec.mini-batch.size and table.exec.mini-batch.allow-latency

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251080#comment-17251080 ] Jark Wu commented on FLINK-19146: - Btw, please use {{set table.exec.mini-batch.enabled=t

[jira] [Updated] (FLINK-20587) Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20587: Summary: Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source (was: INSERT INTO TIMESTAMP WITH

[jira] [Commented] (FLINK-20587) Support TIMESTAMP WITH LOCAL TIME ZONE type for datagen source

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251081#comment-17251081 ] Jark Wu commented on FLINK-20587: - cc [~danny0405] > Support TIMESTAMP WITH LOCAL TIME

[jira] [Commented] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251086#comment-17251086 ] Jark Wu commented on FLINK-19691: - Sounds good to me. But maybe {{connection.check-timeo

[jira] [Assigned] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19691: --- Assignee: jiawen xiao > Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc

[jira] [Updated] (FLINK-19691) Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19691: Component/s: Table SQL / Ecosystem > Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in

[jira] [Commented] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251089#comment-17251089 ] Jark Wu commented on FLINK-18640: - I don't think exposing postgres' specific configurati

[jira] [Comment Edited] (FLINK-18640) Fix PostgresDialect doesn't quote the identifiers

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251089#comment-17251089 ] Jark Wu edited comment on FLINK-18640 at 12/17/20, 1:29 PM:

[jira] [Commented] (FLINK-19612) Support CUMULATE window table function in planner

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251090#comment-17251090 ] Jark Wu commented on FLINK-19612: - Hi [~maosuhan], CUMULATE is not a keyword, but just a

[jira] [Commented] (FLINK-20638) Flink hive modules Function with the same name bug

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251094#comment-17251094 ] Jark Wu commented on FLINK-20638: - Hi [~HideOnBush], AFAIK, you can't use them both at t

[jira] [Commented] (FLINK-19880) flink-json The validation and incoming parameters do not match

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251095#comment-17251095 ] Jark Wu commented on FLINK-19880: - Yes [~cxiii]. > flink-json The validation and in

[jira] [Comment Edited] (FLINK-20638) Flink hive modules Function with the same name bug

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251094#comment-17251094 ] Jark Wu edited comment on FLINK-20638 at 12/17/20, 1:36 PM:

[jira] [Closed] (FLINK-20638) Flink hive modules Function with the same name bug

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20638. --- Resolution: Not A Problem > Flink hive modules Function with the same name bug > ---

[jira] [Commented] (FLINK-16325) A connection check is required, and it needs to be reopened when the JDBC connection is interrupted

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251102#comment-17251102 ] Jark Wu commented on FLINK-16325: - [~todd5167], however, the {{JdbcBatchingOutputFormat#

[jira] [Commented] (FLINK-20637) Table convert to dataStream twice will result in two data streams

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251103#comment-17251103 ] Jark Wu commented on FLINK-20637: - [~Janze], {{Table#toRetractStream}} will convert the

[jira] [Commented] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251105#comment-17251105 ] Jark Wu commented on FLINK-20644: - [~shiyu2030], do you mean the exception message shoul

[jira] [Updated] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Priority: Major (was: Critical) > table api use UDF(ScalarFunction ) if eval return Unit > -

[jira] [Updated] (FLINK-20644) table api use UDF(ScalarFunction ) if eval return Unit

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Labels: starter (was: ) > table api use UDF(ScalarFunction ) if eval return Unit > -

[jira] [Assigned] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20576: --- Assignee: Leonard Xu > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20576: Fix Version/s: 1.12.1 > Flink Temporal Join Hive Dim Error > -- > >

[jira] [Assigned] (FLINK-20567) Document Error

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20567: --- Assignee: appleyuchi > Document Error > -- > > Key: FLINK-20567 >

[jira] [Updated] (FLINK-20567) Document Error in UDTF section

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20567: Summary: Document Error in UDTF section (was: Document Error) > Document Error in UDTF section >

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Summary: Check return type of ScalarFunction eval method (was: table api use UDF(ScalarFunction ) if eva

[jira] [Updated] (FLINK-20644) Check return type of ScalarFunction eval method shouldn't be void

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20644: Summary: Check return type of ScalarFunction eval method shouldn't be void (was: Check return type of Sca

[jira] [Updated] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20552: Fix Version/s: 1.13.0 > JdbcDynamicTableSink doesn't sink buffered data on checkpoint > --

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-17 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251536#comment-17251536 ] Jark Wu commented on FLINK-20552: - Hi [~meijies], are you still working on this? > Jdb

[jira] [Updated] (FLINK-20665) FileNotFoundException when restore from latest Checkpoint

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20665: Component/s: Table SQL / Ecosystem > FileNotFoundException when restore from latest Checkpoint > -

[jira] [Commented] (FLINK-20660) Time window operator with computed column triggers an exception in batch mode

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251626#comment-17251626 ] Jark Wu commented on FLINK-20660: - It would be helpful if [~sujun1020] can share the imp

[jira] [Assigned] (FLINK-18578) Add rejecting checkpoint logic in source

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18578: --- Assignee: Qingsheng Ren > Add rejecting checkpoint logic in source > --

[jira] [Updated] (FLINK-6810) Add a set of built-in scalar functions to Table API & SQL

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-6810: --- Labels: (was: starter) > Add a set of built-in scalar functions to Table API & SQL > --

[jira] [Closed] (FLINK-18768) Imporve SQL kafka connector docs about passing kafka properties

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18768?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18768. --- Resolution: Duplicate > Imporve SQL kafka connector docs about passing kafka properties > --

[jira] [Updated] (FLINK-6976) Add STR_TO_DATE supported in TableAPI

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-6976: --- Labels: (was: starter) > Add STR_TO_DATE supported in TableAPI > - > >

[jira] [Updated] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16295: Labels: (was: starter) > Optimize BinaryString.copy to not materialize if there is javaObject >

[jira] [Updated] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16295: Fix Version/s: (was: 1.13.0) > Optimize BinaryString.copy to not materialize if there is javaObject >

[jira] [Updated] (FLINK-19880) Support ignore-parse-errors for the legacy JSON format

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Summary: Support ignore-parse-errors for the legacy JSON format (was: flink-json The validation and incom

[jira] [Updated] (FLINK-19880) Support ignore-parse-errors for the legacy JSON format

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Fix Version/s: (was: 1.11.2) > Support ignore-parse-errors for the legacy JSON format > --

[jira] [Updated] (FLINK-19880) Fix ignore-parse-errors not work for the legacy JSON format

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Summary: Fix ignore-parse-errors not work for the legacy JSON format (was: Support ignore-parse-errors fo

[jira] [Updated] (FLINK-19880) Fix ignore-parse-errors not work for the legacy JSON format

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19880: Fix Version/s: 1.12.1 1.13.0 > Fix ignore-parse-errors not work for the legacy JSON for

[jira] [Updated] (FLINK-20658) Make sure jdbc connection is established by target driver

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20658: Component/s: Table SQL / Ecosystem > Make sure jdbc connection is established by target driver > -

[jira] [Updated] (FLINK-19435) Deadlock when loading different driver classes concurrently using Class.forName

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19435: Summary: Deadlock when loading different driver classes concurrently using Class.forName (was: jdbc JDBCO

[jira] [Updated] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20657: Component/s: Table SQL / Ecosystem > Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction,

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251717#comment-17251717 ] Jark Wu commented on FLINK-20662: - Similar problem but slightly different exception stac

[jira] [Assigned] (FLINK-20624) Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20624: --- Assignee: wangsan > Refactor StreamExecJoinRule、StreamExecIntervalJoinRule and > StreamExecTempora

[jira] [Closed] (FLINK-20582) Fix typos in `CREATE Statements` docs

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20582. --- Fix Version/s: 1.12.1 1.13.0 Assignee: xiaozilong Resolution: Fixed Fixed

[jira] [Closed] (FLINK-19947) Support sink parallelism configuration to Print connector

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19947. --- Fix Version/s: 1.13.0 Resolution: Fixed > Support sink parallelism configuration to Print connector >

[jira] [Commented] (FLINK-19947) Support sink parallelism configuration to Print connector

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251789#comment-17251789 ] Jark Wu commented on FLINK-19947: - Fixed in master: af57682fdb2c46509d3b0bc8e51c6eff3b7f

[jira] [Updated] (FLINK-19947) Support sink parallelism configuration to Print connector

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19947: Component/s: Table SQL / Ecosystem > Support sink parallelism configuration to Print connector > -

[jira] [Updated] (FLINK-20671) Partition doesn't commit until the end of partition

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20671: Component/s: Table SQL / Ecosystem > Partition doesn't commit until the end of partition > ---

[jira] [Closed] (FLINK-19880) Fix ignore-parse-errors not work for the legacy JSON format

2020-12-18 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19880. --- Resolution: Fixed Fixed in - master: fc660274a5c7b4cdea00335cac87bdf5d421db92 - release-1.12: 3bfb2ab611ac

[jira] [Updated] (FLINK-20680) Fails to call var-arg function with no parameters

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20680: Fix Version/s: 1.13.0 > Fails to call var-arg function with no parameters > --

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252190#comment-17252190 ] Jark Wu commented on FLINK-20662: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Closed] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-12-19 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19905. --- Resolution: Fixed Fixed in master: cc9ccc42e8c8f7221c6d35f4c011d573577d0505 > The Jdbc-connector's 'lookup.

[jira] [Commented] (FLINK-19435) Deadlock when loading different driver classes concurrently using Class.forName

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252580#comment-17252580 ] Jark Wu commented on FLINK-19435: - Fixed in - master: 7ca2dd311a2e5dc3b30a99ce56ad384f

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252590#comment-17252590 ] Jark Wu commented on FLINK-20552: - [~meijies], how did you create SinkOperator? > Jdbc

[jira] [Assigned] (FLINK-20686) CLI help message should include 'run-application' action

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20686: --- Assignee: Ruguo Yu > CLI help message should include 'run-application' action > ---

[jira] [Commented] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252597#comment-17252597 ] Jark Wu commented on FLINK-20657: - I'm fine with the changes. Another idea is just makin

[jira] [Assigned] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20657: --- Assignee: Kezhu Wang > Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, > Jdbc

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20091: Component/s: Table SQL / Ecosystem > Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSch

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20091: Fix Version/s: 1.13.0 > Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema > ---

[jira] [Assigned] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

2020-12-20 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20091: --- Assignee: Shengkai Fang > Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

[jira] [Commented] (FLINK-19905) The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

2020-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224216#comment-17224216 ] Jark Wu commented on FLINK-19905: - I think it's in a low priority to fix the legacy {{Jd

[jira] [Commented] (FLINK-19896) Support first-n-rows deduplication in the Deduplicate operator

2020-10-31 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224217#comment-17224217 ] Jark Wu commented on FLINK-19896: - I agree this can be a nice improvement. But please do

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224263#comment-17224263 ] Jark Wu commented on FLINK-19912: - What's the error when serializing {{RowData}} into JS

[jira] [Assigned] (FLINK-18846) Set a meaningful operator name for the filesystem sink

2020-11-01 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-18846: --- Assignee: CloseRiver (was: zhuqi) > Set a meaningful operator name for the filesystem sink > -

[jira] [Commented] (FLINK-19914) TemporalJoinITCase.testEventTimeTemporalJoinChangelogUsingBeforeTime is instable

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224518#comment-17224518 ] Jark Wu commented on FLINK-19914: - Temporarily disable the unstable tests in master: bf

[jira] [Updated] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19739: Description: Example script: {code:python} from pyflink.table import EnvironmentSettings, BatchTableEnvir

[jira] [Commented] (FLINK-19739) CompileException when windowing in batch mode: A method named "replace" is not declared in any enclosing class nor any supertype

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224625#comment-17224625 ] Jark Wu commented on FLINK-19739: - I think this is a bug in batch code generator for win

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224693#comment-17224693 ] Jark Wu commented on FLINK-19912: - [~hailong wang] could you share the query which gener

[jira] [Commented] (FLINK-19912) Support ignoreParseErrors option for json serializationSchema

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225124#comment-17225124 ] Jark Wu commented on FLINK-19912: - I think we should first investigate how other system

[jira] [Closed] (FLINK-19294) Support key and value formats in Kafka connector

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19294. --- Fix Version/s: 1.12.0 Resolution: Fixed Implemented in master (1.12.0): 59d2a2dd9c4ade641793fecc9c208

[jira] [Commented] (FLINK-18938) Throw better exception message for quering sink-only connector

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225140#comment-17225140 ] Jark Wu commented on FLINK-18938: - [~liufangliang] Sure, this is already in my review li

[jira] [Updated] (FLINK-19937) Support sink parallelism for all connectors

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19937: Component/s: Table SQL / Ecosystem > Support sink parallelism for all connectors > ---

[jira] [Closed] (FLINK-19861) Improve the document of now() function

2020-11-02 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19861. --- Assignee: hailong wang Resolution: Fixed Fixed in master: 0d7d8c8b965e8d6780cff43cd2a21e093ba6c43d >

<    4   5   6   7   8   9   10   11   12   13   >