WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360096007
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
[
https://issues.apache.org/jira/browse/FLINK-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775540#comment-17775540
]
Yangze Guo commented on FLINK-33185:
Another instance [~Weijie Guo]
KarmaGYZ commented on PR #23526:
URL: https://github.com/apache/flink/pull/23526#issuecomment-1763772532
@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.
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775527#comment-17775527
]
Zhenqiu Huang commented on FLINK-31275:
---
[~zjureel]
We have similar requirements. To accelerate
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360095973
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
1996fanrui commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1360079090
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricCollector.java:
##
@@ -441,15 +442,21 @@ protected Collection
Jiabao-Sun commented on PR #23507:
URL: https://github.com/apache/flink/pull/23507#issuecomment-1763677474
@luoyuxia, @lsyldliu, please take a look when you have time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Jiabao-Sun commented on PR #23515:
URL: https://github.com/apache/flink/pull/23515#issuecomment-1763676473
Hi @fsk119, could you help review this when you have time?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/FLINK-20281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-20281:
Priority: Major (was: Not a Priority)
> Window aggregation supports changelog stream input
>
flinkbot commented on PR #23526:
URL: https://github.com/apache/flink/pull/23526#issuecomment-1763646179
## CI report:
* 4a70cc843fa8a12097a43567d23e4ce6191aeae5 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljw-hit commented on code in PR #23162:
URL: https://github.com/apache/flink/pull/23162#discussion_r1360044268
##
flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/BigProtoBufCodeSpiltterTest.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-33203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33203:
---
Labels: pull-request-available (was: )
> FLIP-374: Adding a separate configuration for
KarmaGYZ opened a new pull request, #23526:
URL: https://github.com/apache/flink/pull/23526
…cify the jvm options of sql gateway
## What is the purpose of the change
Introduce env.java.opts.sql-gateway to specify the jvm options of sql
gateway.
## Verifying this
HuangZhenQiu commented on PR #23511:
URL: https://github.com/apache/flink/pull/23511#issuecomment-1763633001
> Thank you @HuangZhenQiu a lot for contributing this.
>
> After reading the [Avro
spec](https://avro.apache.org/docs/1.11.0/spec.html), I think we have wrongly
mapped the
1996fanrui commented on code in PR #677:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/677#discussion_r1360032639
##
flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesJobAutoScalerContext.java:
##
@@ -0,0 +1,67 @@
KarmaGYZ merged PR #23525:
URL: https://github.com/apache/flink/pull/23525
--
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:
Matthias Pohl created FLINK-33277:
-
Summary: Upgrading to actions/checkout@v4 requires GLIBC 2.25,
2.27, or 2.28 to be installed, apparently
Key: FLINK-33277
URL: https://issues.apache.org/jira/browse/FLINK-33277
[
https://issues.apache.org/jira/browse/FLINK-33254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl resolved FLINK-33254.
---
Resolution: Fixed
> Improve speed of compile step
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-33254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17775373#comment-17775373
]
Matthias Pohl commented on FLINK-33254:
---
The issues above are fixed. I tried to introduce caching
lincoln-lil commented on PR #23478:
URL: https://github.com/apache/flink/pull/23478#issuecomment-1763405879
> @lincoln-lil Based on the approach you provided, I attempted to write some
test cases. However, there are two types that are not covered:
>
> 1. non comparable types: I don't
lincoln-lil commented on code in PR #23478:
URL: https://github.com/apache/flink/pull/23478#discussion_r1359886599
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala:
##
@@ -488,6 +488,18 @@ object
wuchong commented on code in PR #23511:
URL: https://github.com/apache/flink/pull/23511#discussion_r1359881451
##
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/utils/AvroTestUtils.java:
##
@@ -102,6 +104,13 @@ public final class AvroTestUtils {
[
https://issues.apache.org/jira/browse/FLINK-33181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33181:
---
Labels: pull-request-available (was: )
> Table using `kinesis` connector can not be used
boring-cyborg[bot] commented on PR #105:
URL:
https://github.com/apache/flink-connector-aws/pull/105#issuecomment-1763380621
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
vtkhanh opened a new pull request, #105:
URL: https://github.com/apache/flink-connector-aws/pull/105
## Purpose of the change
Allow a table can be used as a source and sink when it's defined with both
consumer & producer options. The ability is achieved by not verifying an
[
https://issues.apache.org/jira/browse/FLINK-33030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-33030.
--
Resolution: Implemented
mbalassi merged PR #23417:
URL: https://github.com/apache/flink/pull/23417
--
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:
27 matches
Mail list logo
