Zongwen Li created FLINK-25521:
--
Summary: The composition description of 'INTERVAL DAY TO SECOND'
in the Data Type is incorrect
Key: FLINK-25521
URL: https://issues.apache.org/jira/browse/FLINK-25521
[
https://issues.apache.org/jira/browse/FLINK-25521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25521:
---
Priority: Minor (was: Major)
> The composition description of 'INTERVAL DAY TO SECOND' in the Data
[
https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25503:
---
Description:
If the group-offset startup mode is directly used when the submitted offset
does not
Zongwen Li created FLINK-25503:
--
Summary: KafkaDynamicSource: can't use group-offsets startup mode
directly
Key: FLINK-25503
URL: https://issues.apache.org/jira/browse/FLINK-25503
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17467927#comment-17467927
]
Zongwen Li commented on FLINK-25503:
Can you give me the ticket and let me have a try?
>
[
https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17468379#comment-17468379
]
Zongwen Li commented on FLINK-25503:
[~ruanhang1993] Thanks for reminding, I will close this ISSUE
[
https://issues.apache.org/jira/browse/FLINK-25503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li closed FLINK-25503.
--
Resolution: Duplicate
> KafkaDynamicSource: can't use group-offsets startup mode directly
>
Zongwen Li created FLINK-25510:
--
Summary: Add test cases for KafkaPartitionSplitReader
Key: FLINK-25510
URL: https://issues.apache.org/jira/browse/FLINK-25510
Project: Flink
Issue Type:
Zongwen Li created FLINK-24881:
--
Summary: When the Source is back pressured, the checkpoint
interval may not take effect
Key: FLINK-24881
URL: https://issues.apache.org/jira/browse/FLINK-24881
Project:
Zongwen Li created FLINK-24726:
--
Summary: Hive Lookup Join SQL: decimal type
UnsupportedOperationException
Key: FLINK-24726
URL: https://issues.apache.org/jira/browse/FLINK-24726
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24726:
---
Description:
exception trace:
{code:java}
java.lang.UnsupportedOperationException:
[
https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24726:
---
Description:
exception trace:
{code:java}
java.lang.UnsupportedOperationException:
[
https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437146#comment-17437146
]
Zongwen Li commented on FLINK-24726:
hi, [~jark] . Please take a look.
> Hive Lookup Join SQL:
[
https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24726:
---
Description:
exception trace:
{code:java}
java.lang.UnsupportedOperationException:
[
https://issues.apache.org/jira/browse/FLINK-24726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441209#comment-17441209
]
Zongwen Li commented on FLINK-24726:
[~TsReaper] , Please assign to me. Thank you.
> Hive Lookup
Zongwen Li created FLINK-24691:
--
Summary: FLINK SQL SUM() causes a precision error
Key: FLINK-24691
URL: https://issues.apache.org/jira/browse/FLINK-24691
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Description:
code:
{code:java}
tableEnv.executeSql("select sum(cast( 1.03520274 as decimal(32,
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435830#comment-17435830
]
Zongwen Li commented on FLINK-24691:
[~matriv]
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Attachment: (was: image-2021-10-29-15-48-58-563.png)
> FLINK SQL SUM() causes a precision error
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Attachment: image-2021-10-29-15-49-14-419.png
> FLINK SQL SUM() causes a precision error
>
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Attachment: image-2021-10-29-15-48-58-563.png
> FLINK SQL SUM() causes a precision error
>
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Description:
code:
{code:java}
tableEnv.executeSql("select sum(cast( 1.03520274 as decimal(32,
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Description:
code:
{code:java}
tableEnv.executeSql("select sum(cast( 1.03520274 as decimal(32,
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-24691:
---
Description:
code:
{code:java}
tableEnv.executeSql("select sum(cast( 1.03520274 as decimal(32,
[
https://issues.apache.org/jira/browse/FLINK-24691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17435830#comment-17435830
]
Zongwen Li edited comment on FLINK-24691 at 10/29/21, 7:59 AM:
---
[~matriv]
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17475137#comment-17475137
]
Zongwen Li commented on FLINK-25559:
[~monster#12] Following Lincoln's suggestion, I tried using
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li closed FLINK-25559.
--
Fix Version/s: 1.15.0
1.13.6
1.14.3
Resolution: Fixed
>
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
//sink table,omits some physical fields
CREATE TABLE kd_product_info (
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470352#comment-17470352
]
Zongwen Li commented on FLINK-25559:
[~lincoln.86xy] Yes, the primary key of the Sink table is
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
//sink table,omits some physical fields
CREATE TABLE kd_product_info (
Zongwen Li created FLINK-25559:
--
Summary: SQL JOIN causes data loss
Key: FLINK-25559
URL: https://issues.apache.org/jira/browse/FLINK-25559
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470298#comment-17470298
]
Zongwen Li commented on FLINK-25559:
similar
> SQL JOIN causes data loss
>
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[ https://issues.apache.org/jira/browse/FLINK-25559 ]
Zongwen Li deleted comment on FLINK-25559:
was (Author: ashulin):
similar
> SQL JOIN causes data loss
> -
>
> Key: FLINK-25559
> URL:
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470318#comment-17470318
]
Zongwen Li commented on FLINK-25559:
[~lzljs3620320] Hi，Please take a look.
> SQL JOIN causes data
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470316#comment-17470316
]
Zongwen Li edited comment on FLINK-25559 at 1/7/22, 3:52 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17470316#comment-17470316
]
Zongwen Li commented on FLINK-25559:
[~lincoln.86xy]
{code:java}
WITH (
'connector' =
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Attachment: image-2022-01-07-11-27-01-010.png
> SQL JOIN causes data loss
>
[
https://issues.apache.org/jira/browse/FLINK-25559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zongwen Li updated FLINK-25559:
---
Description:
{code:java}
// sql omits some selected fields
INSERT INTO kd_product_info
SELECT
49 matches
Mail list logo
