[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893031#comment-17893031
]
Anil Dasari commented on FLINK-36584:
-
I found high watermark info here -
[https://
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893029#comment-17893029
]
Anil Dasari commented on FLINK-36584:
-
"backfill log" mean DB updates during snapsho
[
https://issues.apache.org/jira/browse/FLINK-36584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17893028#comment-17893028
]
Anil Dasari commented on FLINK-36584:
-
[~loserwang1024] Thank you for sharing the de
ferenc-csaky merged PR #25557:
URL: https://github.com/apache/flink/pull/25557
--
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.
ferenc-csaky merged PR #25558:
URL: https://github.com/apache/flink/pull/25558
--
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.
liuml07 opened a new pull request, #25576:
URL: https://github.com/apache/flink/pull/25576
https://issues.apache.org/jira/browse/FLINK-36604
## What is the purpose of the change
We can add a precondition check and report meaningful error message for
debugging.
## Verifyi
flinkbot commented on PR #25576:
URL: https://github.com/apache/flink/pull/25576#issuecomment-2439076207
## CI report:
* ce5a58f65a4e29cd717a37a087334ef11d6205fa UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36604:
---
Labels: pull-request-available (was: )
> StreamingJobGraphGenerator::setOperatorConfig chec
github-actions[bot] commented on PR #3289:
URL: https://github.com/apache/flink-cdc/pull/3289#issuecomment-2439061784
This pull request has been closed because it has not had recent activity.
You could reopen it if you try to continue your work, and anyone who are
interested in it are encou
Mingliang Liu created FLINK-36604:
-
Summary: StreamingJobGraphGenerator::setOperatorConfig checks
input serializer lengh
Key: FLINK-36604
URL: https://issues.apache.org/jira/browse/FLINK-36604
Project
github-actions[bot] commented on PR #3254:
URL: https://github.com/apache/flink-cdc/pull/3254#issuecomment-2439061801
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] closed pull request #3289: [FLINK-35291] Improve the ROW
data deserialization performance of DebeziumEventDeserializationScheme
URL: https://github.com/apache/flink-cdc/pull/3289
--
This is an automated message from the Apache Git Service.
To respond to the message, please
github-actions[bot] commented on PR #3437:
URL: https://github.com/apache/flink-cdc/pull/3437#issuecomment-2439061718
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
snuyanzin commented on PR #25316:
URL: https://github.com/apache/flink/pull/25316#issuecomment-2438607426
@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.
snuyanzin commented on PR #25316:
URL: https://github.com/apache/flink/pull/25316#issuecomment-2438463937
@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.
ferenc-csaky merged PR #25525:
URL: https://github.com/apache/flink/pull/25525
--
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-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36542:
-
Priority: Minor (was: Major)
> Bump spotless version to 2.35.0
> --
[
https://issues.apache.org/jira/browse/FLINK-36542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-36542.
Resolution: Fixed
[{{5872a7a}}|https://github.com/apache/flink/commit/5872a7afd9ab1646278740f01324
[
https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-36591:
---
Fix Version/s: 2.0.0
1.18.2
1.19.2
1
[
https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-36591.
--
Resolution: Fixed
> WikipediaEditsSourceTest fails in all cases
>
[
https://issues.apache.org/jira/browse/FLINK-36591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892847#comment-17892847
]
Martijn Visser commented on FLINK-36591:
Fixed in:
release-1.18: b2a260ac957dac
MartijnVisser merged PR #25572:
URL: https://github.com/apache/flink/pull/25572
--
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
MartijnVisser merged PR #25571:
URL: https://github.com/apache/flink/pull/25571
--
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
MartijnVisser merged PR #25570:
URL: https://github.com/apache/flink/pull/25570
--
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
nicusX opened a new pull request, #10:
URL: https://github.com/apache/flink-connector-prometheus/pull/10
## Purpose of the change
Fixed spelling of words "behavior" and "retryable" inconsistently used
across the code and the API
## Verifying this change
Please make sure
pnowojski merged PR #25574:
URL: https://github.com/apache/flink/pull/25574
--
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-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36603:
---
Labels: pull-request-available (was: )
> Inconsistent spelling of "behavior" and "retryable
[
https://issues.apache.org/jira/browse/FLINK-36555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36555.
--
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to master as d488b7a989d
> Guarantee deb
[
https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-36556:
---
Release Note: When using buffer debloating, during job's startup or
recovery, when we don't
[
https://issues.apache.org/jira/browse/FLINK-36556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36556.
--
Fix Version/s: 2.0.0
Release Note:
When using buffer debloating, during job's startup int
[
https://issues.apache.org/jira/browse/FLINK-36593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-36593.
--
Fix Version/s: 2.0.0
Assignee: Thomas Cooper
Resolution: Fixed
Fixed in apache
MartijnVisser merged PR #25567:
URL: https://github.com/apache/flink/pull/25567
--
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
myskaludek commented on PR #848:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2437590183
Hi
I made changes to helm template file, but operator pod will not start with
error
```
Exception in thread "main"
org.apache.flink.configuration.IllegalC
[
https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-36603:
---
Description:
The spelling of the word "behavior" is inconsistent across the API
e.g.
{{.set
[
https://issues.apache.org/jira/browse/FLINK-36603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lorenzo Nicora updated FLINK-36603:
---
Summary: Inconsistent spelling of "behavior" and "retryable" across the API
(was: Inconsist
hlteoh37 commented on PR #25548:
URL: https://github.com/apache/flink/pull/25548#issuecomment-2437902849
@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-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36602:
--
Description:
The currently used Calcite version (1.32) has a high severity vulnerability
([CV
hlteoh37 commented on PR #25548:
URL: https://github.com/apache/flink/pull/25548#issuecomment-2437865377
CI seems to be failing because of editing a wiki -.- 99.9% sure it's not
related to this change!
![image](https://github.com/user-attachments/assets/219bd6c8-b03b-42dd-9fea-306f3e
Lorenzo Nicora created FLINK-36603:
--
Summary: Inconsistent spelling of "behavior" across the API
Key: FLINK-36603
URL: https://issues.apache.org/jira/browse/FLINK-36603
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36602:
--
Description: The currently used Calcite version (1.32) has a high severity
vulnerability ([CVE
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36602:
--
Issue Type: Improvement (was: Technical Debt)
> Upgrade Calcite version to 1.38.0
> -
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36602:
--
Affects Version/s: 2.0-preview
> Upgrade Calcite version to 1.38.0
> -
[
https://issues.apache.org/jira/browse/FLINK-36602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Cooper updated FLINK-36602:
--
Description: The currently used Calcite version (1.32) has a high severity
vulnerability ([CVE
Thomas Cooper created FLINK-36602:
-
Summary: Upgrade Calcite version to 1.38.0
Key: FLINK-36602
URL: https://issues.apache.org/jira/browse/FLINK-36602
Project: Flink
Issue Type: Technical Deb
[
https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-36377:
--
Assignee: Yang Li
> Support the use of the LAST_VALUE aggregate function on ROW type
[
https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892801#comment-17892801
]
Martijn Visser commented on FLINK-36377:
[~dezhouliyang] I've assigned it to you
myskaludek commented on PR #848:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2437587335
Hi , i made changes to helm template and in values set
```yaml
defaultConfiguration:
standardYaml: true
```
The operator dont start pod with errror
ruanwenjun commented on PR #25525:
URL: https://github.com/apache/flink/pull/25525#issuecomment-2437568942
Done.
--
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 unsubscr
Zakelly commented on PR #25560:
URL: https://github.com/apache/flink/pull/25560#issuecomment-2437562920
@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-33571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892173#comment-17892173
]
Thomas Cooper edited comment on FLINK-33571 at 10/24/24 2:46 PM:
-
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1816437897
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the A
nicusX commented on PR #3:
URL:
https://github.com/apache/flink-connector-prometheus/pull/3#issuecomment-2437409370
New
[docs
preview](https://github.com/user-attachments/files/17520427/prometheus-connectr-docs-preview.pdf)
with latest changes
--
This is an automated message fro
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1816418355
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Licensed to the A
noorall commented on code in PR #25414:
URL: https://github.com/apache/flink/pull/25414#discussion_r1816403718
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/util/StreamEdgeUpdateRequestInfo.java:
##
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software F
MartijnVisser commented on PR #25570:
URL: https://github.com/apache/flink/pull/25570#issuecomment-2437305946
@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 comm
xiangyuf commented on PR #25554:
URL: https://github.com/apache/flink/pull/25554#issuecomment-2437301871
@Zakelly hi, all comments have been resolved. Would you kindly take a look
when you have time?
--
This is an automated message from the Apache Git Service.
To respond to the message, p
tinaselenge commented on PR #25565:
URL: https://github.com/apache/flink/pull/25565#issuecomment-2437269158
@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 commen
tinaselenge commented on PR #25563:
URL: https://github.com/apache/flink/pull/25563#issuecomment-2437266570
Failing test seems to be unrelated to this 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 abo
tinaselenge commented on PR #25564:
URL: https://github.com/apache/flink/pull/25564#issuecomment-2437263499
Failing test is unrelated to this 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
xiangyuf commented on code in PR #25554:
URL: https://github.com/apache/flink/pull/25554#discussion_r1816289307
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
flinkbot commented on PR #25572:
URL: https://github.com/apache/flink/pull/25572#issuecomment-2432909372
## CI report:
* f6802244c03f4855910a9bbfc8585c63005d437b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangli updated FLINK-34792:
---
Attachment: image-2024-10-25-16-00-58-373.png
> [Bug] Incremental source never switches to streaming mode wi
[
https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892701#comment-17892701
]
wangli commented on FLINK-34792:
I think there are two problems here.
# If checkpointin
xiangyuf commented on code in PR #25554:
URL: https://github.com/apache/flink/pull/25554#discussion_r1816190153
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
tomncooper commented on PR #25573:
URL: https://github.com/apache/flink/pull/25573#issuecomment-2435518436
This is failing to build with JDK 11 but the main `release-1.20` branch also
fails to build with JDK 11
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-36317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892498#comment-17892498
]
Eaugene Thomas commented on FLINK-36317:
Hi [~mapohl] , Can you assign to me ?
SamBarker commented on PR #893:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/893#issuecomment-2437141425
This shows it in action on my fork: ![Screenshot 2024-10-25 at 8 58 16
pm](https://github.com/user-attachments/assets/6e69c7b2-eaea-4b35-abe5-c898d02b2461)
--
Thi
SamBarker commented on PR #893:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/893#issuecomment-2437138461
@gyfora alternative CI matrix as requested. Even if the matrix proposed in
this PR doesn't feel "right" it sets things up so that the matrix is
considerably easier to c
[
https://issues.apache.org/jira/browse/FLINK-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangli updated FLINK-34792:
---
Attachment: (was: image-2024-10-25-15-46-28-124.png)
> [Bug] Incremental source never switches to stream
hlteoh37 commented on PR #25548:
URL: https://github.com/apache/flink/pull/25548#issuecomment-2437121774
@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-34792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
wangli updated FLINK-34792:
---
Attachment: image-2024-10-25-15-46-28-124.png
> [Bug] Incremental source never switches to streaming mode wi
tttzzzwww commented on PR #1079:
URL: https://github.com/apache/flink-cdc/pull/1079#issuecomment-2437099920
hello!In flink cdc 2.2, flink does need to build table permission and write
permission, because in io.debezium.connector. oracle.logminer Log location of
the latest read to be logged,
cy2008 commented on PR #25575:
URL: https://github.com/apache/flink/pull/25575#issuecomment-2437089614
@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.
T
[
https://issues.apache.org/jira/browse/FLINK-36600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36600:
---
Labels: pull-request-available (was: )
> Implement java.sql.Wrapper interface.
> --
Zakelly commented on code in PR #25554:
URL: https://github.com/apache/flink/pull/25554#discussion_r1814205003
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlAwareSerializer.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
ruanhang1993 commented on code in PR #3619:
URL: https://github.com/apache/flink-cdc/pull/3619#discussion_r1816066674
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/HybridSplitAssigner.java:
##
@
hlteoh37 merged PR #173:
URL: https://github.com/apache/flink-connector-aws/pull/173
--
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...@
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1815533393
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/facets/KafkaDatasetFacet.java:
##
@@ -0,0 +1,97 @@
+package org.apache.flink
flinkbot commented on PR #25573:
URL: https://github.com/apache/flink/pull/25573#issuecomment-2435389238
## CI report:
* 16b263e8fec166a065f50877b6aa9491e1c43fca UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
tomncooper commented on PR #25567:
URL: https://github.com/apache/flink/pull/25567#issuecomment-2435193363
@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
flinkbot commented on PR #25575:
URL: https://github.com/apache/flink/pull/25575#issuecomment-2437053426
## CI report:
* 866e0fd0b4a546dbd8e3dc340a8b29468839b41b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
cy2008 opened a new pull request, #25575:
URL: https://github.com/apache/flink/pull/25575
## What is the purpose of the change
Improve Flink SQL JDBC
## Brief change log
[FLINK-36600][jdbc-driver] Implement java.sql.Wrapper interface
[FLINK-36600][jdbc-driv
82 matches
Mail list logo