[
https://issues.apache.org/jira/browse/FLINK-33288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xin Chen updated FLINK-33288:
-
Attachment: py问题.txt
> Empty directory residue with appid name in HA(highly-available) related
> direct
github-actions[bot] commented on PR #26003:
URL: https://github.com/apache/flink/pull/26003#issuecomment-2837618330
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
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947996#comment-17947996
]
Leonard Xu edited comment on FLINK-37462 at 4/29/25 5:59 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37462.
Resolution: Fixed
> [Unstable Test Case]
> FlinkParallelizedPipelineITCase.testRegularTablesSourc
[
https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37741.
Resolution: Fixed
> Severe performance regression of transform operator node
> ---
[
https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947995#comment-17947995
]
Leonard Xu edited comment on FLINK-37741 at 4/29/25 5:58 AM:
-
leonardBang merged PR #4010:
URL: https://github.com/apache/flink-cdc/pull/4010
--
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
leonardBang merged PR #4011:
URL: https://github.com/apache/flink-cdc/pull/4011
--
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
hansh0801 commented on PR #969:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/969#issuecomment-2837525307
when this feature gonna be released?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
ekazakas commented on PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#issuecomment-2837523694
> These were added to improve java 17 compatibility for Flink apps, will
this affect that? If so having the warnings doesn't seem like a big deal
It should not aff
XComp merged PR #224:
URL: https://github.com/apache/flink-docker/pull/224
--
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
gyfora commented on PR #975:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/975#issuecomment-2837504259
These were added to improve java 17 compatibility for Flink apps, will this
affect that? If so having the warnings doesn't seem like a big deal
--
This is an automated m
[
https://issues.apache.org/jira/browse/FLINK-37748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37748:
---
Labels: pull-request-available (was: )
> Remove JDK only JVM arguments from Flink operator
ekazakas opened a new pull request, #975:
URL: https://github.com/apache/flink-kubernetes-operator/pull/975
## What is the purpose of the change
There is an issue with Flink Kubernetes operator where JVM reports
unrecognized options. These options are:
```
--add-exports=
Eduardas Kazakas created FLINK-37748:
Summary: Remove JDK only JVM arguments from Flink operator Helm
chart
Key: FLINK-37748
URL: https://issues.apache.org/jira/browse/FLINK-37748
Project: Flink
flinkbot commented on PR #26518:
URL: https://github.com/apache/flink/pull/26518#issuecomment-2837368198
## CI report:
* 045d00172fa1199dfea23f89f0a3f3a866ea2061 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37747:
---
Labels: pull-request-available (was: )
> GlobalCommitterOperator cannot commit after scalin
bjlovegithub opened a new pull request, #26518:
URL: https://github.com/apache/flink/pull/26518
## What is the purpose of the change
Fix the issue that GlobalCommitterOperator stuck when upstream operator -
writer/committer is scaled up.
## Brief change log
Use the o
joyCurry30 opened a new pull request, #4012:
URL: https://github.com/apache/flink-cdc/pull/4012
Fix environment variable check for FLINK_CDC_HOME in
YarnApplicationDeploymentExecutor.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ChenYi015 closed pull request #974: [FLINK-37744][Helm] Add Helm lint and test
CI
URL: https://github.com/apache/flink-kubernetes-operator/pull/974
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
leonardBang merged PR #4008:
URL: https://github.com/apache/flink-cdc/pull/4008
--
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-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947995#comment-17947995
]
Leonard Xu edited comment on FLINK-37741 at 4/29/25 2:30 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reopened FLINK-37741:
> Severe performance regression of transform operator node
> -
[
https://issues.apache.org/jira/browse/FLINK-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37741:
---
Fix Version/s: cdc-3.5.0
> Severe performance regression of transform operator node
> --
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947996#comment-17947996
]
Leonard Xu commented on FLINK-37462:
Fixed via master: a9911695cb205a3262be561c47789
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reopened FLINK-37462:
> [Unstable Test Case]
> FlinkParallelizedPipelineITCase.testRegularTablesSourceInMultipleParallelism
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-37462:
---
Fix Version/s: cdc-3.5.0
> [Unstable Test Case]
> FlinkParallelizedPipelineITCase.testRegularTables
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37462:
--
Assignee: Xiqian Yu
> [Unstable Test Case]
> FlinkParallelizedPipelineITCase.testRegularTabl
[
https://issues.apache.org/jira/browse/FLINK-37462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37462.
Fix Version/s: cdc-3.4.0
Resolution: Fixed
> [Unstable Test Case]
> FlinkParallelizedPipel
leonardBang merged PR #4009:
URL: https://github.com/apache/flink-cdc/pull/4009
--
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-37741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37741.
Resolution: Fixed
via master: 250ab43e185ee39b23c4fb6376b84ea9e6741f58
> Severe performance regre
leonardBang merged PR #4007:
URL: https://github.com/apache/flink-cdc/pull/4007
--
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
flinkbot commented on PR #26517:
URL: https://github.com/apache/flink/pull/26517#issuecomment-2837260960
## CI report:
* 95cf58c56406e19be82f9464fdcd69a71f1f62c6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
dependabot[bot] opened a new pull request, #26517:
URL: https://github.com/apache/flink/pull/26517
Bumps
[http-proxy-middleware](https://github.com/chimurai/http-proxy-middleware) to
3.0.5 and updates ancestor dependency
[@angular-devkit/build-angular](https://github.com/angular/angular-cl
[
https://issues.apache.org/jira/browse/FLINK-37702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947994#comment-17947994
]
dalongliu commented on FLINK-37702:
---
https://dev.azure.com/apache-flink/apache-flink/_
[
https://issues.apache.org/jira/browse/FLINK-18590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuyang Zhong closed FLINK-18590.
Fix Version/s: 2.1.0
Resolution: Fixed
> Support json array explode to multi messages
> ---
[
https://issues.apache.org/jira/browse/FLINK-18590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947991#comment-17947991
]
Xuyang Zhong commented on FLINK-18590:
--
Merge into master: 444732e25ab87a1d0e283504
xuyangzhong merged PR #26473:
URL: https://github.com/apache/flink/pull/26473
--
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-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David updated FLINK-37747:
--
Description:
Hey,
Our FLINK job stopped writing into Delta table with FLINK Delta connector
frequently. Afte
[
https://issues.apache.org/jira/browse/FLINK-34992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947968#comment-17947968
]
Hao Li commented on FLINK-34992:
Discussed with [~fsk119] offline and proposed the FLIP
[
https://issues.apache.org/jira/browse/FLINK-37747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David updated FLINK-37747:
--
Priority: Blocker (was: Major)
> GlobalCommitterOperator cannot commit after scaling writer/committer
> -
David created FLINK-37747:
-
Summary: GlobalCommitterOperator cannot commit after scaling
writer/committer
Key: FLINK-37747
URL: https://issues.apache.org/jira/browse/FLINK-37747
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-37687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947957#comment-17947957
]
Mohsen Rezaei commented on FLINK-37687:
---
I can contribute to this change for the K
[
https://issues.apache.org/jira/browse/FLINK-37687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947955#comment-17947955
]
Mohsen Rezaei commented on FLINK-37687:
---
An example for the {{KinesisStreamsSink}}
mohsenrezaeithe commented on code in PR #196:
URL:
https://github.com/apache/flink-connector-aws/pull/196#discussion_r2064532605
##
flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java:
##
@@
pranav234 commented on code in PR #26515:
URL: https://github.com/apache/flink/pull/26515#discussion_r2064250397
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java:
##
@@ -39,6 +39,8 @@
@PublicEvolving
public class MapTypeInfo extends TypeInformat
morazow commented on PR #223:
URL: https://github.com/apache/flink-docker/pull/223#issuecomment-2835917104
Here is the PR: https://github.com/apache/flink-docker/pull/224 cc:
@dstreitfeld-sn 🤞
--
This is an automated message from the Apache Git Service.
To respond to the message, please
morazow commented on PR #224:
URL: https://github.com/apache/flink-docker/pull/224#issuecomment-2835915952
Hey @XComp, please have a look 🤝
I have also run the workflow with last docker build step commented:
https://github.com/morazow/flink-docker/actions/runs/14713380144
--
This
morazow opened a new pull request, #224:
URL: https://github.com/apache/flink-docker/pull/224
Update the `snapshots.yml` GitHub workflow matrix so that Docker snapshot
builds work.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-37740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37740:
---
Labels: pull-request-available (was: )
> Fix flink-docker snapshots GitHub workflow
> -
davidradl commented on code in PR #26378:
URL: https://github.com/apache/flink/pull/26378#discussion_r2064086750
##
docs/content/docs/dev/table/sqlClient.md:
##
@@ -69,6 +69,12 @@ In the gateway mode, the CLI submits the SQL to the
specified remote gateway to
The `` can be p
[
https://issues.apache.org/jira/browse/FLINK-35744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-35744.
--
Fix Version/s: kubernetes-operator-1.12.0
Resolution: Fixed
merged to main 2bf49a2570a056bc1352
gyfora merged PR #848:
URL: https://github.com/apache/flink-kubernetes-operator/pull/848
--
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
[
https://issues.apache.org/jira/browse/FLINK-37657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-37657.
--
Fix Version/s: kubernetes-operator-1.12.0
Resolution: Fixed
merged to main 44b1ff6a4e25f69528ac
gyfora merged PR #970:
URL: https://github.com/apache/flink-kubernetes-operator/pull/970
--
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
pchoudhury22 commented on code in PR #968:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/968#discussion_r2064042112
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -202,13 +2
[
https://issues.apache.org/jira/browse/FLINK-36828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947873#comment-17947873
]
Lorenzo Nicora commented on FLINK-36828:
I have a working [example]
([https://g
[
https://issues.apache.org/jira/browse/FLINK-36767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora updated FLINK-36767:
---
Fix Version/s: kubernetes-operator-1.12.0
> Bump cyclonedx-maven-plugin from 2.7.9 to 2.9.0
> --
[
https://issues.apache.org/jira/browse/FLINK-36767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17947861#comment-17947861
]
Gyula Fora commented on FLINK-36767:
merged to operator main: 29c0403862ece8f32ce738
morazow commented on PR #26514:
URL: https://github.com/apache/flink/pull/26514#issuecomment-2835669773
Thanks @davidradl, addressed your findings, please have another look 🤝
> the filtered pushed down joins cause the Volcano planner to uniquely
identify each look up join.
Yes
[
https://issues.apache.org/jira/browse/FLINK-36808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36808:
---
Labels: pull-request-available (was: )
> UNION ALL after lookup join produces unexpected re
morazow commented on code in PR #26514:
URL: https://github.com/apache/flink/pull/26514#discussion_r2063919658
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalLookupJoin.scala:
##
@@ -21,16 +21,18 @@ impor
davidradl commented on code in PR #26515:
URL: https://github.com/apache/flink/pull/26515#discussion_r2063916814
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/MapTypeInfo.java:
##
@@ -39,6 +39,8 @@
@PublicEvolving
public class MapTypeInfo extends TypeInformat
gyfora commented on PR #973:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/973#issuecomment-2835616450
What is the reason for 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
gyfora merged PR #917:
URL: https://github.com/apache/flink-kubernetes-operator/pull/917
--
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
gyfora commented on PR #974:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/974#issuecomment-2835533451
This commit should be included in the PR that introduced the test
functionality
--
This is an automated message from the Apache Git Service.
To respond to the message, p
flinkbot commented on PR #26516:
URL: https://github.com/apache/flink/pull/26516#issuecomment-2835476572
## CI report:
* 11fea88837a7507ef0d8cee509e7734ea58880fd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37745:
---
Labels: pull-request-available (was: )
> ChangelogModeJsonSerializer doesn't handle partial
dawidwys opened a new pull request, #26516:
URL: https://github.com/apache/flink/pull/26516
## What is the purpose of the change
Make it possible to serialize partial deletes into a compiled plan
## Verifying this change
Added a test in `ChangelogModeJsonSerdeTest`
pranav234 commented on PR #26515:
URL: https://github.com/apache/flink/pull/26515#issuecomment-2835274255
@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 #26515:
URL: https://github.com/apache/flink/pull/26515#issuecomment-2835284175
## CI report:
* 404759144a67e27810e72972543eea324c3de5cf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on PR #971:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/971#issuecomment-2835278514
> > Makes sense, would it be possible to integrate the helm test into the
maven build or at least the GitHub CI?
>
> Have raised PR #974 to add Helm lint and tests t
[
https://issues.apache.org/jira/browse/FLINK-37746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37746:
---
Labels: pull-request-available (was: )
> Missing serialVersionUID in MapTypeInfo class
> --
pranav234 opened a new pull request, #26515:
URL: https://github.com/apache/flink/pull/26515
## What is the purpose of the change
Adding serialVersionUID in MapTypeInfo class
## Verifying this change
This change is a trivial rework / code cleanup without any test
Pranav Mahajan created FLINK-37746:
--
Summary: Missing serialVersionUID in MapTypeInfo class
Key: FLINK-37746
URL: https://issues.apache.org/jira/browse/FLINK-37746
Project: Flink
Issue Type:
gyfora commented on code in PR #968:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/968#discussion_r2063647322
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/AbstractJobReconciler.java:
##
@@ -575,7 +602,7 @@
ChenYi015 commented on PR #971:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/971#issuecomment-2835200945
> Makes sense, would it be possible to integrate the helm test into the
maven build or at least the GitHub CI?
Have raised PR #974 to add Helm lint and tests to t
[
https://issues.apache.org/jira/browse/FLINK-37744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37744:
---
Labels: pull-request-available (was: )
> [Helm] Add Helm lint and test CI
> ---
ChenYi015 opened a new pull request, #974:
URL: https://github.com/apache/flink-kubernetes-operator/pull/974
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment` cu
Timo Walther created FLINK-37745:
Summary: ChangelogModeJsonSerializer doesn't handle partial deletes
Key: FLINK-37745
URL: https://issues.apache.org/jira/browse/FLINK-37745
Project: Flink
Is
davidradl commented on code in PR #26510:
URL: https://github.com/apache/flink/pull/26510#discussion_r2063601798
##
flink-python/docs/conf.py:
##
@@ -102,6 +103,11 @@
autosummary_generate = True
autodoc_docstring_signature = True
+# Map to external docs for type annotations
Yi Chen created FLINK-37744:
---
Summary: [Helm] Add Helm lint and test CI
Key: FLINK-37744
URL: https://issues.apache.org/jira/browse/FLINK-37744
Project: Flink
Issue Type: Improvement
Re
davidradl commented on code in PR #25982:
URL: https://github.com/apache/flink/pull/25982#discussion_r2063583925
##
docs/content/docs/dev/table/sql/create.md:
##
@@ -197,6 +197,19 @@ CREATE TABLE [IF NOT EXISTS]
[catalog_name.][db_name.]table_name
The statement above creates a
jeff-zou commented on PR #3973:
URL: https://github.com/apache/flink-cdc/pull/3973#issuecomment-2835110623
> You can view this discussion #3338.您可以查看此讨论 #3338 。
--
This is an automated mes
davidradl commented on PR #26514:
URL: https://github.com/apache/flink/pull/26514#issuecomment-2835102889
@morazow If I am understanding this correctly, the filtered pushed down
joins cause the Volcano planner to uniquely identify
each look up join.
I wonder what happens if one o
Yanquan Lv created FLINK-37743:
--
Summary: Add benchmark test for Flink CDC Pipeline job
Key: FLINK-37743
URL: https://issues.apache.org/jira/browse/FLINK-37743
Project: Flink
Issue Type: Improve
davidradl commented on code in PR #26514:
URL: https://github.com/apache/flink/pull/26514#discussion_r2063548638
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/common/CommonPhysicalLookupJoin.scala:
##
@@ -21,16 +21,18 @@ imp
davidradl commented on PR #26514:
URL: https://github.com/apache/flink/pull/26514#issuecomment-2835069177
nit: the Jira number has an extra `0` at the end in the PR title
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
davidradl commented on code in PR #26313:
URL: https://github.com/apache/flink/pull/26313#discussion_r2063520935
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingMultiJoinOperator.java:
##
@@ -0,0 +1,806 @@
+/*
+ * Li
lianghongjia6 commented on code in PR #26473:
URL: https://github.com/apache/flink/pull/26473#discussion_r2063519487
##
docs/content.zh/docs/connectors/table/formats/json.md:
##
@@ -243,3 +243,34 @@ Format 参数
+
+特性
+
+
+### 允许 json array 直接展开成多行数据
+
+通常，我们假
lianghongjia6 commented on PR #26473:
URL: https://github.com/apache/flink/pull/26473#issuecomment-2835021315
@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
lianghongjia6 commented on code in PR #26473:
URL: https://github.com/apache/flink/pull/26473#discussion_r2063517965
##
flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/JsonRowDataSerDeSchemaTest.java:
##
@@ -224,6 +227,55 @@ void testSerDe() throws Exception
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Description:
Remove the implementation of
`AbstractJsonDeserializationSchema#deserialize(byte
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Summary: Remove the implementation of
AbstractJsonDeserializationSchema#deserialize(byte[]) (
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Description:
Remove the implementation of `DeserializationSchema#deserialize(byte[])` and
use
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Summary: Remove the implementation of
DeserializationSchema#deserialize(byte[]) (was: Remove
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Description:
Remove method `DeserializationSchema#deserialize(byte[])` and use
`Deserializati
[
https://issues.apache.org/jira/browse/FLINK-37707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongjia Liang updated FLINK-37707:
--
Summary: Remove DeserializationSchema#deserialize(byte[]) (was:
Deprecate DeserializationSc
[
https://issues.apache.org/jira/browse/FLINK-37521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-37521:
Fix Version/s: 2.1.0
> Implement async state version of KeyedCoProcessOperator
> -
[
https://issues.apache.org/jira/browse/FLINK-37693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-37693.
--
Resolution: Fixed
Merged into master via d82cc3f
> ForSt fails to restore from reused checkpo
1 - 100 of 141 matches
Mail list logo
