[jira] [Commented] (FLINK-28569) SinkUpsertMaterializer should be aware of the input upsertKey if it is not empty otherwise wrong result maybe produced

2022-10-11 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615706#comment-17615706 ] Terry Wang commented on FLINK-28569: But for the query which don't have upsert key a

[jira] [Commented] (FLINK-28569) SinkUpsertMaterializer should be aware of the input upsertKey if it is not empty otherwise wrong result maybe produced

2022-10-11 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17615681#comment-17615681 ] Terry Wang commented on FLINK-28569: +1 to backport this fix into 1.14 and 1.15 > S

[jira] [Commented] (FLINK-26334) When timestamp - offset + windowSize < 0, elements cannot be assigned to the correct window

2022-03-04 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17501258#comment-17501258 ] Terry Wang commented on FLINK-26334: Good insight about the description of problem a

[jira] [Updated] (FLINK-23289) BinarySection should add null check in constructor method

2021-07-06 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-23289: --- Summary: BinarySection should add null check in constructor method (was: BinarySection should null

[jira] [Updated] (FLINK-23289) BinarySection should null check in constructor method

2021-07-06 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-23289: --- Component/s: Table SQL / Runtime > BinarySection should null check in constructor method > -

[jira] [Created] (FLINK-23289) BinarySection should null check in contusctor method

2021-07-06 Thread Terry Wang (Jira)
Terry Wang created FLINK-23289: -- Summary: BinarySection should null check in contusctor method Key: FLINK-23289 URL: https://issues.apache.org/jira/browse/FLINK-23289 Project: Flink Issue Type:

[jira] [Updated] (FLINK-23289) BinarySection should null check in constructor method

2021-07-06 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-23289: --- Summary: BinarySection should null check in constructor method (was: BinarySection should null chec

[jira] [Closed] (FLINK-18516) Improve error message for rank function in streaming mode

2021-06-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang closed FLINK-18516. -- Resolution: Works for Me > Improve error message for rank function in streaming mode > ---

[jira] [Comment Edited] (FLINK-18516) Improve error message for rank function in streaming mode

2021-06-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357087#comment-17357087 ] Terry Wang edited comment on FLINK-18516 at 6/4/21, 6:13 AM: -

[jira] [Commented] (FLINK-18516) Improve error message for rank function in streaming mode

2021-06-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17357087#comment-17357087 ] Terry Wang commented on FLINK-18516: hi [~lirui] What's your flink version reporting

[jira] [Closed] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

2021-05-28 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang closed FLINK-15775. -- Fix Version/s: 1.11.0 Release Note: Has fixed after flink 1.11 Resolution: Invalid > Sourc

[jira] [Comment Edited] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

2021-05-25 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351040#comment-17351040 ] Terry Wang edited comment on FLINK-15775 at 5/25/21, 12:50 PM: ---

[jira] [Commented] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

2021-05-25 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17351040#comment-17351040 ] Terry Wang commented on FLINK-15775: Hi, [~BenoitParis]~ > SourceFunctions are inst

[jira] [Commented] (FLINK-22654) SqlCreateTable toString()/unparse() lose CONSTRAINTS and watermarks

2021-05-13 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17344282#comment-17344282 ] Terry Wang commented on FLINK-22654: I reproduce this problem in my local environmen

[jira] [Created] (FLINK-21972) Check whether TemporalTableSourceSpec can be serialized or not

2021-03-25 Thread Terry Wang (Jira)
Terry Wang created FLINK-21972: -- Summary: Check whether TemporalTableSourceSpec can be serialized or not Key: FLINK-21972 URL: https://issues.apache.org/jira/browse/FLINK-21972 Project: Flink

[jira] [Created] (FLINK-21868) Support StreamExecLookupJoin json serialization/deserialization

2021-03-19 Thread Terry Wang (Jira)
Terry Wang created FLINK-21868: -- Summary: Support StreamExecLookupJoin json serialization/deserialization Key: FLINK-21868 URL: https://issues.apache.org/jira/browse/FLINK-21868 Project: Flink

[jira] [Created] (FLINK-21864) Support StreamExecTemporalJoin json serialization/deserialization

2021-03-18 Thread Terry Wang (Jira)
Terry Wang created FLINK-21864: -- Summary: Support StreamExecTemporalJoin json serialization/deserialization Key: FLINK-21864 URL: https://issues.apache.org/jira/browse/FLINK-21864 Project: Flink

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin json ser/de

2021-03-18 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21837: --- Description: Support StreamExecIntervalJoin json ser/des (was: Support StreamExecIntervalJoin/Strea

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin json ser/de

2021-03-18 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21837: --- Summary: Support StreamExecIntervalJoin json ser/de (was: Support StreamExecIntervalJoin/StreamExec

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/de

2021-03-16 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21837: --- Summary: Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/de (w

[jira] [Created] (FLINK-21837) Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/des

2021-03-16 Thread Terry Wang (Jira)
Terry Wang created FLINK-21837: -- Summary: Support StreamExecIntervalJoin/StreamExecLookupJoin/StreamExecTemporalJoin json ser/des Key: FLINK-21837 URL: https://issues.apache.org/jira/browse/FLINK-21837 P

[jira] [Created] (FLINK-21811) Support StreamExecJoin json serialization/deserialization

2021-03-16 Thread Terry Wang (Jira)
Terry Wang created FLINK-21811: -- Summary: Support StreamExecJoin json serialization/deserialization Key: FLINK-21811 URL: https://issues.apache.org/jira/browse/FLINK-21811 Project: Flink Issue T

[jira] [Comment Edited] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302255#comment-17302255 ] Terry Wang edited comment on FLINK-21802 at 3/16/21, 6:40 AM:

[jira] [Commented] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302255#comment-17302255 ] Terry Wang commented on FLINK-21802: It seems I mistakenly put this issure under FLI

[jira] [Created] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
Terry Wang created FLINK-21802: -- Summary: LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType Key: FLINK-21802 URL: https://issues.apache.org/jira/browse/FLINK-21802 Proj

[jira] [Commented] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization

2021-03-12 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300167#comment-17300167 ] Terry Wang commented on FLINK-21744: hi [~godfreyhe]~ I'd like to complete this exci

[jira] [Updated] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization

2021-03-12 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21744: --- Fix Version/s: 1.13.0 > Support StreamExecDeduplicate json serialization/deserialization > -

[jira] [Created] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization

2021-03-12 Thread Terry Wang (Jira)
Terry Wang created FLINK-21744: -- Summary: Support StreamExecDeduplicate json serialization/deserialization Key: FLINK-21744 URL: https://issues.apache.org/jira/browse/FLINK-21744 Project: Flink

[jira] [Commented] (FLINK-15848) Support both fixed allocator and dynamic allocator in flink

2020-05-25 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17115867#comment-17115867 ] Terry Wang commented on FLINK-15848: +1 for this feature. It's very useful in benchm

[jira] [Commented] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102290#comment-17102290 ] Terry Wang commented on FLINK-17553: I open a PR https://github.com/apache/flink/pul

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Fix Version/s: 1.11.0 > Constant exists in group window key leads to error: Unsupported call: > T

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: !temp.png! We can reproduce this problem by add fol

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: !temp.png! We can reproduce this problem by add fol

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: !temp.png! We can reproduce this problem by add fol

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: !temp.png! We can reproduce this problem by add fol

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: !temp.png! We can reproduce this problem by add fol

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Description: Exception stack is as following: > Constant exists in group window key leads to err

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Attachment: temp.png > Constant exists in group window key leads to error: Unsupported call: > TU

[jira] [Updated] (FLINK-17553) Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17553: --- Summary: Constant exists in group window key leads to error: Unsupported call: TUMBLE_END(TIMESTAM

[jira] [Created] (FLINK-17553) Group by constant and window causes error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL)

2020-05-07 Thread Terry Wang (Jira)
Terry Wang created FLINK-17553: -- Summary: Group by constant and window causes error: Unsupported call: TUMBLE_END(TIMESTAMP(3) NOT NULL) Key: FLINK-17553 URL: https://issues.apache.org/jira/browse/FLINK-17553

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/varchar with precision into sink using TypeInformation of row

2020-04-24 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java} tEnv.sqlUpdate("

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/varchar with precision into sink using TypeInformation of row

2020-04-24 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17313: --- Summary: Validation error when insert decimal/varchar with precision into sink using TypeInformation

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089530#comment-17089530 ] Terry Wang commented on FLINK-17313: supportsAvoidingCast method behavior looks righ

[jira] [Comment Edited] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089371#comment-17089371 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:35 AM:

[jira] [Comment Edited] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089371#comment-17089371 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:24 AM:

[jira] [Comment Edited] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089370#comment-17089370 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:22 AM:

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089371#comment-17089371 ] Terry Wang commented on FLINK-17313: We can not forbid using old connector in ddl, a

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089370#comment-17089370 ] Terry Wang commented on FLINK-17313: I think you may misunderstand my fix. Source an

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089362#comment-17089362 ] Terry Wang commented on FLINK-17313: Hi [~dwysakowicz] The types that originate form

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-22 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089357#comment-17089357 ] Terry Wang commented on FLINK-17313: [~lzljs3620320] There isn't much need to introd

[jira] [Comment Edited] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089326#comment-17089326 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 6:19 AM:

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089326#comment-17089326 ] Terry Wang commented on FLINK-17313: [~jark] I agree with you that new sink interfa

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089258#comment-17089258 ] Terry Wang commented on FLINK-17313: I open a [https://github.com/apache/flink/pull

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java} tEnv.sqlUpdate("

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java} tEnv.sqlUpdate("

[jira] [Commented] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089251#comment-17089251 ] Terry Wang commented on FLINK-17313: cc [~ykt836][~jark][~dwysakowicz]Please have a

[jira] [Updated] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-17313: --- Description: Test code like follwing(in blink planner): {code:java} tEnv.sqlUpdate("

[jira] [Created] (FLINK-17313) Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row

2020-04-21 Thread Terry Wang (Jira)
Terry Wang created FLINK-17313: -- Summary: Validation error when insert decimal/timestamp/varchar with precision into sink using TypeInformation of row Key: FLINK-17313 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Commented] (FLINK-17263) Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker

2020-04-20 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17087585#comment-17087585 ] Terry Wang commented on FLINK-17263: I open a [PR|https://github.com/apache/flink/pu

[jira] [Created] (FLINK-17263) Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker

2020-04-20 Thread Terry Wang (Jira)
Terry Wang created FLINK-17263: -- Summary: Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker Key: FLINK-17263 URL: https://issues.apache.org/jira/browse/

[jira] [Comment Edited] (FLINK-17152) FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition

2020-04-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083878#comment-17083878 ] Terry Wang edited comment on FLINK-17152 at 4/15/20, 7:48 AM:

[jira] [Commented] (FLINK-17152) FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition

2020-04-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17083878#comment-17083878 ] Terry Wang commented on FLINK-17152: cc [~liyu2] I think this bug should be included

[jira] [Created] (FLINK-17152) FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition

2020-04-15 Thread Terry Wang (Jira)
Terry Wang created FLINK-17152: -- Summary: FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition Key: FLINK-17152 URL: https://issues.apache.org/jira/browse/FLINK-17152

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-02 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073653#comment-17073653 ] Terry Wang commented on FLINK-16924: hi [~jark] It's ok doing so. It's okey for me t

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-02 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17073443#comment-17073443 ] Terry Wang commented on FLINK-16924: hi [~twalthr] My use case is to explain the exe

[jira] [Commented] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17072801#comment-17072801 ] Terry Wang commented on FLINK-16924: cc [~danny0405] > TableEnvironment#sqlUpdate t

[jira] [Updated] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16924: --- Description: Now in the latest code of flink master branch, we encountered unexpected npe exception

[jira] [Updated] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16924: --- Attachment: 7871C046-4D67-49C8-AC8A-A4030A7981CC.png > TableEnvironment#sqlUpdate throw NPE when cal

[jira] [Created] (FLINK-16924) TableEnvironment#sqlUpdate throw NPE when called in async thread

2020-04-01 Thread Terry Wang (Jira)
Terry Wang created FLINK-16924: -- Summary: TableEnvironment#sqlUpdate throw NPE when called in async thread Key: FLINK-16924 URL: https://issues.apache.org/jira/browse/FLINK-16924 Project: Flink

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Description: We can reproduce this problem in FlinkSqlParserImplTest, add one more column definitio

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Affects Version/s: 1.10.0 > SqlCreateTable can not get the original text when there exists non-ascii

[jira] [Commented] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17055527#comment-17055527 ] Terry Wang commented on FLINK-16506: cc [~danny0405] to have a look > SqlCreateTabl

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii code in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Description: We can reproduce this problem in FlinkSqlParserImplTest, add one more column definitio

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii char in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Summary: SqlCreateTable can not get the original text when there exists non-ascii char in the column

[jira] [Updated] (FLINK-16506) SqlCreateTable can not get the original text when there exists non-ascii code in the column definition

2020-03-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16506: --- Summary: SqlCreateTable can not get the original text when there exists non-ascii code in the column

[jira] [Created] (FLINK-16506) Sql

2020-03-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-16506: -- Summary: Sql Key: FLINK-16506 URL: https://issues.apache.org/jira/browse/FLINK-16506 Project: Flink Issue Type: Bug Reporter: Terry Wang -- Thi

[jira] [Commented] (FLINK-16414) create udaf/udtf function using sql casuing ValidationException: SQL validation failed. null

2020-03-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050923#comment-17050923 ] Terry Wang commented on FLINK-16414: cc [~bli] to confirm~ > create udaf/udtf funct

[jira] [Updated] (FLINK-16414) create udaf/udtf function using sql casuing ValidationException: SQL validation failed. null

2020-03-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-16414: --- Description: When using TableEnvironment#sqlupdate to create a udaf or udtf function, which doesn't

[jira] [Created] (FLINK-16414) create udaf/udtf function using sql casuing ValidationException: SQL validation failed. null

2020-03-03 Thread Terry Wang (Jira)
Terry Wang created FLINK-16414: -- Summary: create udaf/udtf function using sql casuing ValidationException: SQL validation failed. null Key: FLINK-16414 URL: https://issues.apache.org/jira/browse/FLINK-16414

[jira] [Commented] (FLINK-15544) Upgrade http-core version to avoid potential DeadLock problem

2020-02-03 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028767#comment-17028767 ] Terry Wang commented on FLINK-15544: hi [~chesnay] It works well after I bundle a ne

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-13 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014903#comment-17014903 ] Terry Wang commented on FLINK-15552: Hi, [~jark]. I'm sure about it. As for SQL CLI

[jira] [Updated] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-10 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15552: --- Description: How to Reproduce: first, I start a sql client and using `-l` to point to a kafka connec

[jira] [Updated] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-10 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15552: --- Description: How to Reproduce: first, I start a sql client and using `-l` to point to a kafka connec

[jira] [Updated] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-10 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15552: --- Description: How to Reproduce: first, I start a sql client and using `-l` to point to a kafka connec

[jira] [Created] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

2020-01-10 Thread Terry Wang (Jira)
Terry Wang created FLINK-15552: -- Summary: SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory Key: FLINK-15552 URL: https://issues.apache.org/jira/browse/FLINK-1555

[jira] [Updated] (FLINK-15544) Upgrade http-core version to avoid potential DeadLock problem

2020-01-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15544: --- Description: Due to the bug of http-core:4..46 (we current use) HTTPCORE-446, it may cause the bug

[jira] [Updated] (FLINK-15544) Upgrade http-core version to avoid potential DeadLock problem

2020-01-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15544: --- Description: Due to the bug of http-core:4..46 (we current use) https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-15544) Upgrade http-core version to avoid potential DeadLock problem

2020-01-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-15544: -- Summary: Upgrade http-core version to avoid potential DeadLock problem Key: FLINK-15544 URL: https://issues.apache.org/jira/browse/FLINK-15544 Project: Flink Is

[jira] [Commented] (FLINK-15429) read hive table null value of timestamp type will throw an npe

2019-12-27 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004153#comment-17004153 ] Terry Wang commented on FLINK-15429: cc [~lirui] > read hive table null value of ti

[jira] [Created] (FLINK-15429) read hive table null value of timestamp type will throw an npe

2019-12-27 Thread Terry Wang (Jira)
Terry Wang created FLINK-15429: -- Summary: read hive table null value of timestamp type will throw an npe Key: FLINK-15429 URL: https://issues.apache.org/jira/browse/FLINK-15429 Project: Flink I

[jira] [Created] (FLINK-15398) Correct catalog doc example mistake

2019-12-25 Thread Terry Wang (Jira)
Terry Wang created FLINK-15398: -- Summary: Correct catalog doc example mistake Key: FLINK-15398 URL: https://issues.apache.org/jira/browse/FLINK-15398 Project: Flink Issue Type: Bug Com

[jira] [Comment Edited] (FLINK-15256) unable to drop table in HiveCatalogITCase

2019-12-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996974#comment-16996974 ] Terry Wang edited comment on FLINK-15256 at 12/16/19 5:17 AM:

[jira] [Commented] (FLINK-15256) unable to drop table in HiveCatalogITCase

2019-12-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996974#comment-16996974 ] Terry Wang commented on FLINK-15256: I add `tableEnv.sqlUpdate("drop table myhive.`d

[jira] [Commented] (FLINK-15259) HiveInspector.toInspectors() should convert Flink constant to Hive constant

2019-12-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16996942#comment-16996942 ] Terry Wang commented on FLINK-15259: Why it is not a blocker? It'll cause hive funct

[jira] [Commented] (FLINK-15192) consider split 'SQL' page into multiple sub pages for better clarity

2019-12-13 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995463#comment-16995463 ] Terry Wang commented on FLINK-15192: I'd like to improve it. After https://issues.ap

[jira] [Created] (FLINK-15242) Add doc to introduce ddls or dmls supported by sql cli

2019-12-13 Thread Terry Wang (Jira)
Terry Wang created FLINK-15242: -- Summary: Add doc to introduce ddls or dmls supported by sql cli Key: FLINK-15242 URL: https://issues.apache.org/jira/browse/FLINK-15242 Project: Flink Issue Type

[jira] [Commented] (FLINK-13437) Add Hive SQL E2E test

2019-12-10 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993142#comment-16993142 ] Terry Wang commented on FLINK-13437: hi [~liyu] I didn't have the permission to chan

[jira] [Updated] (FLINK-15148) Add doc for create/drop/alter database ddl

2019-12-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15148: --- Component/s: Documentation > Add doc for create/drop/alter database ddl > --

[jira] [Updated] (FLINK-15147) Add doc for alter table set properties and rename table ddl

2019-12-09 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-15147: --- Summary: Add doc for alter table set properties and rename table ddl (was: Add doc for alter table

[jira] [Created] (FLINK-15148) Add doc for create/drop/alter database ddl

2019-12-09 Thread Terry Wang (Jira)
Terry Wang created FLINK-15148: -- Summary: Add doc for create/drop/alter database ddl Key: FLINK-15148 URL: https://issues.apache.org/jira/browse/FLINK-15148 Project: Flink Issue Type: Sub-task

  1   2   >