Zakelly opened a new pull request, #23441:
URL: https://github.com/apache/flink/pull/23441
## What is the purpose of the change
After FLINK-8411, the ListState.update/add/addAll do not allow a null value
passed in, while the javadoc says "If null is passed in, the state value will
re
[
https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yue Ma updated FLINK-33126:
---
Issue Type: Bug (was: Improvement)
> Fix EventTimeAllWindowCheckpointingITCase jobName typo
> -
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767032#comment-17767032
]
Zakelly Lan commented on FLINK-33052:
-
Hi [~pnowojski] [~jingge] ,
Is it possible w
[
https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-20767:
---
Fix Version/s: (was: 1.18.0)
> add nested field support for SupportsFilterPushDown
> ---
911432 closed pull request #23380: Readme.md changes according to [FLINK-25002]
URL: https://github.com/apache/flink/pull/23380
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
Yue Ma created FLINK-33126:
--
Summary: Fix EventTimeAllWindowCheckpointingITCase jobName typo
Key: FLINK-33126
URL: https://issues.apache.org/jira/browse/FLINK-33126
Project: Flink
Issue Type: Improv
[
https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767104#comment-17767104
]
Martijn Visser commented on FLINK-33111:
[~Tison] WDYT?
> Flink Pulsar Connecto
mayuehappy opened a new pull request, #23444:
URL: https://github.com/apache/flink/pull/23444
## What is the purpose of the change
Fix EventTimeAllWindowCheckpointingITCase jobName typo
## Brief change log
Adjust the jobName of test in EventTimeAllWindowCheckpointing
echauchot opened a new pull request, #23443:
URL: https://github.com/apache/flink/pull/23443
## What is the purpose of the change
Support transparent compression for file-connector for all file input
formats.
## Brief change log
- Force reading the whole file split (like
zentol opened a new pull request, #23445:
URL: https://github.com/apache/flink/pull/23445
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mai
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767089#comment-17767089
]
Weijie Guo commented on FLINK-33044:
master(1.19) via b076c52d8da914e81c3e004c0b0c78
Aarsh Shah created FLINK-33124:
--
Summary: Kafka Connector not working for table
Key: FLINK-33124
URL: https://issues.apache.org/jira/browse/FLINK-33124
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767035#comment-17767035
]
Zhanghao Chen commented on FLINK-33123:
---
Hi [~gyfora] [~mxm] , please help take a
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Summary: Wrong dynamic replacement of partitioner from FORWARD to REBLANCE
for autoscaler and
reswqa merged PR #23369:
URL: https://github.com/apache/flink/pull/23369
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33044:
---
Fix Version/s: 1.19.0
> Reduce the frequency of triggering flush for the disk tier of the tiered
>
[
https://issues.apache.org/jira/browse/FLINK-32197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767055#comment-17767055
]
Yun Tang edited comment on FLINK-32197 at 9/20/23 8:59 AM:
---
[~
flinkbot commented on PR #23443:
URL: https://github.com/apache/flink/pull/23443#issuecomment-1727591627
## CI report:
* f5e4b88c3c51e1759e42cc06373fa608cb3bd1f9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23444:
URL: https://github.com/apache/flink/pull/23444#issuecomment-1727680576
## CI report:
* d6bfd73e33c038e4b3f66f15b7f8b75b69a651a3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-33126:
-
Assignee: Yue Ma
> Fix EventTimeAllWindowCheckpointingITCase jobName typo
> ---
TanYuxin-tyx opened a new pull request, #23442:
URL: https://github.com/apache/flink/pull/23442
## What is the purpose of the change
*Backport the pr https://github.com/apache/flink/pull/23369 to release 1.18.*
## Brief change log
- *Backport the pr http
[
https://issues.apache.org/jira/browse/FLINK-32197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767055#comment-17767055
]
Yun Tang commented on FLINK-32197:
--
[~mason6345] Thanks for the information! I will als
[
https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767056#comment-17767056
]
Weihua Hu commented on FLINK-32846:
---
Metrics merged in master: 5a8321f6385f9a108773989
[
https://issues.apache.org/jira/browse/FLINK-30314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767099#comment-17767099
]
Etienne Chauchot commented on FLINK-30314:
--
https://github.com/apache/flink/pul
flinkbot commented on PR #23445:
URL: https://github.com/apache/flink/pull/23445#issuecomment-1727692469
## CI report:
* 9ae7f3e45446f34d806ea6a98e6aa5be548b2b78 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23441:
URL: https://github.com/apache/flink/pull/23441#issuecomment-1727408582
## CI report:
* 99f4dd9965ba131ba6abceada5a9969555fbb033 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767106#comment-17767106
]
Martijn Visser commented on FLINK-33110:
[~romanlupiichuk] Can you please verify
[
https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu reassigned FLINK-33126:
-
Assignee: Yue Ma (was: Yue Ma)
> Fix EventTimeAllWindowCheckpointingITCase jobName typo
>
Nicolas Fraison created FLINK-33125:
---
Summary: Upgrade JOSDK to 4.4.4
Key: FLINK-33125
URL: https://issues.apache.org/jira/browse/FLINK-33125
Project: Flink
Issue Type: Bug
Compon
TanYuxin-tyx commented on PR #23369:
URL: https://github.com/apache/flink/pull/23369#issuecomment-1727044233
@xintongsong @reswqa Thanks for review the change.
I update the code to rebase the fixup commit and trigger the tests again.
--
This is an automated message from the Apache G
flinkbot commented on PR #23442:
URL: https://github.com/apache/flink/pull/23442#issuecomment-1727552325
## CI report:
* 40bead52d200f8aa9cd30336dcc4c3f6f8c68636 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-32846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weihua Hu resolved FLINK-32846.
---
Fix Version/s: 1.19.0
Resolution: Fixed
> [JUnit5 Migration] The metrics, minicluster and net
FangYongs commented on PR #78:
URL: https://github.com/apache/flink-benchmarks/pull/78#issuecomment-1727208341
@KarmaGYZ I think there is another purpose to evaluate the performance of
OLAP cluster with cluster ZOOKEEPER HA and NONE job HA, and whether it is
consistent with the current perf
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767012#comment-17767012
]
Yordan Pavlov commented on FLINK-33109:
---
Hi [~fanrui] can I ask for your help in t
[
https://issues.apache.org/jira/browse/FLINK-33059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot updated FLINK-33059:
-
Description: Some FileInputFormats don't use FileInputFormat#createSplits
(that would de
ashangit opened a new pull request, #680:
URL: https://github.com/apache/flink-kubernetes-operator/pull/680
## What is the purpose of the change
Upgrade JOSDK to 4.4.4 which contains fix on leader election stop not called
## Brief change log
- Update depende
[
https://issues.apache.org/jira/browse/FLINK-33124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aarsh Shah updated FLINK-33124:
---
Component/s: Connectors / Kafka
Table SQL / Runtime
Affects Version/
FangYongs commented on code in PR #78:
URL: https://github.com/apache/flink-benchmarks/pull/78#discussion_r1331196199
##
src/main/java/org/apache/flink/olap/benchmark/HighAvailabilityServiceBenchmark.java:
##
@@ -0,0 +1,133 @@
+/*
+ * Licensed to the Apache Software Foundation (
huwh commented on code in PR #23242:
URL: https://github.com/apache/flink/pull/23242#discussion_r1328092633
##
flink-runtime/src/test/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCacheTest.java:
##
@@ -154,35 +149,35 @@ public void testCacheTimeoutCanBeConf
snuyanzin commented on code in PR #23445:
URL: https://github.com/apache/flink/pull/23445#discussion_r1331730072
##
docs/content.zh/docs/deployment/java_compatibility.md:
##
@@ -0,0 +1,77 @@
+---
+title: Java Compatibility
+weight: 2
+type: docs
+---
+
+
+# Java compatibility
+
Zakelly Lan created FLINK-33122:
---
Summary: [Benchmark] Null checkpoint directory in rescaling
benchmarks
Key: FLINK-33122
URL: https://issues.apache.org/jira/browse/FLINK-33122
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767128#comment-17767128
]
Rui Fan commented on FLINK-33109:
-
Could you try this image? It's the offcial image base
zentol commented on code in PR #23445:
URL: https://github.com/apache/flink/pull/23445#discussion_r1331743142
##
docs/content.zh/docs/deployment/java_compatibility.md:
##
@@ -0,0 +1,77 @@
+---
+title: Java Compatibility
+weight: 2
+type: docs
+---
+
+
+# Java compatibility
+
+Th
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Attachment: image-2023-09-20-15-14-04-679.png
> Wrong dynamic replacement of partitioner from
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Description:
*Background*
https://issues.apache.org/jira/browse/FLINK-30213 reported that the
huwh merged PR #23243:
URL: https://github.com/apache/flink/pull/23243
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.o
CuiYanxiang commented on PR #23439:
URL: https://github.com/apache/flink/pull/23439#issuecomment-1727100811
Hi @wuchong , would you mind helping review this pr? thanks~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
Aoboyan closed pull request #20923: Update temporal_table_function.md
URL: https://github.com/apache/flink/pull/20923
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubsc
[
https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767131#comment-17767131
]
Zili Chen commented on FLINK-33111:
---
We upgrade the Pulsar client version in
https://
Aoboyan closed pull request #20926: Update ch temporal_table_function.md
URL: https://github.com/apache/flink/pull/20926
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsu
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162
]
Rui Fan edited comment on FLINK-33123 at 9/20/23 3:30 PM:
--
Hi [
Zhanghao Chen created FLINK-33123:
-
Summary: Wrong dynamic replacement of partitioner from FORWARD to
REBLANCE for autoscaler and adaptive scheduler and
Key: FLINK-33123
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Attachment: image-2023-09-20-15-09-22-733.png
> Wrong dynamic replacement of partitioner from
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767029#comment-17767029
]
Chesnay Schepler commented on FLINK-33121:
--
??there are rare cases where multip
[
https://issues.apache.org/jira/browse/FLINK-33052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767153#comment-17767153
]
Piotr Nowojski commented on FLINK-33052:
I think there is no big difference one
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhanghao Chen updated FLINK-33123:
--
Description:
*Background*
https://issues.apache.org/jira/browse/FLINK-30213 reported that the
hackergin opened a new pull request, #23446:
URL: https://github.com/apache/flink/pull/23446
## What is the purpose of the change
*Fix NullPointException when starting flink cluster in standalone mode with
hadoop configuration*
## Brief change log
- Add
[
https://issues.apache.org/jira/browse/FLINK-33123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767162#comment-17767162
]
Rui Fan commented on FLINK-33123:
-
Hi [~Zhanghao Chen] , thanks for your report!
Your a
flinkbot commented on PR #23446:
URL: https://github.com/apache/flink/pull/23446#issuecomment-1728047395
## CI report:
* b75bf886971e4dc1ec4567177e2bb94cd28a3be4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767154#comment-17767154
]
Flaviu Cicio commented on FLINK-30649:
--
Hi, [~mapohl]
Can I have this one as my fi
[
https://issues.apache.org/jira/browse/FLINK-32976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-32976:
---
Labels: pull-request-available (was: )
> NullPointException when starting flink cluster in
venkata91 commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1331904794
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java:
##
@@ -1183,7 +1194,9 @@ private Map, Collectio
venkata91 commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1331904794
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java:
##
@@ -1183,7 +1194,9 @@ private Map, Collectio
X-czh opened a new pull request, #23447:
URL: https://github.com/apache/flink/pull/23447
## What is the purpose of the change
This pull request cleanups terminal subtask attempt metrics to avoid
confusion caused by outdated metrics. For example, a FINISHED task may have its
l
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31650:
---
Labels: pull-request-available (was: )
> Incorrect busyMsTimePerSecond metric value for FIN
[
https://issues.apache.org/jira/browse/FLINK-31650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767191#comment-17767191
]
Zhanghao Chen commented on FLINK-31650:
---
[~wanglijie] [~JunRuiLi] Hi, I've created
flinkbot commented on PR #23447:
URL: https://github.com/apache/flink/pull/23447#issuecomment-1728104779
## CI report:
* a3d22bcb204a26716c51f71ef66c0cf58e5fff92 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767214#comment-17767214
]
Chesnay Schepler commented on FLINK-33121:
--
Had an offline chat; our suspicion
[
https://issues.apache.org/jira/browse/FLINK-33104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767232#comment-17767232
]
Mason Chen commented on FLINK-33104:
Do we want to ignore the violations for now? or
tzulitai commented on code in PR #20:
URL:
https://github.com/apache/flink-connector-kafka/pull/20#discussion_r1332045177
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSource.java:
##
@@ -98,20 +98,24 @@
private final KafkaRecordDeseri
zentol merged PR #23445:
URL: https://github.com/apache/flink/pull/23445
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
[
https://issues.apache.org/jira/browse/FLINK-15736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767273#comment-17767273
]
Chesnay Schepler commented on FLINK-15736:
--
Documentation added:
master: 388601
[
https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767290#comment-17767290
]
Matthias Pohl commented on FLINK-30649:
---
Thanks for volunteering. Do you have an i
[
https://issues.apache.org/jira/browse/FLINK-32418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32418:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-32223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-32223:
---
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink
[
https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-33018:
---
Labels: auto-deprioritized-blocker pull-request-available (was:
pull-request-available st
becketqin commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1332312205
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory.java:
##
@@ -1183,7 +1194,9 @@ private Map, Collectio
[
https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong closed FLINK-32848.
-
Resolution: Fixed
Fixed by
2ced46b6ed4ebfb20f9b392cba4e789e16e4da7d...f2cb1d247283344e9194e63931a2948e0
luoyuxia closed pull request #23389: [FLINK-33050][table] Atomicity is not
supported prompting the user to disable
URL: https://github.com/apache/flink/pull/23389
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
reswqa merged PR #23442:
URL: https://github.com/apache/flink/pull/23442
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache
TanYuxin-tyx commented on PR #23442:
URL: https://github.com/apache/flink/pull/23442#issuecomment-1728657634
Thanks @reswqa for reviewing the change.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33044:
---
Labels: pull-request-available (was: )
> Reduce the frequency of triggering flush for the d
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767089#comment-17767089
]
Weijie Guo edited comment on FLINK-33044 at 9/21/23 2:04 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-33044.
--
Resolution: Fixed
> Reduce the frequency of triggering flush for the disk tier of the tiered
> storag
[
https://issues.apache.org/jira/browse/FLINK-33044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-33044:
---
Fix Version/s: 1.18.0
> Reduce the frequency of triggering flush for the disk tier of the tiered
>
[
https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong reopened FLINK-32405:
---
> Initialize catalog listener for CatalogManager
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767354#comment-17767354
]
Fang Yong commented on FLINK-32405:
---
OK, it is a duplicate issue with FLINK-32404
> I
[
https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fang Yong closed FLINK-32405.
-
Resolution: Duplicate
Duplicate with FLINK-32404
> Initialize catalog listener for CatalogManager
> ---
[
https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767356#comment-17767356
]
Benchao Li commented on FLINK-32405:
[~zjureel] Thanks for the updating, I've also a
[
https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang resolved FLINK-32974.
Fix Version/s: 1.18.0
1.17.2
Resolution: Fixed
> RestClusterClient alway
[
https://issues.apache.org/jira/browse/FLINK-32974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767357#comment-17767357
]
Lijie Wang commented on FLINK-32974:
Fix via
master: 6034d5ff335dc970672c29085181123
elkhand commented on code in PR #23406:
URL: https://github.com/apache/flink/pull/23406#discussion_r1332375725
##
flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java:
##
@@ -255,10 +266,22 @@ private RestClusterClient(
RestCl
[
https://issues.apache.org/jira/browse/FLINK-33060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33060:
---
Labels: pull-request-available (was: )
> Fix the javadoc of ListState.update/addAll about n
mayuehappy commented on PR #23444:
URL: https://github.com/apache/flink/pull/23444#issuecomment-1728690076
@flinkbot run azure
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment
[
https://issues.apache.org/jira/browse/FLINK-33126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33126:
---
Labels: pull-request-available (was: )
> Fix EventTimeAllWindowCheckpointingITCase jobName
Yangyang ZHANG created FLINK-33127:
--
Summary: HeapKeyedStateBackend: use buffered I/O to speed up local
recovery
Key: FLINK-33127
URL: https://issues.apache.org/jira/browse/FLINK-33127
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-33127:
--
Assignee: Yangyang ZHANG
> HeapKeyedStateBackend: use buffered I/O to speed up local recovery
[
https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen reassigned FLINK-32938:
-
Assignee: Neng Lu
> flink-connector-pulsar should remove all `PulsarAdmin` calls
>
[
https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zili Chen resolved FLINK-32938.
---
Fix Version/s: pulsar-4.1.0
Resolution: Fixed
master via 78d00ea9e3e278d4ce2fbb0c8a8d380abef7
Tartarus0zm opened a new pull request, #23448:
URL: https://github.com/apache/flink/pull/23448
## What is the purpose of the change
* When atomicity is enabled, an exception may occur when creating a
DynamicTableSink, and we need to prompt the user to disable atomicity.
* When we u
1 - 100 of 108 matches
Mail list logo
