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

[ https://issues.apache.org/jira/browse/FLINK-28569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17615706#comment-17615706 ] Terry Wang commented on FLINK-28569: But for the query which don't have upsert key and with

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-26334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501258#comment-17501258 ] Terry Wang commented on FLINK-26334: Good insight about the description of problem and cause

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

[ 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

[ 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

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

[ 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

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

[ 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

[ https://issues.apache.org/jira/browse/FLINK-18516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17357087#comment-17357087 ] Terry Wang edited comment on FLINK-18516 at 6/4/21, 6:13 AM: - hi [~lirui]

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

[ https://issues.apache.org/jira/browse/FLINK-18516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17357087#comment-17357087 ] Terry Wang commented on FLINK-18516: hi [~lirui] What's your flink version reporting this npe? I can

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

[ 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 >

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17351040#comment-17351040 ] Terry Wang commented on FLINK-15775: Hi, [~BenoitParis]~ > SourceFunctions are instantiated twice

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

[ https://issues.apache.org/jira/browse/FLINK-22654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344282#comment-17344282 ] Terry Wang commented on FLINK-22654: I reproduce this problem in my local environment, and it's a

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

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

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

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

[ 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

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

[ 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

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

[ 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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302255#comment-17302255 ] Terry Wang edited comment on FLINK-21802 at 3/16/21, 6:40 AM: -- It seems I

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

[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302255#comment-17302255 ] Terry Wang commented on FLINK-21802: It seems I mistakenly put this issure under FLINK-20435, anyone

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-21744?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300167#comment-17300167 ] Terry Wang commented on FLINK-21744: hi [~godfreyhe]~ I'd like to complete this exciting task. Feel

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115867#comment-17115867 ] Terry Wang commented on FLINK-15848: +1 for this feature. It's very useful in benchmark and some

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

[ https://issues.apache.org/jira/browse/FLINK-17553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102290#comment-17102290 ] Terry Wang commented on FLINK-17553: I open a PR https://github.com/apache/flink/pull/12028 to help

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

[ 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: >

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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

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

[ 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: >

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

[ 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:

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

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

[ 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}

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089530#comment-17089530 ] Terry Wang commented on FLINK-17313: supportsAvoidingCast method behavior looks right to me, relaxed

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089371#comment-17089371 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:35 AM: -- We can not

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089371#comment-17089371 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:24 AM: -- We can not

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089370#comment-17089370 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 7:22 AM: -- I think you

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089371#comment-17089371 ] Terry Wang commented on FLINK-17313: We can not forbid using old connector in ddl, and the old type

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089370#comment-17089370 ] Terry Wang commented on FLINK-17313: I think you may misunderstand my fix. Source and sink should be

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089362#comment-17089362 ] Terry Wang commented on FLINK-17313: Hi [~dwysakowicz] The types that originate form the old type

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089357#comment-17089357 ] Terry Wang commented on FLINK-17313: [~lzljs3620320] There isn't much need to introduce a new

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089326#comment-17089326 ] Terry Wang edited comment on FLINK-17313 at 4/22/20, 6:19 AM: -- [~jark] I

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089326#comment-17089326 ] Terry Wang commented on FLINK-17313: [~jark] I agree with you that new sink interface of FLIP-95

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089258#comment-17089258 ] Terry Wang commented on FLINK-17313: I open a

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

[ 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}

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

[ 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}

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

[ https://issues.apache.org/jira/browse/FLINK-17313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089251#comment-17089251 ] Terry Wang commented on FLINK-17313: cc [~ykt836][~jark][~dwysakowicz]Please have a look on this

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

[ 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}

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

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:

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

[ https://issues.apache.org/jira/browse/FLINK-17263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087585#comment-17087585 ] Terry Wang commented on FLINK-17263: I open a [PR|https://github.com/apache/flink/pull/11819], and

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

Terry Wang created FLINK-17263: -- Summary: Remove RepeatFamilyOperandTypeChecker in blink planner and replace it with calcite's CompositeOperandTypeChecker Key: FLINK-17263 URL:

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

[ https://issues.apache.org/jira/browse/FLINK-17152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083878#comment-17083878 ] Terry Wang edited comment on FLINK-17152 at 4/15/20, 7:48 AM: -- cc [~liyu] I

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

[ https://issues.apache.org/jira/browse/FLINK-17152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083878#comment-17083878 ] Terry Wang commented on FLINK-17152: cc [~liyu2] I think this bug should be included in flink 1.10.1

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

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

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073653#comment-17073653 ] Terry Wang commented on FLINK-16924: hi [~jark] It's ok doing so. It's okey for me to add

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

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073443#comment-17073443 ] Terry Wang commented on FLINK-16924: hi [~twalthr] My use case is to explain the execute plan in

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

[ https://issues.apache.org/jira/browse/FLINK-16924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17072801#comment-17072801 ] Terry Wang commented on FLINK-16924: cc [~danny0405] > TableEnvironment#sqlUpdate throw NPE when

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

[ 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

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

[ 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

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

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

[ 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

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

[ 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

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

[ https://issues.apache.org/jira/browse/FLINK-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055527#comment-17055527 ] Terry Wang commented on FLINK-16506: cc [~danny0405] to have a look > SqlCreateTable can not get

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

[ 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

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

[ 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

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

[ 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

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

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 --

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

[ https://issues.apache.org/jira/browse/FLINK-16414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050923#comment-17050923 ] Terry Wang commented on FLINK-16414: cc [~bli] to confirm~ > create udaf/udtf function using sql

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

[ 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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028767#comment-17028767 ] Terry Wang commented on FLINK-15544: hi [~chesnay] It works well after I bundle a newer http-core

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

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

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

[ 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

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

[ 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

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

[ 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

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

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:

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

[ 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

[ 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)

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17004153#comment-17004153 ] Terry Wang commented on FLINK-15429: cc [~lirui] > read hive table null value of timestamp type

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

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

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996974#comment-16996974 ] Terry Wang edited comment on FLINK-15256 at 12/16/19 5:17 AM: -- I add

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

[ https://issues.apache.org/jira/browse/FLINK-15256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996974#comment-16996974 ] Terry Wang commented on FLINK-15256: I add `tableEnv.sqlUpdate("drop table

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

[ https://issues.apache.org/jira/browse/FLINK-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16996942#comment-16996942 ] Terry Wang commented on FLINK-15259: Why it is not a blocker? It'll cause hive function not work

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

[ https://issues.apache.org/jira/browse/FLINK-15192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16995463#comment-16995463 ] Terry Wang commented on FLINK-15192: I'd like to improve it. After

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-13437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16993142#comment-16993142 ] Terry Wang commented on FLINK-13437: hi [~liyu] I didn't have the permission to change the status,

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

[ 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] [Created] (FLINK-15148) Add doc for create/drop/alter database ddl

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

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

[ 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

  1   2   >