Keith Lee created FLINK-35853:
-
Summary: Regression in checkpoint size when performing full
checkpointing in RocksDB
Key: FLINK-35853
URL: https://issues.apache.org/jira/browse/FLINK-35853
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866287#comment-17866287
]
Keith Lee commented on FLINK-35853:
---
I dug around code but was unfamiliar with the sta
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35853:
--
Description:
We have a job with small and static state size (states are updated instead of
added), th
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35853:
--
Description:
We have a job with small and static state size (states are updated instead of
added), th
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866287#comment-17866287
]
Keith Lee edited comment on FLINK-35853 at 7/16/24 8:07 AM:
[
https://issues.apache.org/jira/browse/FLINK-35853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867735#comment-17867735
]
Keith Lee commented on FLINK-35853:
---
Thanks for your response Jinzhong.
I understand
Keith Lee created FLINK-36155:
-
Summary: ByteBuf.release() was not called before it's
garbage-collected
Key: FLINK-36155
URL: https://issues.apache.org/jira/browse/FLINK-36155
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Summary: ByteBuf.release() was not called before it's garbage-collected in
Kinesis Connector (was: By
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Description:
The following warning logs are seen from kinesis connector indicating memory
leak.
```
[
https://issues.apache.org/jira/browse/FLINK-36155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36155:
--
Description:
The following warning logs are seen from kinesis connector indicating
```
LEAK: ByteBuf
Keith Lee created FLINK-35336:
-
Summary: SQL failed to restore from savepoint after change in
default-parallelismFlink/Flink:User
Key: FLINK-35336
URL: https://issues.apache.org/jira/browse/FLINK-35336
Pr
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35336:
--
Description:
After bumping 'table.exec.resource.default-parallelism' from 1 to 4, I am
observing the
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35336:
--
Summary: SQL failed to restore from savepoint after change in
default-parallelism (was: SQL failed to
Keith Lee created FLINK-35369:
-
Summary: Improve `Table API and SQL` page or add new page to guide
new users to right Flink SQL option
Key: FLINK-35369
URL: https://issues.apache.org/jira/browse/FLINK-35369
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new u
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new u
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Summary: Improve `Table API and SQL` overview page or add new page to guide
new users to right Flink S
[
https://issues.apache.org/jira/browse/FLINK-35369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-35369:
--
Description:
Flink has rich and varied SQL offerings/deployment mode, it can take some time
for new u
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847791#comment-17847791
]
Keith Lee commented on FLINK-33251:
---
I've also experience similar issue so adding my o
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847791#comment-17847791
]
Keith Lee edited comment on FLINK-33251 at 5/20/24 8:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849440#comment-17849440
]
Keith Lee commented on FLINK-33251:
---
It seems that reproducing this on M1 Mac is not d
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-33251:
--
Attachment: reproduce_FLINK-33251.java
> SQL Client query execution aborts after a few seconds: Connec
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849467#comment-17849467
]
Keith Lee commented on FLINK-33251:
---
Adding IntelliJ scratch file that can reliably re
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee commented on FLINK-33251:
---
The timeout could come from any of:
1. SQL Gatew
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:18 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:20 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:21 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:22 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849961#comment-17849961
]
Keith Lee edited comment on FLINK-33251 at 5/28/24 10:27 AM:
-
Keith Lee created FLINK-36939:
-
Summary: High CPU Utilization with Flink Kinesis EFO Consumer
Key: FLINK-36939
URL: https://issues.apache.org/jira/browse/FLINK-36939
Project: Flink
Issue Type: Bu
[
https://issues.apache.org/jira/browse/FLINK-36939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Keith Lee updated FLINK-36939:
--
Attachment: Screenshot 1734584781285.png
Screenshot 1734584639640.png
> High CPU Utili
Keith Lee created FLINK-37627:
-
Summary: Restarting from a checkpoint/savepoint which coincides
with shard split causes data loss
Key: FLINK-37627
URL: https://issues.apache.org/jira/browse/FLINK-37627
Pr
[
https://issues.apache.org/jira/browse/FLINK-36939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17943940#comment-17943940
]
Keith Lee commented on FLINK-36939:
---
Refactored the changes for https://issues.apache.
Keith Lee created FLINK-37687:
-
Summary: Bump flink-connector-aws to 2.0
Key: FLINK-37687
URL: https://issues.apache.org/jira/browse/FLINK-37687
Project: Flink
Issue Type: Bug
Component
Keith Lee created FLINK-37808:
-
Summary: Checkpoint completed after job failure
Key: FLINK-37808
URL: https://issues.apache.org/jira/browse/FLINK-37808
Project: Flink
Issue Type: Bug
C
Keith Lee created FLINK-37949:
-
Summary: FlinkKinesisConsumer on EFO mode runs into Netty deadlock
on client close during stop-with-savepoint
Key: FLINK-37949
URL: https://issues.apache.org/jira/browse/FLINK-37949
37 matches
Mail list logo
