[jira] [Commented] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524693#comment-17524693 ] Wenlong Lyu commented on FLINK-27212: - +1 for printing binary in hexadecimal, thanks for the quick

[jira] [Commented] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

[ https://issues.apache.org/jira/browse/FLINK-27212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522618#comment-17522618 ] Wenlong Lyu commented on FLINK-27212: - [~matriv] I think you may have some misunderstanding here.

[jira] [Updated] (FLINK-26770) Nullable ArrayData should not be Object[]

[ https://issues.apache.org/jira/browse/FLINK-26770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-26770: Description: sql: "INSERT INTO %s " + "

[jira] [Updated] (FLINK-26770) Nullable ArrayData should not be Object[]

[ https://issues.apache.org/jira/browse/FLINK-26770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-26770: Description: sql: "INSERT INTO %s " + "

[jira] [Created] (FLINK-26770) Nullable ArrayData should not be Object[]

Wenlong Lyu created FLINK-26770: --- Summary: Nullable ArrayData should not be Object[] Key: FLINK-26770 URL: https://issues.apache.org/jira/browse/FLINK-26770 Project: Flink Issue Type: Bug

[jira] [Comment Edited] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499317#comment-17499317 ] Wenlong Lyu edited comment on FLINK-25695 at 3/1/22, 4:12 AM: -- hi， [~zicat]

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499317#comment-17499317 ] Wenlong Lyu commented on FLINK-25695: - hi， [~wenlong.lwl] thanks for sharing your investigation. Are

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

[ https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495479#comment-17495479 ] Wenlong Lyu commented on FLINK-25932: - [~slinkydeveloper] when the sql is not changed, most of the

[jira] [Commented] (FLINK-25932) Introduce ExecNodeContext.generateUid()

[ https://issues.apache.org/jira/browse/FLINK-25932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495392#comment-17495392 ] Wenlong Lyu commented on FLINK-25932: - hi, [~twalthr] [~slinkydeveloper] we may need to have an

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491746#comment-17491746 ] Wenlong Lyu commented on FLINK-25600: - [~slinkydeveloper] I am sorry that the title format of pr is

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490661#comment-17490661 ] Wenlong Lyu commented on FLINK-25600: - [~slinkydeveloper] the pr is waiting to be reviewed. I have

[jira] [Commented] (FLINK-25730) Fix chaining strategy (and typo?) in RowTimeMiniBatchAssginerOperator

[ https://issues.apache.org/jira/browse/FLINK-25730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479782#comment-17479782 ] Wenlong Lyu commented on FLINK-25730: - thanks for the reviewing. Yes, we should correct the typo,

[jira] [Commented] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception

[ https://issues.apache.org/jira/browse/FLINK-25700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479110#comment-17479110 ] Wenlong Lyu commented on FLINK-25700: - [~simen] it is not a bug actually, you should rename

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478471#comment-17478471 ] Wenlong Lyu commented on FLINK-25695: - According to the description in FLINK-21833, I think the root

[jira] [Commented] (FLINK-25695) TemporalJoin cause state leak in some cases

[ https://issues.apache.org/jira/browse/FLINK-25695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478465#comment-17478465 ] Wenlong Lyu commented on FLINK-25695: - [~zicat] could you share your sql too? it would be easier

[jira] [Commented] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477534#comment-17477534 ] Wenlong Lyu commented on FLINK-25070: - [~MartijnVisser] users cannot control operator name, but they

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477160#comment-17477160 ] Wenlong Lyu commented on FLINK-25614: - [~jark][~jingzhang], we can not use getLong anymore actually

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475093#comment-17475093 ] Wenlong Lyu commented on FLINK-25600: - [~monster#12] thanks for offering help, I am sorry that the

[jira] [Commented] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

[ https://issues.apache.org/jira/browse/FLINK-25614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474394#comment-17474394 ] Wenlong Lyu commented on FLINK-25614: - hi, I think this is a bug actually. [~lmagics] could you also

[jira] [Commented] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474384#comment-17474384 ] Wenlong Lyu commented on FLINK-25070: - [~MartijnVisser], yes, by default the sql operator name would

[jira] [Updated] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25600: Component/s: Table SQL / API Table SQL / Client > Support new statement set

[jira] [Created] (FLINK-25600) Support new statement set syntax in sql client and update docs

Wenlong Lyu created FLINK-25600: --- Summary: Support new statement set syntax in sql client and update docs Key: FLINK-25600 URL: https://issues.apache.org/jira/browse/FLINK-25600 Project: Flink

[jira] [Commented] (FLINK-23031) Support to emit window result with periodic or non_periodic

[ https://issues.apache.org/jira/browse/FLINK-23031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17471687#comment-17471687 ] Wenlong Lyu commented on FLINK-23031: - hi, [~aitozi], according to your description: you are trying

[jira] [Commented] (FLINK-25463) Set is not supported in User Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-25463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17466356#comment-17466356 ] Wenlong Lyu commented on FLINK-25463: - hi, [~surendra.lalwani], As I known, there is no type of Set

[jira] [Commented] (FLINK-25463) Set is not supported in User Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-25463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465973#comment-17465973 ] Wenlong Lyu commented on FLINK-25463: - hi, [~surendra.lalwani] could you post more detail about your

[jira] [Commented] (FLINK-25459) When inserting row type fields into sink, the order needs to be maintained

[ https://issues.apache.org/jira/browse/FLINK-25459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465946#comment-17465946 ] Wenlong Lyu commented on FLINK-25459: - [~qyw919867774] the matching logic is defined in SQL standard

[jira] [Commented] (FLINK-25459) When inserting row type fields into sink, the order needs to be maintained

[ https://issues.apache.org/jira/browse/FLINK-25459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465916#comment-17465916 ] Wenlong Lyu commented on FLINK-25459: - [~qyw919867774] this is by designed. you can try insert into

[jira] [Commented] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463861#comment-17463861 ] Wenlong Lyu commented on FLINK-25409: - hi, [~MartijnVisser], you are right about the sharing.

[jira] [Commented] (FLINK-25411) JsonRowSerializationSchema unable to parse TIMESTAMP_LTZ fields

[ https://issues.apache.org/jira/browse/FLINK-25411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463849#comment-17463849 ] Wenlong Lyu commented on FLINK-25411: - [~surendra.lalwani] I think it would be better to post an

[jira] [Commented] (FLINK-25409) Add cache metric to LookupFunction

[ https://issues.apache.org/jira/browse/FLINK-25409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463826#comment-17463826 ] Wenlong Lyu commented on FLINK-25409: - hi, [~MartijnVisser] this ticket may be not relevant to the

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17463276#comment-17463276 ] Wenlong Lyu commented on FLINK-25217: - [~twalthr] ok, I can take subtask 1 first, if no one take it

[jira] [Commented] (FLINK-25217) FLIP-190: Support Version Upgrades for Table API & SQL Programs

[ https://issues.apache.org/jira/browse/FLINK-25217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462929#comment-17462929 ] Wenlong Lyu commented on FLINK-25217: - hi, [~twalthr] could you assign the issues on table

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462909#comment-17462909 ] Wenlong Lyu commented on FLINK-25137: - [~liuhb86] you could close this issue, since it is not a bug

[jira] [Commented] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462579#comment-17462579 ] Wenlong Lyu commented on FLINK-25337: - Regarding sql validation，I think it is necessary to go

[jira] [Commented] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462572#comment-17462572 ] Wenlong Lyu commented on FLINK-25337: - hi,[~vim-wang] I think it would be better if you could post

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17462349#comment-17462349 ] Wenlong Lyu commented on FLINK-25330: - Hi, Maybe we could support customized DeserializationSchema,

[jira] [Commented] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460499#comment-17460499 ] Wenlong Lyu commented on FLINK-25337: - hi, [~vim-wang], I think it is because we need to check not

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460396#comment-17460396 ] Wenlong Lyu commented on FLINK-25330: - hi, [~Bruce Wong] I have a concern on deleting all of the

[jira] [Commented] (FLINK-25272) Flink sql syntax analysis is inconsistent with the sql grammer declared now

[ https://issues.apache.org/jira/browse/FLINK-25272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458209#comment-17458209 ] Wenlong Lyu commented on FLINK-25272: - hi， [~lam167] I think this is a doc missing issue instead of

[jira] [Commented] (FLINK-25265) RUNNING to FAILED with failure cause. This might indicate that the remote task manager was lost.

[ https://issues.apache.org/jira/browse/FLINK-25265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17458134#comment-17458134 ] Wenlong Lyu commented on FLINK-25265: - hi， [~coco_yiyayiya] have you checked the log of task manager

[jira] [Commented] (FLINK-25171) When the DDL statement was executed, the column names of the Derived Columns were not validated

[ https://issues.apache.org/jira/browse/FLINK-25171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454432#comment-17454432 ] Wenlong Lyu commented on FLINK-25171: - I think it is good to not allow duplicated column name in

[jira] [Created] (FLINK-25198) add document about how to debug with the name and description

Wenlong Lyu created FLINK-25198: --- Summary: add document about how to debug with the name and description Key: FLINK-25198 URL: https://issues.apache.org/jira/browse/FLINK-25198 Project: Flink

[jira] [Commented] (FLINK-25149) getScanRuntimeProvider method called before the pushDown method,

[ https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452845#comment-17452845 ] Wenlong Lyu commented on FLINK-25149: - [~waittting] no, source function will not execute in

[jira] [Commented] (FLINK-25149) getScanRuntimeProvider method called before the pushDown method,

[ https://issues.apache.org/jira/browse/FLINK-25149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452788#comment-17452788 ] Wenlong Lyu commented on FLINK-25149: - [~waittting] currently the table planner will validate the

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452708#comment-17452708 ] Wenlong Lyu commented on FLINK-25137: - [~liuhb86] there is no much documents about it. Generally

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452705#comment-17452705 ] Wenlong Lyu commented on FLINK-25117: - [~zzt] when using the image, you can copy only connector

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17452108#comment-17452108 ] Wenlong Lyu commented on FLINK-25137: - hi, [~liuhb86] this is a by-designed limitation on Flink

[jira] [Updated] (FLINK-25123) Improve expression description in SQL operator

[ https://issues.apache.org/jira/browse/FLINK-25123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25123: Fix Version/s: 1.15.0 > Improve expression description in SQL operator >

[jira] [Updated] (FLINK-25076) Simplify name of SQL operators

[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25076: Fix Version/s: 1.15.0 > Simplify name of SQL operators > -- > >

[jira] [Updated] (FLINK-25076) Simplify name of SQL operators

[ https://issues.apache.org/jira/browse/FLINK-25076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25076: Component/s: Table SQL / Planner > Simplify name of SQL operators >

[jira] [Updated] (FLINK-25074) Simplify name of window operators in DS by moving details to description

[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25074: Fix Version/s: 1.15.0 > Simplify name of window operators in DS by moving details to description

[jira] [Updated] (FLINK-25074) Simplify name of window operators in DS by moving details to description

[ https://issues.apache.org/jira/browse/FLINK-25074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25074: Component/s: API / DataStream > Simplify name of window operators in DS by moving details to

[jira] [Updated] (FLINK-25073) Introduce Tree Mode description for job vertex

[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25073: Component/s: API / DataStream > Introduce Tree Mode description for job vertex >

[jira] [Updated] (FLINK-25073) Introduce Tree Mode description for job vertex

[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25073: Fix Version/s: 1.15.0 > Introduce Tree Mode description for job vertex >

[jira] [Updated] (FLINK-25072) Introduce description for operator

[ https://issues.apache.org/jira/browse/FLINK-25072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25072: Fix Version/s: 1.15.0 > Introduce description for operator > -- >

[jira] [Updated] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25070: Fix Version/s: 1.15.0 > FLIP-195: Improve the name and structure of vertex and operator name for

[jira] [Created] (FLINK-25123) Improve expression description in SQL operator

Wenlong Lyu created FLINK-25123: --- Summary: Improve expression description in SQL operator Key: FLINK-25123 URL: https://issues.apache.org/jira/browse/FLINK-25123 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451528#comment-17451528 ] Wenlong Lyu commented on FLINK-25117: - [~zzt] I would suggest you not put any flink jars from 1.13.3

[jira] [Commented] (FLINK-25117) NoSuchMethodError getCatalog()

[ https://issues.apache.org/jira/browse/FLINK-25117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17451499#comment-17451499 ] Wenlong Lyu commented on FLINK-25117: - hi, [~zzt] the method

[jira] [Created] (FLINK-25118) Add vertex index as prefix in vertex name

Wenlong Lyu created FLINK-25118: --- Summary: Add vertex index as prefix in vertex name Key: FLINK-25118 URL: https://issues.apache.org/jira/browse/FLINK-25118 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450880#comment-17450880 ] Wenlong Lyu commented on FLINK-20370: - [~lincoln.86xy] Even sink implements ParallelismProvider,

[jira] [Created] (FLINK-25074) Simplify name of window operators in DS by moving details to description

Wenlong Lyu created FLINK-25074: --- Summary: Simplify name of window operators in DS by moving details to description Key: FLINK-25074 URL: https://issues.apache.org/jira/browse/FLINK-25074 Project:

[jira] [Created] (FLINK-25076) Simplify name of SQL operators

Wenlong Lyu created FLINK-25076: --- Summary: Simplify name of SQL operators Key: FLINK-25076 URL: https://issues.apache.org/jira/browse/FLINK-25076 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-25073) Introduce Tree Mode description for job vertex

[ https://issues.apache.org/jira/browse/FLINK-25073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25073: Summary: Introduce Tree Mode description for job vertex (was: Introduce Tree Mode) > Introduce

[jira] [Created] (FLINK-25073) Introduce Tree Mode

Wenlong Lyu created FLINK-25073: --- Summary: Introduce Tree Mode Key: FLINK-25073 URL: https://issues.apache.org/jira/browse/FLINK-25073 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-25072) Introduce description for operator

Wenlong Lyu created FLINK-25072: --- Summary: Introduce description for operator Key: FLINK-25072 URL: https://issues.apache.org/jira/browse/FLINK-25072 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

Wenlong Lyu created FLINK-25070: --- Summary: FLIP-195: Improve the name and structure of vertex and operator name for job Key: FLINK-25070 URL: https://issues.apache.org/jira/browse/FLINK-25070 Project:

[jira] [Updated] (FLINK-25070) FLIP-195: Improve the name and structure of vertex and operator name for job

[ https://issues.apache.org/jira/browse/FLINK-25070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-25070: Description: this is an umbrella issue tracking the improvement of operator/vertex names in

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447367#comment-17447367 ] Wenlong Lyu commented on FLINK-20370: - hi, [~lincoln.86xy], what do you think we should provide when

[jira] [Commented] (FLINK-24975) Add hooks and extension points to FlinkSQL

[ https://issues.apache.org/jira/browse/FLINK-24975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17447194#comment-17447194 ] Wenlong Lyu commented on FLINK-24975: - hi, [~dahaishuantuoba], it is an interesting idea. Do you

[jira] [Commented] (FLINK-24870) Cannot cast "java.util.Date" to "java.time.Instant"

[ https://issues.apache.org/jira/browse/FLINK-24870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442191#comment-17442191 ] Wenlong Lyu commented on FLINK-24870: - [~wangbaohua] default external type for TIMESTAMP_LTZ is

[jira] [Commented] (FLINK-24861) Flink MySQL Look cache update for empty hit

[ https://issues.apache.org/jira/browse/FLINK-24861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17442186#comment-17442186 ] Wenlong Lyu commented on FLINK-24861: - hi, [~gaurav726] I have a different point: it is ok to cache

[jira] [Commented] (FLINK-24847) Decide the overflows behaviour

[ https://issues.apache.org/jira/browse/FLINK-24847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441198#comment-17441198 ] Wenlong Lyu commented on FLINK-24847: - hi, have you try the latest code to see if the inconsistent

[jira] [Commented] (FLINK-24843) DynamicTableFactory.Context.getCatalogTable().getPartitionKeys() should return indexes

[ https://issues.apache.org/jira/browse/FLINK-24843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441143#comment-17441143 ] Wenlong Lyu commented on FLINK-24843: - hi, I'm afraid that return index may not friendly at api,

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440153#comment-17440153 ] Wenlong Lyu commented on FLINK-20370: - [~twalthr] thanks for the explanation. However, I think when

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439220#comment-17439220 ] Wenlong Lyu commented on FLINK-20370: - hi, [~twalthr], could you explain more about case 2, what

[jira] [Commented] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans

[ https://issues.apache.org/jira/browse/FLINK-24716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437103#comment-17437103 ] Wenlong Lyu commented on FLINK-24716: - the filter is pruned, not lost. I am also +1 for not keeping

[jira] [Commented] (FLINK-24716) Non-equality predicates on partition columns lead to incorrect plans

[ https://issues.apache.org/jira/browse/FLINK-24716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17436901#comment-17436901 ] Wenlong Lyu commented on FLINK-24716: - I think the plan is correct, the swallowed predicate has been

[jira] [Commented] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435175#comment-17435175 ] Wenlong Lyu commented on FLINK-24501: - [~qingru zhang] in you case，if the watermark can be

[jira] [Commented] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435137#comment-17435137 ] Wenlong Lyu commented on FLINK-24501: - [~qingru zhang] I think watermark should be the min of all

[jira] [Commented] (FLINK-24501) Unexpected behavior of cumulate window aggregate for late event after recover from sp/cp

[ https://issues.apache.org/jira/browse/FLINK-24501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17432190#comment-17432190 ] Wenlong Lyu commented on FLINK-24501: - I think it may be better to make sure that watermark would

[jira] [Commented] (FLINK-24412) retract stream join on topN error

[ https://issues.apache.org/jira/browse/FLINK-24412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17422603#comment-17422603 ] Wenlong Lyu commented on FLINK-24412: - hi, [~sandyfog], Lookup join can not work well on

[jira] [Commented] (FLINK-23353) UDTAGG can't execute in Batch mode

[ https://issues.apache.org/jira/browse/FLINK-23353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382014#comment-17382014 ] Wenlong Lyu commented on FLINK-23353: - hi, [~hayden zhou], Table Aggregate only supported in

[jira] [Commented] (FLINK-23385) Fix nullability of COALESCE

[ https://issues.apache.org/jira/browse/FLINK-23385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17382009#comment-17382009 ] Wenlong Lyu commented on FLINK-23385: - hi, [~twalthr] I think the root cause of the issue is the

[jira] [Commented] (FLINK-23159) Correlated sql subquery on the source created via fromValues() failed to compile

[ https://issues.apache.org/jira/browse/FLINK-23159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17373308#comment-17373308 ] Wenlong Lyu commented on FLINK-23159: - [~gaoyunhaii] Thanks for reporting the issue, the root cause

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365301#comment-17365301 ] Wenlong Lyu commented on FLINK-22954: - [~godfreyhe] thanks for correct me, you are right. so when

[jira] [Commented] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365238#comment-17365238 ] Wenlong Lyu commented on FLINK-22954: - [~jark][~godfreyhe], I think ConstantTableFunctionScanRule

[jira] [Comment Edited] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17365238#comment-17365238 ] Wenlong Lyu edited comment on FLINK-22954 at 6/18/21, 4:37 AM: ---

[jira] [Updated] (FLINK-22998) Flink SQL does not support block comment before SET command

[ https://issues.apache.org/jira/browse/FLINK-22998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-22998: Component/s: (was: Table SQL / Planner) Table SQL / API > Flink SQL does not

[jira] [Commented] (FLINK-22714) Simplify `StreamPhysicalWindowTableFunction` to a simple window assigner if successor node with `WindowAttachedWindowingStrategy` in planner

[ https://issues.apache.org/jira/browse/FLINK-22714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17358430#comment-17358430 ] Wenlong Lyu commented on FLINK-22714: - hi, [~qingru zhang], is this issue depends on other feature

[jira] [Commented] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

[ https://issues.apache.org/jira/browse/FLINK-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348947#comment-17348947 ] Wenlong Lyu commented on FLINK-7271: hi, [~twalthr] [~xueyu] I investigate a bit on the case, the

[jira] [Commented] (FLINK-22437) Miss adding parallesim for filter operator in batch mode

[ https://issues.apache.org/jira/browse/FLINK-22437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348082#comment-17348082 ] Wenlong Lyu commented on FLINK-22437: - [~zoucao] thanks for reporting the bug, the bug is already

[jira] [Commented] (FLINK-22454) Failed to translate Lookup Join when join on a CAST expression on dimention table column

[ https://issues.apache.org/jira/browse/FLINK-22454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17348075#comment-17348075 ] Wenlong Lyu commented on FLINK-22454: - Hi, [~fsk119], I think is error is by designed. Lookup join

[jira] [Commented] (FLINK-22486) Wrong results of the IN operator

[ https://issues.apache.org/jira/browse/FLINK-22486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342973#comment-17342973 ] Wenlong Lyu commented on FLINK-22486: - discussed with [~fsk119] offline, this issue is invalid, can

[jira] [Commented] (FLINK-22448) FlinkRexUtil create Sarg String array elemet supplement space

[ https://issues.apache.org/jira/browse/FLINK-22448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342972#comment-17342972 ] Wenlong Lyu commented on FLINK-22448: - hi, [~Akihito Liang], as tested in Flink-22486, I think this

[jira] [Commented] (FLINK-22486) Wrong results of the IN operator

[ https://issues.apache.org/jira/browse/FLINK-22486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17342613#comment-17342613 ] Wenlong Lyu commented on FLINK-22486: - Hi, [~fsk119] I have tried the case you post on master and

[jira] [Updated] (FLINK-14763) flink sql cep parallelism error

[ https://issues.apache.org/jira/browse/FLINK-14763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-14763: Component/s: (was: Table SQL / Planner) Table SQL / Runtime > flink sql cep

[jira] [Updated] (FLINK-14848) BaseRowSerializer.toBinaryRow wrongly process null for non-compact decimal

[ https://issues.apache.org/jira/browse/FLINK-14848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-14848: Component/s: (was: Table SQL / Planner) Table SQL / Runtime >

[jira] [Updated] (FLINK-15040) Open function is not called in UDF AggregateFunction

[ https://issues.apache.org/jira/browse/FLINK-15040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-15040: Component/s: (was: Table SQL / Planner) Table SQL / Runtime > Open function

[jira] [Updated] (FLINK-15183) Use SQL-CLI to TPC-DS E2E test

[ https://issues.apache.org/jira/browse/FLINK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenlong Lyu updated FLINK-15183: Component/s: (was: Table SQL / Planner) Table SQL / API > Use SQL-CLI to

  1   2   3   >