Jiaan Geng created FLINK-37440:
--
Summary: Fix the bug that parallelism.default do not always adopts
1 as the default value.
Key: FLINK-37440
URL: https://issues.apache.org/jira/browse/FLINK-37440
Project
[
https://issues.apache.org/jira/browse/FLINK-37440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37440:
---
Labels: pull-request-available (was: )
> Fix the bug that parallelism.default do not always
beliefer commented on PR #26277:
URL: https://github.com/apache/flink/pull/26277#issuecomment-2708618133
ping @1996fanrui cc @davidradl
--
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
beliefer opened a new pull request, #26277:
URL: https://github.com/apache/flink/pull/26277
## What is the purpose of the change
This PR proposes to fix the bug that parallelism.default do not always
adopts 1 as the default value.
The config parallelism.default defined as follows.
xintongsong commented on code in PR #777:
URL: https://github.com/apache/flink-web/pull/777#discussion_r1986203389
##
docs/content/posts/2025-03-01-release-2.0.0.md:
##
@@ -0,0 +1,1639 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2025-03-01T08:00:00Z"
+title: "Ap
xintongsong commented on code in PR #777:
URL: https://github.com/apache/flink-web/pull/777#discussion_r1986203389
##
docs/content/posts/2025-03-01-release-2.0.0.md:
##
@@ -0,0 +1,1639 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2025-03-01T08:00:00Z"
+title: "Ap
beliefer opened a new pull request, #26278:
URL: https://github.com/apache/flink/pull/26278
## What is the purpose of the change
This PR proposes to improve the code for TypeExtractor.
## Brief change log
Improve the code for TypeExtractor
## Verifying this
Jiaan Geng created FLINK-37441:
--
Summary: Improve the code for TypeExtractor
Key: FLINK-37441
URL: https://issues.apache.org/jira/browse/FLINK-37441
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-37441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiaan Geng updated FLINK-37441:
---
Summary: Rename `factoryHierarchy` to `typeHierarchy` for `TypeExtractor`
(was: Improve the code fo
Poorvankbhatia opened a new pull request, #26274:
URL: https://github.com/apache/flink/pull/26274
## What is the purpose of the change
[FLIP-509](https://cwiki.apache.org/confluence/display/FLINK/FLIP-509+Add+pluggable+Batching+for+Async+Sink)
* The current AsyncSinkWriter handles
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986108140
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112578
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112578
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110353
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110733
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110888
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110757
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112285
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112324
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r198641
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
[
https://issues.apache.org/jira/browse/FLINK-37298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37298:
---
Labels: pull-request-available (was: )
> Custom Batch Handling in AsyncSink
> -
Zakelly Lan created FLINK-37439:
---
Summary: Missing file creation with overwrite semantic in ForSt
wrapped file system
Key: FLINK-37439
URL: https://issues.apache.org/jira/browse/FLINK-37439
Project: Fli
snuyanzin opened a new pull request, #26275:
URL: https://github.com/apache/flink/pull/26275
## What is the purpose of the change
Follow up for https://github.com/apache/flink/pull/26220
## Verifying this change
This change is a trivial rework / code c
snuyanzin commented on PR #26275:
URL: https://github.com/apache/flink/pull/26275#issuecomment-2708415747
Hi @Zakelly, @davidradl , @nilmadhab
since you were participated at https://github.com/apache/flink/pull/26220
there is one missed step which is covered by this PR
could you
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111230
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986107668
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
ctrlaltdilj commented on PR #848:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/848#issuecomment-2708366566
@hugovideira-ppb , I have updated the helm chart, if this approach looks
good, can I proceed with some documentation changes and adding some tests?
--
This is an au
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r198681
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111230
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111715
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986109368
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111880
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112085
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986108526
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112159
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112016
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986112389
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
snuyanzin commented on code in PR #26193:
URL: https://github.com/apache/flink/pull/26193#discussion_r1986133627
##
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/sink/FileSinkTest.java:
##
@@ -23,14 +23,14 @@
import
org.apache.flink.conne
Efrat19 opened a new pull request, #26276:
URL: https://github.com/apache/flink/pull/26276
## 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
[
https://issues.apache.org/jira/browse/FLINK-37410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37410:
---
Labels: pull-request-available (was: )
> [FLIP-513] Split-level Watermark Metrics
> ---
flinkbot commented on PR #26276:
URL: https://github.com/apache/flink/pull/26276#issuecomment-2708519076
## CI report:
* 028379e924d9dbb8fe80db8b6753cde6911329b6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #26278:
URL: https://github.com/apache/flink/pull/26278#issuecomment-2708673385
## CI report:
* 8251f3b4fe8f4b550d2a138e744b5f56f182e9b8 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37441:
---
Labels: pull-request-available (was: )
> Improve the code for TypeExtractor
> -
snuyanzin merged PR #26275:
URL: https://github.com/apache/flink/pull/26275
--
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-36402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933597#comment-17933597
]
Sergey Nuyanzin commented on FLINK-36402:
-
follow up finding merged to master as
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110946
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111016
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986111075
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
snuyanzin commented on code in PR #777:
URL: https://github.com/apache/flink-web/pull/777#discussion_r1986118593
##
docs/content/posts/2025-03-01-release-2.0.0.md:
##
@@ -0,0 +1,1639 @@
+---
+authors:
+- xtsong:
+ name: "Xintong Song"
+date: "2025-03-01T08:00:00Z"
+title: "Apac
davidradl commented on code in PR #26266:
URL: https://github.com/apache/flink/pull/26266#discussion_r1986110353
##
docs/content/release-notes/flink-2.0.md:
##
@@ -0,0 +1,1666 @@
+---
+title: "Release Notes - Flink 2.0"
+---
+
+
+# Release notes - Flink 2.0
+
+These release note
nilmadhab commented on PR #26239:
URL: https://github.com/apache/flink/pull/26239#issuecomment-2702881218
@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.
reswqa commented on code in PR #217:
URL: https://github.com/apache/flink-docker/pull/217#discussion_r1982929521
##
add-version.sh:
##
@@ -59,7 +59,7 @@ fi
# Defaults, can vary between versions
scala_versions=( 2.12 )
-java_versions=( 8 11 17 )
+java_versions=( 11 17 21 )
R
flinkbot commented on PR #26274:
URL: https://github.com/apache/flink/pull/26274#issuecomment-2708374566
## CI report:
* 06749e6b51ef34b43e2caf967c504b3bb3023329 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
twalthr commented on code in PR #26250:
URL: https://github.com/apache/flink/pull/26250#discussion_r1983424932
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java:
##
@@ -351,9 +439,158 @@ public interface Context {
flinkbot commented on PR #26275:
URL: https://github.com/apache/flink/pull/26275#issuecomment-2708426180
## CI report:
* bf1279ab6b063a25c8852e92ab6e1d96e21c5d35 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
beliefer opened a new pull request, #26273:
URL: https://github.com/apache/flink/pull/26273
## What is the purpose of the change
This PR proposes to improve the `createLocalEnvironment` by reduce duplicate
operation on `Configuration`.
## Brief change log
Improve the
flinkbot commented on PR #26273:
URL: https://github.com/apache/flink/pull/26273#issuecomment-2708292917
## CI report:
* 6b5686bb453c211e110e96a20469f195daf6e843 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly merged PR #26271:
URL: https://github.com/apache/flink/pull/26271
--
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.apach
Xiao Huang created FLINK-37429:
--
Summary: Map each original column name to a new name and support
column name containing '-'
Key: FLINK-37429
URL: https://issues.apache.org/jira/browse/FLINK-37429
Projec
Zakelly commented on code in PR #26271:
URL: https://github.com/apache/flink/pull/26271#discussion_r1986038886
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ForStFlinkFileSystem.java:
##
@@ -273,18 +277,38 @@ public synchronized b
[
https://issues.apache.org/jira/browse/FLINK-37437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933534#comment-17933534
]
Zakelly Lan commented on FLINK-37437:
-
Merged into master: 9da1e10
and 2.0: 458529f
[
https://issues.apache.org/jira/browse/FLINK-37437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-37437.
-
Resolution: Fixed
> ForSt checkpoint failure due to file not visible when writing
>
snuyanzin opened a new pull request, #34:
URL: https://github.com/apache/flink-connector-hive/pull/34
Move commits from flink main repo
--
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 specifi
Zakelly closed pull request #26221: FLINK-36402: edgeRemapings typo fixed to
edgeRemappings
URL: https://github.com/apache/flink/pull/26221
--
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 specif
[
https://issues.apache.org/jira/browse/FLINK-36402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933535#comment-17933535
]
Zakelly Lan commented on FLINK-36402:
-
Merge 506ac18 into master
> Improper variabl
[
https://issues.apache.org/jira/browse/FLINK-36402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36402.
-
Fix Version/s: 2.1.0
(was: 1.18.2)
Resolution: Fixed
> Improper va
Zakelly merged PR #26220:
URL: https://github.com/apache/flink/pull/26220
--
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.apach
Zakelly merged PR #26272:
URL: https://github.com/apache/flink/pull/26272
--
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.apach
Zakelly merged PR #25977:
URL: https://github.com/apache/flink/pull/25977
--
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.apach
[
https://issues.apache.org/jira/browse/FLINK-37438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37438:
---
Labels: pull-request-available (was: )
> Improve the createLocalEnvironment by reduce dupli
Zakelly commented on PR #26221:
URL: https://github.com/apache/flink/pull/26221#issuecomment-2708298050
Identical with #26220
--
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-37257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinkun Liu closed FLINK-37257.
--
Resolution: Won't Do
> Add an API on keyedStream to allow users to customize the hash method from
> k
[
https://issues.apache.org/jira/browse/FLINK-37438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiaan Geng updated FLINK-37438:
---
Summary: Improve the createLocalEnvironment by reduce duplicate operation
on Configuration (was: Im
[
https://issues.apache.org/jira/browse/FLINK-37435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933203#comment-17933203
]
Gyula Fora commented on FLINK-37435:
Maybe [~nicknezis] or [~kurto] has some insight
beliefer commented on PR #26273:
URL: https://github.com/apache/flink/pull/26273#issuecomment-2708295559
ping @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 comment.
T
75 matches
Mail list logo
