[jira] [Created] (FLINK-35406) Use inner serializer when casting RAW type to BINARY or STRING in cast rules

2024-05-21 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-35406: Summary: Use inner serializer when casting RAW type to BINARY or STRING in cast rules Key: FLINK-35406 URL: https://issues.apache.org/jira/browse/FLINK-35406 Project

[jira] [Created] (FLINK-21026) Align column list specification with Hive in INSERT statement

2021-01-19 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-21026: Summary: Align column list specification with Hive in INSERT statement Key: FLINK-21026 URL: https://issues.apache.org/jira/browse/FLINK-21026 Project: Flink

[jira] [Created] (FLINK-17113) Refactor view support in SQL Client

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17113: Summary: Refactor view support in SQL Client Key: FLINK-17113 URL: https://issues.apache.org/jira/browse/FLINK-17113 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17112) Support DESCRIBE VIEW view_name in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17112: Summary: Support DESCRIBE VIEW view_name in Flink SQL Key: FLINK-17112 URL: https://issues.apache.org/jira/browse/FLINK-17112 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-17111) Support SHOW VIEWS in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17111: Summary: Support SHOW VIEWS in Flink SQL Key: FLINK-17111 URL: https://issues.apache.org/jira/browse/FLINK-17111 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17106) Support create/drop view in Flink SQL

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17106: Summary: Support create/drop view in Flink SQL Key: FLINK-17106 URL: https://issues.apache.org/jira/browse/FLINK-17106 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17105) FLIP-71: E2E viewsupport

2020-04-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17105: Summary: FLIP-71: E2E viewsupport Key: FLINK-17105 URL: https://issues.apache.org/jira/browse/FLINK-17105 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-17098) CatalogManager#dropTemporaryTable and dropTemporaryView should use ObjectIdentifier as its argument

2020-04-12 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17098: Summary: CatalogManager#dropTemporaryTable and dropTemporaryView should use ObjectIdentifier as its argument Key: FLINK-17098 URL: https://issues.apache.org/jira/browse/FLINK

Re: [VOTE] FLIP-71: E2E View support in Flink SQL

2020-04-12 Thread Zhenghua Gao
Regards,* *Zhenghua Gao* On Mon, Apr 13, 2020 at 10:30 AM Jark Wu wrote: > +1 > > Best, > Jark > > On Sun, 12 Apr 2020 at 12:28, Benchao Li wrote: > > > +1 (non-binding) > > > > zoudan 于2020年4月12日周日 上午9:52写道: > > > > > +1 (non-binding) > >

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-10 Thread Zhenghua Gao
Hi Jark, >> Shall we remove the view support in those commands if we want to support a >> dedicate "SHOW VIEWS|DESCRIBE VIEW name"? Yes, we should correct those commands in SQL client. Will open tickets after the vote. *Best Regards,* *Zhenghua Gao* On Sat, Apr 11, 20

[VOTE] FLIP-71: E2E View support in Flink SQL

2020-04-09 Thread Zhenghua Gao
. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-71%3A+E2E+View+support+in+FLINK+SQL [2] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-71-E2E-View-support-in-Flink-SQL-td33131.html#a39787 *Best Regards,* *Zhenghua Gao*

[jira] [Created] (FLINK-17067) CatalogManager#createTable and createTemporaryTable should provide consistent semantics

2020-04-09 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-17067: Summary: CatalogManager#createTable and createTemporaryTable should provide consistent semantics Key: FLINK-17067 URL: https://issues.apache.org/jira/browse/FLINK-17067

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-08 Thread Zhenghua Gao
Hi Timo, Actually "TEMPORARY" is not supported in table DDL now. But you are right I could support "CREATE TEMPORARY VIEW" in this FLIP. And may be we should open a separate JIRA ticket to track supporting it in table DDL? *Best Regards,* *Zhenghua Gao* On Wed, Apr 8,

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-08 Thread Zhenghua Gao
uot; syntax and postpone the "OR REPLACE" syntax until we need it. *Best Regards,* *Zhenghua Gao* On Wed, Apr 8, 2020 at 4:46 PM Zhenghua Gao wrote: > Hi Timo, > > Shall we postpone the support of 'TEMPORARY' keyword since it's not > mentioned in FLINK-10232? > <

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-08 Thread Zhenghua Gao
Hi Timo, Shall we postpone the support of 'TEMPORARY' keyword since it's not mentioned in FLINK-10232? <https://issues.apache.org/jira/browse/FLINK-10232> *Best Regards,* *Zhenghua Gao* On Wed, Apr 8, 2020 at 3:30 PM Timo Walther wrote: > Hi Zhenghua, > > VIEWS shou

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-07 Thread Zhenghua Gao
@Danny Chan you‘re right. I have updated the doc. *Best Regards,* *Zhenghua Gao* On Wed, Apr 8, 2020 at 1:20 PM Danny Chan wrote: > +1 for the proposal, a small concern for drop view statement: > > dropViewStatement: > DROP VIEW name [ IF EXISTS ] > I think the drop s

Fwd: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-07 Thread Zhenghua Gao
forward the reply to ML too. *Best Regards,* *Zhenghua Gao* -- Forwarded message - From: Zhenghua Gao Date: Tue, Apr 7, 2020 at 8:40 PM Subject: Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL To: godfrey he >> regarding to "Interoperability between Fli

Re: [DISCUSS] FLIP-71 - E2E View support in Flink SQL

2020-04-03 Thread Zhenghua Gao
the original/expanded text in the catalog. I have updated the design doc of FLIP-71, https://cwiki.apache.org/confluence/display/FLINK/FLIP-71%3A+E2E+View+support+in+FLINK+SQL Any comments and feedbacks are welcome and appreciated. Thanks. *Best Regards,* *Zhenghua Gao* On Tue, Sep 17, 2019 at 11

Re: [DISCUSS] Change default planner to blink planner in 1.11

2020-04-01 Thread Zhenghua Gao
+1 to make blink planner as the default. It's more powerful and has richer features. *Best Regards,* *Zhenghua Gao* On Thu, Apr 2, 2020 at 11:12 AM zoudan wrote: > > +1 to make the blink planner be the planner in 1.11. > We have already user blink planner as default planner in our p

Re: [DISCUSS] FLIP-122: New Connector Property Keys for New Factory

2020-03-31 Thread Zhenghua Gao
Hi Jark, Thanks for the proposal. I'm +1 since it's more simple and clear for sql users. I have a question about this: does this affect descriptors and related validators? *Best Regards,* *Zhenghua Gao* On Mon, Mar 30, 2020 at 2:02 PM Jark Wu wrote: > Hi everyone, > > I want

[jira] [Created] (FLINK-16800) TypeMappingUtils#checkPhysicalLogicalTypeCompatible didn't deal with nested types

2020-03-26 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16800: Summary: TypeMappingUtils#checkPhysicalLogicalTypeCompatible didn't deal with nested types Key: FLINK-16800 URL: https://issues.apache.org/jira/browse/FLINK-16800

[jira] [Created] (FLINK-16327) Add TableEnvironment.fromElements interfaces for usability

2020-02-28 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16327: Summary: Add TableEnvironment.fromElements interfaces for usability Key: FLINK-16327 URL: https://issues.apache.org/jira/browse/FLINK-16327 Project: Flink

Re: [ANNOUNCE] Jingsong Lee becomes a Flink committer

2020-02-20 Thread Zhenghua Gao
Congrats Jingsong! *Best Regards,* *Zhenghua Gao* On Fri, Feb 21, 2020 at 11:59 AM godfrey he wrote: > Congrats Jingsong! Well deserved. > > Best, > godfrey > > Jeff Zhang 于2020年2月21日周五 上午11:49写道: > >> Congratulations!Jingsong. You deserve it >> >&g

[jira] [Created] (FLINK-16160) Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path

2020-02-19 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16160: Summary: Schema#proctime and Schema#rowtime don't work in TableEnvironment#connect code path Key: FLINK-16160 URL: https://issues.apache.org/jira/browse/FLINK-16160

[jira] [Created] (FLINK-16117) Avoid register source in TableTestBase#addTableSource

2020-02-17 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16117: Summary: Avoid register source in TableTestBase#addTableSource Key: FLINK-16117 URL: https://issues.apache.org/jira/browse/FLINK-16117 Project: Flink Issue

[jira] [Created] (FLINK-16029) Remove register source and sink in test cases of planner

2020-02-12 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16029: Summary: Remove register source and sink in test cases of planner Key: FLINK-16029 URL: https://issues.apache.org/jira/browse/FLINK-16029 Project: Flink

[jira] [Created] (FLINK-15968) LegacyTypeInfoDataTypeConverter should support conversion between BINARY/VARBINARY and BYTE_PRIMITIVE_ARRAY_TYPE_INFO

2020-02-10 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15968: Summary: LegacyTypeInfoDataTypeConverter should support conversion between BINARY/VARBINARY and BYTE_PRIMITIVE_ARRAY_TYPE_INFO Key: FLINK-15968 URL: https://issues.apache.org

Re: [VOTE] Improve TableFactory to add Context

2020-02-09 Thread Zhenghua Gao
+1 (non-binding). Thanks for driving this. *Best Regards,* *Zhenghua Gao* On Fri, Feb 7, 2020 at 5:05 PM Leonard Xu wrote: > +1(non-binding), nice design! > after read full discussion mail list. > > Best, > Leonard Xu > > > 在 2020年2月6日,23:12,Timo Walther 写道: > >

Re: [DISCUSS] Update UpsertStreamTableSink and RetractStreamTableSink to new type system

2020-02-07 Thread Zhenghua Gao
Thanks Timo! Look forward your design! *Best Regards,* *Zhenghua Gao* On Fri, Feb 7, 2020 at 5:26 PM Timo Walther wrote: > Hi Zhenghua, > > Jark is right. The reason why we haven't updated those interfaces yet is > because we are actually would like to introduce new interfaces.

Re: [DISCUSS] Remove registration of TableSource/TableSink in Table Env and ConnectTableDescriptor

2020-02-05 Thread Zhenghua Gao
). But in other place we need field types and names of the table source(such as BatchExecLookupJoinRule/StreamExecLookupJoinRule, PushProjectIntoTableSourceScanRule, CommonLookupJoin). So how should we deal with this? *Best Regards,* *Zhenghua Gao* On Wed, Feb 5, 2020 at 2:36 PM Kurt Young wrote

Re: [DISCUSS] Update UpsertStreamTableSink and RetractStreamTableSink to new type system

2020-02-03 Thread Zhenghua Gao
ady has >>>three getXXXType(). the getRecordType and getOutputType is deprecated and mainly for backward compatibility. *Best Regards,* *Zhenghua Gao* On Mon, Feb 3, 2020 at 10:11 PM Jark Wu wrote: > Thanks Zhenghua for starting this discussion. > > Currently, all the UpsertStreamTabl

Re: [DISCUSS] Update UpsertStreamTableSink and RetractStreamTableSink to new type system

2020-02-03 Thread Zhenghua Gao
distinguish *record data type* and *consumed data type*. *Best Regards,* *Zhenghua Gao* On Mon, Feb 3, 2020 at 4:49 PM Kurt Young wrote: > Would overriding `getConsumedDataType` do the job? > > Best, > Kurt > > > On Mon, Feb 3, 2020 at 3:52 PM Zhenghua Gao wrote: > > >

Re: [DISCUSS] Update UpsertStreamTableSink and RetractStreamTableSink to new type system

2020-02-03 Thread Zhenghua Gao
.com/apache/flink/pull/10880/files#diff-8405c17e5155aa63d16e497c4c96a842R304 What about stay the same to use RAW type? *Best Regards,* *Zhenghua Gao* On Mon, Feb 3, 2020 at 4:59 PM Jingsong Li wrote: > Hi Zhenghua, > > The *getRecordDataType* looks good to me. > > But the

[DISCUSS] Update UpsertStreamTableSink and RetractStreamTableSink to new type system

2020-02-02 Thread Zhenghua Gao
/browse/FLINK-15469 *Best Regards,* *Zhenghua Gao*

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

2020-01-14 Thread Zhenghua Gao
+1 (non-binding) *Best Regards,* *Zhenghua Gao* On Wed, Jan 15, 2020 at 10:11 AM Danny Chan wrote: > +1 (non-binding) > > Best, > Danny Chan > 在 2019年12月31日 +0800 PM5:09,Forward Xu ,写道: > > Hi all, > > > > I'd like to start the vote of FLIP-90 [1] since that

Re: Re: [VOTE] FLIP-92: Add N-Ary Stream Operator in Flink

2020-01-13 Thread Zhenghua Gao
+1 (non-binding). Thanks for driving this. It's an important improvement in the discussed scenarios. *Best Regards,* *Zhenghua Gao* On Mon, Jan 13, 2020 at 6:13 PM Haibo Sun wrote: > +1 (non-binding) > > > Best, > Haibo > > At 2020-01-13 11:36:12, "Yun Gao&q

Re: [DISCUSS] A mechanism to validate the precision of columns for connectors

2020-01-10 Thread Zhenghua Gao
Hi Jingsong Lee You are right that the connectors don't validate data types either now. We seems lack a mechanism to validate with properties[1], data types, etc for CREATE TABLE. [1] https://issues.apache.org/jira/browse/FLINK-15509 *Best Regards,* *Zhenghua Gao* On Fri, Jan 10, 2020 at 2:59

Re: [DISCUSS] FLIP-92: JDBC catalog and Postgres catalog

2020-01-09 Thread Zhenghua Gao
be mapped to Flink's TIME/TIMESTAMP WITH LOCAL TIME ZONE *Best Regards,* *Zhenghua Gao* On Fri, Jan 10, 2020 at 11:09 AM Jingsong Li wrote: > Hi Bowen, thanks for reply and updating. > > > I don't see much value in providing a builder for jdbc catalogs, as they > only have 4 or 5 req

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

2020-01-09 Thread Zhenghua Gao
+1 from my side and thanks for driving this. *Best Regards,* *Zhenghua Gao* On Fri, Jan 10, 2020 at 11:10 AM Forward Xu wrote: > Hi Danny, > Thank you very much. > > Best, > Forward > > Danny Chan 于2020年1月10日周五 上午11:08写道: > > > Thanks Forward ~ > > +

[DISCUSS] A mechanism to validate the precision of columns for connectors

2020-01-09 Thread Zhenghua Gao
) in Flink - User defines a table with DECIMAL(10, 4) in underlying DB, and want to define a table with DECIMAL(5, 2) in Flink - The precision of the underlying DB varies between different versions What do you think about this? any feedback are appreciates. *Best Regards,* *Zhenghua Gao*

[jira] [Created] (FLINK-15525) HBase connector should use new type system to suppport precision/scale

2020-01-08 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15525: Summary: HBase connector should use new type system to suppport precision/scale Key: FLINK-15525 URL: https://issues.apache.org/jira/browse/FLINK-15525 Project

Re: [VOTE] Rename terminology "Time-windowed Join" to "Interval Join" in Table API & SQL

2020-01-06 Thread Zhenghua Gao
+1 to align the terminology. *Best Regards,* *Zhenghua Gao* On Fri, Jan 3, 2020 at 12:59 PM Jingsong Li wrote: > +1 for this documentation change. > Hope less confuse to users. > > Best, > Jingsong Lee > > On Fri, Jan 3, 2020 at 12:09 PM Benchao Li wrote: > > >

Re: [DISCUSS] Set default planner for SQL Client to Blink planner in 1.10 release

2020-01-05 Thread Zhenghua Gao
+1 for making blink planner as the default planner for SQL Client since we have made a huge improvement in 1.10. *Best Regards,* *Zhenghua Gao* On Sun, Jan 5, 2020 at 2:42 PM Benchao Li wrote: > +1 > > We have used blink planner since 1.9.0 release in our production >

[jira] [Created] (FLINK-15469) UpsertStreamTableSink should support new type system

2020-01-03 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15469: Summary: UpsertStreamTableSink should support new type system Key: FLINK-15469 URL: https://issues.apache.org/jira/browse/FLINK-15469 Project: Flink Issue

[jira] [Created] (FLINK-15460) planner dependencies won't be necessary for JDBC connector

2020-01-02 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15460: Summary: planner dependencies won't be necessary for JDBC connector Key: FLINK-15460 URL: https://issues.apache.org/jira/browse/FLINK-15460 Project: Flink

[jira] [Created] (FLINK-15445) JDBC Table Source didn't work for Types with precision (or/and scale)

2019-12-31 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15445: Summary: JDBC Table Source didn't work for Types with precision (or/and scale) Key: FLINK-15445 URL: https://issues.apache.org/jira/browse/FLINK-15445 Project: Flink

Re: [ANNOUNCE] Zhu Zhu becomes a Flink committer

2019-12-15 Thread Zhenghua Gao
Congrats! *Best Regards,* *Zhenghua Gao* On Mon, Dec 16, 2019 at 10:36 AM Biao Liu wrote: > Congrats Zhu Zhu! > > Thanks, > Biao /'bɪ.aʊ/ > > > > On Mon, 16 Dec 2019 at 10:23, Congxian Qiu wrote: > > > Congrats, Zhu Zhu! > > > > Best, > > Co

[jira] [Created] (FLINK-15231) Wrong HeapVector in AbstractHeapVector.createHeapColumn

2019-12-12 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15231: Summary: Wrong HeapVector in AbstractHeapVector.createHeapColumn Key: FLINK-15231 URL: https://issues.apache.org/jira/browse/FLINK-15231 Project: Flink

[jira] [Created] (FLINK-15213) The conversion between java.sql.Timestamp and long is not asymmetric

2019-12-11 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15213: Summary: The conversion between java.sql.Timestamp and long is not asymmetric Key: FLINK-15213 URL: https://issues.apache.org/jira/browse/FLINK-15213 Project: Flink

[jira] [Created] (FLINK-15151) Use new type system in TableSourceUtil.computeIndexMapping of blink planner

2019-12-09 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-15151: Summary: Use new type system in TableSourceUtil.computeIndexMapping of blink planner Key: FLINK-15151 URL: https://issues.apache.org/jira/browse/FLINK-15151 Project

Re: [DISCUSS] Drop Kafka 0.8/0.9

2019-12-05 Thread Zhenghua Gao
+1 for dropping. *Best Regards,* *Zhenghua Gao* On Thu, Dec 5, 2019 at 11:08 AM Dian Fu wrote: > +1 for dropping them. > > Just FYI: there was a similar discussion few months ago [1]. > > [1] > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/DISCUSS-D

Re: [DISCUSS] Disable conversion between TIMESTAMP and Long in parameters and results of UDXs

2019-12-01 Thread Zhenghua Gao
ull/10268> [1] https://github.com/apache/flink/pull/10268 [2] https://issues.apache.org/jira/browse/FLINK-14599 *Best Regards,* *Zhenghua Gao* On Sun, Nov 24, 2019 at 8:44 PM Jark Wu wrote: > Hi, > > +1 to disable it in 1.10. I think it's time to disable and correct the > beha

[jira] [Created] (FLINK-14959) Support precision of LocalZonedTimestampType in blink planner

2019-11-26 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14959: Summary: Support precision of LocalZonedTimestampType in blink planner Key: FLINK-14959 URL: https://issues.apache.org/jira/browse/FLINK-14959 Project: Flink

Re: [DISCUSS] Remove old WebUI

2019-11-24 Thread Zhenghua Gao
+1 to drop the old one. *Best Regards,* *Zhenghua Gao* On Thu, Nov 21, 2019 at 8:05 PM Chesnay Schepler wrote: > Hello everyone, > > Flink 1.9 shipped with a new UI, with the old one being kept around as a > backup in case something wasn't working as expected. &

[DISCUSS] Disable conversion between TIMESTAMP and Long in parameters and results of UDXs

2019-11-22 Thread Zhenghua Gao
-release-1.9/dev/table/udfs.html#best-practices-for-implementing-udfs *Best Regards,* *Zhenghua Gao*

[jira] [Created] (FLINK-14927) Remove LegacyTimestampTypeInfo and LegacyLocalDateTimeTypeInfo when the conversion is not needed

2019-11-22 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14927: Summary: Remove LegacyTimestampTypeInfo and LegacyLocalDateTimeTypeInfo when the conversion is not needed Key: FLINK-14927 URL: https://issues.apache.org/jira/browse/FLINK-14927

[jira] [Created] (FLINK-14925) the return type of TO_TIMESTAMP should be Timestamp(9) instead of Timestamp(3)

2019-11-21 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14925: Summary: the return type of TO_TIMESTAMP should be Timestamp(9) instead of Timestamp(3) Key: FLINK-14925 URL: https://issues.apache.org/jira/browse/FLINK-14925

[jira] [Created] (FLINK-14889) TIMESTAMPADD/TIMESTAMPDIFF with microsecond/nanosecond unit lost precision

2019-11-21 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14889: Summary: TIMESTAMPADD/TIMESTAMPDIFF with microsecond/nanosecond unit lost precision Key: FLINK-14889 URL: https://issues.apache.org/jira/browse/FLINK-14889 Project

[jira] [Created] (FLINK-14848) BaseRowSerializer.toBinaryRow wrongly process null for objects with variable-length part

2019-11-18 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14848: Summary: BaseRowSerializer.toBinaryRow wrongly process null for objects with variable-length part Key: FLINK-14848 URL: https://issues.apache.org/jira/browse/FLINK-14848

[jira] [Created] (FLINK-14810) It's weird that copy julianDateFloor from DateTimeUtils and change the implementation

2019-11-15 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14810: Summary: It's weird that copy julianDateFloor from DateTimeUtils and change the implementation Key: FLINK-14810 URL: https://issues.apache.org/jira/browse/FLINK-14810

[jira] [Created] (FLINK-14806) Introduce setTimestamp/getTimestamp interface to TypeGetterSetters/VectorizedColumnBatch and writeTimestamp interface to BinaryWriter

2019-11-14 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14806: Summary: Introduce setTimestamp/getTimestamp interface to TypeGetterSetters/VectorizedColumnBatch and writeTimestamp interface to BinaryWriter Key: FLINK-14806 URL: https

[jira] [Created] (FLINK-14805) Remove unixDateCeil related code

2019-11-14 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14805: Summary: Remove unixDateCeil related code Key: FLINK-14805 URL: https://issues.apache.org/jira/browse/FLINK-14805 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14764) The final Explicit/Implicit conversion matrix we should support in our planner

2019-11-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14764: Summary: The final Explicit/Implicit conversion matrix we should support in our planner Key: FLINK-14764 URL: https://issues.apache.org/jira/browse/FLINK-14764

[jira] [Created] (FLINK-14737) HiveTypeUtil.toFlinkPrimitiveType returns wrong Timestamp(6) instead of Timestamp(9)

2019-11-13 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14737: Summary: HiveTypeUtil.toFlinkPrimitiveType returns wrong Timestamp(6) instead of Timestamp(9) Key: FLINK-14737 URL: https://issues.apache.org/jira/browse/FLINK-14737

[jira] [Created] (FLINK-14696) Support precision of TimestampType in built-in SQL functions and operators

2019-11-10 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14696: Summary: Support precision of TimestampType in built-in SQL functions and operators Key: FLINK-14696 URL: https://issues.apache.org/jira/browse/FLINK-14696 Project

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

2019-11-10 Thread Zhenghua Gao
Congratulations Jark! *Best Regards,* *Zhenghua Gao* On Mon, Nov 11, 2019 at 8:54 AM SHI Xiaogang wrote: > Congratulations, Jark. > You make a great job of improving the community. > > Regards, > Xiaogang > > Benchao Li 于2019年11月10日周日 下午4:14写道: > > > Congratulat

[jira] [Created] (FLINK-14650) Thread safety issue in the piece of code example of dev/stream/testing document

2019-11-06 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14650: Summary: Thread safety issue in the piece of code example of dev/stream/testing document Key: FLINK-14650 URL: https://issues.apache.org/jira/browse/FLINK-14650

[jira] [Created] (FLINK-14599) Support precision of TimestampType

2019-11-04 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14599: Summary: Support precision of TimestampType Key: FLINK-14599 URL: https://issues.apache.org/jira/browse/FLINK-14599 Project: Flink Issue Type: Sub-task

Re: [VOTE] Move flink-orc to flink-formats from flink-connectors

2019-10-30 Thread Zhenghua Gao
+1 (non-binding) *Best Regards,* *Zhenghua Gao* On Wed, Oct 30, 2019 at 12:05 PM Jingsong Li wrote: > Hi all: > > We already have the parent model of formats. we have put other > formats(flink-avro, flink-json, flink-parquet, flink-json, flink-csv, > flink-sequence-file) t

Re: [DISCUSS] Move flink-orc to flink-formats from flink-connectors

2019-10-29 Thread Zhenghua Gao
+1 to move flink-orc to flink-formats. Since we have put other file-based formats(flink-avro, flink-json, flink-parquet, flink-json, flink-csv, flink-sequence-file) in flink-formats, flink-orc should be the same. *Best Regards,* *Zhenghua Gao* On Tue, Oct 29, 2019 at 11:10 AM Jingsong Lee

Re: How to specify a test to run in Flink?

2019-10-28 Thread Zhenghua Gao
, OR just CD to your module directory and run "mvn -Dtest=YOUR_TEST test" *Best Regards,* *Zhenghua Gao* On Tue, Oct 29, 2019 at 10:19 AM 朱国梁 wrote: > > Hi community! I have a problem that I cannot solve by google. > > > I am trying to specify a test to

Re: [VOTE] FLIP-70: Flink SQL Computed Column Design

2019-10-28 Thread Zhenghua Gao
+1 (non-binding) *Best Regards,* *Zhenghua Gao* On Mon, Oct 28, 2019 at 2:26 PM Danny Chan wrote: > Hi all, > > I would like to start the vote for FLIP-70[1] which is discussed and > reached consensus in the discussion thread[2]. > > The vote will be open for at least

Re: [ANNOUNCE] Becket Qin joins the Flink PMC

2019-10-28 Thread Zhenghua Gao
Congratulations, Becket! *Best Regards,* *Zhenghua Gao* On Tue, Oct 29, 2019 at 10:34 AM Yun Gao wrote: > Congratulations Becket! > > Best, > Yun > > > -- > From:Jingsong Li > Send Time:2019 Oc

[jira] [Created] (FLINK-14535) Fix distinct key type for DecimalType in DistinctInfo

2019-10-25 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-14535: Summary: Fix distinct key type for DecimalType in DistinctInfo Key: FLINK-14535 URL: https://issues.apache.org/jira/browse/FLINK-14535 Project: Flink Issue

Re: Confluence permission for FLIP creation

2019-09-24 Thread Zhenghua Gao
Many Thanks for your help! *Best Regards,* *Zhenghua Gao* On Wed, Sep 25, 2019 at 9:33 AM jincheng sun wrote: > I have given you edit permission, could you please re-login and check it. > :) > > Zhenghua Gao 于2019年9月24日周二 下午8:13写道: > > > Hi all, > > > > I'm p

Confluence permission for FLIP creation

2019-09-24 Thread Zhenghua Gao
Regards,* *Zhenghua Gao*

Re: Can I do a lookup in FlinkSQL?

2019-09-16 Thread Zhenghua Gao
/blob/master/flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/AsyncLookupJoinITCase.scala *Best Regards,* *Zhenghua Gao* On Mon, Sep 16, 2019 at 9:23 PM srikanth flink wrote: > Hi there, > > I'm working with streaming in FlinkSQL.

[DISCUSS] FLIP-71 - E2E View support in Flink SQL

2019-09-16 Thread Zhenghua Gao
- support other view related DDLs Any comments and feedbacks are welcome and appreciated. Thanks. *Best Regards,* *Zhenghua Gao*

Re: [DISCUSS] FLIP-64: Support for Temporary Objects in Table module

2019-09-12 Thread Zhenghua Gao
that session logs off. So in that sense, all objects in non-persistent catalogs should be temporary. My concern is: How does the non-persistent catalog work with temporary objects? *Best Regards,* *Zhenghua Gao* On Wed, Sep 4, 2019 at 10:20 PM Dawid Wysakowicz wrote: > Hi all, > > As par

Re: [DISCUSS] Best practice to run flink on kubernetes

2019-08-28 Thread Zhenghua Gao
nching taskmanager pods dynamically? *Best Regards,* *Zhenghua Gao* On Fri, Aug 9, 2019 at 9:12 PM Yang Wang wrote: > Hi all, > > Currently cloud native architectures has been introduced to many companies > in production. They use kubernetes to run deep learning, web server, etc. &g

[jira] [Created] (FLINK-13665) decimal(p, s) where p is less than s should be illegal

2019-08-09 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13665: Summary: decimal(p, s) where p is less than s should be illegal Key: FLINK-13665 URL: https://issues.apache.org/jira/browse/FLINK-13665 Project: Flink Issue

[jira] [Created] (FLINK-13664) "MD5" and "SHA" functions should SqlTypeFamily.CHARACTER instend of SqlTypeFamily.STRING

2019-08-09 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13664: Summary: "MD5" and "SHA" functions should SqlTypeFamily.CHARACTER instend of SqlTypeFamily.STRING Key: FLINK-13664 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-13651) table api not support cast to decimal with precision and scale

2019-08-08 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13651: Summary: table api not support cast to decimal with precision and scale Key: FLINK-13651 URL: https://issues.apache.org/jira/browse/FLINK-13651 Project: Flink

[jira] [Created] (FLINK-13547) Verify and correct string function's semantic for Blink planner

2019-08-02 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13547: Summary: Verify and correct string function's semantic for Blink planner Key: FLINK-13547 URL: https://issues.apache.org/jira/browse/FLINK-13547 Project: Flink

[jira] [Created] (FLINK-13523) Verify and correct arithmetic function's semantic for Blink planner

2019-07-31 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13523: Summary: Verify and correct arithmetic function's semantic for Blink planner Key: FLINK-13523 URL: https://issues.apache.org/jira/browse/FLINK-13523 Project: Flink

[jira] [Created] (FLINK-13522) Verify and correct builtin function's semantic for Blink planner

2019-07-31 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13522: Summary: Verify and correct builtin function's semantic for Blink planner Key: FLINK-13522 URL: https://issues.apache.org/jira/browse/FLINK-13522 Project: Flink

[jira] [Created] (FLINK-13494) Blink planner changes source parallelism which causes stream SQL e2e test fails

2019-07-30 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13494: Summary: Blink planner changes source parallelism which causes stream SQL e2e test fails Key: FLINK-13494 URL: https://issues.apache.org/jira/browse/FLINK-13494

[jira] [Created] (FLINK-13394) secure MapR repo URL is not work in E2E crontab builds

2019-07-23 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13394: Summary: secure MapR repo URL is not work in E2E crontab builds Key: FLINK-13394 URL: https://issues.apache.org/jira/browse/FLINK-13394 Project: Flink Issue

[jira] [Created] (FLINK-13377) Streaming SQL e2e test failed on travis

2019-07-23 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13377: Summary: Streaming SQL e2e test failed on travis Key: FLINK-13377 URL: https://issues.apache.org/jira/browse/FLINK-13377 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

2019-07-22 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13374: Summary: flink-table-planner-blink compile failed for scala-2.12 on travis Key: FLINK-13374 URL: https://issues.apache.org/jira/browse/FLINK-13374 Project: Flink

[jira] [Created] (FLINK-13302) DateTimeUtils.unixDateCeil returns the same value as unixDateFloor does

2019-07-17 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13302: Summary: DateTimeUtils.unixDateCeil returns the same value as unixDateFloor does Key: FLINK-13302 URL: https://issues.apache.org/jira/browse/FLINK-13302 Project

[jira] [Created] (FLINK-13280) Revert blink changes in DateTimeUtils, and keep it same as flink version.

2019-07-15 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13280: Summary: Revert blink changes in DateTimeUtils, and keep it same as flink version. Key: FLINK-13280 URL: https://issues.apache.org/jira/browse/FLINK-13280 Project

[jira] [Created] (FLINK-13105) Add documentation for blink planner's built-in functions

2019-07-04 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-13105: Summary: Add documentation for blink planner's built-in functions Key: FLINK-13105 URL: https://issues.apache.org/jira/browse/FLINK-13105 Project: Flink

[jira] [Created] (FLINK-12999) Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1) T(a)"

2019-06-26 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-12999: Summary: Can't generate valid execution plan for "SELECT uuid() FROM VALUES(1) T(a)" Key: FLINK-12999 URL: https://issues.apache.org/jira/browse/FLINK-12999

[jira] [Created] (FLINK-12845) Execute multiple statements in command line or sql script file

2019-06-14 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-12845: Summary: Execute multiple statements in command line or sql script file Key: FLINK-12845 URL: https://issues.apache.org/jira/browse/FLINK-12845 Project: Flink

[jira] [Created] (FLINK-12828) Support -f option with a sql script file as input

2019-06-13 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-12828: Summary: Support -f option with a sql script file as input Key: FLINK-12828 URL: https://issues.apache.org/jira/browse/FLINK-12828 Project: Flink Issue Type

[jira] [Created] (FLINK-12819) Reuse TableEnvironment between different SQL statements

2019-06-12 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-12819: Summary: Reuse TableEnvironment between different SQL statements Key: FLINK-12819 URL: https://issues.apache.org/jira/browse/FLINK-12819 Project: Flink

[jira] [Created] (FLINK-12814) Support a traditional and scrolling view of result (non-interactive)

2019-06-12 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-12814: Summary: Support a traditional and scrolling view of result (non-interactive) Key: FLINK-12814 URL: https://issues.apache.org/jira/browse/FLINK-12814 Project: Flink

[jira] [Created] (FLINK-8045) Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP

2017-11-10 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-8045: --- Summary: Add Internal DATE/TIME/TIMESTAMP as internal representation of DATE/TIME/TIMESTAMP Key: FLINK-8045 URL: https://issues.apache.org/jira/browse/FLINK-8045

[jira] [Created] (FLINK-6173) flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414

2017-03-22 Thread Zhenghua Gao (JIRA)
Zhenghua Gao created FLINK-6173: --- Summary: flink-table not pack-in com.fasterxml.jackson.* in after #FLINK-5414 Key: FLINK-6173 URL: https://issues.apache.org/jira/browse/FLINK-6173 Project: Flink

  1   2   >