WencongLiu commented on code in PR #23362:
URL: https://github.com/apache/flink/pull/23362#discussion_r1378418615
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378417184
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378417033
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378416760
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378416526
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378416167
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378414045
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378413855
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378413349
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378413003
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378412748
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378412480
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+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_r1378412317
##
docs/content/docs/dev/datastream/dataset_migration.md:
##
@@ -0,0 +1,778 @@
+---
+title: "How to Migrate from DataSet to DataStream"
+weight: 302
+type: docs
FangYongs commented on code in PR #22768:
URL: https://github.com/apache/flink/pull/22768#discussion_r1378393971
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/operation/OperationExecutor.java:
##
@@ -176,14 +184,17 @@ public ResultFetcher
flinkbot commented on PR #23641:
URL: https://github.com/apache/flink/pull/23641#issuecomment-1788392864
## CI report:
* ccdfdc101e0b67b72aa5d5e6dfe291987ae72cbf UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
victor9309 opened a new pull request, #23641:
URL: https://github.com/apache/flink/pull/23641
## What is the purpose of the change
*RMQSourceITCase failed on azure due to ContainerLaunchException: Container
startup failed, Increase the number of TestContainer startup
StefanXiepj commented on code in PR #74:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/74#discussion_r1378366427
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8Sink.java:
##
@@ -0,0 +1,85 @@
flinkbot commented on PR #23640:
URL: https://github.com/apache/flink/pull/23640#issuecomment-1788357441
## CI report:
* 68d2083bb1e8be0e89408a8dc73e1c26646f4981 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhu closed FLINK-33014.
---
Resolution: Not A Bug
Insufficient resource allocation for Tm
> flink jobmanager raise java.io.IOException:
[
https://issues.apache.org/jira/browse/FLINK-32943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhu closed FLINK-32943.
---
Resolution: Not A Bug
> run batch tasks concurrently, the tasks still in the initialization status
>
[
https://issues.apache.org/jira/browse/FLINK-26907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-26907:
---
Labels: auto-deprioritized-major pull-request-available starter
test-stability (was:
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1378358266
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -708,6 +708,20 @@ public class TaskManagerOptions {
flinkbot commented on PR #23639:
URL: https://github.com/apache/flink/pull/23639#issuecomment-1788353704
## CI report:
* b914c663f2955c007ac560a465e2799328ef3e04 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
RocMarshal commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1378352765
##
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/BalancedPreferredSlotSharingStrategy.java:
##
@@ -0,0 +1,275 @@
+/*
+ * Licensed to the Apache
lsyldliu opened a new pull request, #23640:
URL: https://github.com/apache/flink/pull/23640
## What is the purpose of the change
*Fix adaptive local hash can't work when auxGrouping exists*
## Brief change log
- *Fix adaptive local hash can't work when auxGrouping
victor9309 opened a new pull request, #23639:
URL: https://github.com/apache/flink/pull/23639
## What is the purpose of the change
*RMQSourceITCase failed on azure due to ContainerLaunchException: Container
startup failed, Increase the number of TestContainer startup
liyubin117 commented on code in PR #74:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/74#discussion_r1378357036
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8Sink.java:
##
@@ -0,0 +1,85 @@
KarmaGYZ commented on code in PR #22768:
URL: https://github.com/apache/flink/pull/22768#discussion_r1364801781
##
flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/resource/ClientResourceManager.java:
##
@@ -59,4 +68,10 @@ public URL
lsyldliu commented on PR #23629:
URL: https://github.com/apache/flink/pull/23629#issuecomment-1788343978
> In my humble opinion, this change is fine. But I don't know much about the
details of flink sql, and I'm not sure whether this change introduces
additional risks. It would be better
1996fanrui commented on PR #23589:
URL: https://github.com/apache/flink/pull/23589#issuecomment-1788342771
Hi @pnowojski @RocMarshal , some unit tests failed when
`getStreamOperatorFactory` throwing an exception after `SERIALIZED_UDF` is
removed.
I researched it for a while and
liyubin117 commented on code in PR #74:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/74#discussion_r1377514898
##
flink-connector-elasticsearch8/src/test/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8SinkBaseITCase.java:
##
@@ -0,0
liyubin117 commented on code in PR #74:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/74#discussion_r1377503899
##
flink-connector-elasticsearch8/.gitignore:
##
@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1378332744
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -708,6 +708,20 @@ public class TaskManagerOptions {
1996fanrui commented on code in PR #23635:
URL: https://github.com/apache/flink/pull/23635#discussion_r1378331133
##
flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java:
##
@@ -708,6 +708,20 @@ public class TaskManagerOptions {
victor9309 closed pull request #23636: [FLINK-32107] [Tests] 1.17 Kubernetes
test failed because ofunable to establish ssl connection to github on AZP
URL: https://github.com/apache/flink/pull/23636
--
This is an automated message from the Apache Git Service.
To respond to the message,
victor9309 closed pull request #23636: [FLINK-32107] [Tests] 1.17 Kubernetes
test failed because ofunable to establish ssl connection to github on AZP
URL: https://github.com/apache/flink/pull/23636
--
This is an automated message from the Apache Git Service.
To respond to the message,
flinkbot commented on PR #23638:
URL: https://github.com/apache/flink/pull/23638#issuecomment-1788261124
## CI report:
* d07d72543b49f24c788d5c52834e286f8e5350d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23637:
URL: https://github.com/apache/flink/pull/23637#issuecomment-1788260613
## CI report:
* 1c7554f97aee03b0ab87c129eb2defd63d949718 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
victor9309 opened a new pull request, #23638:
URL: https://github.com/apache/flink/pull/23638
## What is the purpose of the change
* Backport of https://github.com/apache/flink/pull/23528 to release-1.17，We
could make CI fail earlier when download fails.*
## Brief
victor9309 opened a new pull request, #23637:
URL: https://github.com/apache/flink/pull/23637
## What is the purpose of the change
* Backport of https://github.com/apache/flink/pull/23528 to release-1.18，We
could make CI fail earlier when download fails.*
## Brief
flinkbot commented on PR #23636:
URL: https://github.com/apache/flink/pull/23636#issuecomment-1788253541
## CI report:
* d07d72543b49f24c788d5c52834e286f8e5350d7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
victor9309 opened a new pull request, #23636:
URL: https://github.com/apache/flink/pull/23636
## What is the purpose of the change
*(We could make CI fail earlier when download fails.)*
## Brief change log
- *backports 1.17，modify common_kubernetes.sh*
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781563#comment-17781563
]
Yuxin Tan edited comment on FLINK-33401 at 11/1/23 12:24 AM:
-
[~pavelhp] If
[
https://issues.apache.org/jira/browse/FLINK-33401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781563#comment-17781563
]
Yuxin Tan commented on FLINK-33401:
---
[~pavelhp] If you wish to try it in Flink 1.18, you may need to
TanYuxin-tyx commented on PR #64:
URL:
https://github.com/apache/flink-connector-kafka/pull/64#issuecomment-1788206919
@MartijnVisser, Thanks for helping review.
This fix aims to resolve the issue of displaying the incorrect version
number (-1.18) for the Kafka connector.
[
https://issues.apache.org/jira/browse/FLINK-33422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bonnie Varghese updated FLINK-33422:
Summary: Implement restore tests for Calc node (was: Add restore tests for
Calc node)
>
Bonnie Varghese created FLINK-33422:
---
Summary: Add restore tests for Calc node
Key: FLINK-33422
URL: https://issues.apache.org/jira/browse/FLINK-33422
Project: Flink
Issue Type: Sub-task
Bonnie Varghese created FLINK-33421:
---
Summary: Implement ExecNode Restore Tests
Key: FLINK-33421
URL: https://issues.apache.org/jira/browse/FLINK-33421
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781516#comment-17781516
]
Varun Narayanan Chakravarthy edited comment on FLINK-33402 at 10/31/23 9:10 PM:
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781516#comment-17781516
]
Varun Narayanan Chakravarthy commented on FLINK-33402:
--
I had previously
[ https://issues.apache.org/jira/browse/FLINK-27758 ]
Chao Liu deleted comment on FLINK-27758:
--
was (Author: JIRAUSER302840):
Hi [~Sergey Nuyanzin] I'd like to work on this ticket, could I get assigned to
this?
> [JUnit5 Migration] Module:
afedulov commented on PR #23553:
URL: https://github.com/apache/flink/pull/23553#issuecomment-1787923597
@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-33420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Samrat Deb updated FLINK-33420:
---
Description:
```
Oct 31 08:49:37 2023-10-31 08:49:33,348 ERROR
Samrat Deb created FLINK-33420:
--
Summary: Run e2e test fails Intermetiently with
ClientCoordinationHandler : Unhandled exception
Key: FLINK-33420
URL: https://issues.apache.org/jira/browse/FLINK-33420
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Varun Narayanan Chakravarthy updated FLINK-33402:
-
Description:
Hello Team,
I noticed that there is data loss when
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Varun Narayanan Chakravarthy updated FLINK-33402:
-
Priority: Blocker (was: Major)
> Hybrid Source Concurrency
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781476#comment-17781476
]
Varun Narayanan Chakravarthy commented on FLINK-33402:
--
Similar issues
[
https://issues.apache.org/jira/browse/FLINK-33402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Varun Narayanan Chakravarthy updated FLINK-33402:
-
Summary: Hybrid Source Concurrency Race Condition Fixes and
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781471#comment-17781471
]
Maciej Obuchowski commented on FLINK-31275:
---
[~zjureel] Sorry, it's probably too late for this
[ https://issues.apache.org/jira/browse/FLINK-31275 ]
Maciej Obuchowski deleted comment on FLINK-31275:
---
was (Author: mobuchowski):
[~zjureel] Sorry, it's probably too late for this comment as FLIP is accepted.
But I'll still voice
[
https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781458#comment-17781458
]
Maciej Obuchowski commented on FLINK-31275:
---
[~zjureel] Sorry, it's probably too late for this
[
https://issues.apache.org/jira/browse/FLINK-33418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781449#comment-17781449
]
Matthias Pohl commented on FLINK-33418:
---
PrabhuJoseph commented on PR #23629:
URL: https://github.com/apache/flink/pull/23629#issuecomment-1787531140
@Samrat002 @1996fanrui Could you review this patch when you have time?
Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-24379:
-
Assignee: Lorenzo Nicora
> Support AWS Glue Schema Registry Avro for Table API
>
gyfora commented on PR #23490:
URL: https://github.com/apache/flink/pull/23490#issuecomment-1787514161
@XComp we have a green CI run with the Java tests enabled , I will remove
that commit before merging.
Do you have any further comments? I think I addressed most things
--
This is
flinkbot commented on PR #23635:
URL: https://github.com/apache/flink/pull/23635#issuecomment-1787488771
## CI report:
* 0816a1779cbf97c1e3526e18e70d3d2e09817a05 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #23634:
URL: https://github.com/apache/flink/pull/23634#issuecomment-1787478201
## CI report:
* e204a5e3d94da5b0e4f31af5f31846c910a924f3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33386:
---
Labels: pull-request-available (was: )
> Support tasks balancing at slot level for Default
RocMarshal opened a new pull request, #23635:
URL: https://github.com/apache/flink/pull/23635
## What is the purpose of the change
- Support tasks balancing at slot level for Default Scheduler
## Brief change log
- *Introduce
[
https://issues.apache.org/jira/browse/FLINK-33242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781430#comment-17781430
]
Matthias Pohl commented on FLINK-33242:
---
Interestingly, we have a build where the yarn tests
[
https://issues.apache.org/jira/browse/FLINK-33419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-33419:
---
Labels: pull-request-available (was: )
> Port PROCTIME/ROWTIME functions to the new
dawidwys opened a new pull request, #23634:
URL: https://github.com/apache/flink/pull/23634
## What is the purpose of the change
Ports `PROCTIME` & `ROWTIME` functions to the new inference stack.
## Verifying this change
Added tests for the input type strategy
##
Dawid Wysakowicz created FLINK-33419:
Summary: Port PROCTIME/ROWTIME functions to the new inference stack
Key: FLINK-33419
URL: https://issues.apache.org/jira/browse/FLINK-33419
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-33418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781426#comment-17781426
]
Matthias Pohl commented on FLINK-33418:
---
[
https://issues.apache.org/jira/browse/FLINK-33418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-33418:
--
Description:
The container couldn't be started in [this
Matthias Pohl created FLINK-33418:
-
Summary: SqlGatewayE2ECase failed due to ConnectException
Key: FLINK-33418
URL: https://issues.apache.org/jira/browse/FLINK-33418
Project: Flink
Issue
ShijieHome commented on PR #23631:
URL: https://github.com/apache/flink/pull/23631#issuecomment-1787444937
@tweise @mbalassi @gyfora , could you please check this PR for me.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
dannycranmer opened a new pull request, #693:
URL: https://github.com/apache/flink-web/pull/693
(no comment)
--
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
[
https://issues.apache.org/jira/browse/FLINK-33283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781422#comment-17781422
]
Matthias Pohl commented on FLINK-33283:
---
I did a test run where I repeatedly run
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
>
[
https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33260:
--
Affects Version/s: aws-connector-4.2.0
> Custom Error Handling for Kinesis Consumer
>
[
https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33260:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
> Custom
[
https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33259:
--
Affects Version/s: aws-connector-4.2.0
(was: aws-connector-4.1.0)
[
https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-33072.
---
Assignee: Hong Liang Teoh
Resolution: Done
> Implement end-to-end tests for AWS
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Affects Version/s: aws-connector-4.2.0
(was: aws-connector-4.1.0)
[
https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33072:
--
Fix Version/s: aws-connector-4.2.0
(was: 2.0.0)
> Implement end-to-end
[
https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-33073.
---
Resolution: Fixed
> Implement end-to-end tests for the Kinesis Streams Sink
>
[
https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32116:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
>
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
> Add
[
https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31872:
--
Affects Version/s: aws-connector-4.2.0
> Add Support for Configuring AIMD Ratelimiting
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Affects Version/s: aws-connector-4.2.0
> Port over Kinesis Client configurations for retry
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
> Port
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-24379:
-
Assignee: (was: Karthi Thyagarajan)
> Support AWS Glue Schema Registry Avro for
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
> Define
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Fix Version/s: aws-connector-4.3.0
(was: aws-connector-4.2.0)
>
[
https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-25779:
--
Affects Version/s: aws-connector-4.2.0
> Define ConfigOption for aws, scan and sink map in
[
https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-24379:
--
Affects Version/s: aws-connector-4.2.0
(was: 1.14.0)
> Support AWS
[
https://issues.apache.org/jira/browse/FLINK-31815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781407#comment-17781407
]
Zhou Shijie commented on FLINK-31815:
-
Hi, [~gyfora], could you help me review the issue
[
https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-25809.
Resolution: Fixed
Based on recent feedback, we slightly improved the API.
Fixed in master:
[
https://issues.apache.org/jira/browse/FLINK-25809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reopened FLINK-25809:
--
> Introduce test infra for building FLIP-190 tests
>
1 - 100 of 265 matches
Mail list logo
