[
https://issues.apache.org/jira/browse/FLINK-34127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837982#comment-17837982
]
Mason Chen commented on FLINK-34127:
It seems to be a bug in junit. https://github.c
Zakelly commented on PR #24657:
URL: https://github.com/apache/flink/pull/24657#issuecomment-2060481241
Thanks @fredia and @yunfengzhou-hub for your detailed review! Really
appreciate it. 🚀
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
yunfengzhou-hub commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1568257919
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImpl.java:
##
@@ -0,0 +1,145 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-35031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837980#comment-17837980
]
Yunfeng Zhou commented on FLINK-35031:
--
What is the relationship between this ticke
LadyForest commented on code in PR #24510:
URL: https://github.com/apache/flink/pull/24510#discussion_r1568258000
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/UncollectToTableFunctionScanRule.java:
##
@@ -0,0 +1,135 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-34752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837975#comment-17837975
]
LvYanquan commented on FLINK-34752:
---
[~siriusfan] Thanks for taking this, I don't have
[
https://issues.apache.org/jira/browse/FLINK-35112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837965#comment-17837965
]
Dian Fu commented on FLINK-35112:
-
Great (y). Thanks [~wzorgdrager]Â
> Membership for R
[
https://issues.apache.org/jira/browse/FLINK-35089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song closed FLINK-35089.
Fix Version/s: 1.20.0
1.19.1
Resolution: Fixed
- master (1.20): 7a90a05e
xintongsong closed pull request #24655: [FLINK-35089][runtime] Initialize
lastRecordAttributes in AbstractStreamOperator during setup
URL: https://github.com/apache/flink/pull/24655
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
fredia commented on code in PR #24671:
URL: https://github.com/apache/flink/pull/24671#discussion_r1568129118
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/InternalSyncState.java:
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
[
https://issues.apache.org/jira/browse/FLINK-34907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-34907:
Description:
Currently, we consider the timestamp that JobStatus is changed to RUNNING as
jobRunningTs. B
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837942#comment-17837942
]
Hongshun Wang commented on FLINK-35129:
---
[~m.orazow] , would you like to take it?
Hongshun Wang created FLINK-35129:
-
Summary: Postgres source commits the offset after every multiple
checkpoint cycles.
Key: FLINK-35129
URL: https://issues.apache.org/jira/browse/FLINK-35129
Project:
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1568151628
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessing.java:
##
@@ -34,19 +34,6 @@ public interface Asy
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1568147623
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessingOperator.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licens
masteryhx commented on PR #24651:
URL: https://github.com/apache/flink/pull/24651#issuecomment-2060251285
Rebased master.
I will merge it after the CI is green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
[
https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiqian YU updated FLINK-35092:
--
Summary: Add integrated test for Doris / Starrocks sink pipeline connector
(was: Add integrated test
[
https://issues.apache.org/jira/browse/FLINK-35071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35071:
---
Labels: pull-request-available (was: )
> Remove dependency on flink-shaded from cdc source
loserwang1024 commented on PR #3083:
URL: https://github.com/apache/flink-cdc/pull/3083#issuecomment-2060246663
@PatrickRen , CC?
--
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
yuxiqian commented on code in PR #3207:
URL: https://github.com/apache/flink-cdc/pull/3207#discussion_r1568134905
##
flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java:
##
loserwang1024 commented on PR #3230:
URL: https://github.com/apache/flink-cdc/pull/3230#issuecomment-2060235695
@PatrickRen , @morazow , CC
--
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 spe
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35128:
---
Labels: pull-request-available (was: )
> Re-calculate the starting change log offset after
loserwang1024 opened a new pull request, #3230:
URL: https://github.com/apache/flink-cdc/pull/3230
In mysql cdc, re-calculate the starting binlog offset after the new table
added in MySqlBinlogSplit#appendFinishedSplitInfos, while there lack of same
action in StreamSplit#appendFinishedSplit
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei reassigned FLINK-35028:
--
Assignee: Yanfei Lei
> Timer firing under async execution model
> ---
[
https://issues.apache.org/jira/browse/FLINK-35079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiabao Sun resolved FLINK-35079.
Fix Version/s: cdc-3.1.0
Resolution: Fixed
resolved via cdc master: 0562e35da75fb2c8e512d43
Jiabao-Sun merged PR #3221:
URL: https://github.com/apache/flink-cdc/pull/3221
--
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-35046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-35046.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged 691cc671 into master.
> Introduce New K
masteryhx closed pull request #24663: [FLINK-35046][state] Introduce
AsyncKeyedStateBackend supporting to create StateExecutor
URL: https://github.com/apache/flink/pull/24663
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Description:
In mysql cdc, re-calculate the starting binlog offset after the new table added
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-35128:
--
Summary: Re-calculate the starting change log offset after the new table
added (was: Re-calcu
Hongshun Wang created FLINK-35128:
-
Summary: Re-calculate the starting binlog offset after the new
table added
Key: FLINK-35128
URL: https://issues.apache.org/jira/browse/FLINK-35128
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837929#comment-17837929
]
Jiabao Sun commented on FLINK-35127:
Hi [~kunni],
Could you help take a look?
> CDC
Jiabao Sun created FLINK-35127:
--
Summary: CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
Key: FLINK-35127
URL: https://issues.apache.org/jira/browse/FLINK-35127
Project: Flink
Issue
ZmmBigdata opened a new pull request, #3229:
URL: https://github.com/apache/flink-cdc/pull/3229
There is an issue with the format of three shell scripts
![cc29
yunfengzhou-hub commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567131634
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AsyncStateProcessingOperator.java:
##
@@ -0,0 +1,54 @@
+/*
+
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568044466
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref: '#/compo
mas-chen commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568044466
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref: '#/compo
gyfora commented on PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#issuecomment-2059797010
Together with the version bump, this workaround can also be removed I
believe:
https://github.com/apache/flink-kubernetes-operator/commit/726e484c6a9b4121563829bc094b3eebe
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian Vasiliu updated FLINK-31966:
---
Attachment: (was: image-2024-04-16-16-33-39-644.png)
> Flink Kubernetes operator lacks T
snuyanzin merged PR #45:
URL: https://github.com/apache/flink-connector-hbase/pull/45
--
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...
Gyula Fora created FLINK-35126:
--
Summary: Improve checkpoint progress health check config and
enable by default
Key: FLINK-35126
URL: https://issues.apache.org/jira/browse/FLINK-35126
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837752#comment-17837752
]
Leonard Xu commented on FLINK-34653:
master via 6017b165289d8e6f40db396cd07c62285be7
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-34653:
---
Release Note: (was: master via 6017b165289d8e6f40db396cd07c62285be7fca9)
> Support table merging w
[
https://issues.apache.org/jira/browse/FLINK-34653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-34653.
--
Release Note: master via 6017b165289d8e6f40db396cd07c62285be7fca9
Resolution: Fixed
> Support ta
leonardBang merged PR #3129:
URL: https://github.com/apache/flink-cdc/pull/3129
--
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
leonardBang commented on PR #2997:
URL: https://github.com/apache/flink-cdc/pull/2997#issuecomment-2059264100
@lvyanquan kindly ping
--
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
leonardBang commented on code in PR #3128:
URL: https://github.com/apache/flink-cdc/pull/3128#discussion_r1567483688
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java:
##
@@ -85,5 +89,12 @@ public class PipelineOptions {
[
https://issues.apache.org/jira/browse/FLINK-31966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Adrian Vasiliu updated FLINK-31966:
---
Attachment: image-2024-04-16-16-33-39-644.png
> Flink Kubernetes operator lacks TLS support
snuyanzin merged PR #44:
URL: https://github.com/apache/flink-connector-hbase/pull/44
--
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...
snuyanzin commented on PR #44:
URL:
https://github.com/apache/flink-connector-hbase/pull/44#issuecomment-2059202176
Thanks for taking 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 to the s
snuyanzin opened a new pull request, #44:
URL: https://github.com/apache/flink-connector-hbase/pull/44
The PR will allow to differentiate between Hbase connector statistics and
others with name ci
--
This is an automated message from the Apache Git Service.
To respond to the m
[
https://issues.apache.org/jira/browse/FLINK-34878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34878:
---
Labels: github-import pull-request-available (was: github-import)
> [Feature][Pipeline] Fli
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin closed FLINK-33440.
---
> Bump flink version on flink-connectors-hbase
>
>
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-33440.
-
Fix Version/s: hbase-4.0.0
Resolution: Fixed
> Bump flink version on flink-connec
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837705#comment-17837705
]
Sergey Nuyanzin commented on FLINK-33440:
-
Merged as
[08b7b69cd82acf3e8ba9af08d
csviri commented on code in PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#discussion_r1567338233
##
flink-kubernetes-operator-api/src/main/java/org/apache/flink/kubernetes/operator/api/validation/CrdCompatibilityChecker.java:
##
@@ -93,7 +93,10 @@ p
[
https://issues.apache.org/jira/browse/FLINK-33440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-33440:
---
Assignee: Ferenc Csaky
> Bump flink version on flink-connectors-hbase
> ---
snuyanzin merged PR #35:
URL: https://github.com/apache/flink-connector-hbase/pull/35
--
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...
mbalassi commented on PR #816:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/816#issuecomment-2059011676
I will take a look at the test failure later, it is a timeout in
`AbstractFlinkServiceTest#testBlockingDeploymentDeletion`. I managed to
reproduce it locally.
--
This
flinkbot commented on PR #24672:
URL: https://github.com/apache/flink/pull/24672#issuecomment-2059006200
## CI report:
* 6507dc0d38dec17e91fa3f722cd924ca82197622 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1567286518
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref: '#/compo
[
https://issues.apache.org/jira/browse/FLINK-35028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35028:
---
Labels: pull-request-available (was: )
> Timer firing under async execution model
> ---
fredia opened a new pull request, #24672:
URL: https://github.com/apache/flink/pull/24672
## What is the purpose of the change
This PR adapts timer firing to async state execution. The entrances are
`AbstractAsyncStateStreamOperator ` and `AbstractAsyncStateStreamOperatorV2`,
dfontana commented on PR #23226:
URL: https://github.com/apache/flink/pull/23226#issuecomment-2058978531
Hi @singhravidutt thank you for your efforts; are you actively working on
this PR? I am also interested in seeing this land; am happy to help where needed
--
This is an automated messa
flinkbot commented on PR #24671:
URL: https://github.com/apache/flink/pull/24671#issuecomment-2058974205
## CI report:
* f4b1a4374cc6c579ff50e5b09bb5715b386645d2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35125:
---
Labels: pull-request-available (was: )
> Implement ValueState for ForStStateBackend
> -
ljz2051 opened a new pull request, #24671:
URL: https://github.com/apache/flink/pull/24671
## What is the purpose of the change
This pull request implements the ValueState for ForStStateBackend.
## Brief change log
- Define the InternalSyncState interfaces in flink-run
Jinzhong Li created FLINK-35125:
---
Summary: Implement ValueState for ForStStateBackend
Key: FLINK-35125
URL: https://issues.apache.org/jira/browse/FLINK-35125
Project: Flink
Issue Type: Sub-task
ferenc-csaky commented on PR #35:
URL:
https://github.com/apache/flink-connector-hbase/pull/35#issuecomment-2058924269
@snuyanzin I fixed the dep convergence for 1.19 the last CI run failed on,
also had to change `HBaseTablePlanTest` as the JUnit5 migration for
`TableTestBase` in the core
Zakelly commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567158767
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void e
[
https://issues.apache.org/jira/browse/FLINK-35116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35116:
---
Labels: pull-request-available (was: )
> Upgrade JOSDK dependency to 4.8.3
> --
mbalassi opened a new pull request, #816:
URL: https://github.com/apache/flink-kubernetes-operator/pull/816
Also bumps fabric8 client 6.11.0 to harmonize it with JOSDK.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
dannycranmer opened a new pull request, #733:
URL: https://github.com/apache/flink-web/pull/733
(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 unsubscribe,
Zakelly commented on code in PR #24632:
URL: https://github.com/apache/flink/pull/24632#discussion_r1567124524
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/ByteBufferReadableFSDataInputStream.java:
##
@@ -0,0 +1,195 @@
+/*
+ * Li
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Affects Version/s: (was: aws-connector-4.2.0)
> Custom Error Handling for Kinesis Polling
[
https://issues.apache.org/jira/browse/FLINK-32007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-32007:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Impleme
[
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.4.0
(was: aws-connector-4.3.0)
> flink-c
[
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.3.0
> flink-connector-aws should use/extend the common conn
[
https://issues.apache.org/jira/browse/FLINK-33991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer updated FLINK-33991:
--
Fix Version/s: aws-connector-4.4.0
(was: aws-connector-4.3.0)
> Custom
[
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: (was: aws-connector-4.2.0)
> Add Support for Configuring AIMD Ratelimit
[
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.3.0
> FlinkKinesisConsumer cannot stop-with-savepoint when
[
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.4.0
(was: aws-connector-4.3.0)
> Define
[
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.3.0
> Port over Kinesis Client configurations for retry and
[
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: (was: aws-connector-4.2.0)
> Support AWS Glue Schema Registry Avro for
[
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.4.0
(was: aws-connector-4.3.0)
> Port ov
[
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.4.0
(was: aws-connector-4.3.0)
> FlinkKi
[
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.4.0
(was: aws-connector-4.3.0)
> Support
[
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.3.0
> Define ConfigOption for aws, scan and sink map in Kin
[
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.4.0
(was: aws-connector-4.3.0)
> Add Sup
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837654#comment-17837654
]
Danny Cranmer commented on FLINK-35124:
---
[~echauchot] do you recall why the tools
Danny Cranmer created FLINK-35124:
-
Summary: Connector Release Fails to run Checkstyle
Key: FLINK-35124
URL: https://issues.apache.org/jira/browse/FLINK-35124
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837647#comment-17837647
]
Ryan Skraba commented on FLINK-35041:
-
1.20 test_ci core
https://dev.azure.com/apac
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837642#comment-17837642
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Java 11: Test (module: core)
https://
[
https://issues.apache.org/jira/browse/FLINK-34919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837643#comment-17837643
]
Ryan Skraba commented on FLINK-34919:
-
1.19 Java 21: Test (module: core)
https://gi
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567096409
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/StateRequestBuffer.java:
##
@@ -59,6 +60,9 @@ public StateRequestBuffer() {
}
void en
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837641#comment-17837641
]
Ryan Skraba commented on FLINK-35002:
-
1.20 AdaptiveScheduler: Compile
https://gith
flinkbot commented on PR #24670:
URL: https://github.com/apache/flink/pull/24670#issuecomment-2058604771
## CI report:
* aae449392b8ce075a2413679ed2a0c42eaa52c68 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
fredia commented on code in PR #24657:
URL: https://github.com/apache/flink/pull/24657#discussion_r1567004818
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordProcessorUtils.java:
##
@@ -82,6 +87,10 @@ public static ThrowingConsumer,
Exception>
snuyanzin merged PR #89:
URL: https://github.com/apache/flink-connector-pulsar/pull/89
--
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..
[
https://issues.apache.org/jira/browse/FLINK-35123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837610#comment-17837610
]
Gyula Fora commented on FLINK-35123:
I agree that if the rest api is accessible we c
1 - 100 of 163 matches
Mail list logo
