superdiaodiao commented on code in PR #24773:
URL: https://github.com/apache/flink/pull/24773#discussion_r1623199122
##
flink-python/pyflink/table/expression.py:
##
@@ -1273,6 +1273,23 @@ def locate(self, s: Union[str, 'Expression[str]'],
else:
return _tern
Ying Z created FLINK-35502:
--
Summary: compress the checkpoint metadata ZK/ETCD HA Services
Key: FLINK-35502
URL: https://issues.apache.org/jira/browse/FLINK-35502
Project: Flink
Issue Type: Improvem
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Z updated FLINK-35502:
---
Summary: compress the checkpoint metadata generated by ZK/ETCD HA Services
(was: compress the checkpoint me
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Z updated FLINK-35502:
---
Description:
In the implementation of Flink HA, the metadata of checkpoints is stored in
either Zookeeper (
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ying Z updated FLINK-35502:
---
Description:
In the implementation of Flink HA, the metadata of checkpoints is stored in
either Zookeeper (
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851292#comment-17851292
]
Roman Khachatryan commented on FLINK-35502:
---
[~yingz] , could you clarify the
lsyldliu merged PR #24866:
URL: https://github.com/apache/flink/pull/24866
--
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.apac
[
https://issues.apache.org/jira/browse/FLINK-35199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851294#comment-17851294
]
dalongliu commented on FLINK-35199:
---
Merged in master: e4fa72d9e480664656818395741c37a
[
https://issues.apache.org/jira/browse/FLINK-35199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu resolved FLINK-35199.
---
Resolution: Fixed
> Support the execution of create materialized table in full refresh mode
> --
[
https://issues.apache.org/jira/browse/FLINK-35200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35200:
---
Labels: pull-request-available (was: )
> Support the execution of suspend, resume materiali
hackergin opened a new pull request, #24877:
URL: https://github.com/apache/flink/pull/24877
## What is the purpose of the change
*Support the execution of suspend, resume materialized table in full refresh
mode*
## Brief change log
* Add dynamic options for ResumeRe
dongwoo6kim commented on PR #100:
URL:
https://github.com/apache/flink-connector-kafka/pull/100#issuecomment-2143497305
Hello @morazow I've added ITCase for this case.
This case fails for current main branch due to timeout and works okay with
fixed code.
--
This is an automated messa
flinkbot commented on PR #24877:
URL: https://github.com/apache/flink/pull/24877#issuecomment-2143497653
## CI report:
* 4940feeb60b1438b3fe1ac7ee487a48f78e2d629 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-34470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851305#comment-17851305
]
dongwoo.kim commented on FLINK-34470:
-
Hello [~m.orazow] thanks for the review. I've
Saketh Kurnool created FLINK-35503:
--
Summary: OracleE2eITCase fails with error ORA-12528 on Mac M2
Key: FLINK-35503
URL: https://issues.apache.org/jira/browse/FLINK-35503
Project: Flink
Issu
Mingliang Liu created FLINK-35504:
-
Summary: Improve Elasticsearch 8 connector observability
Key: FLINK-35504
URL: https://issues.apache.org/jira/browse/FLINK-35504
Project: Flink
Issue Type:
liuml07 opened a new pull request, #106:
URL: https://github.com/apache/flink-connector-elasticsearch/pull/106
From https://issues.apache.org/jira/browse/FLINK-35504:
> Currently all logs are in DEBUG level. Some of those messages are very
helpful to get the progress and errors, which can
[
https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-35504:
---
Labels: pull-request-available (was: )
> Improve Elasticsearch 8 connector observability
>
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1623296583
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -133,7 +136,11
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1623296654
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -145,6 +152,7 @
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1623296687
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -163,7 +171,7 @
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1623296736
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -102,13 +103,15
liuml07 commented on code in PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#discussion_r1623296736
##
flink-connector-elasticsearch8/src/main/java/org/apache/flink/connector/elasticsearch/sink/Elasticsearch8AsyncWriter.java:
##
@@ -102,13 +103,15
[
https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35504:
--
Description:
Currently all logs are in DEBUG level. Some of those messages are very helpful
t
[
https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35504:
--
Description:
Currently all logs are in DEBUG level. Some of those messages are very helpful
t
[
https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35504:
--
Description:
Currently all logs are in DEBUG level. Some of those messages are very helpful
t
[
https://issues.apache.org/jira/browse/FLINK-35504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35504:
--
Description:
Currently all logs are in DEBUG level. Some of those messages are very helpful
t
liuml07 commented on PR #106:
URL:
https://github.com/apache/flink-connector-elasticsearch/pull/106#issuecomment-2143657505
@mtfelisb and @reswqa mind taking a look? Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851346#comment-17851346
]
Ying Z commented on FLINK-35502:
[~roman]
My usage scenario is as follows:
The checkpoi
29 matches
Mail list logo
