Yuxin Tan created FLINK-35169:
-
Summary: Recycle buffers to freeSegments before releasing data
buffer for sort accumulator
Key: FLINK-35169
URL: https://issues.apache.org/jira/browse/FLINK-35169
Project:
hugogu commented on PR #89:
URL:
https://github.com/apache/flink-connector-kafka/pull/89#issuecomment-2065806444
Hi @uce and @rmetzger, do you mind reviewing the change and let me know if
any change is required before merging. Thanks.
--
This is an automated message from the Apache Git
flinkbot commented on PR #24684:
URL: https://github.com/apache/flink/pull/24684#issuecomment-2065793603
## CI report:
* b2a3ede0b60213c2dc38e5ff050c5f827e1e86bc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35154:
---
Labels: pull-request-available (was: )
> Javadoc aggregate fails
> ---
ldadima opened a new pull request, #24684:
URL: https://github.com/apache/flink/pull/24684
## What is the purpose of the change
To fix [FLINK-35154](https://issues.apache.org/jira/browse/FLINK-35154)
## Verifying this change
Run mvn javadoc:aggregate -Prelease
##
RocMarshal commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1571809638
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,6 +101,11 @@ public
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838854#comment-17838854
]
Vadim Vararu edited comment on FLINK-35115 at 4/19/24 4:54 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838854#comment-17838854
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] 4.3.0 will be released for Flink 1.18 as
[ https://issues.apache.org/jira/browse/FLINK-35115 ]
Vadim Vararu deleted comment on FLINK-35115:
--
was (Author: JIRAUSER305101):
[~a.pilipenko] 4.3.0 will be released for Flink 1.18 as well, right?
> Kinesis connector writes wrong Kinesis
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838853#comment-17838853
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] 4.3.0 will be released for Flink 1.18 as
Zakelly commented on code in PR #24676:
URL: https://github.com/apache/flink/pull/24676#discussion_r1571777947
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/asyncprocessing/AbstractAsyncStateStreamOperator.java:
##
@@ -133,6 +136,20 @@
ferenc-csaky commented on PR #24303:
URL: https://github.com/apache/flink/pull/24303#issuecomment-2065736703
@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
Zakelly commented on code in PR #24667:
URL: https://github.com/apache/flink/pull/24667#discussion_r1571771428
##
flink-core/src/main/java/org/apache/flink/configuration/ExecutionOptions.java:
##
@@ -181,4 +182,73 @@ public class ExecutionOptions {
Zakelly commented on code in PR #24672:
URL: https://github.com/apache/flink/pull/24672#discussion_r1571754617
##
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceAsyncImpl.java:
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-35168:
Component/s: Runtime / State Backends
> Basic State Iterator for async processing
>
Zakelly Lan created FLINK-35168:
---
Summary: Basic State Iterator for async processing
Key: FLINK-35168
URL: https://issues.apache.org/jira/browse/FLINK-35168
Project: Flink
Issue Type: Sub-task
Zakelly commented on code in PR #24681:
URL: https://github.com/apache/flink/pull/24681#discussion_r1571721125
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStValueState.java:
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache
lvyanquan commented on PR #3237:
URL: https://github.com/apache/flink-cdc/pull/3237#issuecomment-2065637354
The failure in current CI contains a error message of
```
(4185ef2c5087300d32f25ea842d3ec59_cbc357ccb763df2852fee8c4fc7d55f2_0_0)
switched from RUNNING to FAILED with failure
flinkbot commented on PR #24683:
URL: https://github.com/apache/flink/pull/24683#issuecomment-2065635252
## CI report:
* 0d0a7bcca23de55518958f32eb36a242bd4b615d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24682:
URL: https://github.com/apache/flink/pull/24682#issuecomment-2065635116
## CI report:
* a5be0a188101bcaf6fb76c8d5144ad002a79a192 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-35167:
--
Fix Version/s: cdc-3.2.0
> Introduce MaxCompute pipeline DataSink
>
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838836#comment-17838836
]
zhangdingxin edited comment on FLINK-35167 at 4/19/24 2:22 AM:
---
I'd like
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangdingxin updated FLINK-35167:
-
Labels: (was: Flink-CDC connector)
> Introduce MaxCompute pipeline DataSink
>
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35167:
-
Assignee: zhangdingxin
> Introduce MaxCompute pipeline DataSink
>
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838836#comment-17838836
]
zhangdingxin commented on FLINK-35167:
--
I'd like to do it
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2065632965
@LadyForest Hi, I have updated as you said, besides, rebased on the latest
master branch and CI passed, PTAL, thanks :)
--
This is an automated message from the Apache Git Service.
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangdingxin updated FLINK-35167:
-
Summary: Introduce MaxCompute pipeline DataSink (was: [CDC] Introduce
MaxCompute pipeline
[
https://issues.apache.org/jira/browse/FLINK-35161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35161:
Component/s: Runtime / State Backends
> Implement StateExecutor for ForStStateBackend
>
[
https://issues.apache.org/jira/browse/FLINK-35163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35163:
Component/s: Runtime / State Backends
> Utilize ForSt's native MultiGet API to optimize remote
[
https://issues.apache.org/jira/browse/FLINK-35162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinzhong Li updated FLINK-35162:
Component/s: Runtime / State Backends
> Support grouping state get and put access
>
zhangdingxin created FLINK-35167:
Summary: [CDC] Introduce MaxCompute pipeline DataSink
Key: FLINK-35167
URL: https://issues.apache.org/jira/browse/FLINK-35167
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-35166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35166:
---
Labels: pull-request-available (was: )
> Improve the performance of Hybrid Shuffle when
jiangxin369 opened a new pull request, #24683:
URL: https://github.com/apache/flink/pull/24683
## What is the purpose of the change
Improve the performance of hybrid shuffle when enable memory decoupling and
meantime the parallelism is small.
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-35047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35047:
---
Labels: pull-request-available (was: )
> Introduce ForStStateBackend to manage ForSt
>
masteryhx opened a new pull request, #24682:
URL: https://github.com/apache/flink/pull/24682
## What is the purpose of the change
A ForStStateBackend is introduced to leverage ForSt as state store for Flink.
This ticket includes:
- Life cycle of ForSt, including
Jiang Xin created FLINK-35166:
-
Summary: Improve the performance of Hybrid Shuffle when enable
memory decoupling
Key: FLINK-35166
URL: https://issues.apache.org/jira/browse/FLINK-35166
Project: Flink
lvyanquan commented on PR #3237:
URL: https://github.com/apache/flink-cdc/pull/3237#issuecomment-2065589494
Looks like HybridSource has a requirement for parallelism, but some of our
tests use the core number of the machine itself
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2065504494
@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
liuml07 commented on PR #96:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/96#issuecomment-2065368913
Thank you @tosone . Could you help review that PR? Also I can update that
one to port your change about Table API changes. If you would like to co-author
that by
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1571313741
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/metrics/MetricStore.java:
##
@@ -184,6 +184,21 @@ public synchronized ComponentMetricStore
pvary commented on PR #3233:
URL: https://github.com/apache/flink-cdc/pull/3233#issuecomment-2065143602
Good catch @loserwang1024!
Could you please add a test case to prevent later code changes to revert
this fix?
--
This is an automated message from the Apache Git Service.
To
Venkata krishnan Sowrirajan created FLINK-35165:
---
Summary: AdaptiveBatch Scheduler should not restrict the default
source parallelism to the max parallelism set
Key: FLINK-35165
URL:
afedulov commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-2064985125
@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.
z3d1k commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1571233482
##
flink-connector-aws/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumerTest.java:
##
@@ -312,6
z3d1k commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1571230798
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java:
##
@@ -149,6 +149,7 @@
zentol commented on code in PR #24680:
URL: https://github.com/apache/flink/pull/24680#discussion_r1571216654
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java:
##
@@ -93,8 +93,12 @@ void
zentol commented on code in PR #24680:
URL: https://github.com/apache/flink/pull/24680#discussion_r1571218899
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java:
##
@@ -166,18 +170,19 @@ static class
zentol commented on code in PR #24680:
URL: https://github.com/apache/flink/pull/24680#discussion_r1571216390
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/AdaptiveSchedulerTest.java:
##
@@ -1783,56 +1778,6 @@ void
dmvk commented on code in PR #24680:
URL: https://github.com/apache/flink/pull/24680#discussion_r1571177099
##
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraphTest.java:
##
@@ -166,18 +170,19 @@ static class
Samrat002 commented on code in PR #734:
URL: https://github.com/apache/flink-web/pull/734#discussion_r1571145570
##
docs/data/flink_connectors.yml:
##
@@ -51,11 +51,11 @@ hbase:
compatibility: ["1.16.x", "1.17.x"]
jdbc:
- name: "Apache Flink JDBC Connector 3.1.2"
-
Samrat002 commented on code in PR #734:
URL: https://github.com/apache/flink-web/pull/734#discussion_r1571145570
##
docs/data/flink_connectors.yml:
##
@@ -51,11 +51,11 @@ hbase:
compatibility: ["1.16.x", "1.17.x"]
jdbc:
- name: "Apache Flink JDBC Connector 3.1.2"
-
zentol commented on PR #24680:
URL: https://github.com/apache/flink/pull/24680#issuecomment-2064570934
meh, stop-with-savepoint failures need to be able to transition back into
executing without recreating the EG :/
--
This is an automated message from the Apache Git Service.
To respond
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2064501044
@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
eskabetxe commented on code in PR #115:
URL:
https://github.com/apache/flink-connector-jdbc/pull/115#discussion_r1571058904
##
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcConnectionOptions.java:
##
@@ -90,6 +101,11 @@ public
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2064332698
@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
Yubin Li created FLINK-35164:
Summary: Support `ALTER CATALOG RESET` syntax
Key: FLINK-35164
URL: https://issues.apache.org/jira/browse/FLINK-35164
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-34916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-34916:
-
Summary: Support `ALTER CATALOG SET` syntax (was: Support `ALTER CATALOG`
syntax)
> Support `ALTER
afedulov commented on PR #23777:
URL: https://github.com/apache/flink/pull/23777#issuecomment-2064139948
@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-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP_LTZ{}}}, nor
{{TIMESTAMP WITH TIME
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP_LTZ{}}}, nor
{{TIMESTAMP WITH TIME
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Summary: TIMESTAMP with LOCAL TIME ZONE not supported by JDBC connector for
Postgres (was: TIMESTAMP with
twalthr commented on code in PR #24679:
URL: https://github.com/apache/flink/pull/24679#discussion_r1570922395
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/MiscAggFunctionITCase.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
dawidwys commented on PR #24679:
URL: https://github.com/apache/flink/pull/24679#issuecomment-2063994171
> Let's already fix some other locations with this exception:
for example:
AbstractCodeGeneratorCastRule and CastExecutor
SqlJsonUtils
Sure, any other places that you're
flinkbot commented on PR #24681:
URL: https://github.com/apache/flink/pull/24681#issuecomment-2063985516
## CI report:
* b1abbbc14798703d82a9115d42141aa0bb62abbc UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
ljz2051 commented on PR #24681:
URL: https://github.com/apache/flink/pull/24681#issuecomment-2063978444
@Zakelly @fredia @masteryhx Could 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
[
https://issues.apache.org/jira/browse/FLINK-35162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35162:
---
Labels: pull-request-available (was: )
> Support grouping state get and put access
>
ljz2051 opened a new pull request, #24681:
URL: https://github.com/apache/flink/pull/24681
## What is the purpose of the change
This pull request introduces the ForStValueState and support
WriteBatchOperation and general MultiGetOperation for ForSt.
## Brief change log
dawidwys commented on code in PR #24679:
URL: https://github.com/apache/flink/pull/24679#discussion_r1570850917
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java:
##
@@ -344,6 +361,38 @@ public void
dawidwys commented on code in PR #24679:
URL: https://github.com/apache/flink/pull/24679#discussion_r1570846758
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/MiscAggFunctionITCase.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the
ljz2051 closed pull request #24671: [FLINK-35125][state] Implement ValueState
for ForStStateBackend
URL: https://github.com/apache/flink/pull/24671
--
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
Jinzhong Li created FLINK-35163:
---
Summary: Utilize ForSt's native MultiGet API to optimize remote
state access
Key: FLINK-35163
URL: https://issues.apache.org/jira/browse/FLINK-35163
Project: Flink
Jinzhong Li created FLINK-35162:
---
Summary: Support grouping state get and put access
Key: FLINK-35162
URL: https://issues.apache.org/jira/browse/FLINK-35162
Project: Flink
Issue Type: Sub-task
Jinzhong Li created FLINK-35161:
---
Summary: Implement StateExecutor for ForStStateBackend
Key: FLINK-35161
URL: https://issues.apache.org/jira/browse/FLINK-35161
Project: Flink
Issue Type:
liyubin117 commented on PR #24630:
URL: https://github.com/apache/flink/pull/24630#issuecomment-2063913126
@LadyForest Hi, I have updated as you said and CI passed, PTAL, thanks :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
elon_X created FLINK-35160:
--
Summary: Support for Thread Dump provides a convenient way to
display issues of thread deadlocks in tasks
Key: FLINK-35160
URL: https://issues.apache.org/jira/browse/FLINK-35160
tosone commented on PR #96:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/96#issuecomment-2063868124
It seems that the commit has already done the same thing. I hope that the
commit can be merged as soon as possible. @liuml07
--
This is an automated message from the
flinkbot commented on PR #24680:
URL: https://github.com/apache/flink/pull/24680#issuecomment-2063860095
## CI report:
* bac810fd425ebf07f82c84a41611e8b873edb9e4 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35159:
---
Labels: pull-request-available (was: )
> CreatingExecutionGraph can leak
twalthr commented on code in PR #24679:
URL: https://github.com/apache/flink/pull/24679#discussion_r1570701741
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/BuiltInAggregateFunctionTestBase.java:
##
@@ -344,6 +361,38 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-35045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-35045.
--
Fix Version/s: 1.20.0
Resolution: Fixed
merged 369bbb8f...a312a3bd into master
>
Chesnay Schepler created FLINK-35159:
Summary: CreatingExecutionGraph can leak CheckpointCoordinator and
cause JM crash
Key: FLINK-35159
URL: https://issues.apache.org/jira/browse/FLINK-35159
masteryhx closed pull request #24632: [FLINK-35045][state] Introduce
ForStFlinkFileSystem to support reading and writing with ByteBuffer
URL: https://github.com/apache/flink/pull/24632
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
flinkbot commented on PR #24679:
URL: https://github.com/apache/flink/pull/24679#issuecomment-2063755509
## CI report:
* c7d65d5679cbe4bfc52db6a2a718b8a5d2515ea3 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24678:
URL: https://github.com/apache/flink/pull/24678#issuecomment-2063745225
## CI report:
* 503f01052e16a806da7589a8dc0ed645ff00d282 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838630#comment-17838630
]
yazgoo commented on FLINK-35007:
Hi,
Do you plan on publishing flink-connector-kafka:3.1.0-1.19 ?
[
https://issues.apache.org/jira/browse/FLINK-35155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35155:
---
Labels: pull-request-available (was: )
> Introduce TableRuntimeException
>
dawidwys opened a new pull request, #24679:
URL: https://github.com/apache/flink/pull/24679
## What is the purpose of the change
Introduce `TableRuntimeException` to better classify intentional exceptions
thrown from SQL runtime.
## Verifying this change
Added tests
[
https://issues.apache.org/jira/browse/FLINK-35156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35156:
---
Labels: pull-request-available (was: )
> Wire new operators for async state with
Zakelly opened a new pull request, #24678:
URL: https://github.com/apache/flink/pull/24678
## What is the purpose of the change
This is a simple PR that wire the new introduced operators of DataStream V2
with the `AbstractAsyncStateStreamOperator`.
## Brief change log
Yanfei Lei created FLINK-35158:
--
Summary: Error handling in StateFuture's callback
Key: FLINK-35158
URL: https://issues.apache.org/jira/browse/FLINK-35158
Project: Flink
Issue Type: Sub-task
GOODBOY008 commented on code in PR #732:
URL: https://github.com/apache/flink-web/pull/732#discussion_r1568758762
##
.github/workflows/docs.yml:
##
@@ -0,0 +1,68 @@
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements. See the
yuxiqian commented on PR #3235:
URL: https://github.com/apache/flink-cdc/pull/3235#issuecomment-2063673721
Fixed in #3237.
--
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.
yuxiqian closed pull request #3235: [hotfix][values] Temporary fix for
ValuesDataSource stuck in infinite loop
URL: https://github.com/apache/flink-cdc/pull/3235
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Gyula Fora created FLINK-35157:
--
Summary: Sources with watermark alignment get stuck once some
subtasks finish
Key: FLINK-35157
URL: https://issues.apache.org/jira/browse/FLINK-35157
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
Jiabao-Sun commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063604709
> > Hi @ZmmBigdata, you don't need submit a new PR. Just rebase the master
branch into yours.
>
> @Jiabao-Sun Ok, thank you for your reply. Will this PR still be merged？Not
ZmmBigdata commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063603076
> Hi @ZmmBigdata, you don't need submit a new PR. Just rebase the master
branch into yours.
@Jiabao-Sun Ok, thank you for your reply. Will this PR still be merged？Not
very
[
https://issues.apache.org/jira/browse/FLINK-35053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pietro updated FLINK-35053:
---
Description:
The JDBC sink for Postgres does not support {{{}TIMESTAMP WITH TIME ZONE{}}},
nor
Jiabao-Sun commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063583687
Hi @ZmmBigdata, you don't need submit a new PR.
Just rebase the master branch into yours.
--
This is an automated message from the Apache Git Service.
To respond to the message,
1 - 100 of 197 matches
Mail list logo
