codenohup opened a new pull request, #26161:
URL: https://github.com/apache/flink/pull/26161
**(The sections below can be removed for hotfixes of typos)**
-->
## What is the purpose of the change
The deprecated StreamExecutionEnvironment#readTextFile(*) method has been
remov
ryanvanhuuksloot commented on PR #25888:
URL: https://github.com/apache/flink/pull/25888#issuecomment-2660565860
@davidradl bump^
--
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
[
https://issues.apache.org/jira/browse/FLINK-37328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37328:
---
Labels: pull-request-available (was: )
> Upgrade GCS Connector to 2.2.26.
> ---
flinkbot commented on PR #26160:
URL: https://github.com/apache/flink/pull/26160#issuecomment-2660570698
## CI report:
* 038e09cb672b8c234da20de9429ad268c9082a8b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
cnauroth opened a new pull request, #26160:
URL: https://github.com/apache/flink/pull/26160
## What is the purpose of the change
Upgrade GCS connector to 2.2.26.
## Brief change log
Upgrade the [GCS
Connector](https://github.com/GoogleCloudDataproc/hadoop-connectors/tree
Chris Nauroth created FLINK-37328:
-
Summary: Upgrade GCS Connector to 2.2.26.
Key: FLINK-37328
URL: https://issues.apache.org/jira/browse/FLINK-37328
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #26159:
URL: https://github.com/apache/flink/pull/26159#issuecomment-2660255145
## CI report:
* 7538c1b60c950d00d272b4dbcf6ee923336dca7e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37327:
---
Labels: pull-request-available (was: )
> Debezium Avro Format: Add FormatOption to Optional
klam-shop opened a new pull request, #26159:
URL: https://github.com/apache/flink/pull/26159
…
## What is the purpose of the change
Add a Format Option to the Debezium Format to optionally skip emitting the
UPDATE_BEFORE Rows when deserializing a Debezium message with op='u
Kevin Lam created FLINK-37327:
-
Summary: Debezium Avro Format: Add FormatOption to Optionally Skip
emitting UPDATE_BEFORE Rows
Key: FLINK-37327
URL: https://issues.apache.org/jira/browse/FLINK-37327
Proje
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927247#comment-17927247
]
Tommy Schnabel commented on FLINK-23886:
[~gaborgsomogyi] This is the closest to
snuyanzin commented on code in PR #26157:
URL: https://github.com/apache/flink/pull/26157#discussion_r1956427182
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowUtil.scala:
##
@@ -227,6 +232,11 @@ object WindowUtil {
}
snuyanzin commented on code in PR #26157:
URL: https://github.com/apache/flink/pull/26157#discussion_r1956427182
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowUtil.scala:
##
@@ -227,6 +232,11 @@ object WindowUtil {
}
fapaul commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1956378108
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:
##
@@ -359,14 +356,14 @@ void useSameProducerForNonTran
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1956398378
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1956398378
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1956384544
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1956384544
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927161#comment-17927161
]
Gabor Somogyi commented on FLINK-23886:
---
This question applies to all the peoples
[
https://issues.apache.org/jira/browse/FLINK-23886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927160#comment-17927160
]
Gabor Somogyi commented on FLINK-23886:
---
[~tommyschnabel] can you give me some con
[
https://issues.apache.org/jira/browse/FLINK-37310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-37310.
-
> SQL connector for keyed savepoint data documentation
> ---
[
https://issues.apache.org/jira/browse/FLINK-37310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-37310.
---
Fix Version/s: 2.0.0
Resolution: Fixed
[{{4efbc91}}|https://github.com/apache/flink/c
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi resolved FLINK-37109.
---
Fix Version/s: 2.0.0
1.20.2
Resolution: Fixed
> Improve state proc
flinkbot commented on PR #26158:
URL: https://github.com/apache/flink/pull/26158#issuecomment-2659647620
## CI report:
* b0b225b10a6dc5e390df626910f056b72c39ea61 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927154#comment-17927154
]
Gabor Somogyi commented on FLINK-37109:
---
[{{dd3eb7b}}|https://github.com/apache/fl
gaborgsomogyi merged PR #26154:
URL: https://github.com/apache/flink/pull/26154
--
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-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi closed FLINK-37109.
-
> Improve state processor API performance when reading keyed rocksdb state by
> allowing duplicates
gaborgsomogyi merged PR #26145:
URL: https://github.com/apache/flink/pull/26145
--
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
hanyuzheng7 commented on PR #25897:
URL: https://github.com/apache/flink/pull/25897#issuecomment-2659636431
@snuyanzin can we change the method in TimestampData
```
private TimestampData(long millisecond, int nanoOfMillisecond) {
Preconditions.checkArgument(nanoOfMillisec
davidradl commented on code in PR #26157:
URL: https://github.com/apache/flink/pull/26157#discussion_r1956259835
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/WindowUtil.scala:
##
@@ -227,6 +232,11 @@ object WindowUtil {
}
dependabot[bot] closed pull request #25750: Bump io.netty:netty-common from
4.1.46.Final to 4.1.115.Final in
/flink-end-to-end-tests/flink-end-to-end-tests-hive
URL: https://github.com/apache/flink/pull/25750
--
This is an automated message from the Apache Git Service.
To respond to the mess
dependabot[bot] commented on PR #25750:
URL: https://github.com/apache/flink/pull/25750#issuecomment-2659572336
Superseded by #26158.
--
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
dependabot[bot] opened a new pull request, #26158:
URL: https://github.com/apache/flink/pull/26158
Bumps [io.netty:netty-common](https://github.com/netty/netty) from
4.1.46.Final to 4.1.118.Final.
Commits
https://github.com/netty/netty/commit/36f95cfaeed0c1313b21f1b5350c19436ae
dependabot[bot] commented on PR #27:
URL:
https://github.com/apache/flink-connector-hive/pull/27#issuecomment-2659571656
A newer version of io.netty:netty-common exists, but since this PR has been
edited by someone other than Dependabot I haven't updated it. You'll get a PR
for the updated
pnowojski commented on PR #26051:
URL: https://github.com/apache/flink/pull/26051#issuecomment-2659343708
@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.
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1956126504
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Ap
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1956126504
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/ProducerPoolImpl.java:
##
@@ -0,0 +1,241 @@
+/*
+ * Licensed to the Ap
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1956121906
##
flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImplTest.java:
##
@@ -0,0 +1,163 @@
+/*
+ * Licensed to the
AHeise commented on code in PR #152:
URL:
https://github.com/apache/flink-connector-kafka/pull/152#discussion_r1956117000
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/internal/BackchannelImpl.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apa
gaborgsomogyi commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1956062376
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,119 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Tabl
Zakelly commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1956024216
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,119 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Table API
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1956017956
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/table/UnnestRowsFunction.java:
##
@@ -19,169 +19,89 @@
package org.ap
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1955988937
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1955988937
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
gustavodemorais commented on code in PR #26113:
URL: https://github.com/apache/flink/pull/26113#discussion_r1955968662
##
docs/content/docs/dev/table/sql/queries/joins.md:
##
@@ -326,16 +326,55 @@ FROM Orders AS o
In the example above, the Orders table is enriched with data f
[
https://issues.apache.org/jira/browse/FLINK-37326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zexin gong updated FLINK-37326:
---
Description:
For example: When column is class
!字段为Java关键字.jpg!
was:For example: When column is
[
https://issues.apache.org/jira/browse/FLINK-37326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927095#comment-17927095
]
zexin gong commented on FLINK-37326:
I'd like to work on a fix for this issue, pleas
zexin gong created FLINK-37326:
--
Summary: The transform module reports an error when column is a
Java keyword
Key: FLINK-37326
URL: https://issues.apache.org/jira/browse/FLINK-37326
Project: Flink
afedulov merged PR #216:
URL: https://github.com/apache/flink-docker/pull/216
--
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
afedulov opened a new pull request, #216:
URL: https://github.com/apache/flink-docker/pull/216
1.19.1 release entrypoint seem to have been generated off of 1.20 release
branch. This raises questions for publishing in the official-images repo
https://github.com/docker-library/official-ima
[
https://issues.apache.org/jira/browse/FLINK-37241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Morávek resolved FLINK-37241.
---
Resolution: Fixed
> Remove Mockito dependency from StateBackendTestBase
> --
[
https://issues.apache.org/jira/browse/FLINK-37241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17926749#comment-17926749
]
David Morávek edited comment on FLINK-37241 at 2/14/25 9:35 AM:
--
gaborgsomogyi commented on PR #26145:
URL: https://github.com/apache/flink/pull/26145#issuecomment-2658732568
Adapted all the changes to this branch and rebased to the latest
`release-1.20`. Checking the performance with some load.
--
This is an automated message from the Apache Git Servi
gaborgsomogyi commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1955808914
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,119 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Tabl
gaborgsomogyi commented on PR #26154:
URL: https://github.com/apache/flink/pull/26154#issuecomment-2658682417
> And I suggest another ticket for the chinese doc.
Just created https://issues.apache.org/jira/browse/FLINK-37325
--
This is an automated message from the Apache Git Servic
Gabor Somogyi created FLINK-37325:
-
Summary: SQL connector for keyed savepoint data Chinese
documentation
Key: FLINK-37325
URL: https://issues.apache.org/jira/browse/FLINK-37325
Project: Flink
gaborgsomogyi commented on code in PR #26154:
URL: https://github.com/apache/flink/pull/26154#discussion_r1955788750
##
docs/content/docs/libs/state_processor_api.md:
##
@@ -514,3 +512,119 @@ savepointWriter
OperatorIdentifier.forUid("new-uid"))
...
```
+
+## Tabl
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Somogyi reassigned FLINK-37109:
-
Assignee: Gabor Somogyi
> Improve state processor API performance when reading keyed ro
Gabor Somogyi created FLINK-37324:
-
Summary: RocksDB keys iterator performance improvement
Key: FLINK-37324
URL: https://issues.apache.org/jira/browse/FLINK-37324
Project: Flink
Issue Type: I
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927074#comment-17927074
]
Gabor Somogyi commented on FLINK-37109:
---
[{{9bcc41d}}|https://github.com/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-36795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927071#comment-17927071
]
ouyangwulin commented on FLINK-36795:
-
duplicate https://issues.apache.org/jira/brow
gaborgsomogyi merged PR #26134:
URL: https://github.com/apache/flink/pull/26134
--
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
mbalassi merged PR #215:
URL: https://github.com/apache/flink-docker/pull/215
--
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
xintongsong commented on code in PR #26118:
URL: https://github.com/apache/flink/pull/26118#discussion_r1955711278
##
flink-examples/flink-examples-streaming/src/main/resources/datas/dsv2/windowing/CountProductSalesWindowingResult.csv:
##
@@ -0,0 +1,115 @@
+5,173882520,2
Re
[
https://issues.apache.org/jira/browse/FLINK-37283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-37283:
Description:
1. We need to distinguish between '*' and 'app.\*', the expression of two
different
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927059#comment-17927059
]
Hongshun Wang edited comment on FLINK-31363 at 2/14/25 8:11 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927059#comment-17927059
]
Hongshun Wang commented on FLINK-31363:
---
Hi, [~tzulitai] [~lightzhao]
I have not
67 matches
Mail list logo
