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
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
[
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
[
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
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
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 #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
[
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:
--
[
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-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`
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-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-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
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
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.
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 {
}
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
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`
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
[
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
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
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
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:all-tabpanel
]
Gabor Somogyi reassigned FLINK-37109:
-
Assignee: Gabor Somogyi
> Improve state processor API performance when reading keyed ro
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
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
[
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
[
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
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
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
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
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
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
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
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
[
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
[
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:
--
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
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
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
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
[
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
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
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
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 {
}
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 {
}
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
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
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-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 closed FLINK-37109.
-
> Improve state processor API performance when reading keyed rocksdb state by
> allowing duplicates
[
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
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:comment-tabpanel&focusedCommentId=17927154#comment-17927154
]
Gabor Somogyi commented on FLINK-37109:
---
[{{dd3eb7b}}|https://github.com/apache/fl
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
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
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
67 matches
Mail list logo
