hlteoh37 commented on code in PR #138:
URL:
https://github.com/apache/flink-connector-aws/pull/138#discussion_r1570320954
##
flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java:
##
@@ -149,6 +149,7
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838575#comment-17838575
]
Danny Cranmer commented on FLINK-35124:
---
Merged commit c411561 into apache:release_utils
>
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren updated FLINK-35127:
--
Priority: Blocker (was: Major)
> CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838575#comment-17838575
]
Danny Cranmer edited comment on FLINK-35124 at 4/18/24 9:54 AM:
Merged
lvyanquan opened a new pull request, #3237:
URL: https://github.com/apache/flink-cdc/pull/3237
At present, CI testing often causes OOM due to ValuesSource, which may be
caused by the use of HybridSource. Considering that this will block other prs,
remove it first to restore CI.
--
This
dannycranmer opened a new pull request, #736:
URL: https://github.com/apache/flink-web/pull/736
(no comment)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To
[
https://issues.apache.org/jira/browse/FLINK-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
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
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.
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
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-35156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan reassigned FLINK-35156:
---
Assignee: Zakelly Lan
> Wire new operators for async state with DataStream V2
>
Zakelly Lan created FLINK-35156:
---
Summary: Wire new operators for async state with DataStream V2
Key: FLINK-35156
URL: https://issues.apache.org/jira/browse/FLINK-35156
Project: Flink
Issue
[
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
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:
boring-cyborg[bot] commented on PR #25:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/25#issuecomment-2063392255
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
dannycranmer commented on code in PR #25:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/25#discussion_r1570324100
##
.github/workflows/push_pr.yml:
##
@@ -28,11 +28,9 @@ jobs:
compile_and_test:
strategy:
matrix:
- flink: [ 1.17-SNAPSHOT
Jiabao-Sun commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063581154
@ZmmBigdata yes, please go ahead.
--
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
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
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`
[
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
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`
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`
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838558#comment-17838558
]
Danny Cranmer commented on FLINK-35124:
---
> In the case of regular connectors it was containing ci
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838572#comment-17838572
]
Etienne Chauchot commented on FLINK-35124:
--
Ok fair enough to put back {_}ci{_}, _maven_ and
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838572#comment-17838572
]
Etienne Chauchot edited comment on FLINK-35124 at 4/18/24 9:45 AM:
---
Ok
[
https://issues.apache.org/jira/browse/FLINK-35120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35120:
-
Assignee: Xiqian YU
> Add Doris Pipeline connector integration test cases
>
Dawid Wysakowicz created FLINK-35155:
Summary: Introduce TableRuntimeException
Key: FLINK-35155
URL: https://issues.apache.org/jira/browse/FLINK-35155
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35127:
-
Assignee: LvYanquan
> CDC ValuesDataSourceITCase crashed due to OutOfMemoryError
>
[
https://issues.apache.org/jira/browse/FLINK-35143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35143:
-
Assignee: Hongshun Wang
> Expose newly added tables capture in mysql pipeline
[
https://issues.apache.org/jira/browse/FLINK-35129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35129:
-
Assignee: Muhammet Orazov
> Postgres source commits the offset after every multiple
[
https://issues.apache.org/jira/browse/FLINK-35128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35128:
-
Assignee: Hongshun Wang
> Re-calculate the starting change log offset after the new
afedulov commented on code in PR #24564:
URL: https://github.com/apache/flink/pull/24564#discussion_r1568653505
##
docs/static/generated/rest_v1_dispatcher.yml:
##
@@ -1089,6 +1089,37 @@ paths:
application/json:
schema:
$ref:
TobaccoProduct opened a new pull request, #24677:
URL: https://github.com/apache/flink/pull/24677
Document bug fixed:
missing character '>' in line 257, between 'String' and '()'
## What is the purpose of the change
*(For example: This pull request makes task
ZmmBigdata commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063508038
> @ZmmBigdata @Jiabao-Sun Issue was fixed in pr #3217 and merged.
@GOODBOY008 In PR # 3217, only two files were modified, while I modified
three files
--
This is an
flinkbot commented on PR #24677:
URL: https://github.com/apache/flink/pull/24677#issuecomment-2063525108
## CI report:
* ef29926a603bc02167158b83b8c705208018adce UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
liyubin117 commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570448160
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
[
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
>
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
[
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
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
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
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
[
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
>
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
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838553#comment-17838553
]
Ryan Skraba commented on FLINK-28440:
-
1.19 Java 8 / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838548#comment-17838548
]
Ryan Skraba commented on FLINK-34227:
-
1.19 AdaptiveScheduler / Test (module: table)
liyubin117 commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570466913
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
[
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
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
[
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 ?
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
dannycranmer merged PR #25:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/25
--
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:
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570355268
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-35102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35102:
-
Assignee: Xiqian YU
> Incorret Type mapping for Flink CDC Doris connector
>
[
https://issues.apache.org/jira/browse/FLINK-35077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35077:
-
Assignee: Xiqian YU
> Add package license check for Flink CDC modules.
>
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35127:
---
Labels: pull-request-available test-stability (was: test-stability)
> CDC
lvyanquan commented on PR #3237:
URL: https://github.com/apache/flink-cdc/pull/3237#issuecomment-2063493735
@PatrickRen @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
[
https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838591#comment-17838591
]
Danny Cranmer commented on FLINK-35137:
---
[
https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838590#comment-17838590
]
Danny Cranmer commented on FLINK-35135:
---
[
https://issues.apache.org/jira/browse/FLINK-35124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer resolved FLINK-35124.
---
Resolution: Fixed
> Connector Release Fails to run Checkstyle
>
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
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
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-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
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
[
https://issues.apache.org/jira/browse/FLINK-32523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838550#comment-17838550
]
Ryan Skraba commented on FLINK-32523:
-
1.19 AdaptiveScheduler / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-34224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838552#comment-17838552
]
Ryan Skraba commented on FLINK-34224:
-
1.20 Hadoop 3.1.3 / Test (module: core)
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838551#comment-17838551
]
Ryan Skraba commented on FLINK-35041:
-
* 1.20 Java 8 / Test (module: core)
ferenc-csaky commented on PR #46:
URL:
https://github.com/apache/flink-connector-hbase/pull/46#issuecomment-2063424524
@dannycranmer if you have some time can you trigger a CI run? Thanks in
advance!
--
This is an automated message from the Apache Git Service.
To respond to the message,
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570354008
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
LadyForest commented on code in PR #24630:
URL: https://github.com/apache/flink/pull/24630#discussion_r1570354008
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeCatalogOperation.java:
##
@@ -0,0 +1,114 @@
+/*
+ * Licensed to the
dannycranmer merged PR #40:
URL: https://github.com/apache/flink-connector-shared-utils/pull/40
--
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:
dannycranmer commented on PR #40:
URL:
https://github.com/apache/flink-connector-shared-utils/pull/40#issuecomment-2063479840
> But did you find the reason why the suppressions.xml path ends up being
/tools/maven/suppressions.xml and not tools/maven/suppressions.xml ?
No, but I
[
https://issues.apache.org/jira/browse/FLINK-35072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35072:
-
Assignee: Xiqian YU
> Doris pipeline sink does not support applying
[
https://issues.apache.org/jira/browse/FLINK-35092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren reassigned FLINK-35092:
-
Assignee: Xiqian YU
> Add integrated test for Doris / Starrocks sink pipeline
[
https://issues.apache.org/jira/browse/FLINK-35144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Qingsheng Ren closed FLINK-35144.
-
Resolution: Duplicate
> Support various sources sync for FlinkCDC in one pipeline
>
ZmmBigdata commented on PR #3229:
URL: https://github.com/apache/flink-cdc/pull/3229#issuecomment-2063554270
@GOODBOY008 Do I need to resynchronize the master repositories and resubmit
the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838592#comment-17838592
]
Danny Cranmer commented on FLINK-35139:
---
[
https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Danny Cranmer reassigned FLINK-35133:
-
Assignee: Danny Cranmer
> Release flink-connector-cassandra v3.x.x for Flink 1.19
>
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
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
[
https://issues.apache.org/jira/browse/FLINK-35127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838576#comment-17838576
]
Qingsheng Ren commented on FLINK-35127:
---
I increased the priority to blocker as many PRs are
[
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,
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
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
[
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 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-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
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
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
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"
-
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
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
[
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
1 - 100 of 197 matches
Mail list logo
