[
https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-36043:
-
Description:
As deigned, the SinkMaterializer operator should not be generated when the
upsert keys are
[
https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-36043:
-
Description:
As deigned, the SinkMaterializer operator should not be generated when the
upsert keys are
[
https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-36043:
-
Description:
As deigned, the SinkMaterializer operator should not be generated when the
upsert keys are
[
https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-36043:
-
Description:
As deigned, the SinkMaterializer operator should not be generated when the
upsert keys are
[
https://issues.apache.org/jira/browse/FLINK-36043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-36043:
-
Description:
As deigned, the SinkMaterializer operator should not be generated when the
upsert keys are
Yuan Kui created FLINK-36043:
Summary: [SQL] Unexpected SinkMaterializer operator generated when
use coalesce function on upsert key fields
Key: FLINK-36043
URL: https://issues.apache.org/jira/browse/FLINK-36043
[
https://issues.apache.org/jira/browse/FLINK-35826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-35826:
-
Description:
Calculation results may be unstable when using a sliding window to process
changelog data.
Yuan Kui created FLINK-35826:
Summary: [SQL] Sliding window may produce unstable calculations
when processing changelog data.
Key: FLINK-35826
URL: https://issues.apache.org/jira/browse/FLINK-35826
Projec
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32793:
-
Attachment: (was: image-2023-08-21-15-59-32-439.png)
> Release Testing: Verify FLINK-31535 - Extend
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756722#comment-17756722
]
Yuan Kui edited comment on FLINK-32793 at 8/21/23 8:05 AM:
---
Hi
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17756722#comment-17756722
]
Yuan Kui commented on FLINK-32793:
--
Hi, all.
I have tested this feature and it looks g
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32793:
-
Attachment: image-2023-08-21-16-01-15-515.png
> Release Testing: Verify FLINK-31535 - Extend watermark-r
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32793:
-
Attachment: image-2023-08-21-15-59-32-439.png
> Release Testing: Verify FLINK-31535 - Extend watermark-r
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32793:
-
Attachment: image-2023-08-21-15-58-16-215.png
> Release Testing: Verify FLINK-31535 - Extend watermark-r
[
https://issues.apache.org/jira/browse/FLINK-32793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32793:
-
Attachment: image-2023-08-21-15-56-38-669.png
> Release Testing: Verify FLINK-31535 - Extend watermark-r
[
https://issues.apache.org/jira/browse/FLINK-31535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31535:
-
Release Note: Flink now enable user config watermark emit
strategy/watermark alignment/watermark idle-ti
[
https://issues.apache.org/jira/browse/FLINK-31535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31535:
-
Release Note:
release note:
1. User can config watermark emit strategy in flink sql job with dynamic tab
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Description:
When reading the parquet format files, if the data of some fields is too
large(to support
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Description:
When reading the parquet format files, if the data of some fields is too large,
HeapBytesV
[
https://issues.apache.org/jira/browse/FLINK-32566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-32566:
-
Affects Version/s: 1.17.1
> HeapBytesVector meets java.lang.NegativeArraySizeException
> ---
Yuan Kui created FLINK-32566:
Summary: HeapBytesVector meets java.lang.NegativeArraySizeException
Key: FLINK-32566
URL: https://issues.apache.org/jira/browse/FLINK-32566
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-31819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31819:
-
Description:
Add document for using watermark advanced functions in sql
was:
Add document for u
[
https://issues.apache.org/jira/browse/FLINK-31819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31819:
-
Description:
Add document for using watermark advanced functions in sql:
1、How to set watermark emit st
Yuan Kui created FLINK-31819:
Summary: Add document for using watermark advanced functions in sql
Key: FLINK-31819
URL: https://issues.apache.org/jira/browse/FLINK-31819
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui closed FLINK-31653.
Resolution: Duplicate
> Using`if` statement for a string subtype of the row type may meet npe in code
> g
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17706711#comment-17706711
]
Yuan Kui commented on FLINK-31653:
--
[~martijnvisser] It does seem to be duplicated with
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Attachment: (was: image-2023-03-29-14-52-17-277.png)
> Using`if` statement for a string subtype of t
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Attachment: image-2023-03-29-16-06-19-351.png
> Using`if` statement for a string subtype of the row type
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Fix Version/s: 1.15.5
> Using`if` statement for a string subtype of the row type may meet npe in code
>
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Attachment: StreamExecCalc$17
> Using`if` statement for a string subtype of the row type may meet npe in
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Description:
When I use the `if` statement for the string subtype of the row type, the code
generated b
[
https://issues.apache.org/jira/browse/FLINK-31653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31653:
-
Summary: Using`if` statement for a string subtype of the row type may meet
npe in code generated by code
Yuan Kui created FLINK-31653:
Summary: codegen npe when using `if` statement for a string
subtype of the row type
Key: FLINK-31653
URL: https://issues.apache.org/jira/browse/FLINK-31653
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31536:
-
Description:
Support to configure the watermark emit strategy for the source which
implements the `Supp
[
https://issues.apache.org/jira/browse/FLINK-31540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31540:
-
Description:
Support to configure the source idle-timeout for the source which implements
the `Supports
[
https://issues.apache.org/jira/browse/FLINK-31536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31536:
-
Summary: Support to set watermark emit strategy in sql layer (was: Support
to set watermark emit strate
[
https://issues.apache.org/jira/browse/FLINK-31539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-31539:
-
Description:
Support to configure the watermark alignment for the source which implements
the `Supports
Yuan Kui created FLINK-31540:
Summary: Support to set source idle-timeout options in sql layer
Key: FLINK-31540
URL: https://issues.apache.org/jira/browse/FLINK-31540
Project: Flink
Issue Type: S
Yuan Kui created FLINK-31539:
Summary: Support to configure watermark alignment in sql layer
Key: FLINK-31539
URL: https://issues.apache.org/jira/browse/FLINK-31539
Project: Flink
Issue Type: Sub
Yuan Kui created FLINK-31536:
Summary: Support to set watermark emit strategy with table options
or 'OPTIONS' hint
Key: FLINK-31536
URL: https://issues.apache.org/jira/browse/FLINK-31536
Project: Flink
Yuan Kui created FLINK-31535:
Summary: Extend watermark-related features for SQL
Key: FLINK-31535
URL: https://issues.apache.org/jira/browse/FLINK-31535
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-24697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683220#comment-17683220
]
Yuan Kui commented on FLINK-24697:
--
[~renqs] Thanks your answer,If we keep the default
[
https://issues.apache.org/jira/browse/FLINK-24697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682984#comment-17682984
]
Yuan Kui commented on FLINK-24697:
--
[~renqs] The default value of 'auto.offset.reset' w
[
https://issues.apache.org/jira/browse/FLINK-29366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-29366:
-
Summary: Use flink-shaded-jacson to parse flink-conf.yaml (was: Use flink
shaded jacson to parse flink-
[
https://issues.apache.org/jira/browse/FLINK-29366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-29366:
-
Summary: Use flink-shaded-jacson library to parse flink-conf.yaml (was:
Use flink-shaded-jacson to pars
[
https://issues.apache.org/jira/browse/FLINK-29366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuan Kui updated FLINK-29366:
-
Description:
Now we use a simple
implementation(org.apache.flink.configuration.GlobalConfiguration#load
[
https://issues.apache.org/jira/browse/FLINK-29366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607487#comment-17607487
]
Yuan Kui commented on FLINK-29366:
--
[~chesnay] What do you think about this idea?
> Us
Yuan Kui created FLINK-29366:
Summary: Use flink shaded jacson to parse flink-conf.yaml
Key: FLINK-29366
URL: https://issues.apache.org/jira/browse/FLINK-29366
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-24318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578884#comment-17578884
]
Yuan Kui commented on FLINK-24318:
--
In 1.13.4, correct commit is: ea53e4a6cd1d39592cf3a
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561987#comment-17561987
]
Yuan Kui edited comment on FLINK-25315 at 7/4/22 3:25 AM:
--
I'm
[
https://issues.apache.org/jira/browse/FLINK-25315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17561987#comment-17561987
]
Yuan Kui commented on FLINK-25315:
--
I'm going to finish this work, could you assign thi
65 matches
Mail list logo