[
https://issues.apache.org/jira/browse/FLINK-33201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sunyeop Lee resolved FLINK-33201.
-
Resolution: Fixed
The PR has been merged and released in v3.3.0 (including v3.3.0-rc1)
> Memory
[
https://issues.apache.org/jira/browse/FLINK-36535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890332#comment-17890332
]
Rui Fan commented on FLINK-36535:
-
Thanks [~heigebupahei] for the comment!
{quote}that w
gracegrimwood commented on code in PR #25494:
URL: https://github.com/apache/flink/pull/25494#discussion_r1804138258
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -94,8 +94,8 @@ under the License.
io.netty
-
[
https://issues.apache.org/jira/browse/FLINK-36533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky closed FLINK-36533.
Resolution: Fixed
[{{8ef273c}}|https://github.com/apache/flink/commit/8ef273c54da8286218f8a46c33a3
ferenc-csaky merged PR #25532:
URL: https://github.com/apache/flink/pull/25532
--
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 #25531:
URL: https://github.com/apache/flink/pull/25531
--
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 #25518:
URL: https://github.com/apache/flink/pull/25518
--
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.
SamBarker commented on code in PR #25494:
URL: https://github.com/apache/flink/pull/25494#discussion_r1804065549
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -94,8 +94,8 @@ under the License.
io.netty
-
[
https://issues.apache.org/jira/browse/FLINK-36372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Nguyen updated FLINK-36372:
---
Labels: reserved-word sink table-api (was: )
> Can not insert data to sink with reserved keywords c
[
https://issues.apache.org/jira/browse/FLINK-36372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Nguyen updated FLINK-36372:
---
Component/s: Table SQL / API
> Can not insert data to sink with reserved keywords column name
>
[
https://issues.apache.org/jira/browse/FLINK-36372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tan Nguyen updated FLINK-36372:
---
Affects Version/s: 1.18.1
> Can not insert data to sink with reserved keywords column name
> ---
gracegrimwood commented on code in PR #25494:
URL: https://github.com/apache/flink/pull/25494#discussion_r1804047289
##
flink-rpc/flink-rpc-akka/pom.xml:
##
@@ -94,8 +94,8 @@ under the License.
io.netty
-
[
https://issues.apache.org/jira/browse/FLINK-36558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36558:
---
Labels: pull-request-available (was: )
> MySQL CDC Fails to parse array-typed key index bin
yuxiqian opened a new pull request, #3647:
URL: https://github.com/apache/flink-cdc/pull/3647
This closes FLINK-36558.This closes FLINK-36558.
It is known that MySQL 8.0.17 and 8.0.18 writes Array-typed key index
TableMap data into Binlog differently.
* MySQL 8.0.17 used a diff
noorall commented on PR #25414:
URL: https://github.com/apache/flink/pull/25414#issuecomment-2418323698
@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.
1996fanrui commented on code in PR #758:
URL: https://github.com/apache/flink-web/pull/758#discussion_r1803996694
##
docs/content/posts/2024-10-30-release-kubernetes-operator-1.10.0.md:
##
@@ -0,0 +1,75 @@
+---
+title: "Apache Flink Kubernetes Operator 1.10.0 Release Announceme
yux created FLINK-36558:
---
Summary: MySQL CDC Fails to parse array-typed key index binlog
created between 8.0.17 and 8.0.18
Key: FLINK-36558
URL: https://issues.apache.org/jira/browse/FLINK-36558
Project: Flink
yunfengzhou-hub commented on PR #25503:
URL: https://github.com/apache/flink/pull/25503#issuecomment-2418271874
Thank for the update. LGTM.
--
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 spe
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2418177120
> Sorry for the delayed response due to the National Day holiday in China.
>
> Currently, there are three key fields related to parallelism:
>
> 1. defaultMaxParallelism: Th
rkhachatryan commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1803880302
##
flink-metrics/flink-metrics-otel/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
rkhachatryan commented on code in PR #25539:
URL: https://github.com/apache/flink/pull/25539#discussion_r1803878264
##
flink-metrics/flink-metrics-otel/pom.xml:
##
@@ -0,0 +1,141 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
gguptp commented on code in PR #177:
URL:
https://github.com/apache/flink-connector-aws/pull/177#discussion_r1803887401
##
flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/source/enumerator/tracker/SplitTracker.java:
##
@@ -89,13 +9
[
https://issues.apache.org/jira/browse/FLINK-36557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890258#comment-17890258
]
Sai Sharath Dandi commented on FLINK-36557:
---
We're trying to build an autoscal
Sai Sharath Dandi created FLINK-36557:
-
Summary: Stale Autoscaler Context in Kubernetes Operator
Key: FLINK-36557
URL: https://issues.apache.org/jira/browse/FLINK-36557
Project: Flink
Iss
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Fix Version/s: cdc-3.3.0
> Handle batch sources in DataSinkTranslator
>
flinkbot commented on PR #25541:
URL: https://github.com/apache/flink/pull/25541#issuecomment-2417994708
## CI report:
* 81019ec9eaaae96e1873b1bc2a19efb56a52c32f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
xaniasd opened a new pull request, #25541:
URL: https://github.com/apache/flink/pull/25541
## What is the purpose of the change
Based on #24908, upgrade Apache Beam dependency to >2.54.
## Brief change log
Changes flink-python code and tests for compatibility with
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Description:
Currently, there is hard-coded {{boolean isBatchMode = false}} in
{{DataSinkTr
[
https://issues.apache.org/jira/browse/FLINK-36546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergei Morozov updated FLINK-36546:
---
Description:
Currently, there is hard-coded {{boolean isBatchMode = false}} in
{{DataSinkTr
morozov commented on PR #3646:
URL: https://github.com/apache/flink-cdc/pull/3646#issuecomment-2417745420
@lvyanquan please see the temporary reproducer in the second commit.
> and I don't get the point that you said "the sink never receives the
end-of-input signal", can you provide a
Piotr Nowojski created FLINK-36556:
--
Summary: Allow to configure starting buffer size when using buffer
debloating
Key: FLINK-36556
URL: https://issues.apache.org/jira/browse/FLINK-36556
Project: Fli
Piotr Nowojski created FLINK-36555:
--
Summary: Guarantee debloated buffer size grows even with very
small alpha
Key: FLINK-36555
URL: https://issues.apache.org/jira/browse/FLINK-36555
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-36416.
--
Resolution: Fixed
merged commit 00a94ad into apache:master
> Enable splittable timers for tem
[
https://issues.apache.org/jira/browse/FLINK-36379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36379:
---
Labels: pull-request-available (was: )
> Improve (Global)Committer with UC disabled
> -
fapaul commented on code in PR #25456:
URL: https://github.com/apache/flink/pull/25456#discussion_r1803152409
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/connector/sink2/GlobalCommitterOperator.java:
##
@@ -47,10 +47,50 @@
import java.util.Collections;
import
jbalchan commented on PR #25538:
URL: https://github.com/apache/flink/pull/25538#issuecomment-2416890299
@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 #25540:
URL: https://github.com/apache/flink/pull/25540#issuecomment-2416887514
## CI report:
* 2301bb6bfe7e0f5596690386ac7a56170c771077 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
jbalchan opened a new pull request, #25540:
URL: https://github.com/apache/flink/pull/25540
## What is the purpose of the change
[FLINK-36479] (https://issues.apache.org/jira/browse/FLINK-36479)
Component: [Table SQL /
API](https://issues.apache.org/jira/issues/?jql=projec
jbalchan commented on PR #25524:
URL: https://github.com/apache/flink/pull/25524#issuecomment-2416864438
@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.
jbalchan commented on PR #25519:
URL: https://github.com/apache/flink/pull/25519#issuecomment-2416861263
i'm sorry. I was trying to remove my commit which failed the jenkins check.
But PR itself got closed.
--
This is an automated message from the Apache Git Service.
To respond to th
jbalchan closed pull request #25519: FLINK-36479 Remove deprecated method Table
getSchema as
URL: https://github.com/apache/flink/pull/25519
--
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
dawidwys merged PR #25530:
URL: https://github.com/apache/flink/pull/25530
--
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.apac
dmariassy commented on PR #25114:
URL: https://github.com/apache/flink/pull/25114#issuecomment-2416769187
> Looks like I failed so far, sorry.
Thanks @rmetzger ! We'd love to get this reviewed and merged 🙂
--
This is an automated message from the Apache Git Service.
To respond to t
AHeise commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1803045472
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageUtil.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed to the Apache Softwa
[
https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890062#comment-17890062
]
david radley commented on FLINK-36476:
--
[~xuyangzhong] I think getting wider points
flinkbot commented on PR #25539:
URL: https://github.com/apache/flink/pull/25539#issuecomment-2416698429
## CI report:
* 8c7b919e63eccbe14fb80c7df136b9b8a5493b45 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33696:
---
Labels: pull-request-available (was: )
> FLIP-385: Add OpenTelemetryTraceReporter and OpenT
pnowojski opened a new pull request, #25539:
URL: https://github.com/apache/flink/pull/25539
## What is the purpose of the change
This adds support for reporting metrics and traces to OpenTelemetry using
gRPC.
## Brief change log
Please check individual commit messages.
flinkbot commented on PR #25538:
URL: https://github.com/apache/flink/pull/25538#issuecomment-2416677634
## CI report:
* bf8d5e0cff634c86fc51e278f677a7c2d4389664 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802998271
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java:
##
@@ -369,5 +377,23 @@
[
https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890052#comment-17890052
]
Jeyassri Balachandran commented on FLINK-36505:
---
I have started looking in
[
https://issues.apache.org/jira/browse/FLINK-36505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36505:
---
Labels: pull-request-available (was: )
> Remove all deprecated methods in `ImperativeAggreg
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802993588
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaRecordSerializationSchemaBuilder.java:
##
@@ -369,5 +377,23 @@
jbalchan opened a new pull request, #25538:
URL: https://github.com/apache/flink/pull/25538
## What is the purpose of the change
[FLINK-36505] https://issues.apache.org/jira/browse/FLINK-36505 Removed all
deprecated methods - getResultType and getParameterTypes from TableFunct
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802987183
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/facets/KafkaPropertiesFacet.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Li
flinkbot commented on PR #25537:
URL: https://github.com/apache/flink/pull/25537#issuecomment-2416628988
## CI report:
* 0ad46f9fb5ebd67527652fc7e79d7b2accd4f631 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36500:
---
Labels: pull-request-available (was: )
> Remove all deprecated methods in `CallExpression`
jbalchan opened a new pull request, #25537:
URL: https://github.com/apache/flink/pull/25537
## What is the purpose of the change
[FLINK-36500] https://issues.apache.org/jira/browse/FLINK-36500 Remove all
deprecated methods in CallExpression
## Brief change log
Re
[
https://issues.apache.org/jira/browse/FLINK-36500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890047#comment-17890047
]
Jeyassri Balachandran commented on FLINK-36500:
---
I have started looking in
[
https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890045#comment-17890045
]
xuyang commented on FLINK-36476:
Hi, [~davidradl] .
> I suggest in addition to the code
Jacob Jona Fahlenkamp created FLINK-36554:
-
Summary: Support MapState in Operator State
Key: FLINK-36554
URL: https://issues.apache.org/jira/browse/FLINK-36554
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-36553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Jona Fahlenkamp updated FLINK-36553:
--
Description:
This would be useful for the same reasons as in Table API. Aggreg
[
https://issues.apache.org/jira/browse/FLINK-36553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jacob Jona Fahlenkamp updated FLINK-36553:
--
Description:
This would be useful for the same reasons as in Table API. Aggreg
Jacob Jona Fahlenkamp created FLINK-36553:
-
Summary: Local Global aggregation in Datasream API
Key: FLINK-36553
URL: https://issues.apache.org/jira/browse/FLINK-36553
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36551:
---
Labels: pull-request-available (was: )
> Generated OLM bundle fails to deploy with install
k-wall opened a new pull request, #903:
URL: https://github.com/apache/flink-kubernetes-operator/pull/903
## Contribution Checklist
- Make sure that the pull request corresponds to a [JIRA
issue](https://issues.apache.org/jira/projects/FLINK/issues). Exceptions are
made for typ
[
https://issues.apache.org/jira/browse/FLINK-36476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890033#comment-17890033
]
david radley commented on FLINK-36476:
--
[~xuyangzhong] somne thoughts on the scope
[
https://issues.apache.org/jira/browse/FLINK-36511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-36511.
Resolution: Fixed
master: 52e034f7a8d7f456ce3cc48b63d0e88d5d3210e6
1.20: b59241970d92b32bd
zentol merged PR #25497:
URL: https://github.com/apache/flink/pull/25497
--
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
zentol merged PR #25495:
URL: https://github.com/apache/flink/pull/25495
--
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
zentol merged PR #25496:
URL: https://github.com/apache/flink/pull/25496
--
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
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802892892
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageFacetProvider.java:
##
@@ -0,0 +1,19 @@
+package org.apac
pawel-big-lebowski commented on code in PR #130:
URL:
https://github.com/apache/flink-connector-kafka/pull/130#discussion_r1802889898
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/lineage/LineageFacetProvider.java:
##
@@ -0,0 +1,19 @@
+package org.apac
Dawid Wysakowicz created FLINK-36552:
Summary: Fix Table API OVER window support in batch mode
Key: FLINK-36552
URL: https://issues.apache.org/jira/browse/FLINK-36552
Project: Flink
Issue
flinkbot commented on PR #25536:
URL: https://github.com/apache/flink/pull/25536#issuecomment-2416449626
## CI report:
* dcc95d8c6ccdc2e130aa3d4e56f9d2f4b73344ed UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dawidwys commented on code in PR #25526:
URL: https://github.com/apache/flink/pull/25526#discussion_r1802865897
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java:
##
@@ -316,4 +316,23 @@ private String doUnParse(
dawidwys commented on code in PR #25526:
URL: https://github.com/apache/flink/pull/25526#discussion_r1802857026
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java:
##
@@ -316,4 +316,23 @@ private String doUnParse(
dawidwys commented on PR #25536:
URL: https://github.com/apache/flink/pull/25536#issuecomment-2416436664
Do you mind reviewing this PR @fhueske? I added the test you asked for.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890024#comment-17890024
]
Keith Wall edited comment on FLINK-36551 at 10/16/24 10:34 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-36551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17890024#comment-17890024
]
Keith Wall commented on FLINK-36551:
I believe the intent of
[docker-entry.sh#L88|h
[
https://issues.apache.org/jira/browse/FLINK-24530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise closed FLINK-24530.
---
Resolution: Fixed
> GlobalCommitter might not commit all records on drain
>
Keith Wall created FLINK-36551:
--
Summary: Generated OLM bundle fails to deploy with install
strategy failed .. Duplicate value: "keystore"
Key: FLINK-36551
URL: https://issues.apache.org/jira/browse/FLINK-36551
AHeise merged PR #131:
URL: https://github.com/apache/flink-connector-kafka/pull/131
--
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...@
lvyanquan commented on PR #3646:
URL: https://github.com/apache/flink-cdc/pull/3646#issuecomment-2416311635
I think a test for this is still necessary.
We have two bound sources(values, MySQL when setting scan.startup.mode to
snapshot), and I don't get the point that you said "the sink n
[
https://issues.apache.org/jira/browse/FLINK-36544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17889756#comment-17889756
]
Keith Wall edited comment on FLINK-36544 at 10/16/24 9:53 AM:
AHeise merged PR #25535:
URL: https://github.com/apache/flink/pull/25535
--
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
AHeise opened a new pull request, #25535:
URL: https://github.com/apache/flink/pull/25535
## 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 them on
AHeise merged PR #25533:
URL: https://github.com/apache/flink/pull/25533
--
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
AHeise merged PR #25534:
URL: https://github.com/apache/flink/pull/25534
--
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
AHeise opened a new pull request, #25534:
URL: https://github.com/apache/flink/pull/25534
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mai
AHeise opened a new pull request, #25533:
URL: https://github.com/apache/flink/pull/25533
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mai
fhueske commented on code in PR #25526:
URL: https://github.com/apache/flink/pull/25526#discussion_r1802680725
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java:
##
@@ -316,4 +316,23 @@ private String doUnParse(
[
https://issues.apache.org/jira/browse/FLINK-36550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
原来你是小幸运001 updated FLINK-36550:
---
Description:
ClassLoader. getSystemClassLoad() only loads dependencies under the ClassPath,
which c
原来你是小幸运001 created FLINK-36550:
--
Summary: Use ‘Thread.currentThread().getContextClassLoader()’
instead of ‘ClassLoader.getSystemClassLoader()’ when passing ClassLoader
Key: FLINK-36550
URL: https://issues.apache.org/
[
https://issues.apache.org/jira/browse/FLINK-36484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36484:
---
Labels: pull-request-available (was: )
> Remove deprecated method `StreamTableEnvironment#r
ammu20-dev commented on code in PR #25529:
URL: https://github.com/apache/flink/pull/25529#discussion_r1802607402
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java:
##
@@ -122,56 +118,6 @@ static StreamTab
davidradl commented on code in PR #25529:
URL: https://github.com/apache/flink/pull/25529#discussion_r1802593639
##
flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/StreamTableEnvironment.java:
##
@@ -122,56 +118,6 @@ static StreamTabl
davidradl commented on PR #25529:
URL: https://github.com/apache/flink/pull/25529#issuecomment-2416058016
@ammu20-dev please could you amend the title to follow the usual pattern to
include the issue number in square brackets.
--
This is an automated message from the Apache Git Service.
flinkbot commented on PR #25532:
URL: https://github.com/apache/flink/pull/25532#issuecomment-2416049215
## CI report:
* 641366e7206059552ba894222df9df0a84aa8222 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-34063:
--
Fix Version/s: 1.19.0
> When snapshot compression is enabled, rescaling of a source operator l
1 - 100 of 119 matches
Mail list logo
