[
https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35424:
--
Parent: FLINK-34369
Issue Type: Sub-task (was: Improvement)
> Elasticsearch
[
https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35424:
--
Description:
In FLINK-34369, we added SSL support for the base Elasticsearch sink class
[
https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35424:
--
Description: In FLINK-34369, we added SSL support for the base
Elasticsearch sink class that
[
https://issues.apache.org/jira/browse/FLINK-35424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35424:
--
Description: In (was: The current Flink ElasticSearch connector does not
support SSL
Mingliang Liu created FLINK-35424:
-
Summary: Elasticsearch connector 8 supports SSL context
Key: FLINK-35424
URL: https://issues.apache.org/jira/browse/FLINK-35424
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843288#comment-17843288
]
Mingliang Liu commented on FLINK-27054:
---
Hi, the FLINK-34369 was merged and I can use the same
Mingliang Liu created FLINK-35287:
-
Summary: Builder builds NetworkConfig for Elasticsearch connector 8
Key: FLINK-35287
URL: https://issues.apache.org/jira/browse/FLINK-35287
Project: Flink
Mingliang Liu created FLINK-35148:
-
Summary: Improve InstantiationUtil for checking nullary public
constructor
Key: FLINK-35148
URL: https://issues.apache.org/jira/browse/FLINK-35148
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824890#comment-17824890
]
Mingliang Liu commented on FLINK-34632:
---
CC [~markcho]
> Log checkpoint Id when logging
Mingliang Liu created FLINK-34632:
-
Summary: Log checkpoint Id when logging checkpoint processing delay
Key: FLINK-34632
URL: https://issues.apache.org/jira/browse/FLINK-34632
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-34369:
--
Description:
The current Flink ElasticSearch connector does not support SSL option, causing
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-34369:
--
Description:
The current Flink ElasticSearch connector does not support SSL option, causing
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-34369:
--
Description:
The current Flink ElasticSearch connector does not support SSL option, causing
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-34369:
--
Summary: Elasticsearch connector supports SSL context (was: Elasticsearch
connector supports
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17814504#comment-17814504
]
Mingliang Liu commented on FLINK-34369:
---
Note the Flink ElasticSearch [SQL
Mingliang Liu created FLINK-34369:
-
Summary: Elasticsearch connector supports SSL provider
Key: FLINK-34369
URL: https://issues.apache.org/jira/browse/FLINK-34369
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813391#comment-17813391
]
Mingliang Liu commented on FLINK-27054:
---
Any updates on this?
My understanding is this problem
Mingliang Liu created FLINK-34251:
-
Summary: ClosureCleaner to include reference classes for
non-serialization exception
Key: FLINK-34251
URL: https://issues.apache.org/jira/browse/FLINK-34251
[
https://issues.apache.org/jira/browse/FLINK-34251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-34251:
--
Priority: Minor (was: Major)
> ClosureCleaner to include reference classes for
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17786078#comment-17786078
]
Mingliang Liu commented on FLINK-30483:
---
Just a heads up there is a FLIP for this
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17720687#comment-17720687
]
Mingliang Liu commented on FLINK-30081:
---
I checked again and found we have already been logging
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719710#comment-17719710
]
Mingliang Liu commented on FLINK-31984:
---
The new [PR
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17719402#comment-17719402
]
Mingliang Liu commented on FLINK-31984:
---
Thanks for catching this [~mapohl]. Sorry it is my fault
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17718754#comment-17718754
]
Mingliang Liu commented on FLINK-31984:
---
CC: [~markcho]
> Savepoint on S3 should be relocatable
Mingliang Liu created FLINK-31984:
-
Summary: Savepoint on S3 should be relocatable if entropy
injection is not effective
Key: FLINK-31984
URL: https://issues.apache.org/jira/browse/FLINK-31984
[
https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-31110:
--
Attachment: Screenshot 2023-02-18 at 1.24.20 AM.png
> Web UI shows "User Configuration"
[
https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-31110:
--
Description:
Currently one can use \{{env.getConfig().setGlobalJobParameters(...)}} for
[
https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17690044#comment-17690044
]
Mingliang Liu commented on FLINK-31110:
---
CC: [~markcho]
> Web UI shows "User Configuration"
[
https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-31110:
--
Priority: Minor (was: Major)
> Web UI shows "User Configuration" preserving lines and
Mingliang Liu created FLINK-31110:
-
Summary: Web UI shows "User Configuration" preserving lines and
whitespaces
Key: FLINK-31110
URL: https://issues.apache.org/jira/browse/FLINK-31110
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654214#comment-17654214
]
Mingliang Liu commented on FLINK-30483:
---
Thanks [~jadireddi] I'll review from next week. This week
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652926#comment-17652926
]
Mingliang Liu commented on FLINK-30483:
---
Thanks [~jadireddi] ! I started making changes in a local
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651185#comment-17651185
]
Mingliang Liu commented on FLINK-30483:
---
I'm not sure this requires FLINK-17224. Today TIME and
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651154#comment-17651154
]
Mingliang Liu commented on FLINK-30483:
---
[~martijnvisser] I linked FLINK-23589 in the Jira
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17651147#comment-17651147
]
Mingliang Liu commented on FLINK-30483:
---
Sample code:
{code:java}
public static void
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30483:
--
Description:
Currently Avro format does not support TIMESTAMP_LTZ (short for
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30483:
--
Priority: Major (was: Not a Priority)
> Make Avro format support for TIMESTAMP_LTZ
>
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30483:
--
Priority: Not a Priority (was: Major)
> Make Avro format support for TIMESTAMP_LTZ
>
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30483:
--
Description:
Currently Avro format does not support TIMESTAMP_LTZ (short for
Mingliang Liu created FLINK-30483:
-
Summary: Make Avro format support for TIMESTAMP_LTZ
Key: FLINK-30483
URL: https://issues.apache.org/jira/browse/FLINK-30483
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30479:
--
Description:
The file system SQL connector itself is included in Flink and does not require
Mingliang Liu created FLINK-30479:
-
Summary: Document flink-connector-files for local execution
Key: FLINK-30479
URL: https://issues.apache.org/jira/browse/FLINK-30479
Project: Flink
Issue
Mingliang Liu created FLINK-30459:
-
Summary: SQL Client supports "SET 'property'"
Key: FLINK-30459
URL: https://issues.apache.org/jira/browse/FLINK-30459
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645077#comment-17645077
]
Mingliang Liu commented on FLINK-30081:
---
[~xtsong] Thanks for providing more context. I'd love to
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643536#comment-17643536
]
Mingliang Liu commented on FLINK-29940:
---
Yeah, WARN will be much better than INFO. I can update
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642100#comment-17642100
]
Mingliang Liu commented on FLINK-30081:
---
Thanks [~gaoyunhaii] It makes perfect sense to me now
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17642069#comment-17642069
]
Mingliang Liu commented on FLINK-29940:
---
Yes we now search for "switched from RUNNING to FAILED"
[
https://issues.apache.org/jira/browse/FLINK-30179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30179:
--
Description:
In {{org.apache.flink.runtime.taskmanager.Task}} there are multiple places
[
https://issues.apache.org/jira/browse/FLINK-30179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30179:
--
Description:
In {{org.apache.flink.runtime.taskmanager.Task}} there are multiple places
Mingliang Liu created FLINK-30179:
-
Summary: Stop stringifying exception for logging
Key: FLINK-30179
URL: https://issues.apache.org/jira/browse/FLINK-30179
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Priority: Minor (was: Major)
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30081:
--
Description:
In local executor, it's not possible to set different values for
Mingliang Liu created FLINK-30081:
-
Summary: Local executor can not accept different
jvm-overhead.min/max values
Key: FLINK-30081
URL: https://issues.apache.org/jira/browse/FLINK-30081
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17635678#comment-17635678
]
Mingliang Liu commented on FLINK-29940:
---
Thanks for the comment [~gaoyunhaii] . We have been using
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Issue Type: Bug (was: Improvement)
> Stop using deprecated TM options in doc
>
[
https://issues.apache.org/jira/browse/FLINK-30079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-30079:
--
Affects Version/s: 1.16.0
> Stop using deprecated TM options in doc
>
Mingliang Liu created FLINK-30079:
-
Summary: Stop using deprecated TM options in doc
Key: FLINK-30079
URL: https://issues.apache.org/jira/browse/FLINK-30079
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Description:
Make referencing custom image clearer for Docker.
- Rephrase the words how to
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Priority: Minor (was: Major)
> Make referencing custom image clearer for Docker
>
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-29961:
--
Labels: pull-request-available (was: )
> Make referencing custom image clearer for Docker
>
Mingliang Liu created FLINK-29961:
-
Summary: Make referencing custom image clearer for Docker
Key: FLINK-29961
URL: https://issues.apache.org/jira/browse/FLINK-29961
Project: Flink
Issue
Mingliang Liu created FLINK-29940:
-
Summary: ExecutionGraph logs job state change at ERROR level when
job fails
Key: FLINK-29940
URL: https://issues.apache.org/jira/browse/FLINK-29940
Project: Flink
Mingliang Liu created FLINK-29920:
-
Summary: Minor reformat Kafka connector documentation
Key: FLINK-29920
URL: https://issues.apache.org/jira/browse/FLINK-29920
Project: Flink
Issue Type:
Mingliang Liu created FLINK-29750:
-
Summary: Improve PostgresCatalog#listTables() by reusing resources
Key: FLINK-29750
URL: https://issues.apache.org/jira/browse/FLINK-29750
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17578618#comment-17578618
]
Mingliang Liu commented on FLINK-27640:
---
It failed to build with the same error when I used the
[
https://issues.apache.org/jira/browse/FLINK-27278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-27278:
--
Description: Due to special char the current indentation of
{{ProcessWindowFunction}} in doc
Mingliang Liu created FLINK-27278:
-
Summary: Fix wrong indentation in doc
dev/datastream/operators/windows.md
Key: FLINK-27278
URL: https://issues.apache.org/jira/browse/FLINK-27278
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17465569#comment-17465569
]
Mingliang Liu commented on FLINK-25453:
---
I think it makes sense to ignore the FNFE.
>
70 matches
Mail list logo
