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:
[
https://issues.apache.org/jira/browse/FLINK-21542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17294341#comment-17294341
]
Zhenghua Gao commented on FLINK-21542:
--
Is it enough to update the syntax of [inser
[
https://issues.apache.org/jira/browse/FLINK-18726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271091#comment-17271091
]
Zhenghua Gao commented on FLINK-18726:
--
[~twalthr] [~Leonard Xu] [~jark] I have imp
[
https://issues.apache.org/jira/browse/FLINK-21026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-21026:
-
Description:
HIVE-9481 allows column list specification in INSERT statement. The syntax is:
{cod
[
https://issues.apache.org/jira/browse/FLINK-21026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-21026:
-
Description:
HIVE-9481 allows column list specification in INSERT statement. The syntax is:
{cod
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
[
https://issues.apache.org/jira/browse/FLINK-16827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17159601#comment-17159601
]
Zhenghua Gao commented on FLINK-16827:
--
[~jark] [~libenchao] I think this bugfix sh
[
https://issues.apache.org/jira/browse/FLINK-16117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao closed FLINK-16117.
Resolution: Won't Fix
> Avoid register source in TableTestBase#addTableSource
> --
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092691#comment-17092691
]
Zhenghua Gao commented on FLINK-15591:
--
will open a PR soon for temporary table.
>
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092654#comment-17092654
]
Zhenghua Gao edited comment on FLINK-15591 at 4/26/20, 11:34 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092654#comment-17092654
]
Zhenghua Gao commented on FLINK-15591:
--
Supported in https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/FLINK-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17112:
-
Description: FLINK-14688 introduces DESCRIBE statement in sql parser, but
doesn't implement it i
[
https://issues.apache.org/jira/browse/FLINK-17112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17112:
-
Summary: Support DESCRIBE view_name in Flink SQL (was: Support DESCRIBE
VIEW view_name in Flink
[
https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088275#comment-17088275
]
Zhenghua Gao edited comment on FLINK-16160 at 4/21/20, 6:04 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088275#comment-17088275
]
Zhenghua Gao commented on FLINK-16160:
--
The root causes are:
* proctime()/rowtime(
[
https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17111:
-
Description:
SHOW TABLES and SHOW VIEWS are not SQL standard-compliant commands.
MySQL support
[
https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17111:
-
Description:
SHOW TABLES and SHOW VIEWS are not SQL standard-compliant commands.
MySQL support
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
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-
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
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
[
https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17105:
-
Component/s: Table SQL / Planner
Table SQL / Legacy Planner
Tab
[
https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17105:
-
Summary: FLIP-71: E2E view support for Flink SQL (was: FLIP-71: E2E
viewsupport )
> FLIP-71: E
[
https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17105:
-
Affects Version/s: 1.10.0
> FLIP-71: E2E view support for Flink SQL
> --
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
[
https://issues.apache.org/jira/browse/FLINK-17105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17105:
-
Fix Version/s: 1.11.0
> FLIP-71: E2E view support for Flink SQL
> --
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-1709
[
https://issues.apache.org/jira/browse/FLINK-17067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079280#comment-17079280
]
Zhenghua Gao commented on FLINK-17067:
--
Seems we didn't expose [OR REPLACE] out ye
[
https://issues.apache.org/jira/browse/FLINK-17067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-17067:
-
Description:
Currently CatalogManager#createTable provides [IF NOT EXISTS] semantic and
Catalo
[
https://issues.apache.org/jira/browse/FLINK-17067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17079091#comment-17079091
]
Zhenghua Gao commented on FLINK-17067:
--
Or the CREATE [TEMPORARY] TABLE|VIEW [IF NO
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
[
https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17077035#comment-17077035
]
Zhenghua Gao commented on FLINK-16632:
--
SqlDateTimeUtils#toSqlTimestamp(String, Str
[
https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-16632:
-
Summary: SqlDateTimeUtils#toSqlTimestamp(String, String) may yield
incorrect result (was: Cast
[
https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071511#comment-17071511
]
Zhenghua Gao commented on FLINK-16823:
--
After talk with [~danny0405], we decide to
[
https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17070659#comment-17070659
]
Zhenghua Gao commented on FLINK-16379:
--
[~dwysakowicz] You could merge your branch
[
https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068618#comment-17068618
]
Zhenghua Gao commented on FLINK-16823:
--
[~danny0405] What the plan of the upgrading
[
https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068610#comment-17068610
]
Zhenghua Gao commented on FLINK-16823:
--
The root cause is CALCITE-3881, will fix on
[
https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068426#comment-17068426
]
Zhenghua Gao commented on FLINK-16823:
--
Flink use Calcite's SqlFunctions#subtractMo
[
https://issues.apache.org/jira/browse/FLINK-16823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068396#comment-17068396
]
Zhenghua Gao commented on FLINK-16823:
--
OK, i will take a look at it.
> The functi
[
https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-16800:
-
Description:
the planner uses TypeMappingUtils#checkIfCompatible to validate logical schema
and
[
https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-16800:
-
Summary: TypeMappingUtils#checkIfCompatible didn't deal with nested types
(was: TypeMappingUtil
[
https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-16800:
-
Description:
the planner will use TypeMappingUtils#checkIfCompatible to validate logical
schema
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
Pro
[
https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059150#comment-17059150
]
Zhenghua Gao commented on FLINK-16379:
--
+1 to merge fromElements to fromValues.
C
[
https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17057536#comment-17057536
]
Zhenghua Gao commented on FLINK-16379:
--
That's right that we can improve `fromValue
[
https://issues.apache.org/jira/browse/FLINK-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050732#comment-17050732
]
Zhenghua Gao commented on FLINK-16379:
--
>From the user perspective, constructing a
[
https://issues.apache.org/jira/browse/FLINK-16029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-16029:
-
Summary: Remove register source and sink in test cases of blink planner
(was: Remove register s
[
https://issues.apache.org/jira/browse/FLINK-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17048740#comment-17048740
]
Zhenghua Gao commented on FLINK-16327:
--
CC [~twalthr] [~dwysakowicz] What do you th
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
Is
[
https://issues.apache.org/jira/browse/FLINK-13302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041568#comment-17041568
]
Zhenghua Gao commented on FLINK-13302:
--
[~tison] The related issue is fixed in avat
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
P
[
https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039787#comment-17039787
]
Zhenghua Gao commented on FLINK-16143:
--
[~jark] Actually the TIMESTAMPDIFF/TIMESTAM
[
https://issues.apache.org/jira/browse/FLINK-16117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038729#comment-17038729
]
Zhenghua Gao commented on FLINK-16117:
--
Most of these tests are plan tests and ther
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 T
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
Issu
[
https://issues.apache.org/jira/browse/FLINK-15990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17034351#comment-17034351
]
Zhenghua Gao commented on FLINK-15990:
--
the comment of *TableEnvironment.connect()*
[
https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15968:
-
Description:
Currently LegacyTypeInfoDataTypeConverter only support conversion between
DataType
[
https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15968:
-
Summary: LegacyTypeInfoDataTypeConverter should support conversion from
BINARY/VARBINARY to BYTE
[
https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033551#comment-17033551
]
Zhenghua Gao commented on FLINK-15968:
--
[~jark] [~lzljs3620320] What do you think a
[
https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15968:
-
Description:
Currently LegacyTypeInfoDataTypeConverter only support conversion between
DataType
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/jira
[
https://issues.apache.org/jira/browse/FLINK-15881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17030381#comment-17030381
]
Zhenghua Gao commented on FLINK-15881:
--
This duplicates to FLINK-15445. The PR for
[
https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017874#comment-17017874
]
Zhenghua Gao commented on FLINK-15574:
--
The root cause is mix use of conversion log
[
https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017755#comment-17017755
]
Zhenghua Gao commented on FLINK-15469:
--
After an initial POC, the getTypeClass is n
[
https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014828#comment-17014828
]
Zhenghua Gao edited comment on FLINK-15469 at 1/17/20 7:12 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15469:
-
Summary: Update UpsertStreamTableSink and RetractStreamTableSink and
related interface to new ty
[
https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17017666#comment-17017666
]
Zhenghua Gao commented on FLINK-15602:
--
[~twalthr] AFAIK we have padded DECIMAL typ
[
https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016745#comment-17016745
]
Zhenghua Gao commented on FLINK-15602:
--
[~dwysakowicz] [~twalthr] [~jark]
Let's pa
[
https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016740#comment-17016740
]
Zhenghua Gao commented on FLINK-15546:
--
[~lzljs3620320] OK, I will file a PR soon.
[
https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016512#comment-17016512
]
Zhenghua Gao edited comment on FLINK-15602 at 1/16/20 9:16 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17016512#comment-17016512
]
Zhenghua Gao commented on FLINK-15602:
--
Hi [~dwysakowicz] [~tiwalter] I investigate
[
https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014828#comment-17014828
]
Zhenghua Gao edited comment on FLINK-15469 at 1/14/20 3:15 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014828#comment-17014828
]
Zhenghua Gao commented on FLINK-15469:
--
Hi [~lzljs3620320], after re-think the whol
[
https://issues.apache.org/jira/browse/FLINK-15546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014818#comment-17014818
]
Zhenghua Gao commented on FLINK-15546:
--
{code:java}
case (from, to) =>
throw new
[
https://issues.apache.org/jira/browse/FLINK-15574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17014804#comment-17014804
]
Zhenghua Gao commented on FLINK-15574:
--
HI [~b.hanotte], a reason to keep this depr
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012596#comment-17012596
]
Zhenghua Gao commented on FLINK-15509:
--
What about validate data type mismatch in t
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17012429#comment-17012429
]
Zhenghua Gao commented on FLINK-15445:
--
We come to an agreement that the user shoul
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011659#comment-17011659
]
Zhenghua Gao commented on FLINK-15509:
--
Should we verify whether the properties exi
[
https://issues.apache.org/jira/browse/FLINK-15525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011346#comment-17011346
]
Zhenghua Gao commented on FLINK-15525:
--
[~lzljs3620320] [~Leonard Xu] Close this an
[
https://issues.apache.org/jira/browse/FLINK-15363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011343#comment-17011343
]
Zhenghua Gao commented on FLINK-15363:
--
Currently *HBaseTableSchema* use TypeInform
[
https://issues.apache.org/jira/browse/FLINK-15525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao closed FLINK-15525.
Resolution: Duplicate
> HBase connector should use new type system to suppport precision/scale
> -
[
https://issues.apache.org/jira/browse/FLINK-15525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011328#comment-17011328
]
Zhenghua Gao commented on FLINK-15525:
--
[~Leonard Xu] Added a link to old ticket.
[
https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17011306#comment-17011306
]
Zhenghua Gao commented on FLINK-13651:
--
[~liyu] [~jark] The root cause is PlannerEx
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: Flink
[
https://issues.apache.org/jira/browse/FLINK-14925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010512#comment-17010512
]
Zhenghua Gao commented on FLINK-14925:
--
[~jark] Make sense. Is there any ticket to
[
https://issues.apache.org/jira/browse/FLINK-15509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010331#comment-17010331
]
Zhenghua Gao commented on FLINK-15509:
--
Hi [~yesorno], the reason is the table you
[
https://issues.apache.org/jira/browse/FLINK-15508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010323#comment-17010323
]
Zhenghua Gao commented on FLINK-15508:
--
Seem as duplicates of FLINK-13651? The root
[
https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008583#comment-17008583
]
Zhenghua Gao commented on FLINK-15460:
--
[~twalthr] Actually jdbc connector code sho
[
https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15460:
-
Description: remove planner dependencies from JDBC connector by changing
the scope to test.
> p
[
https://issues.apache.org/jira/browse/FLINK-15460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15460:
-
Component/s: (was: Connectors / HBase)
> planner dependencies won't be necessary for JDBC co
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17008529#comment-17008529
]
Zhenghua Gao commented on FLINK-15445:
--
[~jark] [~twalthr] I have opened a PR to le
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 Ty
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
Is
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15445:
-
Description:
{code:java}
public class JDBCSourceExample {
public static void main(String[]
[
https://issues.apache.org/jira/browse/FLINK-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15379:
-
Description:
A mysql table like:
{code:java}
// CREATE TABLE `currency` (
`currency_id` big
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15445:
-
Description:
{code:java}
public class JDBCSourceExample {
public static void main(String[]
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15445:
-
Description:
{code:java}
public class JDBCSourceExample {
public static void main(String[]
[
https://issues.apache.org/jira/browse/FLINK-15445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhenghua Gao updated FLINK-15445:
-
Description:
{code:java}
public class JDBCSourceExample { public static void main(String[] args)
[
https://issues.apache.org/jira/browse/FLINK-15379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006047#comment-17006047
]
Zhenghua Gao commented on FLINK-15379:
--
[~jark] the issue can't reproduce after FLI
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
1 - 100 of 267 matches
Mail list logo