Aitozi commented on code in PR #22324:
URL: https://github.com/apache/flink/pull/22324#discussion_r1165074229
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MapFromEntriesInputTypeStrategy.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licen
flinkbot commented on PR #22389:
URL: https://github.com/apache/flink/pull/22389#issuecomment-1506406729
## CI report:
* 18794c076eca7319a9f351cf6889fbbb4cd78ba8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22388:
URL: https://github.com/apache/flink/pull/22388#issuecomment-1506406558
## CI report:
* 30fd54d3ad0a5dead70b57794c201f21f297034d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dmvk opened a new pull request, #22389:
URL: https://github.com/apache/flink/pull/22389
Backport of https://github.com/apache/flink/pull/22388
--
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
[
https://issues.apache.org/jira/browse/FLINK-31792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31792:
---
Labels: pull-request-available (was: )
> Errors are not reported in the Web UI
> --
dmvk opened a new pull request, #22388:
URL: https://github.com/apache/flink/pull/22388
https://issues.apache.org/jira/browse/FLINK-31792
--
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 speci
[
https://issues.apache.org/jira/browse/FLINK-31765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-31765.
---
Fix Version/s: 1.18.0
Resolution: Fixed
master: a11a8b48b2090677f811f1d735f2a2f8ccaba
XComp merged PR #22377:
URL: https://github.com/apache/flink/pull/22377
--
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.
David Morávek created FLINK-31792:
-
Summary: Errors are not reported in the Web UI
Key: FLINK-31792
URL: https://issues.apache.org/jira/browse/FLINK-31792
Project: Flink
Issue Type: Bug
flinkbot commented on PR #22387:
URL: https://github.com/apache/flink/pull/22387#issuecomment-1506365720
## CI report:
* 1eec46aa7862cd78d0bcd62b27d3b44f8c4df491 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711683#comment-17711683
]
Aitozi commented on FLINK-31790:
CC [~luoyuxia]
> Filesystem batch sink should also re
[
https://issues.apache.org/jira/browse/FLINK-31790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31790:
---
Labels: pull-request-available (was: )
> Filesystem batch sink should also respect to the P
liuyongvs commented on code in PR #22324:
URL: https://github.com/apache/flink/pull/22324#discussion_r1165012228
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MapFromEntriesInputTypeStrategy.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Li
Aitozi opened a new pull request, #22387:
URL: https://github.com/apache/flink/pull/22387
…mode
## What is the purpose of the change
This PR is meant to add the partition commit policy for the filesystem batch
mode.
## Brief change log
*(for example:)*
-
[
https://issues.apache.org/jira/browse/FLINK-31767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Godfrey He closed FLINK-31767.
--
Fix Version/s: 1.18.0
Resolution: Fixed
Fixed in master: 0191cf7d0064003bd2d4b60ebb6e329f791c92
godfreyhe closed pull request #22376: [FLINK-31767][table-planner] Improve the
implementation for "analyze table" execution on partitioned table
URL: https://github.com/apache/flink/pull/22376
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1164941748
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -49,7 +49,11 @@
*
* The size of this pool can be dynamically ch
reswqa commented on PR #22381:
URL: https://github.com/apache/flink/pull/22381#issuecomment-1506298316
Thanks @1996fanrui for the quick reply, I have updated this, PTAL~
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1164959231
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -766,13 +776,12 @@ private void returnExcessMemorySegments() {
Aitozi commented on code in PR #22324:
URL: https://github.com/apache/flink/pull/22324#discussion_r1164956399
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/MapFromEntriesInputTypeStrategy.java:
##
@@ -0,0 +1,75 @@
+/*
+ * Licen
godfreyhe commented on PR #22376:
URL: https://github.com/apache/flink/pull/22376#issuecomment-1506292921
Thanks for the review, I will merge it
--
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 th
[
https://issues.apache.org/jira/browse/FLINK-31655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711663#comment-17711663
]
tartarus commented on FLINK-31655:
--
Hi [~akalash] thanks for your reminder!
In our co
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31764:
---
Description: After FLINK-31763, we don't need the specific field
{{numberOfRequestedOverdraftMemoryS
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31764:
---
Description: After FLINK-31763, we don't need the specific field
{{numberOfRequestedOverdraftMemoryS
[
https://issues.apache.org/jira/browse/FLINK-31374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhipeng Zhang reassigned FLINK-31374:
-
Assignee: Jiang Xin (was: jiangxin li)
> ProxyStreamPartitioner should implement Confi
[
https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-30888:
--
Fix Version/s: 1.18.0
> Flink Doc(zh version) has misspelled words
>
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31764:
---
Description: After FLINK-31763, we are no longer need the specific field
{{numberOfRequestedOverdraf
[
https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711658#comment-17711658
]
Yuxin Tan commented on FLINK-30888:
---
I found the typo has been fixed.
https://github.
[
https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-30888.
-
Release Note:
I found the typo has been fixed.
https://github.com/apache/flink/blob/master/docs/content
[
https://issues.apache.org/jira/browse/FLINK-30888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan updated FLINK-30888:
--
Release Note: (was: I found the typo has been fixed.
https://github.com/apache/flink/blob/master/doc
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31764:
---
Description: After FLINK-31763, we are no longer need the specific (was:
After FLINK-31763)
> Get
[
https://issues.apache.org/jira/browse/FLINK-31764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31764:
---
Description: After FLINK-31763 (was: We can changes the definition of
overdraft buffer from static
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1164944912
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -671,13 +675,20 @@ public void setNumBuffers(int numBuffers) {
reswqa commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1164941748
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -49,7 +49,11 @@
*
* The size of this pool can be dynamically ch
[
https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711656#comment-17711656
]
Xintong Song commented on FLINK-27719:
--
Yes. Thanks for the reminder.
> Create Apa
[
https://issues.apache.org/jira/browse/FLINK-27723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-27723.
Resolution: Resolved
> Slack: revisit how this communication channel works
> -
[
https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-27719.
Resolution: Resolved
> Create Apache Flink slack workspace
> ---
>
[
https://issues.apache.org/jira/browse/FLINK-31763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31763:
---
Description:
As we discussed in FLINK-31610, new buffers can be requested only when
"{_}numOfReques
[
https://issues.apache.org/jira/browse/FLINK-31763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31763:
---
Summary: Convert requested buffers to overdraft buffers when pool size is
decreased (was: Ensure t
Jane Chan created FLINK-31791:
-
Summary: FLIP-292: Enhance COMPILED PLAN to support operator-level
state TTL configuration
Key: FLINK-31791
URL: https://issues.apache.org/jira/browse/FLINK-31791
Project:
[
https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711654#comment-17711654
]
jinghaihang commented on FLINK-31743:
-
Hi [~roman]
Previously, Tang Yun and I disc
[
https://issues.apache.org/jira/browse/FLINK-31530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711649#comment-17711649
]
xingyuan cheng commented on FLINK-31530:
The use of OracleCatalog is similar to
[
https://issues.apache.org/jira/browse/FLINK-27719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711648#comment-17711648
]
Yun Tang commented on FLINK-27719:
--
I think this ticket shall be marked as resolved, ri
1996fanrui commented on code in PR #22381:
URL: https://github.com/apache/flink/pull/22381#discussion_r1164914879
##
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java:
##
@@ -671,13 +675,20 @@ public void setNumBuffers(int numBuffers) {
Aitozi created FLINK-31790:
--
Summary: Filesystem batch sink should also respect to the
PartitionCommitPolicy
Key: FLINK-31790
URL: https://issues.apache.org/jira/browse/FLINK-31790
Project: Flink
I
flinkbot commented on PR #22386:
URL: https://github.com/apache/flink/pull/22386#issuecomment-1506226134
## CI report:
* a350087241b4eee9260a12f3f91181d3bc10109b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31787:
---
Labels: pull-request-available (was: )
> Add the explicit ROW constructor to the system fun
Aitozi opened a new pull request, #22386:
URL: https://github.com/apache/flink/pull/22386
## What is the purpose of the change
Add back the explicit ROW constructor to doc
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob store on job cre
[
https://issues.apache.org/jira/browse/FLINK-28484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-28484.
---
Resolution: Not A Bug
This is not a bug after revisit the code
> UniqueKey inference should respect
slfan1989 commented on PR #22374:
URL: https://github.com/apache/flink/pull/22374#issuecomment-1506183387
@reswqa @1996fanrui Thank you very much for helping to review the code!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711623#comment-17711623
]
Shilun Fan commented on FLINK-31761:
[~martijnvisser] Thanks for your message!
> Fi
FangYongs commented on code in PR #22360:
URL: https://github.com/apache/flink/pull/22360#discussion_r1164814536
##
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/utils/StringDataConverter.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the Apache Sof
[
https://issues.apache.org/jira/browse/FLINK-31787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benchao Li reassigned FLINK-31787:
--
Assignee: Aitozi
> Add the explicit ROW constructor to the system function doc
>
hustonic commented on PR #22370:
URL: https://github.com/apache/flink/pull/22370#issuecomment-1506133377
@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-16868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711590#comment-17711590
]
Chalres Tan commented on FLINK-16868:
-
hi [~jark], I was looking around for a way to
dannycranmer merged PR #6:
URL: https://github.com/apache/flink-connector-mongodb/pull/6
--
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
flinkbot commented on PR #22385:
URL: https://github.com/apache/flink/pull/22385#issuecomment-1505873875
## CI report:
* 57b89bec3f61af58a89a2c742b71eb191671c5ec UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
novakov-alexey closed pull request #22231: [hotfix] [docs] Fix documentation
hyperlink to table formats
URL: https://github.com/apache/flink/pull/22231
--
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 t
novakov-alexey commented on PR #22231:
URL: https://github.com/apache/flink/pull/22231#issuecomment-1505870495
@MartijnVisser I've create new PR. This time to master branch:
https://github.com/apache/flink/pull/22385
--
This is an automated message from the Apache Git Service.
To respond
novakov-alexey opened a new pull request, #22385:
URL: https://github.com/apache/flink/pull/22385
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring
rodmeneses commented on code in PR #563:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/563#discussion_r1164504549
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -217,9 +227,10
morhidi commented on code in PR #563:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/563#discussion_r1164497734
##
flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/controller/FlinkDeploymentControllerTest.java:
##
@@ -217,9 +227,10 @@
Morey Straus created FLINK-31789:
Summary: Update axel to current
Key: FLINK-31789
URL: https://issues.apache.org/jira/browse/FLINK-31789
Project: Flink
Issue Type: Bug
Affects Versions:
mohsenrezaeithe commented on PR #21849:
URL: https://github.com/apache/flink/pull/21849#issuecomment-1505672063
@zentol when you get a chance, could you please take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
mohsenrezaeithe commented on PR #22302:
URL: https://github.com/apache/flink/pull/22302#issuecomment-1505666939
@wuchong, thanks for pointing that out. Chinese docs are gtg.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
XComp commented on code in PR #22317:
URL: https://github.com/apache/flink/pull/22317#discussion_r1164423432
##
flink-runtime/src/test/java/org/apache/flink/runtime/persistence/TestingStateHandleStore.java:
##
@@ -121,11 +121,6 @@ public boolean releaseAndTryRemove(String name)
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-31363.
---
Resolution: Fixed
Merged via flink-connector-kafka a5df3c7c7f4925ff70114f862bca7588b
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31363:
Priority: Blocker (was: Major)
> KafkaSink failed to commit transactions under EX
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31363:
Fix Version/s: kafka-3.0.0
> KafkaSink failed to commit transactions under EXACTLY
[
https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31305:
Priority: Blocker (was: Major)
> KafkaWriter doesn't wait for errors for in-fligh
[
https://issues.apache.org/jira/browse/FLINK-31620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31620:
Priority: Blocker (was: Critical)
> ReducingUpsertWriter does not flush the wrapp
[
https://issues.apache.org/jira/browse/FLINK-30765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30765:
--
Affects Version/s: 1.18.0
(was: 1.17.0)
> LeaderElectionService.sto
[
https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-24456:
Fix Version/s: (was: kafka-3.0.0)
> Support bounded offset in the Kafka table
[
https://issues.apache.org/jira/browse/FLINK-31319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31319:
Fix Version/s: kafka-3.0.0
> Kafka new source partitionDiscoveryIntervalMs=0 cause
[
https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-24456:
Fix Version/s: kafka-3.0.0
> Support bounded offset in the Kafka table connector
>
[
https://issues.apache.org/jira/browse/FLINK-30765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-30765.
---
Resolution: Fixed
master: 3e4f653ffa0e9b86d82b1c1a00a1523e0891635b
> LeaderElectionService.
[
https://issues.apache.org/jira/browse/FLINK-30765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-30765:
--
Fix Version/s: 1.18.0
> LeaderElectionService.stop should always call revokeLeadership
> -
[
https://issues.apache.org/jira/browse/FLINK-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-31305.
---
Resolution: Fixed
Merged to flink-connector-kafka via:
* v3.0 - dd09fa9a3d05c7096c8
[
https://issues.apache.org/jira/browse/FLINK-31620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31620:
Fix Version/s: kafka-3.0.0
> ReducingUpsertWriter does not flush the wrapped write
[
https://issues.apache.org/jira/browse/FLINK-31620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-31620.
---
Resolution: Fixed
Merged to flink-connector-kafka via 15b51f17a1daa2edb4cd17b4100eb4
XComp merged PR #21742:
URL: https://github.com/apache/flink/pull/21742
--
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-31305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31305:
Fix Version/s: kafka-3.0.0
(was: 1.18.0)
> KafkaWriter does
[
https://issues.apache.org/jira/browse/FLINK-31599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31599:
Fix Version/s: kafka-3.1.0
(was: kafka-5.0.0)
> Update Kafk
[
https://issues.apache.org/jira/browse/FLINK-31740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-31740:
Fix Version/s: kafka-3.1.0
(was: kafka-4.1.0)
> Allow setti
[
https://issues.apache.org/jira/browse/FLINK-30963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-30963:
Fix Version/s: kafka-3.0.0
(was: kafka-3.0.1)
> Switch bina
[
https://issues.apache.org/jira/browse/FLINK-30996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-30996:
Fix Version/s: kafka-3.0.0
(was: kafka-4.0.0)
> Sync Kafka
[
https://issues.apache.org/jira/browse/FLINK-25916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai closed FLINK-25916.
---
Resolution: Fixed
> Using upsert-kafka with a flush buffer results in Null Pointer E
[
https://issues.apache.org/jira/browse/FLINK-31765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711487#comment-17711487
]
Matthias Pohl commented on FLINK-31765:
---
After a
[discussion|https://github.com/a
[
https://issues.apache.org/jira/browse/FLINK-31765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-31765:
--
Affects Version/s: (was: 1.17.0)
> Disable changelog backend for the StatefulJobSavepointM
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-31788:
-
Description:
This feature was originally implemented in the old planner:
[https://github.com/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Feng Jin updated FLINK-31788:
-
Description:
This feature was originally implemented in the old planner:
[https://github.com/apache/fli
[
https://issues.apache.org/jira/browse/FLINK-31788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711443#comment-17711443
]
Martijn Visser commented on FLINK-31788:
[~twalthr] WDYT?
> Add back Support em
[
https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711440#comment-17711440
]
Sergio Sainz edited comment on FLINK-31775 at 4/12/23 3:18 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-31775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711440#comment-17711440
]
Sergio Sainz commented on FLINK-31775:
--
Another confusion about how the fix for FL
Feng Jin created FLINK-31788:
Summary: Add back Support emitValueWithRetract for
TableAggregateFunction
Key: FLINK-31788
URL: https://issues.apache.org/jira/browse/FLINK-31788
Project: Flink
Iss
MartijnVisser merged PR #22310:
URL: https://github.com/apache/flink/pull/22310
--
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
hackergin commented on PR #22310:
URL: https://github.com/apache/flink/pull/22310#issuecomment-1505420389
@MartijnVisser Thank you for the suggestion, I have updated the pull request.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
[
https://issues.apache.org/jira/browse/FLINK-31761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711430#comment-17711430
]
Martijn Visser commented on FLINK-31761:
[~slfan1989] Next time, as outlined on
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-31757.
--
Resolution: Invalid
[~RocMarshal] When the ticket is updated, I can re-open it again. Right no
[
https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17711428#comment-17711428
]
Martijn Visser commented on FLINK-31749:
[~echauchot] WDYT? Did we make a mistak
1 - 100 of 253 matches
Mail list logo
