Yanquan Lv created FLINK-37644:
--
Summary: Include guava dependency to package of Kafka connector
release and shade
Key: FLINK-37644
URL: https://issues.apache.org/jira/browse/FLINK-37644
Project: Flink
beliefer commented on code in PR #26426:
URL: https://github.com/apache/flink/pull/26426#discussion_r2036389139
##
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java:
##
@@ -258,12 +270,28 @@ public void addAll(Configuration other, String prefix) {
beliefer commented on code in PR #26426:
URL: https://github.com/apache/flink/pull/26426#discussion_r2036390683
##
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java:
##
@@ -239,9 +239,21 @@ public void addAllToProperties(Properties props) {
}
beliefer commented on PR #26428:
URL: https://github.com/apache/flink/pull/26428#issuecomment-2791500611
@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.
beliefer commented on PR #26429:
URL: https://github.com/apache/flink/pull/26429#issuecomment-2791500256
@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.
beliefer commented on PR #26425:
URL: https://github.com/apache/flink/pull/26425#issuecomment-2791501451
@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.
beliefer commented on PR #26427:
URL: https://github.com/apache/flink/pull/26427#issuecomment-2791501023
@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.
lajith2006 commented on code in PR #957:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/957#discussion_r2036467035
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentStatus.java:
##
@@ -55,4 +60,188 @@ pu
lihaosky commented on PR #26385:
URL: https://github.com/apache/flink/pull/26385#issuecomment-2791506623
@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.
leishuiyu created FLINK-37646:
-
Summary: flink jobmanager oom
Key: FLINK-37646
URL: https://issues.apache.org/jira/browse/FLINK-37646
Project: Flink
Issue Type: Bug
Components: Runtime
Mrart closed pull request #3981: [FLINK-34820][postgressql] Not recycle but
reuse fetcher for all data to improve performant
URL: https://github.com/apache/flink-cdc/pull/3981
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
Bonnie Varghese created FLINK-37647:
---
Summary: Add support for NonTimeRowsUnboundedPrecedingFunction for
OverAggregate
Key: FLINK-37647
URL: https://issues.apache.org/jira/browse/FLINK-37647
Project
leonardBang merged PR #3978:
URL: https://github.com/apache/flink-cdc/pull/3978
--
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
Zakelly commented on code in PR #26419:
URL: https://github.com/apache/flink/pull/26419#discussion_r2036397553
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java:
##
@@ -370,7 +372,7 @@ public SingleOutputStreamOperator process(
@Over
beliefer commented on PR #26423:
URL: https://github.com/apache/flink/pull/26423#issuecomment-2791398146
ping @zentol cc @1996fanrui @davidradl @GOODBOY008
--
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
yanand0909 commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036415069
##
flink-python/pyflink/table/model_descriptor.py:
##
@@ -0,0 +1,140 @@
+
+# License
lvyanquan commented on PR #167:
URL:
https://github.com/apache/flink-connector-kafka/pull/167#issuecomment-2791566495
At present, there is a problem of LICENSE check failure in CI, and I am
trying to solve it
--
This is an automated message from the Apache Git Service.
To respond to the
AHeise commented on code in PR #26433:
URL: https://github.com/apache/flink/pull/26433#discussion_r2036031020
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java:
##
@@ -151,24 +149,23 @@ public void snapshotState(StateSnapshot
lihaosky commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036189107
##
flink-python/pyflink/table/table_environment.py:
##
@@ -656,6 +657,32 @@ def list_temporary_views(self) -> List[str]:
j_view_name_array = self._j_tenv.list
[
https://issues.apache.org/jira/browse/FLINK-37553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-37553.
-
Assignee: Yue Ma
Resolution: Fixed
> Make ForStKeyedStateBackend consider namespaceSeriali
yanand0909 commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036199353
##
flink-python/pyflink/table/table_environment.py:
##
@@ -656,6 +657,32 @@ def list_temporary_views(self) -> List[str]:
j_view_name_array = self._j_tenv.li
gunnarmorling commented on PR #26432:
URL: https://github.com/apache/flink/pull/26432#issuecomment-2789821478
@rmetzger Spotted the notorious "kakfa" typo at a few places. Let me know if
anything else is needed. Thx!
--
This is an automated message from the Apache Git Service.
To respond
davidradl commented on code in PR #26433:
URL: https://github.com/apache/flink/pull/26433#discussion_r2035640177
##
flink-runtime/src/main/java/org/apache/flink/streaming/runtime/operators/sink/CommitterOperator.java:
##
@@ -151,24 +149,23 @@ public void snapshotState(StateSnaps
[
https://issues.apache.org/jira/browse/FLINK-37633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hugo Ricateau updated FLINK-37633:
--
Description:
When performing a temporal join between a left stream and a right versioned
tabl
gaopeng172 opened a new pull request, #26431:
URL: https://github.com/apache/flink/pull/26431
## What is the purpose of the change
This pull request makes the global testing process successful
## Brief change log
- *Create a function with the @VisibleForTesting tag to p
[
https://issues.apache.org/jira/browse/FLINK-37605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37605:
---
Labels: pull-request-available (was: )
> SinkWriter may incorrectly infer end of input duri
davidradl commented on PR #26424:
URL: https://github.com/apache/flink/pull/26424#issuecomment-2789836541
@bvarghese1 please could you add the real Jira number to the title - thanks.
--
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-35466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942194#comment-17942194
]
Timo Walther commented on FLINK-35466:
--
The Table API is more flexible than SQL. Th
davidradl commented on PR #25511:
URL: https://github.com/apache/flink/pull/25511#issuecomment-2789822331
Thanks @rmetzger :-)
--
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
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035532386
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035538351
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-37484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruan Hang resolved FLINK-37484.
---
Resolution: Fixed
master(3.4-SNAPSHOT): 164671558ad41751d8c250b37f3341afecbba413
> unbounded-chunk-
fredia merged PR #26422:
URL: https://github.com/apache/flink/pull/26422
--
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
autophagy commented on code in PR #26247:
URL: https://github.com/apache/flink/pull/26247#discussion_r2035356174
##
flink-python/pyflink/table/catalog.py:
##
@@ -36,6 +37,7 @@
'Constraint', 'UniqueConstraint', 'ResolvedSchema']
+@PublicEvolving()
Review Comment:
beliefer opened a new pull request, #26427:
URL: https://github.com/apache/flink/pull/26427
## What is the purpose of the change
This PR aims to rename `loadJarFile` to `checkJarFile`.
The reason is `loadJarFile` just checking if the jar file is valid and is
not related to load.
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035538351
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
flinkbot commented on PR #26427:
URL: https://github.com/apache/flink/pull/26427#issuecomment-2788756877
## CI report:
* 3ae71235f9cc34c72060bd56fa8846d688615150 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942321#comment-17942321
]
Yanquan Lv commented on FLINK-37644:
I would like to take it.
> Include guava depen
lvyanquan opened a new pull request, #167:
URL: https://github.com/apache/flink-connector-kafka/pull/167
Include guava dependency to avoid ClassNotFoundException, and shade it to
avoid conflict.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37644:
---
Labels: pull-request-available (was: )
> Include guava dependency to package of Kafka conne
lvyanquan opened a new pull request, #168:
URL: https://github.com/apache/flink-connector-kafka/pull/168
Backport fix of FLINK-37644 to 4.0 branch.
--
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
[
https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan closed FLINK-37511.
-
Resolution: Fixed
Merged to master as fc51d4e09b45064e180d48fb3cfcc68865d950d0
> JobPla
kgeis commented on PR #142:
URL:
https://github.com/apache/flink-connector-jdbc/pull/142#issuecomment-2791211700
@1996fanrui 🙏
--
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 comm
rkhachatryan merged PR #26320:
URL: https://github.com/apache/flink/pull/26320
--
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.
[
https://issues.apache.org/jira/browse/FLINK-37511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-37511:
--
Issue Type: Improvement (was: Bug)
> JobPlanInfo properties aren't listed in OpenAPI
beliefer commented on code in PR #26426:
URL: https://github.com/apache/flink/pull/26426#discussion_r2035629008
##
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java:
##
@@ -258,12 +270,28 @@ public void addAll(Configuration other, String prefix) {
bvarghese1 commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035702582
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
ferenc-csaky commented on code in PR #785:
URL: https://github.com/apache/flink-web/pull/785#discussion_r2035544783
##
docs/data/release_archive.yml:
##
@@ -679,6 +679,11 @@ release_archive:
version: 2.0.0
release_date: "2025-03-17"
filename: "mongodb"
+
autophagy commented on code in PR #26247:
URL: https://github.com/apache/flink/pull/26247#discussion_r2035710228
##
flink-python/pyflink/table/catalog.py:
##
@@ -36,6 +37,7 @@
'Constraint', 'UniqueConstraint', 'ResolvedSchema']
+@PublicEvolving()
Review Comment:
bvarghese1 commented on code in PR #26407:
URL: https://github.com/apache/flink/pull/26407#discussion_r2035654644
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala:
##
@@ -310,18 +310,2
beliefer commented on PR #26427:
URL: https://github.com/apache/flink/pull/26427#issuecomment-2789620938
@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.
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035475764
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035477949
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035476609
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035457680
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
beliefer commented on PR #26429:
URL: https://github.com/apache/flink/pull/26429#issuecomment-2789616850
@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.
github-actions[bot] commented on PR #25739:
URL: https://github.com/apache/flink/pull/25739#issuecomment-2788405796
This PR is being marked as stale since it has not had any activity in the
last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a
review
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035522692
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035522692
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
flinkbot commented on PR #26428:
URL: https://github.com/apache/flink/pull/26428#issuecomment-2788829143
## CI report:
* 55ec34348cd901aae8e782fb11e8698c0b92fe43 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
soisyourface opened a new pull request, #197:
URL: https://github.com/apache/flink-connector-aws/pull/197
I am waiting for access to JIRA to create the issue but figured I'd create
the PR to get the conversation started.
There is a conversation in
[slack](https://apache-flink.slack.com/a
snuyanzin commented on code in PR #26407:
URL: https://github.com/apache/flink/pull/26407#discussion_r2035245920
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala:
##
@@ -310,18 +310,26
ls-1801 commented on PR #25511:
URL: https://github.com/apache/flink/pull/25511#issuecomment-2788422040
It’s not stale, I am waiting for reviews.
--
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 t
[
https://issues.apache.org/jira/browse/FLINK-37633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hugo Ricateau updated FLINK-37633:
--
Description:
When performing a temporal join between a left stream and a right versioned
tabl
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36167.
--
Resolution: Duplicate
> testSinkDisorderChangeLog failed on AZP
>
Dawid Wysakowicz created FLINK-37643:
Summary: Support partial deletes when converting to external data
structures
Key: FLINK-37643
URL: https://issues.apache.org/jira/browse/FLINK-37643
Project:
beliefer commented on PR #26423:
URL: https://github.com/apache/flink/pull/26423#issuecomment-2789926608
@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.
davidradl commented on code in PR #26430:
URL: https://github.com/apache/flink/pull/26430#discussion_r2035559270
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuserUtils.java:
##
@@ -203,7 +204,13 @@ private static WatermarkPushD
davidradl commented on code in PR #26430:
URL: https://github.com/apache/flink/pull/26430#discussion_r2035566851
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/ScanReuserUtils.java:
##
@@ -203,7 +204,13 @@ private static WatermarkPushD
Yanquan Lv created FLINK-37636:
--
Summary: Weekly CI failure
Key: FLINK-37636
URL: https://issues.apache.org/jira/browse/FLINK-37636
Project: Flink
Issue Type: Improvement
Components:
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035502507
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
ruanhang1993 commented on code in PR #3812:
URL: https://github.com/apache/flink-cdc/pull/3812#discussion_r2032935652
##
docs/content.zh/docs/core-concept/data-pipeline.md:
##
@@ -115,4 +115,5 @@ under the License.
|-|---|
davidradl commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2035544454
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
lajith2006 commented on code in PR #957:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/957#discussion_r2036467035
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/status/FlinkDeploymentStatus.java:
##
@@ -55,4 +60,188 @@ pu
Jiaan Geng created FLINK-37645:
--
Summary: Improve existsUnboundedSource by avoiding duplicate check
transformations
Key: FLINK-37645
URL: https://issues.apache.org/jira/browse/FLINK-37645
Project: Flink
beliefer opened a new pull request, #26434:
URL: https://github.com/apache/flink/pull/26434
## What is the purpose of the change
This PR aims to improve existsUnboundedSource by avoiding duplicate check
transformations.
## Brief change log
Improve existsUnboundedSour
ruanhang1993 opened a new pull request, #788:
URL: https://github.com/apache/flink-web/pull/788
This PR adds JDBC Connector v3.3.0.
--
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 co
flinkbot commented on PR #26434:
URL: https://github.com/apache/flink/pull/26434#issuecomment-2791452508
## CI report:
* 118377c4cc01292ed406887c15ac6277573291e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia opened a new pull request, #26435:
URL: https://github.com/apache/flink/pull/26435
## What is the purpose of the change
Use the mailboxExecutor with correct priority when creating
`AsyncExecutionController` in Async state processing.
## Brief change log
- Use
[
https://issues.apache.org/jira/browse/FLINK-37642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37642:
---
Labels: pull-request-available (was: )
> Use the mailboxExecutor for operator in Async stat
[
https://issues.apache.org/jira/browse/FLINK-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-37644:
Affects Version/s: kafka-3.4.0
> Include guava dependency to package of Kafka connector release an
AHeise commented on PR #167:
URL:
https://github.com/apache/flink-connector-kafka/pull/167#issuecomment-2791725833
I was wondering if we should already shade in the datastream connector. My
main reason is that if a datastream application uses multiple connectors, we
will already have depen
flinkbot commented on PR #26435:
URL: https://github.com/apache/flink/pull/26435#issuecomment-2791733754
## CI report:
* c6e8d8d98b14c4153aa30ecf03d19e96a797c7b1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
JunRuiLee merged PR #26081:
URL: https://github.com/apache/flink/pull/26081
--
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-37644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37644:
--
Assignee: Yanquan Lv
> Include guava dependency to package of Kafka connector release and sha
[
https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee reassigned FLINK-37225:
--
Assignee: Zhanghao Chen
> Remove remaining test resources of Gelly
>
[
https://issues.apache.org/jira/browse/FLINK-37225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee closed FLINK-37225.
--
Resolution: Fixed
master 0a1b3ca917949e1f1965e8eec27b0d31889d690b
> Remove remaining test resources o
twalthr commented on code in PR #26389:
URL: https://github.com/apache/flink/pull/26389#discussion_r2035131209
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java:
##
@@ -561,12 +560,12 @@ ANY, and(logical(LogicalTypeR
[
https://issues.apache.org/jira/browse/FLINK-37631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-37631:
Summary: Support flink cdc pipeline k8s session mode (was: Support flink
cdc pipeline k session m
darenwkt commented on code in PR #195:
URL:
https://github.com/apache/flink-connector-aws/pull/195#discussion_r2035325733
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/polling/PollingKinesisShardSplitReader.jav
[
https://issues.apache.org/jira/browse/FLINK-36821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-36821:
Issue Type: Technical Debt (was: Improvement)
> Upgrade Kafka Client version to 3.9.0
> -
yanand0909 commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036413716
##
docs/content/docs/dev/python/table/table_environment.md:
##
@@ -795,6 +850,29 @@ These APIs are used to access catalogs and modules. You
can find more detailed i
yanand0909 commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036415613
##
flink-python/pyflink/table/model_descriptor.py:
##
@@ -0,0 +1,140 @@
+
+# License
yanand0909 commented on code in PR #26385:
URL: https://github.com/apache/flink/pull/26385#discussion_r2036414569
##
docs/content/docs/dev/python/table/table_environment.md:
##
@@ -199,6 +199,61 @@ These APIs are used to create/remove Table API/SQL Tables
and write queries:
joyCurry30 commented on PR #3979:
URL: https://github.com/apache/flink-cdc/pull/3979#issuecomment-2791651031
Please make your branch rebase on master.
--
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
thomasg19930417 commented on PR #103:
URL:
https://github.com/apache/flink-connector-pulsar/pull/103#issuecomment-2791619064
@yebai1105 If the StartCursor for consumption is set to "earliest", will
there be any issues just by changing this part? Looking at the code, there is
no other place
[
https://issues.apache.org/jira/browse/FLINK-37647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37647:
---
Labels: pull-request-available (was: )
> Add support for NonTimeRowsUnboundedPrecedingFunct
bvarghese1 commented on code in PR #26424:
URL: https://github.com/apache/flink/pull/26424#discussion_r2036575201
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRowsUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,719 @@
+/*
+
hql0312 closed pull request #3979: [postgres] fix when backfill will scan all
table schame which match config
URL: https://github.com/apache/flink-cdc/pull/3979
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
hql0312 commented on PR #3985:
URL: https://github.com/apache/flink-cdc/pull/3985#issuecomment-2791663503
@joyCurry30 i add new pr from https://github.com/apache/flink-cdc/pull/3979
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
1 - 100 of 185 matches
Mail list logo
