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: issues-unsubscr...@flink.apac
[
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
[{{2da9a96}}|https://github.com/apache/flink/commit/2da9a9639216b8c488
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 opt
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 a
[
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 fo
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 {
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 ScalarOperat
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
[
https://issues.apache.org/jira/browse/FLINK-33254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775373#comment-17775373
]
Matthias Pohl commented on FLINK-33254:
---
The issues above are fixed. I tried to in
[
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
> -
>
>
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
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: issues-unsubscr...@flink.apac
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 @@
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 Avr
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
[
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 spec
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 Sof
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`
[
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
>
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 a
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 th
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
queryAggre
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
+---
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775527#comment-17775527
]
Zhenqiu Huang commented on FLINK-31275:
---
[~zjureel]
We have similar requirements.
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-33185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775540#comment-17775540
]
Yangze Guo commented on FLINK-33185:
Another instance [~Weijie Guo]
https://dev.azu
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
+---
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
+---
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360151349
##
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-33254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775543#comment-17775543
]
Matthias Pohl commented on FLINK-33254:
---
I also reverted copying the build artifac
[
https://issues.apache.org/jira/browse/FLINK-33254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775543#comment-17775543
]
Matthias Pohl edited comment on FLINK-33254 at 10/16/23 6:17 AM:
-
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360163929
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
+---
KarmaGYZ commented on PR #23526:
URL: https://github.com/apache/flink/pull/23526#issuecomment-1763808155
@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.
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360170833
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
+---
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360172067
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
+---
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360172356
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
+---
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360175011
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,758 @@
+---
+title: "How To Migrate From DataSet to DataStream"
+weight: 302
+type: docs
+---
WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1360180272
##
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-33017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-33017.
--
Fix Version/s: (was: kafka-3.0.1)
(was: kafka-3.1.0)
Assign
[
https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24179:
---
Fix Version/s: (was: 1.19.0)
> KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fail
[
https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-17987.
--
Resolution: Cannot Reproduce
> KafkaITCase.testStartFromGroupOffsets fails with SchemaExceptio
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-18634:
--
Assignee: (was: Fabian Paul)
> FlinkKafkaProducerITCase.testRecoverCommittedTrans
[
https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-17987:
---
Fix Version/s: (was: 1.19.0)
> KafkaITCase.testStartFromGroupOffsets fails with SchemaEx
[
https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-18634.
--
Fix Version/s: (was: 1.19.0)
Resolution: Cannot Reproduce
> FlinkKafkaProducerITCas
[
https://issues.apache.org/jira/browse/FLINK-24179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24179.
--
Resolution: Cannot Reproduce
> KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee fails on a
[
https://issues.apache.org/jira/browse/FLINK-17987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-17987:
--
Assignee: (was: Fabian Paul)
> KafkaITCase.testStartFromGroupOffsets fails with S
[
https://issues.apache.org/jira/browse/FLINK-24261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24261.
--
Fix Version/s: (was: 1.19.0)
Resolution: Cannot Reproduce
> KafkaSourceITCase.testM
[
https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24497:
---
Fix Version/s: (was: 1.19.0)
> Kafka metrics fetching throws IllegalStateException
> --
[
https://issues.apache.org/jira/browse/FLINK-32101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-32101.
--
Resolution: Cannot Reproduce
> FlinkKafkaInternalProducerITCase.testInitTransactionId test fai
[
https://issues.apache.org/jira/browse/FLINK-30932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-30932:
---
Fix Version/s: kafka-3.1.0
(was: 1.19.0)
> Enabling producer metrics
[
https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-16027:
---
Fix Version/s: (was: 1.19.0)
> kafka connector's 'connector.topic' property should be op
[
https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-16027.
--
Resolution: Invalid
> kafka connector's 'connector.topic' property should be optional rather t
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24542.
--
Resolution: Invalid
> Expose the freshness metrics for kafka connector
> -
[
https://issues.apache.org/jira/browse/FLINK-24542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24542:
---
Fix Version/s: (was: 1.19.0)
> Expose the freshness metrics for kafka connector
> --
[
https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-20849:
---
Fix Version/s: (was: 1.19.0)
> Improve JavaDoc and logging of new KafkaSource
>
[
https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-20849.
--
Resolution: Invalid
Closing because it isn't really clear anymore what's missing the docs. Fee
[
https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-20656:
---
Fix Version/s: (was: 1.19.0)
> Update docs for new KafkaSource connector.
>
[
https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-20656.
--
Resolution: Done
> Update docs for new KafkaSource connector.
> --
[
https://issues.apache.org/jira/browse/FLINK-24259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24259.
--
Assignee: (was: Mans Singh)
Resolution: Won't Fix
Given that FlinkKafkaConsumer is d
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-22457:
--
Assignee: (was: Fabian Paul)
> KafkaSourceLegacyITCase.testMultipleSourcesOnePart
[
https://issues.apache.org/jira/browse/FLINK-32607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-32607:
---
Fix Version/s: kafka-3.1.0
> Kafka table source and json format support projection pushdown
[
https://issues.apache.org/jira/browse/FLINK-24259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-24259:
---
Fix Version/s: (was: 1.19.0)
> Exception message when Kafka topic is null in FlinkKafkaC
[
https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-17916:
---
Fix Version/s: (was: 1.19.0)
> Provide API to separate KafkaShuffle's Producer and Consu
[
https://issues.apache.org/jira/browse/FLINK-28475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-28475.
--
Resolution: Fixed
> kafka connector won't stop when the stopping offset is zero
>
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-22457:
---
Fix Version/s: (was: 1.19.0)
> KafkaSourceLegacyITCase.testMultipleSourcesOnePartition f
[
https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-22457.
--
Resolution: Cannot Reproduce
> KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails b
[
https://issues.apache.org/jira/browse/FLINK-17916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17775557#comment-17775557
]
Martijn Visser commented on FLINK-17916:
[~ym] Do you think we can close this ti
[
https://issues.apache.org/jira/browse/FLINK-28475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-28475:
---
Fix Version/s: 1.17.0
(was: 1.19.0)
> kafka connector won't stop when
[
https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-10119:
---
Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
(was: Conn
[
https://issues.apache.org/jira/browse/FLINK-11799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-11799:
---
Component/s: API / Core
(was: Connectors / Kafka)
> KryoSerializer/Oper
[
https://issues.apache.org/jira/browse/FLINK-14729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-14729.
--
Resolution: Duplicate
> Multi-topics consuming from KafkaTableSource
> ---
[
https://issues.apache.org/jira/browse/FLINK-30822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30822.
--
Resolution: Cannot Reproduce
> KafkaSinkITCase fails in setup and teardown method because the
[
https://issues.apache.org/jira/browse/FLINK-30911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-30911.
--
Resolution: Cannot Reproduce
> KafkaSinkE2ECase.testStartFromSavepoint fails with TimeoutExcep
[
https://issues.apache.org/jira/browse/FLINK-26922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-26922.
--
Resolution: Cannot Reproduce
> KafkaSinkITCase.testRecoveryWithExactlyOnceGuaranteeAndConcurre
[
https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser closed FLINK-24744.
--
Resolution: Cannot Reproduce
> FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnc
MartijnVisser opened a new pull request, #61:
URL: https://github.com/apache/flink-connector-kafka/pull/61
1. Test all PRs for `main` against all supported versions, meaning 1.17.x
and 1.18.x. That's because only PRs run the dependency convergence check, and
not nighly builds.
2. Make su
76 matches
Mail list logo
