loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599417206
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0
zhuzhurk commented on code in PR #24774:
URL: https://github.com/apache/flink/pull/24774#discussion_r1599414778
##
flink-runtime/src/main/java/org/apache/flink/runtime/shuffle/ShuffleMaster.java:
##
@@ -121,4 +122,21 @@ default
CompletableFuture> getAllPartitionWithM
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410767
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0
loserwang1024 commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599410084
##
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846177#comment-17846177
]
Zhu Zhu commented on FLINK-35293:
-
The change is merged. Could you add release notes for it and close
[
https://issues.apache.org/jira/browse/FLINK-35348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35348:
-
Assignee: Feng Jin
> Implement materialized table refresh rest api
>
[
https://issues.apache.org/jira/browse/FLINK-35347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35347:
-
Assignee: dalongliu
> Implement InMemory workflow scheduler service and plugin to support
>
dalongliu created FLINK-35348:
-
Summary: Implement materialized table refresh rest api
Key: FLINK-35348
URL: https://issues.apache.org/jira/browse/FLINK-35348
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-35346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35346:
-
Assignee: dalongliu
> Introduce pluggable workflow scheduler interface for materialized table
dalongliu created FLINK-35347:
-
Summary: Implement InMemory workflow scheduler service and plugin
to support materialized table
Key: FLINK-35347
URL: https://issues.apache.org/jira/browse/FLINK-35347
dalongliu created FLINK-35346:
-
Summary: Introduce pluggable workflow scheduler interface for
materialized table
Key: FLINK-35346
URL: https://issues.apache.org/jira/browse/FLINK-35346
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-35345:
-
Assignee: dalongliu
> FLIP-448: Introduce Pluggable Workflow Scheduler Interface for
flinkbot commented on PR #24781:
URL: https://github.com/apache/flink/pull/24781#issuecomment-2109314883
## CI report:
* 2f5f8598627c98bfa1bf88e7a6e0de51319748f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35153:
---
Labels: pull-request-available (was: )
> Internal Async State Implementation and
Zakelly opened a new pull request, #24781:
URL: https://github.com/apache/flink/pull/24781
## What is the purpose of the change
This PR provides the definition of `StateDescriptor` and simple
implementation for `List` and `Map` state in `State V2`.
## Brief change log
-
[
https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Simon Lee updated FLINK-35334:
--
Priority: Blocker (was: Major)
> Code generation: init method exceeds 64 KB when there is a long
whhe commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599378513
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtil.java:
##
@@ -0,0 +1,132 @@
[
https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei closed FLINK-32443.
--
> Translate "State Processor API" page into Chinese
> -
>
[
https://issues.apache.org/jira/browse/FLINK-32443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-32443.
Resolution: Resolved
Merged into master via 26817092
> Translate "State Processor API" page into
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
dalongliu created FLINK-35345:
-
Summary: FLIP-448: Introduce Pluggable Workflow Scheduler
Interface for Materialized Table
Key: FLINK-35345
URL: https://issues.apache.org/jira/browse/FLINK-35345
Project:
yuxiqian commented on code in PR #3319:
URL: https://github.com/apache/flink-cdc/pull/3319#discussion_r1599352772
##
flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java:
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35344:
---
Labels: pull-request-available (was: )
> Move same code from multiple subclasses to
loserwang1024 opened a new pull request, #3319:
URL: https://github.com/apache/flink-cdc/pull/3319
Current, subclasses of JdbcSourceChunkSplitter almost share same code, but
each have one copy. It's hard for later maintenance.
Thus, this Jira aim to move same code from multiple
[
https://issues.apache.org/jira/browse/FLINK-35344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846167#comment-17846167
]
Hongshun Wang commented on FLINK-35344:
---
I'd like to do it.
> Move same code from multiple
fredia commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2109222070
Hi @drymatini, thanks for your contribution, "State Processor API" was
already translated in master, I think documents do not need to be backported
to the historical release branch,
Hongshun Wang created FLINK-35344:
-
Summary: Move same code from multiple subclasses to
JdbcSourceChunkSplitter
Key: FLINK-35344
URL: https://issues.apache.org/jira/browse/FLINK-35344
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846161#comment-17846161
]
chenyunde commented on FLINK-34756:
---
The range of server-id should be between 1 to 2 ^ 32-1
>
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846157#comment-17846157
]
Gang Yang edited comment on FLINK-35296 at 5/14/24 3:28 AM:
This abnormal
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846157#comment-17846157
]
Gang Yang commented on FLINK-35296:
---
This abnormal situation occurs not only in sub-databases and
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846156#comment-17846156
]
Feng Jin commented on FLINK-35342:
--
{color:#00}This issue will be fixed in this PR.{color}
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gang Yang updated FLINK-35296:
--
Attachment: image-2024-05-14-11-25-55-565.png
> Flink mysql-cdc connector stops reading data
>
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846153#comment-17846153
]
Gang Yang commented on FLINK-35296:
---
Yes, I have checked it. The maximum data volume of a sub-table is
[ https://issues.apache.org/jira/browse/FLINK-35296 ]
Gang Yang deleted comment on FLINK-35296:
---
was (Author: 清月):
是的,已经检查过,分表最大数据量是1315883,最小是443151,差距不超过三倍
> Flink mysql-cdc connector stops reading data
>
[
https://issues.apache.org/jira/browse/FLINK-35296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846152#comment-17846152
]
Gang Yang commented on FLINK-35296:
---
是的,已经检查过,分表最大数据量是1315883,最小是443151,差距不超过三倍
> Flink mysql-cdc
fredia commented on PR #24762:
URL: https://github.com/apache/flink/pull/24762#issuecomment-2109196919
> Thanks for the update! Overall LGTM. And will this `SpaceStat` report to
metrics?
Currently no, will report to metric in FLINK-32091.
--
This is an automated message from the
Zakelly commented on code in PR #24762:
URL: https://github.com/apache/flink/pull/24762#discussion_r1599318520
##
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/PhysicalFile.java:
##
@@ -88,18 +88,34 @@ PhysicalFile perform(
*/
private
[
https://issues.apache.org/jira/browse/FLINK-35343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zyh updated FLINK-35343:
Environment:
* flink(1.17.2), local mode and deploy on k8s
* doris-flink-connector-1.17(1.6.0)
* Doris(2.1)
zyh created FLINK-35343:
---
Summary: NullPointerException in SourceReaderBase
Key: FLINK-35343
URL: https://issues.apache.org/jira/browse/FLINK-35343
Project: Flink
Issue Type: Bug
Components:
[
https://issues.apache.org/jira/browse/FLINK-34380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846141#comment-17846141
]
Roman Boyko commented on FLINK-34380:
-
[~xu_shuai_] , [~xuyangzhong] , could you please take a look?
[
https://issues.apache.org/jira/browse/FLINK-34694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846140#comment-17846140
]
Roman Boyko commented on FLINK-34694:
-
[~xu_shuai_] , please take a look.
> Delete num of
[
https://issues.apache.org/jira/browse/FLINK-35293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846137#comment-17846137
]
Zhu Zhu commented on FLINK-35293:
-
master: ddb5a5355f9aca3d223f1fff6581d83dd317c2de
> FLIP-445: Support
zhuzhurk merged PR #24764:
URL: https://github.com/apache/flink/pull/24764
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846135#comment-17846135
]
Feng Jin commented on FLINK-35342:
--
[~rskraba] {color:#00}Thank you for reporting this issue, I
[
https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846129#comment-17846129
]
Hang Ruan commented on FLINK-35109:
---
[~fpaul] Thanks for your quick reply. I will work on it later.
>
[
https://issues.apache.org/jira/browse/FLINK-35302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-35302:
Fix Version/s: 1.20.0
(was: 1.19.1)
> Flink REST server throws exception on
JunRuiLee commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2109128178
> > Thanks, @venkata91, for your contribution! After reviewing this PR, I'm
concerned that it entirely removes limit that source parallelism should lower
than source jobVertex's max
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846007#comment-17846007
]
Ryan Skraba commented on FLINK-35342:
-
[~hackergin] I found this failure in this new test, from a
[
https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Skraba updated FLINK-35342:
Affects Version/s: 1.20.0
> MaterializedTableStatementITCase test can check for wrong status
>
Ryan Skraba created FLINK-35342:
---
Summary: MaterializedTableStatementITCase test can check for wrong
status
Key: FLINK-35342
URL: https://issues.apache.org/jira/browse/FLINK-35342
Project: Flink
elon-X commented on code in PR #24757:
URL: https://github.com/apache/flink/pull/24757#discussion_r1598735613
##
flink-runtime/src/main/java/org/apache/flink/runtime/source/coordinator/SourceCoordinator.java:
##
@@ -201,8 +201,11 @@ void announceCombinedWatermark() {
empathy87 commented on PR #24659:
URL: https://github.com/apache/flink/pull/24659#issuecomment-2108124573
> @empathy87 please let me know once backports are ready, then we can merge
all of them
@snuyanzin, backport PRs are done, CI succeeded.
venkata91 commented on PR #24736:
URL: https://github.com/apache/flink/pull/24736#issuecomment-2108098806
> Thanks, @venkata91, for your contribution! After reviewing this PR, I'm
concerned that it entirely removes limit that source parallelism should lower
than source jobVertex's max
Lim Qing Wei created FLINK-35341:
Summary: Retraction stop working with Clock dependent function in
Filter
Key: FLINK-35341
URL: https://issues.apache.org/jira/browse/FLINK-35341
Project: Flink
vikramsinghchandel commented on PR #47:
URL:
https://github.com/apache/flink-connector-aws/pull/47#issuecomment-2107813052
any updates here? This is a feature that is already available on Flink EMR
would be great to have it here too.
--
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-35335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845948#comment-17845948
]
Ryan Skraba commented on FLINK-35335:
-
* 1.19 test_cron_adaptive_scheduler tests
[
https://issues.apache.org/jira/browse/FLINK-35254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845946#comment-17845946
]
Ryan Skraba commented on FLINK-35254:
-
* 1.20 build_wheels_on_macos
[
https://issues.apache.org/jira/browse/FLINK-35284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845947#comment-17845947
]
Ryan Skraba commented on FLINK-35284:
-
* 1.20 AdaptiveScheduler / E2E (group 2)
[
https://issues.apache.org/jira/browse/FLINK-35041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845945#comment-17845945
]
Ryan Skraba commented on FLINK-35041:
-
Thanks so much! I've verified that I can no longer reproduce
[
https://issues.apache.org/jira/browse/FLINK-35002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845943#comment-17845943
]
Ryan Skraba commented on FLINK-35002:
-
* 1.18 AdaptiveScheduler / Compile
Neil Prasad created FLINK-35340:
---
Summary: Flink Kubernetes Operator CRDs not applying correctly
Key: FLINK-35340
URL: https://issues.apache.org/jira/browse/FLINK-35340
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-34227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845942#comment-17845942
]
Ryan Skraba commented on FLINK-34227:
-
* 1.19 AdaptiveScheduler / Test (module: table)
[
https://issues.apache.org/jira/browse/FLINK-30644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845940#comment-17845940
]
Ryan Skraba commented on FLINK-30644:
-
* 1.19 test_cron_jdk17 tests
[
https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845939#comment-17845939
]
Ryan Skraba commented on FLINK-28440:
-
* 1.18 Default (Java 8) / Test (module: tests)
[
https://issues.apache.org/jira/browse/FLINK-26644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845938#comment-17845938
]
Ryan Skraba commented on FLINK-26644:
-
* 1.18 Java 11 / Test (module: python)
[
https://issues.apache.org/jira/browse/FLINK-23577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845937#comment-17845937
]
Ryan Skraba commented on FLINK-23577:
-
Looks like this flaky test has made a reappearance!
* 1.19
[
https://issues.apache.org/jira/browse/FLINK-18476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845936#comment-17845936
]
Ryan Skraba commented on FLINK-18476:
-
* 1.19 test_cron_hadoop313 misc
flinkbot commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2107606610
## CI report:
* 557dcaa7bda5fd1b76e446f643012dc4d47a563c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Ryan Skraba created FLINK-35339:
---
Summary: Compilation timeout while building flink-dist
Key: FLINK-35339
URL: https://issues.apache.org/jira/browse/FLINK-35339
Project: Flink
Issue Type: Bug
drymatini commented on PR #24780:
URL: https://github.com/apache/flink/pull/24780#issuecomment-2107594814
@wuchong @reswqa Hi, I have finished the translation of the page.Could you
please verify my pull request?
--
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35253:
---
Labels: pull-request-available (was: )
> Translate "State Processor API "page into Chinese
drymatini opened a new pull request, #24780:
URL: https://github.com/apache/flink/pull/24780
## What is the purpose of the change
"State Processor API "page was newly released and it should be translated
into Chineses
## Brief change log
translate
lsyldliu commented on code in PR #24777:
URL: https://github.com/apache/flink/pull/24777#discussion_r1598351419
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlDropMaterializedTable.java:
##
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107498923
@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
flinkbot commented on PR #24779:
URL: https://github.com/apache/flink/pull/24779#issuecomment-2107496417
## CI report:
* 87c26627c5431157f1e85d35b3ce466ff708ff40 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #24778:
URL: https://github.com/apache/flink/pull/24778#issuecomment-2107479208
## CI report:
* d9dddcd7c6613169b95193b85fdefa29c726996b UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845909#comment-17845909
]
yazgoo commented on FLINK-35138:
Hello, do you have an update on this ticket ?
Looks like the vote was
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845908#comment-17845908
]
Zakelly Lan commented on FLINK-35168:
-
Merged into master via 01586780
> Basic State Iterator for
[
https://issues.apache.org/jira/browse/FLINK-35168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-35168.
-
Resolution: Fixed
> Basic State Iterator for async processing
>
Zakelly merged PR #24690:
URL: https://github.com/apache/flink/pull/24690
--
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:
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-35336:
---
Issue Type: New Feature (was: Bug)
> SQL failed to restore from savepoint after change in
[
https://issues.apache.org/jira/browse/FLINK-35336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845901#comment-17845901
]
Martijn Visser commented on FLINK-35336:
That's not a bug: changing the parallelism is generates
superdiaodiao commented on PR #24773:
URL: https://github.com/apache/flink/pull/24773#issuecomment-2107400121
@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
[
https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845894#comment-17845894
]
Lorenzo Affetti commented on FLINK-16528:
-
[~jark] is this issue still valuable and open
flinkbot commented on PR #24777:
URL: https://github.com/apache/flink/pull/24777#issuecomment-2107395878
## CI report:
* 67ef2ca47615d5b36424af7bc12712071369e358 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Zakelly commented on PR #24690:
URL: https://github.com/apache/flink/pull/24690#issuecomment-2107381572
> @Zakelly Thanks for the PR, I have a question about the overall design. It
seems that an iterator can actually be split into several executions. If other
UPDATE are inserted in the
[
https://issues.apache.org/jira/browse/FLINK-35126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-35126:
--
Assignee: Gyula Fora
> Improve checkpoint progress health check config and enable by default
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
[
https://issues.apache.org/jira/browse/FLINK-5193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-5193:
--
Labels: pull-request-available (was: )
> Recovering all jobs fails completely if a single
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
hackergin opened a new pull request, #24777:
URL: https://github.com/apache/flink/pull/24777
## What is the purpose of the change
*Support drop materialized table syntax and execution in continuous refresh
mode*
## Brief change log
- *Support parser drop
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845887#comment-17845887
]
ouyangwulin commented on FLINK-35337:
-
[~Leonard], Our production environment has been updated tikv
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Description:
[This pull
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35337:
Component/s: Flink CDC
> Keep up with the latest version of tikv client
>
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35337:
---
Labels: pull-request-available (was: )
> Keep up with the latest version of tikv client
>
[
https://issues.apache.org/jira/browse/FLINK-35338?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rasmus Thygesen updated FLINK-35338:
Affects Version/s: 1.8.0
> Enable FS Plugins as non-root
> -
Rasmus Thygesen created FLINK-35338:
---
Summary: Enable FS Plugins as non-root
Key: FLINK-35338
URL: https://issues.apache.org/jira/browse/FLINK-35338
Project: Flink
Issue Type: New Feature
1 - 100 of 166 matches
Mail list logo