[
https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-19432:
--
Affects Version/s: (was: 1.11.2)
1.11.1
> Whether to capture the updates wh
[
https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-19432:
--
Fix Version/s: (was: 1.11.3)
1.12.0
> Whether to capture the updates which don'
[
https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-19432:
--
Description:
with `debezium-json` and `canal-json`:
Whether to capture the updates which don't chang
[
https://issues.apache.org/jira/browse/FLINK-19432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202750#comment-17202750
]
tinny cat commented on FLINK-19432:
---
In fact, I have already mentioned a pull request
tinny cat created FLINK-19432:
-
Summary: Whether to capture the updates which don't change any
monitored columns
Key: FLINK-19432
URL: https://issues.apache.org/jira/browse/FLINK-19432
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196280#comment-17196280
]
tinny cat edited comment on FLINK-19167 at 9/15/20, 4:35 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196280#comment-17196280
]
tinny cat edited comment on FLINK-19167 at 9/15/20, 4:29 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196280#comment-17196280
]
tinny cat commented on FLINK-19167:
---
thank you [~aljoscha] [~dwysakowicz] [~twalthr],
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193306#comment-17193306
]
tinny cat edited comment on FLINK-19167 at 9/15/20, 9:41 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17196015#comment-17196015
]
tinny cat commented on FLINK-19167:
---
The following is my test output code：
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195831#comment-17195831
]
tinny cat commented on FLINK-19167:
---
the timer method did fired, but this if statement
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193306#comment-17193306
]
tinny cat edited comment on FLINK-19167 at 9/15/20, 2:38 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17195154#comment-17195154
]
tinny cat commented on FLINK-19167:
---
The watermark did increase, and the timer did tri
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193305#comment-17193305
]
tinny cat edited comment on FLINK-19167 at 9/10/20, 5:43 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193306#comment-17193306
]
tinny cat commented on FLINK-19167:
---
the watermark is:
{code:java}
stream
.assignTime
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193305#comment-17193305
]
tinny cat commented on FLINK-19167:
---
however, I set the `TimeCharacteristic` was event
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-19167:
--
Description:
Section "*Porccess Function Example*" of
[https://ci.apache.org/projects/flink/flink-doc
[
https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-19167:
--
Description:
Section "*Porccess Function Example*" of
[https://ci.apache.org/projects/flink/flink-doc
tinny cat created FLINK-19167:
-
Summary: Proccess Function Example could not work
Key: FLINK-19167
URL: https://issues.apache.org/jira/browse/FLINK-19167
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-18547:
--
Description:
The options
‘partition.time-extractor.kind’，‘partition.time-extractor.class’，‘partition.
[
https://issues.apache.org/jira/browse/FLINK-18547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
tinny cat updated FLINK-18547:
--
Description:
The options
‘partition.time-extractor.kind’，‘partition.time-extractor.class’，‘partition.
tinny cat created FLINK-18547:
-
Summary: the filesystem sql connector can't work well
Key: FLINK-18547
URL: https://issues.apache.org/jira/browse/FLINK-18547
Project: Flink
Issue Type: Bug
22 matches
Mail list logo
