AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1953999555
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaSink.java:
##
@@ -110,28 +110,35 @@ public SimpleVersionedSerializer
getC
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1954004370
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache S
pnowojski commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2655806513
@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.
boring-cyborg[bot] commented on PR #189:
URL:
https://github.com/apache/flink-connector-aws/pull/189#issuecomment-2655821814
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is a
Sunninsky closed pull request #189: add our own metric for flink-connect-aws
connector
URL: https://github.com/apache/flink-connector-aws/pull/189
--
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
tianyuan created FLINK-37322:
Summary: surport eval groovy scripts udf for flink sql
Key: FLINK-37322
URL: https://issues.apache.org/jira/browse/FLINK-37322
Project: Flink
Issue Type: New Feature
xing1mo commented on PR #25629:
URL: https://github.com/apache/flink/pull/25629#issuecomment-2658146056
> Thanks for this contribution! LGTM overall. I just left some comments.
BTW, could you please explain a little why the current ITCases do not cover
these cases to expose this bug?
Zakelly commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1955472174
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/*
+ *
Zakelly commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1955472739
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Attachment: (was: test-batch-job.yaml)
> FINISHED jobs incorrectly being set to RECONCILIN
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Attachment: test-batch-job.yaml
test-finite-streaming-job.yaml
> FINISHED jobs
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Attachment: operator-log-finite-streaming-job.log
> FINISHED jobs incorrectly being set to REC
Zakelly commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1955530219
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,119 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table API
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
Zakelly commented on PR #26154:
URL: https://github.com/apache/flink/pull/26154#issuecomment-2658230136
And I suggest another ticket for the chinese doc.
--
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
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
[
https://issues.apache.org/jira/browse/FLINK-37314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927040#comment-17927040
]
Liu commented on FLINK-37314:
-
[~jark] Can you help confirm the error? Thanks.
> The water
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
[
https://issues.apache.org/jira/browse/FLINK-37320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luca Castelli updated FLINK-37320:
--
Description:
Hello,
I believe I've found bugs within the observation logic for both finite
s
MOBIN-F commented on code in PR #3918:
URL: https://github.com/apache/flink-cdc/pull/3918#discussion_r1955597041
##
flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java:
##
@@ -79,9 +73,10 @@ public static FlinkPipelineComposer ofRemote
[
https://issues.apache.org/jira/browse/FLINK-36936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927028#comment-17927028
]
Wang Qilong commented on FLINK-36936:
-
Thanks for the reminder. I will make improvem
xuyangzhong commented on PR #25629:
URL: https://github.com/apache/flink/pull/25629#issuecomment-2658307357
> > Thanks for this contribution! LGTM overall. I just left some comments.
BTW, could you please explain a little why the current ITCases do not cover
these cases to expose this bug?
JunRuiLee merged PR #26152:
URL: https://github.com/apache/flink/pull/26152
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee resolved FLINK-37309.
Resolution: Fixed
master * 3790af913214f94c658ad36669c6fd185a9be010
* 05a3e9c578e9efe8755058d1f7f
[
https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926712#comment-17926712
]
Junrui Lee edited comment on FLINK-37309 at 2/13/25 8:35 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-37309.
--
> Skewed join optimization not working as expected
>
>
>
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1954055411
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/Backchannel.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache S
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1954063870
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apa
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1954062766
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apa
codenohup commented on code in PR #26118:
URL: https://github.com/apache/flink/pull/26118#discussion_r1954372293
##
flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test/examples/DSv2ExamplesITCase.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the
Zakelly commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1954387046
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/*
+ *
davidradl commented on code in PR #26126:
URL: https://github.com/apache/flink/pull/26126#discussion_r1952955606
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBSharedResourcesFactory.java:
##
@@ -36,7 +36,7 @@
*/
enum Ro
MOBIN-F commented on code in PR #3643:
URL: https://github.com/apache/flink-cdc/pull/3643#discussion_r1954172258
##
flink-cdc-composer/pom.xml:
##
@@ -61,6 +61,12 @@ limitations under the License.
flink-kubernetes
${flink.version}
+
+
davidradl commented on PR #26128:
URL: https://github.com/apache/flink/pull/26128#issuecomment-2656454241
Reviewed by Chi on 13/02/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
lvyanquan commented on PR #140:
URL:
https://github.com/apache/flink-connector-kafka/pull/140#issuecomment-2656410728
Rebase master to solve conflict.
--
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 g
Zakelly commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1954386503
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/*
+ *
afedulov opened a new pull request, #214:
URL: https://github.com/apache/flink-docker/pull/214
(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,
davidradl commented on PR #26126:
URL: https://github.com/apache/flink/pull/26126#issuecomment-2656442036
Reviewed by Chi on 13/02/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-36569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926765#comment-17926765
]
Hongshun Wang commented on FLINK-36569:
---
[~ft20082]
It seems that :
1. if the K
xuyangzhong commented on code in PR #25637:
URL: https://github.com/apache/flink/pull/25637#discussion_r1954441128
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/window/processors/WindowAggProcessorBase.java:
##
@@ -91,6 +91,9
gaborgsomogyi commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1954140905
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/
Jufang He created FLINK-37317:
-
Summary: Checkpoint asyncOperationsThreadPool has only one thread
running
Key: FLINK-37317
URL: https://issues.apache.org/jira/browse/FLINK-37317
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-37317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jufang He updated FLINK-37317:
--
Description:
org.apache.flink.streaming.runtime.tasks.StreamTask#AsyncOperationsThreadPool
configurat
xuhuang created FLINK-37316:
---
Summary: Add StateManager#getStateOptional and
StateManager#getState methods for DataStream V2
Key: FLINK-37316
URL: https://issues.apache.org/jira/browse/FLINK-37316
Project:
[
https://issues.apache.org/jira/browse/FLINK-37313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37313:
---
Labels: pull-request-available (was: )
> [BUG] MySQL snapshot read phase is unresponsive fo
flinkbot commented on PR #26155:
URL: https://github.com/apache/flink/pull/26155#issuecomment-2656153053
## CI report:
* 24a48e1ad8379b96daa345ac10adac54ef1c99b8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gongzexin opened a new pull request, #3920:
URL: https://github.com/apache/flink-cdc/pull/3920
This closes [FLINK-37313](https://issues.apache.org/jira/browse/FLINK-37313).
# SnapshotSplitReader#isBackfillRequired
If the binlog has not changed during the snapshot split read, the bin
joyCurry30 commented on PR #3643:
URL: https://github.com/apache/flink-cdc/pull/3643#issuecomment-2656286080
I think the feature of allowing Flink configuration to be passed through a
YAML job file should be split into a separate issue, rather than being added
here.
--
This is an automat
GOODBOY008 commented on PR #3873:
URL: https://github.com/apache/flink-cdc/pull/3873#issuecomment-2656294711
@morozov Can you help me review this PR?
--
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
gaborgsomogyi commented on PR #26154:
URL: https://github.com/apache/flink/pull/26154#issuecomment-2656303266
cc @gyfora @Zakelly
--
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 com
[
https://issues.apache.org/jira/browse/FLINK-37241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926749#comment-17926749
]
David Morávek commented on FLINK-37241:
---
master: cd0cfe42c15042a3c27a0c341416aa32c
mbalassi merged PR #211:
URL: https://github.com/apache/flink-docker/pull/211
--
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.a
[
https://issues.apache.org/jira/browse/FLINK-37241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926749#comment-17926749
]
David Morávek edited comment on FLINK-37241 at 2/13/25 1:07 PM:
--
dmvk merged PR #26096:
URL: https://github.com/apache/flink/pull/26096
--
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
[
https://issues.apache.org/jira/browse/FLINK-37241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek updated FLINK-37241:
--
Fix Version/s: 2.0.0
1.20.2
> Remove Mockito dependency from StateBackendTe
mbalassi merged PR #212:
URL: https://github.com/apache/flink-docker/pull/212
--
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.a
mbalassi merged PR #213:
URL: https://github.com/apache/flink-docker/pull/213
--
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.a
mbalassi merged PR #214:
URL: https://github.com/apache/flink-docker/pull/214
--
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.a
davidradl commented on code in PR #26155:
URL: https://github.com/apache/flink/pull/26155#discussion_r1954488306
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala:
##
@@ -541,7 +541,14 @@ class SelectivityEs
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954515580
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954530982
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954530982
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954499033
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on PR #26155:
URL: https://github.com/apache/flink/pull/26155#issuecomment-2656592583
Reviewed by Chi on 13/02/2025 Go back to the submitter with review comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954501891
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954500835
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954514450
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954511630
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954510347
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954505598
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954537188
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -26,7 +26,7 @@ under the License.
# State Processor API
-Apache Flink's State Processor API provides powe
gaborgsomogyi commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1954542463
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954545970
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954518842
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954521009
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954521009
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954522469
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954521009
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954528887
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954529204
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954532918
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954535936
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,120 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table AP
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954537188
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -26,7 +26,7 @@ under the License.
# State Processor API
-Apache Flink's State Processor API provides powe
davidradl commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1954537188
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -26,7 +26,7 @@ under the License.
# State Processor API
-Apache Flink's State Processor API provides powe
davidradl commented on code in PR #26121:
URL: https://github.com/apache/flink/pull/26121#discussion_r1954557783
##
flink-python/pyflink/table/catalog.py:
##
@@ -1391,3 +1398,422 @@ def of(catalog_name: str, configuration: Configuration,
comment: str = None):
j_catalog
littleeleventhwolf commented on code in PR #26128:
URL: https://github.com/apache/flink/pull/26128#discussion_r1954561967
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java:
##
@@ -233,6 +233,19 @@ private TableConfigOptio
littleeleventhwolf commented on code in PR #26126:
URL: https://github.com/apache/flink/pull/26126#discussion_r1954569028
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBSharedResourcesFactory.java:
##
@@ -36,7 +36,7 @@
*/
gaborgsomogyi commented on code in PR #26134:
URL: https://github.com/apache/flink/pull/26134#discussion_r1954578019
##
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/iterator/RocksMultiStateKeysIterator.java:
##
@@ -0,0 +1,180 @@
+/
[
https://issues.apache.org/jira/browse/FLINK-36650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anton Solovev updated FLINK-36650:
--
Affects Version/s: 1.18.1
1.17.2
> ConfluentRegistryAvroSerializationSc
davidradl commented on code in PR #26155:
URL: https://github.com/apache/flink/pull/26155#discussion_r1954617030
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala:
##
@@ -541,7 +541,14 @@ class SelectivityEs
autophagy commented on code in PR #26121:
URL: https://github.com/apache/flink/pull/26121#discussion_r1954107184
##
flink-python/pyflink/table/catalog.py:
##
@@ -1391,3 +1398,422 @@ def of(catalog_name: str, configuration: Configuration,
comment: str = None):
j_catalog
autophagy commented on code in PR #26121:
URL: https://github.com/apache/flink/pull/26121#discussion_r1954106011
##
flink-python/docs/reference/pyflink.table/catalog.rst:
##
@@ -250,3 +250,84 @@ A CatalogDescriptor is a template for creating a catalog
instance. It closely re
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1954107019
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImplTest.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the
gaborgsomogyi opened a new pull request, #26154:
URL: https://github.com/apache/flink/pull/26154
## What is the purpose of the change
[FLIP-496](https://cwiki.apache.org/confluence/display/FLINK/FLIP-496%3A+SQL+connector+for+keyed+savepoint+data)
has described the SQL connector for k
1996fanrui opened a new pull request, #943:
URL: https://github.com/apache/flink-kubernetes-operator/pull/943
## What is the purpose of the change
1.20.0 fixed several of bugs, and we always use the .1 (patch version) as
the dependency to avoid some bugs.
## Brief change log
MOBIN-F closed pull request #3918: [FLINK-36581][cli] Allow passing Flink
configuration by yaml job file
URL: https://github.com/apache/flink-cdc/pull/3918
--
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
MOBIN-F commented on PR #3918:
URL: https://github.com/apache/flink-cdc/pull/3918#issuecomment-2656056743
move to: https://github.com/apache/flink-cdc/pull/3643
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL a
1 - 100 of 188 matches
Mail list logo
