[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36342:
-
Summary: Rename misleading BufferDebloater variable 'targetTotalBufferSize'
(was: Rename mislea
[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36342:
-
Fix Version/s: 2.0-preview
> Rename misleading variable names
>
[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky reassigned FLINK-36342:
Assignee: Xu Hao
> Rename misleading variable names
>
>
[
https://issues.apache.org/jira/browse/FLINK-36345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuxuetong updated FLINK-36345:
---
External issue URL: (was: https://github.com/apache/flink-cdc/pull/3593)
> [feature][cdc-connector
[
https://issues.apache.org/jira/browse/FLINK-36345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhuxuetong updated FLINK-36345:
---
External issue URL: https://github.com/apache/flink-cdc/pull/3593
> [feature][cdc-connector][oracle]
zhuxuetong created FLINK-36345:
--
Summary: [feature][cdc-connector][oracle] Oracle cdc support
partition table
Key: FLINK-36345
URL: https://issues.apache.org/jira/browse/FLINK-36345
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-36344:
Assignee: Baozhu Zhao
> Introduce lastCompletedCheckpointTimestamp metrics
>
[
https://issues.apache.org/jira/browse/FLINK-36320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883445#comment-17883445
]
haiqingchen commented on FLINK-36320:
-
Hi [~libenchao], may I know if you have any i
[
https://issues.apache.org/jira/browse/FLINK-36320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
haiqingchen updated FLINK-36320:
Priority: Minor (was: Major)
> Use Protobuf Nested timestamp field as event time column and water
Yun Tang created FLINK-36344:
Summary: Introduce lastCompletedCheckpointTimestamp metrics
Key: FLINK-36344
URL: https://issues.apache.org/jira/browse/FLINK-36344
Project: Flink
Issue Type: Improv
github-actions[bot] commented on PR #3483:
URL: https://github.com/apache/flink-cdc/pull/3483#issuecomment-2364767272
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
github-actions[bot] commented on PR #3485:
URL: https://github.com/apache/flink-cdc/pull/3485#issuecomment-2364767260
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883431#comment-17883431
]
Luke Chen commented on FLINK-36290:
---
I had a look at all the OOM cases, they seem don'
Da Huo created FLINK-36343:
--
Summary: The description on max-parallelism is misleading and
needs to be more specific
Key: FLINK-36343
URL: https://issues.apache.org/jira/browse/FLINK-36343
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883423#comment-17883423
]
Da Huo commented on FLINK-36343:
I'm happy to help on this ticket as well
> The descrip
[
https://issues.apache.org/jira/browse/FLINK-36318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36318.
-
Fix Version/s: 2.0-preview
Resolution: Fixed
> Fail to restore from 1.18 if LAG f
snuyanzin merged PR #25358:
URL: https://github.com/apache/flink/pull/25358
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883386#comment-17883386
]
Sergey Nuyanzin commented on FLINK-36330:
-
Merged as
[f1a7a10581c89ef59e2a8bbfd
snuyanzin commented on PR #25358:
URL: https://github.com/apache/flink/pull/25358#issuecomment-2364397774
@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-36330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36330.
-
Fix Version/s: 2.0-preview
Resolution: Fixed
> Session Window TVFs with named par
snuyanzin merged PR #25362:
URL: https://github.com/apache/flink/pull/25362
--
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.apa
snuyanzin merged PR #25369:
URL: https://github.com/apache/flink/pull/25369
--
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.apa
[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xu Hao updated FLINK-36342:
---
Description:
The variable named targetTotalBufferSize appears in class
BufferDebloatConfiguration and some
[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xu Hao updated FLINK-36342:
---
Description:
The variable named targetTotalBufferSize appears in class
BufferDebloatConfiguration and some
flinkbot commented on PR #25370:
URL: https://github.com/apache/flink/pull/25370#issuecomment-2364000848
## CI report:
* da167a5cddf4469e18a2eff2100b2ed73180176b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36342:
---
Labels: pull-request-available (was: )
> Rename misleading variable names
> ---
XuHao41 opened a new pull request, #25370:
URL: https://github.com/apache/flink/pull/25370
## What is the purpose of the change
Incorrect variable naming can cause confusion for readers of flink source
code. Given that this variable is involved in the computation within the Bu
spena commented on code in PR #25359:
URL: https://github.com/apache/flink/pull/25359#discussion_r1768799456
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java:
##
@@ -209,6 +213,78 @@ public static RelNode convertSin
spena commented on code in PR #25359:
URL: https://github.com/apache/flink/pull/25359#discussion_r1768799089
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/utils/ParserResource.java:
##
@@ -41,6 +41,10 @@ public interface ParserResource {
@Resourc
flinkbot commented on PR #25369:
URL: https://github.com/apache/flink/pull/25369#issuecomment-2363956380
## CI report:
* 93b2e0c0fe437940921a972056625e709633107a UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Xu Hao created FLINK-36342:
--
Summary: Rename misleading variable names
Key: FLINK-36342
URL: https://issues.apache.org/jira/browse/FLINK-36342
Project: Flink
Issue Type: Improvement
Compon
dawidwys closed pull request #25357: [FLINK-36318] Fix deserializing from 1.18
savepoint with RAW types
URL: https://github.com/apache/flink/pull/25357
--
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 t
yuxiqian commented on PR #3606:
URL: https://github.com/apache/flink-cdc/pull/3606#issuecomment-2363847956
Could @ruanhang1993 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 to
flinkbot commented on PR #25368:
URL: https://github.com/apache/flink/pull/25368#issuecomment-2363846967
## CI report:
* c73bf9a1ac308e6c93dccf3f8ce59df4ee11985c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
AHeise opened a new pull request, #25368:
URL: https://github.com/apache/flink/pull/25368
## What is the purpose of the change
UnifiedSinkMigrationITCase tests that SinkV1 can be read with Flink 1.14
SinkV2. Since we remove SinkV1 entirely from Flink 2.0, we can go ahe
LinMingQiang commented on PR #3606:
URL: https://github.com/apache/flink-cdc/pull/3606#issuecomment-2363810910
@yuxiqian Can you help me merge this PR?
--
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
Wang Qilong created FLINK-36341:
---
Summary: Does FlinkSQL have a setting to prohibit CodeGen
generation
Key: FLINK-36341
URL: https://issues.apache.org/jira/browse/FLINK-36341
Project: Flink
Is
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883247#comment-17883247
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883253#comment-17883253
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883249#comment-17883249
]
Matthias Pohl edited comment on FLINK-36290 at 9/20/24 12:49 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883252#comment-17883252
]
Matthias Pohl commented on FLINK-17274:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883249#comment-17883249
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883244#comment-17883244
]
Matthias Pohl commented on FLINK-36301:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-33555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883235#comment-17883235
]
Matthias Pohl commented on FLINK-33555:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883242#comment-17883242
]
Matthias Pohl commented on FLINK-36166:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883240#comment-17883240
]
Matthias Pohl commented on FLINK-36290:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883239#comment-17883239
]
Matthias Pohl commented on FLINK-36291:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883238#comment-17883238
]
Matthias Pohl commented on FLINK-34273:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883237#comment-17883237
]
Matthias Pohl commented on FLINK-36297:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883236#comment-17883236
]
Matthias Pohl commented on FLINK-36167:
---
https://dev.azure.com/apache-flink/apache
[
https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-36167:
--
Labels: test-stability (was: )
> testSinkDisorderChangeLog failed on AZP
> --
[
https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883234#comment-17883234
]
chenyuzhi edited comment on FLINK-36340 at 9/20/24 12:23 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883234#comment-17883234
]
chenyuzhi commented on FLINK-36340:
---
I think the error is caused by
https://issues.ap
[
https://issues.apache.org/jira/browse/FLINK-36340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chenyuzhi updated FLINK-36340:
--
Description:
When stopping flink application running with kafkaConsumer on k8s operator,
the jobma
chenyuzhi created FLINK-36340:
-
Summary: Can not stop with savepoint
Key: FLINK-36340
URL: https://issues.apache.org/jira/browse/FLINK-36340
Project: Flink
Issue Type: Bug
Components: K
Sxnan merged PR #25355:
URL: https://github.com/apache/flink/pull/25355
--
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.apache.
[
https://issues.apache.org/jira/browse/FLINK-36339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883223#comment-17883223
]
david radley commented on FLINK-36339:
--
[~dwysakowicz] I think this sounds like a g
flinkbot commented on PR #25367:
URL: https://github.com/apache/flink/pull/25367#issuecomment-2363459765
## CI report:
* 90aa9496b9954906ec1cce3c37d67a1ed4f682ea UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36338:
---
Labels: pull-request-available (was: )
> Properly handle KeyContext when using AsyncKeyedSt
Zakelly opened a new pull request, #25367:
URL: https://github.com/apache/flink/pull/25367
## What is the purpose of the change
After [FLINK-36117](https://issues.apache.org/jira/browse/FLINK-36117), we
port old state backends implementation to new api using
AsyncKeyedStateBackendAda
twalthr commented on code in PR #25359:
URL: https://github.com/apache/flink/pull/25359#discussion_r1768388152
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java:
##
@@ -209,6 +213,78 @@ public static RelNode convertS
[
https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-36338:
Summary: Properly handle KeyContext when using
AsyncKeyedStateBackendAdaptor (was: Correct handle
twalthr commented on code in PR #25362:
URL: https://github.com/apache/flink/pull/25362#discussion_r1768379745
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -373,20 +375,30 @@ protected void addToSele
snuyanzin commented on code in PR #25362:
URL: https://github.com/apache/flink/pull/25362#discussion_r1768373194
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -373,20 +375,30 @@ protected void addToSe
[
https://issues.apache.org/jira/browse/FLINK-36284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-36284.
---
Assignee: xuyang
Resolution: Fixed
Fixed in master: 1cd9110f858a809ea640a23e872303be02015db9
lincoln-lil merged PR #25336:
URL: https://github.com/apache/flink/pull/25336
--
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.a
Dawid Wysakowicz created FLINK-36339:
Summary: Remove java serialization from SQL serializers
Key: FLINK-36339
URL: https://issues.apache.org/jira/browse/FLINK-36339
Project: Flink
Issue
flinkbot commented on PR #25366:
URL: https://github.com/apache/flink/pull/25366#issuecomment-2363372428
## CI report:
* 4d46ec3534f888d7ff54c9519acfba024de6f2ed UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on code in PR #25362:
URL: https://github.com/apache/flink/pull/25362#discussion_r1768355815
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -373,20 +375,30 @@ protected void addToSe
Zakelly Lan created FLINK-36338:
---
Summary: Correct handle KeyContext when using
AsyncKeyedStateBackendAdaptor
Key: FLINK-36338
URL: https://issues.apache.org/jira/browse/FLINK-36338
Project: Flink
snuyanzin commented on code in PR #25362:
URL: https://github.com/apache/flink/pull/25362#discussion_r1768348432
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -373,20 +375,30 @@ protected void addToSe
[
https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883214#comment-17883214
]
Xuannan Su commented on FLINK-36292:
https://dev.azure.com/apache-flink/apache-flink
dawidwys commented on code in PR #25357:
URL: https://github.com/apache/flink/pull/25357#discussion_r1768343224
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java:
##
@@ -314,7 +314,8 @@ public void readSnapshot(int r
hlteoh37 commented on PR #169:
URL:
https://github.com/apache/flink-connector-aws/pull/169#issuecomment-2363341100
Merging as tests pass (title validator is not valid test for dependabot)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
noorall opened a new pull request, #25366:
URL: https://github.com/apache/flink/pull/25366
## What is the purpose of the change
Refactor the StreamGraphGenerator by introducing the JobVertexBuildContext
to make more methods reusable.
## Brief change log
- In
[
https://issues.apache.org/jira/browse/FLINK-36335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36335:
---
Labels: pull-request-available (was: )
> Improving Method Reusability in StreamGraphGenerat
Sxnan commented on PR #25355:
URL: https://github.com/apache/flink/pull/25355#issuecomment-2363353508
@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.
To
[
https://issues.apache.org/jira/browse/FLINK-36338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-36338:
---
Assignee: Zakelly Lan
> Correct handle KeyContext when using AsyncKeyedStateBackendAdaptor
Jiabao-Sun commented on code in PR #3615:
URL: https://github.com/apache/flink-cdc/pull/3615#discussion_r1768333821
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/test/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBFullChangelogITCase.java:
hlteoh37 merged PR #169:
URL: https://github.com/apache/flink-connector-aws/pull/169
--
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...@
qg-lin commented on PR #3615:
URL: https://github.com/apache/flink-cdc/pull/3615#issuecomment-2363291818
@Jiabao-Sun @yuxiqian PTAL
--
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 co
JNSimba commented on PR #3415:
URL: https://github.com/apache/flink-cdc/pull/3415#issuecomment-2363300595
Thanks, itcase has been added,PTAL @ruanhang1993
--
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
twalthr commented on code in PR #25362:
URL: https://github.com/apache/flink/pull/25362#discussion_r1768296119
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkCalciteSqlValidator.java:
##
@@ -373,20 +375,30 @@ protected void addToSele
twalthr commented on code in PR #25357:
URL: https://github.com/apache/flink/pull/25357#discussion_r1768266516
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/testutils/RestoreTestBase.java:
##
@@ -144,7 +150,42 @@ private Stream c
xuyangzhong commented on code in PR #25336:
URL: https://github.com/apache/flink/pull/25336#discussion_r1768272670
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1971,7 +1967,7 @@ private TypeInformation
privateGetForClass(
xuyang created FLINK-36337:
--
Summary: Recursively check if the parent class is
org.apache.avro.specific.SpecificRecordBase to confirm whether it is an Avro
type
Key: FLINK-36337
URL: https://issues.apache.org/jira/brows
fredia commented on PR #25360:
URL: https://github.com/apache/flink/pull/25360#issuecomment-2363229911
Rebased to latest master.
--
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 comme
[
https://issues.apache.org/jira/browse/FLINK-36321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36321:
---
Labels: pull-request-available (was: )
> Execute read/write state request in different exec
[
https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-36314.
Assignee: Yanfei Lei
Resolution: Resolved
> Support state V1 interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-36314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883196#comment-17883196
]
Yanfei Lei commented on FLINK-36314:
Merged into master via 1ba8900
> Support state
boring-cyborg[bot] commented on PR #120:
URL:
https://github.com/apache/flink-connector-kafka/pull/120#issuecomment-2363192940
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This is
hansh0801 opened a new pull request, #120:
URL: https://github.com/apache/flink-connector-kafka/pull/120
To use the Rack-aware Partition Assignment for Kafka Consumers
([KIP-881](https://cwiki.apache.org/confluence/display/KAFKA/KIP-881%3A+Rack-aware+Partition+Assignment+for+Kafka+Consumers)
[
https://issues.apache.org/jira/browse/FLINK-34342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-34342:
---
Assignee: Abhishek Kumar
> Address Shard Consistency Issue for DDB Streams Source
>
[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883192#comment-17883192
]
Hong Liang Teoh edited comment on FLINK-31986 at 9/20/24 8:41 AM:
[
https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-31987:
---
Assignee: Burak Ozakinci
> Implement KDS Table API support
> --
[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883192#comment-17883192
]
Hong Liang Teoh commented on FLINK-31986:
-
This is blocked by localstack and Kin
[
https://issues.apache.org/jira/browse/FLINK-31986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh reassigned FLINK-31986:
---
Assignee: (was: Elphas Toringepi)
> Implement Integration test for FLIP-27 Data
davidradl commented on code in PR #25336:
URL: https://github.com/apache/flink/pull/25336#discussion_r1768200714
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -1971,7 +1967,7 @@ private TypeInformation
privateGetForClass(
}
fredia merged PR #25349:
URL: https://github.com/apache/flink/pull/25349
--
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.apache
fredia commented on PR #25349:
URL: https://github.com/apache/flink/pull/25349#issuecomment-2363112692
Thanks for the review🚀, merged.
--
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
100 matches
Mail list logo
