[
https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
datariver updated FLINK-31914:
--
Attachment: (was: image-2023-04-24-16-11-22-251.png)
> Failing to close
[
https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
datariver updated FLINK-31914:
--
Description:
Hi [~arvid] , If Exactly-Once writing is enabled, Kafka's transactional writing
will be
[
https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
datariver updated FLINK-31914:
--
Attachment: image-2023-04-25-13-47-25-703.png
> Failing to close FlinkKafkaInternalProducer created
reswqa commented on PR #22447:
URL: https://github.com/apache/flink/pull/22447#issuecomment-1521183716
Thanks @1996fanrui for the quick review, I have updated this in a fix-up
commit, please take a look~
--
This is an automated message from the Apache Git Service.
To respond to the
reswqa commented on code in PR #22447:
URL: https://github.com/apache/flink/pull/22447#discussion_r1176029546
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -878,6 +874,18 @@ private void
reswqa commented on code in PR #22445:
URL: https://github.com/apache/flink/pull/22445#discussion_r1176019508
##
flink-queryable-state/flink-queryable-state-client-java/src/test/java/org/apache/flink/queryablestate/client/state/ImmutableAggregatingStateTest.java:
##
@@ -53,20
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31748:
---
Affects Version/s: pulsar-4.0.0
> Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31748:
---
Component/s: Connectors / Pulsar
> Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31748.
--
Fix Version/s: pulsar-4.0.1
Resolution: Fixed
> Adapt SplitFetcherManager#removeSplit for
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716082#comment-17716082
]
Weijie Guo commented on FLINK-31748:
Temporarily fixed in main via
[
https://issues.apache.org/jira/browse/FLINK-24785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17707083#comment-17707083
]
jinghaihang edited comment on FLINK-24785 at 4/25/23 4:44 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-31748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31748:
--
Assignee: Zili Chen (was: Yufan Sheng)
> Adapt SplitFetcherManager#removeSplit for
[
https://issues.apache.org/jira/browse/FLINK-31918?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716077#comment-17716077
]
Weijie Guo commented on FLINK-31918:
This compile problem should already be fixed in
[
https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-31560:
--
Assignee: Yanfei Lei
> Savepoint failing to complete with ExternallyInducedSources
>
[
https://issues.apache.org/jira/browse/FLINK-31560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716075#comment-17716075
]
Yanfei Lei commented on FLINK-31560:
[~fyang86] After reading the
[
https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716074#comment-17716074
]
Weijie Guo commented on FLINK-31929:
Thanks [~caiyi], would you mind submitting a pull request and
[
https://issues.apache.org/jira/browse/FLINK-31931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31931:
--
Assignee: Junrui Li
> Exception history page should not link to a non-existent TM log page.
Junrui Li created FLINK-31931:
-
Summary: Exception history page should not link to a non-existent
TM log page.
Key: FLINK-31931
URL: https://issues.apache.org/jira/browse/FLINK-31931
Project: Flink
flinkbot commented on PR #22481:
URL: https://github.com/apache/flink/pull/22481#issuecomment-1521126055
## CI report:
* 8a31508bb40da5f27e122d679175d8d545e6b38e UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned FLINK-31887:
Assignee: Jiang Xin
> Upgrade Flink version of Flink ML to 1.16.1
>
lindong28 commented on PR #234:
URL: https://github.com/apache/flink-ml/pull/234#issuecomment-1521123703
Thanks for the update. LGTM.
--
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
[
https://issues.apache.org/jira/browse/FLINK-27805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-27805:
---
Summary: Bump ORC version to 1.7.8 (was: Bump ORC version to 1.7.5)
> Bump
pgaref opened a new pull request, #22481:
URL: https://github.com/apache/flink/pull/22481
Bump to orc 1.7.8 -- [Release Notes](https://orc.apache.org/news/releases/)
ORC now supports writers with FSDataOutputStream (instead of just paths
previously) so cleaning NoHivePhysicalWriterImpl
1996fanrui commented on code in PR #22447:
URL: https://github.com/apache/flink/pull/22447#discussion_r1175969922
##
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPoolTest.java:
##
@@ -878,6 +874,18 @@ private void
jiangxin369 commented on PR #234:
URL: https://github.com/apache/flink-ml/pull/234#issuecomment-1521110530
@lindong28 Could you have another look?
--
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
jiangxin369 commented on code in PR #234:
URL: https://github.com/apache/flink-ml/pull/234#discussion_r1175973954
##
flink-ml-iteration/src/main/java/org/apache/flink/iteration/operator/OperatorUtils.java:
##
@@ -136,31 +135,20 @@ public static StreamConfig
flinkbot commented on PR #22480:
URL: https://github.com/apache/flink/pull/22480#issuecomment-1521102621
## CI report:
* 64c595bd2cab5baaed949d7702500f800e2c9f1d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #22479:
URL: https://github.com/apache/flink/pull/22479#issuecomment-1521100027
## CI report:
* bb255f2fe9e9341ded3851bdc51816ea54ca8783 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
TanYuxin-tyx opened a new pull request, #22480:
URL: https://github.com/apache/flink/pull/22480
## What is the purpose of the change
Bach port to 1.16, the PR has been reviewed at
https://github.com/apache/flink/pull/22471.
Fix the unstable test
TanYuxin-tyx opened a new pull request, #22479:
URL: https://github.com/apache/flink/pull/22479
## What is the purpose of the change
Bach port to 1.17, the PR has been reviewed at
https://github.com/apache/flink/pull/22471.
Fix the unstable test
[
https://issues.apache.org/jira/browse/FLINK-31907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-31907.
---
Fix Version/s: 1.18.0
Resolution: Fixed
> Remove unused fields inside of
[
https://issues.apache.org/jira/browse/FLINK-31907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716069#comment-17716069
]
Rui Fan commented on FLINK-31907:
-
Thanks [~wanglijie] for the review.
master(1.18) via
1996fanrui merged PR #22472:
URL: https://github.com/apache/flink/pull/22472
--
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:
1996fanrui commented on PR #22472:
URL: https://github.com/apache/flink/pull/22472#issuecomment-1521094800
Hi @wanglijie95 , thanks for your review! Merging.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-31908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716062#comment-17716062
]
jackylau commented on FLINK-31908:
--
hi [~jark] i will fix in calcite first here
[
https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716063#comment-17716063
]
Feifan Wang commented on FLINK-31900:
-
Thanks [~Weijie Guo] for review and merge the PR !
> Fix
[
https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-31900.
--
Fix Version/s: 1.18.0
Resolution: Fixed
master(1.18) via
[
https://issues.apache.org/jira/browse/FLINK-31900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-31900:
--
Assignee: Feifan Wang
> Fix some typo in java doc, comments and assertion message
>
reswqa merged PR #22470:
URL: https://github.com/apache/flink/pull/22470
--
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:
FangYongs commented on code in PR #22362:
URL: https://github.com/apache/flink/pull/22362#discussion_r1175955153
##
flink-table/flink-sql-jdbc-driver/src/main/java/org/apache/flink/table/jdbc/FlinkDatabaseMetaData.java:
##
@@ -0,0 +1,402 @@
+/*
+ * Licensed to the Apache
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175948882
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java:
##
@@ -0,0 +1,1073 @@
+/*
+ * Licensed to
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175946496
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java:
##
@@ -0,0 +1,1359 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175948882
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/GlueCatalog.java:
##
@@ -0,0 +1,1073 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan closed FLINK-31588.
---
Fix Version/s: 1.16.2
1.17.1
Resolution: Fixed
> The unaligned checkpoint type is
[
https://issues.apache.org/jira/browse/FLINK-31588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715340#comment-17715340
]
Rui Fan edited comment on FLINK-31588 at 4/25/23 2:23 AM:
--
Thanks [~pnowojski]
1996fanrui merged PR #22453:
URL: https://github.com/apache/flink/pull/22453
--
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:
1996fanrui merged PR #22454:
URL: https://github.com/apache/flink/pull/22454
--
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:
1996fanrui commented on PR #22454:
URL: https://github.com/apache/flink/pull/22454#issuecomment-1521063518
Thanks for the review, merging.
--
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
1996fanrui commented on PR #22453:
URL: https://github.com/apache/flink/pull/22453#issuecomment-1521062875
Thanks for the review, merging.
--
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
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175947290
##
flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/config/AWSConfigConstants.java:
##
@@ -144,6 +145,194 @@ public enum
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175946496
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java:
##
@@ -0,0 +1,1359 @@
+/*
+ * Licensed
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175945787
##
flink-catalog-aws/flink-catalog-aws-glue/src/test/java/org/apache/flink/table/catalog/glue/GlueCatalogTest.java:
##
@@ -0,0 +1,351 @@
+/*
+ * Licensed to
zoltar9264 commented on PR #22470:
URL: https://github.com/apache/flink/pull/22470#issuecomment-1521057618
Thanks @reswqa and @TanYuxin-tyx for help review the pr ! Since the ci is
passed , can you help me merge it ?
--
This is an automated message from the Apache Git Service.
To respond
Aitozi commented on PR #22455:
URL: https://github.com/apache/flink/pull/22455#issuecomment-1521057087
@wuchong, @twalthr could you help review this fix ?
--
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
[
https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17716059#comment-17716059
]
chouc commented on FLINK-31914:
---
{color:#00}The FlinkKafkaInternalProducer is registered in Closer and
[
https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31928:
--
Summary: flink-kubernetes works not properly in k8s with IPv6 stack (was:
flink-kubernetes works not
[
https://issues.apache.org/jira/browse/FLINK-31930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31930:
--
Component/s: Runtime / RPC
> MetricQueryService works not properly in k8s with IPv6 stack
>
[
https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31929:
--
Summary: HighAvailabilityServicesUtils.getWebMonitorAddress works not
properly in k8s with IPv6 stack (was:
[
https://issues.apache.org/jira/browse/FLINK-31930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31930:
--
Attachment: 1.jpg
> MetricQueryService works not properly in k8s with IPv6 stack
>
caiyi created FLINK-31930:
-
Summary: MetricQueryService works not properly in k8s with IPv6
stack
Key: FLINK-31930
URL: https://issues.apache.org/jira/browse/FLINK-31930
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31928:
--
Description:
As
[https://github.com/square/okhttp/issues/7368|https://github.com/square/okhttp/issues/7368,]
[
https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31928:
--
Priority: Blocker (was: Critical)
> flink-kubernetes works not properly in IPv6 environment in k8s
>
[
https://issues.apache.org/jira/browse/FLINK-31929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31929:
--
Priority: Blocker (was: Critical)
> HighAvailabilityServicesUtils.getWebMonitorAddress works not properly in
[
https://issues.apache.org/jira/browse/FLINK-31914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
datariver updated FLINK-31914:
--
Affects Version/s: 1.16.0
> Failing to close FlinkKafkaInternalProducer created in KafkaWriter with
caiyi created FLINK-31929:
-
Summary: HighAvailabilityServicesUtils.getWebMonitorAddress works
not properly in IPv6 stack of k8s
Key: FLINK-31929
URL: https://issues.apache.org/jira/browse/FLINK-31929
[
https://issues.apache.org/jira/browse/FLINK-31928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
caiyi updated FLINK-31928:
--
Description:
As
[https://github.com/square/okhttp/issues/7368|https://github.com/square/okhttp/issues/7368,]
caiyi created FLINK-31928:
-
Summary: flink-kubernetes works not properly in IPv6 environment
in k8s
Key: FLINK-31928
URL: https://issues.apache.org/jira/browse/FLINK-31928
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-31884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee reassigned FLINK-31884:
---
Assignee: Jane Chan
> Upgrade ExecNode to new version causes the old serialized plan
zzzs commented on code in PR #22452:
URL: https://github.com/apache/flink/pull/22452#discussion_r1175917651
##
docs/content.zh/docs/libs/cep.md:
##
@@ -477,6 +477,11 @@ pattern.oneOrMore()
pattern.timesOrMore(2);
```
{{< /tab >}}
+{{< tab "Scala" >}}
+```scala
[
https://issues.apache.org/jira/browse/FLINK-31898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715632#comment-17715632
]
Kyungmin Kim edited comment on FLINK-31898 at 4/25/23 12:50 AM:
Hi I
noomanee commented on PR #22400:
URL: https://github.com/apache/flink/pull/22400#issuecomment-1521005073
@MartijnVisser Gentle Reminder
--
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
tisonkun merged PR #43:
URL: https://github.com/apache/flink-connector-pulsar/pull/43
--
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:
tisonkun commented on PR #43:
URL:
https://github.com/apache/flink-connector-pulsar/pull/43#issuecomment-1520993271
Merging...
--
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
vahmed-hamdy commented on code in PR #70:
URL:
https://github.com/apache/flink-connector-aws/pull/70#discussion_r1175722682
##
flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/sink/KinesisStreamsSinkWriter.java:
##
@@ -144,6 +150,8 @@
mxm merged PR #574:
URL: https://github.com/apache/flink-kubernetes-operator/pull/574
--
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:
mxm commented on code in PR #574:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175710518
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java:
##
@@ -95,7 +95,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-31927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Etienne Chauchot reassigned FLINK-31927:
Assignee: Etienne Chauchot
> Cassandra source raises an exception on Flink
Etienne Chauchot created FLINK-31927:
Summary: Cassandra source raises an exception on Flink 1.16.0 on a
real Cassandra cluster
Key: FLINK-31927
URL: https://issues.apache.org/jira/browse/FLINK-31927
chachae commented on PR #22446:
URL: https://github.com/apache/flink/pull/22446#issuecomment-1520556636
> @chachae Flink 1.15 is no longer community supported; therefore closing
the PR.
Okay,but we use Flink 1.15 on a large scale, and it's hard to carry out
large scale version
chachae commented on PR #22446:
URL: https://github.com/apache/flink/pull/22446#issuecomment-1520556021
> @chachae Flink 1.15 is no longer community supported; therefore closing
the PR.
> @chachae Flink 1.15 is no longer community supported; therefore closing
the PR.
chachae commented on PR #22446:
URL: https://github.com/apache/flink/pull/22446#issuecomment-1520554286
>
Okay,but we use Flink 1.15 on a large scale, and it's hard to carry out
large scale version upgrade for flink jobs with strong dependence on state
--
This is an automated
pgaref commented on PR #22467:
URL: https://github.com/apache/flink/pull/22467#issuecomment-1520551610
@dmvk / @akalash can you please take a look?
--
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
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-31922:
--
Component/s: Connectors / AWS
> Port over Kinesis Client configurations for retry and backoff
[
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.2.0
> Port over Kinesis Client configurations for retry and
[
https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-31922:
-
Assignee: Daren Wong
> Port over Kinesis Client configurations for retry and backoff
>
Samrat002 commented on code in PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#discussion_r1175579217
##
flink-catalog-aws/flink-catalog-aws-glue/src/main/java/org/apache/flink/table/catalog/glue/util/GlueOperator.java:
##
@@ -0,0 +1,1359 @@
+/*
+ * Licensed
Samrat Deb created FLINK-31926:
--
Summary: Implement rename Table in GlueCatalog
Key: FLINK-31926
URL: https://issues.apache.org/jira/browse/FLINK-31926
Project: Flink
Issue Type: Sub-task
mxm commented on code in PR #574:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175535065
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java:
##
@@ -95,7 +95,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-25003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-25003.
Resolution: Cannot Reproduce
> RestClientTest#testConnectionTimeout fails on Java 17
>
XComp commented on PR #22422:
URL: https://github.com/apache/flink/pull/22422#issuecomment-1520425379
Thanks for the reviews. I squashed the commits in
https://github.com/apache/flink/commit/e1997df38d2bd380804a1a1814d14b75db2493ed
and rebased the branch in
flinkbot commented on PR #22478:
URL: https://github.com/apache/flink/pull/22478#issuecomment-1520406754
## CI report:
* cdeeb1d2fe4be4be301727d378010f7c4750d87c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-31917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-31917:
---
Labels: pull-request-available (was: )
> Loss of Idempotence in JsonSerDe Round Trip for
LadyForest opened a new pull request, #22478:
URL: https://github.com/apache/flink/pull/22478
## What is the purpose of the change
This PR aims to fix the FLINK-31917. The details can be found in the
ticket's description.
## Brief change log
- Fix the issue that
gyfora commented on code in PR #574:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/574#discussion_r1175451671
##
flink-kubernetes-operator-autoscaler/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/AutoScalerInfo.java:
##
@@ -95,7 +95,7 @@ public
mxm opened a new pull request, #574:
URL: https://github.com/apache/flink-kubernetes-operator/pull/574
We recently change the format for the metric history but this also affects
the scaling history because it contains new / old scaling metrics.
--
This is an automated message from
TanYuxin-tyx commented on PR #22471:
URL: https://github.com/apache/flink/pull/22471#issuecomment-1520356264
@zentol Thanks for the quick replies and ideas.
Since no real servers are created based on the server address, I think the
given fixed port is enough. And the hostname has
[
https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-22828:
--
Summary: Allow using a custom AWS credentials provider for AWS Connectors
(was: Allow using
[
https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-22828.
---
Resolution: Done
> Allow using a custom AWS credentials provider for the Kinesis Connector
[
https://issues.apache.org/jira/browse/FLINK-22828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17715857#comment-17715857
]
Danny Cranmer commented on FLINK-22828:
---
Merged commit
dannycranmer merged PR #69:
URL: https://github.com/apache/flink-connector-aws/pull/69
--
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:
1 - 100 of 304 matches
Mail list logo