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-34632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17824890#comment-17824890
]
Mingliang Liu commented on FLINK-34632:
---
CC [~markcho]
> Log checkpoint Id when l
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-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 non-serializat
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
Project
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813391#comment-17813391
]
Mingliang Liu commented on FLINK-27054:
---
Any updates on this?
My understanding is
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: I
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17814504#comment-17814504
]
Mingliang Liu commented on FLINK-34369:
---
Note the Flink ElasticSearch [SQL
connec
[
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:all-tabpanel
]
Mingliang Liu updated FLINK-34369:
--
Description:
The current Flink ElasticSearch connector does not support SSL option, causing
i
[
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
i
[
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
i
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-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17874427#comment-17874427
]
Mingliang Liu commented on FLINK-34369:
---
Can we close this now?
> Elasticsearch c
[ https://issues.apache.org/jira/browse/FLINK-34369 ]
Mingliang Liu deleted comment on FLINK-34369:
---
was (Author: liuml07):
Can we close this now?
> Elasticsearch connector supports SSL context
>
>
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
[
https://issues.apache.org/jira/browse/FLINK-27054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17843288#comment-17843288
]
Mingliang Liu commented on FLINK-27054:
---
Hi, the FLINK-34369 was merged and I can
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-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 option,
[
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 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:
--
Parent: FLINK-34369
Issue Type: Sub-task (was: Improvement)
> Elasticsearch connector
Mingliang Liu created FLINK-35472:
-
Summary: Improve tests for Elasticsearch 8 connector
Key: FLINK-35472
URL: https://issues.apache.org/jira/browse/FLINK-35472
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849908#comment-17849908
]
Mingliang Liu commented on FLINK-34369:
---
Can we close this now?
> Elasticsearch c
[
https://issues.apache.org/jira/browse/FLINK-35472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-35472:
--
Affects Version/s: elasticsearch-3.2.0
> Improve tests for Elasticsearch 8 connector
> ---
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:
[
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
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851744#comment-17851744
]
Mingliang Liu commented on FLINK-35502:
---
When would you need to restore from check
[
https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17852132#comment-17852132
]
Mingliang Liu commented on FLINK-35502:
---
I guess in my day job I don't see user re
Mingliang Liu created FLINK-35546:
-
Summary: Elasticsearch 8 connector fails fast for non-retryable
bulk request items
Key: FLINK-35546
URL: https://issues.apache.org/jira/browse/FLINK-35546
Project:
[
https://issues.apache.org/jira/browse/FLINK-35546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853036#comment-17853036
]
Mingliang Liu commented on FLINK-35546:
---
I plan to submit a PR for discussion. I t
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-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 whitesp
[
https://issues.apache.org/jira/browse/FLINK-31110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17690044#comment-17690044
]
Mingliang Liu commented on FLINK-31110:
---
CC: [~markcho]
> Web UI shows "User Conf
[
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
setti
[
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" preser
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: Improvemen
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 Ty
[
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
a
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: Impr
[
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
TIMESTAMP_WITH_L
[
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:
--
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:
--
Description:
Currently Avro format does not support TIMESTAMP_LTZ (short for
TIMESTAMP_WITH_L
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651147#comment-17651147
]
Mingliang Liu commented on FLINK-30483:
---
Sample code:
{code:java}
public static
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651154#comment-17651154
]
Mingliang Liu commented on FLINK-30483:
---
[~martijnvisser] I linked FLINK-23589 in
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17651185#comment-17651185
]
Mingliang Liu commented on FLINK-30483:
---
I'm not sure this requires FLINK-17224. T
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652926#comment-17652926
]
Mingliang Liu commented on FLINK-30483:
---
Thanks [~jadireddi] ! I started making ch
[
https://issues.apache.org/jira/browse/FLINK-30483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654214#comment-17654214
]
Mingliang Liu commented on FLINK-30483:
---
Thanks [~jadireddi] I'll review from next
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
Project
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17718754#comment-17718754
]
Mingliang Liu commented on FLINK-31984:
---
CC: [~markcho]
> Savepoint on S3 should
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719402#comment-17719402
]
Mingliang Liu commented on FLINK-31984:
---
Thanks for catching this [~mapohl]. Sorry
[
https://issues.apache.org/jira/browse/FLINK-31984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719710#comment-17719710
]
Mingliang Liu commented on FLINK-31984:
---
The new [PR #22522|https://github.com/apa
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720687#comment-17720687
]
Mingliang Liu commented on FLINK-30081:
---
I checked again and found we have already
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: Improve
[
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
>
[
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-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635678#comment-17635678
]
Mingliang Liu commented on FLINK-29940:
---
Thanks for the comment [~gaoyunhaii] . We
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-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
{{taskmanager.m
[
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
{{taskmanager.m
[
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
{{taskmanager.m
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: Improve
[
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
where
[
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
where
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642069#comment-17642069
]
Mingliang Liu commented on FLINK-29940:
---
Yes we now search for "switched from RUNN
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17642100#comment-17642100
]
Mingliang Liu commented on FLINK-30081:
---
Thanks [~gaoyunhaii] It makes perfect sen
[
https://issues.apache.org/jira/browse/FLINK-29940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643536#comment-17643536
]
Mingliang Liu commented on FLINK-29940:
---
Yeah, WARN will be much better than INFO.
[
https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17645077#comment-17645077
]
Mingliang Liu commented on FLINK-30081:
---
[~xtsong] Thanks for providing more conte
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17578618#comment-17578618
]
Mingliang Liu commented on FLINK-27640:
---
It failed to build with the same error wh
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
I
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: Bu
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-29961:
-
Summary: Make referencing custom image clearer for Docker
Key: FLINK-29961
URL: https://issues.apache.org/jira/browse/FLINK-29961
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:
--
Labels: pull-request-available (was: )
> 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:
--
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:
--
Description:
Make referencing custom image clearer for Docker.
- Rephrase the words how to ref
[
https://issues.apache.org/jira/browse/FLINK-25453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17465569#comment-17465569
]
Mingliang Liu commented on FLINK-25453:
---
I think it makes sense to ignore the FNFE
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-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 {
[
https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-36679:
--
Description:
Currently we expose multiple metrics for the checkpoint size. One specific
inter
[
https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-36679:
--
Description:
Currently we expose multiple metrics for the checkpoint size. One specific
inter
Mingliang Liu created FLINK-36679:
-
Summary: Add a metric to track checkpoint _metadata size
Key: FLINK-36679
URL: https://issues.apache.org/jira/browse/FLINK-36679
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17896756#comment-17896756
]
Mingliang Liu commented on FLINK-36679:
---
We have a in-progress patch in our intern
[
https://issues.apache.org/jira/browse/FLINK-36679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-36679:
--
Description:
Currently we expose multiple metrics for the checkpoint size. One specific
inter
Mingliang Liu created FLINK-36604:
-
Summary: StreamingJobGraphGenerator::setOperatorConfig checks
input serializer lengh
Key: FLINK-36604
URL: https://issues.apache.org/jira/browse/FLINK-36604
Project
[ https://issues.apache.org/jira/browse/FLINK-34369 ]
Mingliang Liu deleted comment on FLINK-34369:
---
was (Author: liuml07):
Can we close this now?
> Elasticsearch connector supports SSL context
>
>
[
https://issues.apache.org/jira/browse/FLINK-34369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904897#comment-17904897
]
Mingliang Liu commented on FLINK-34369:
---
[~Sergey Nuyanzin] I think we can close t
[
https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu updated FLINK-36604:
--
Description:
Currently {{StreamingJobGraphGenerator::setOperatorConfig}} does not check the
i
Mingliang Liu created FLINK-36780:
-
Summary: Kafka source disable partition discovery unexpectedly
Key: FLINK-36780
URL: https://issues.apache.org/jira/browse/FLINK-36780
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-36780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17900545#comment-17900545
]
Mingliang Liu commented on FLINK-36780:
---
CC:[~markcho]
> Kafka source disable par
[
https://issues.apache.org/jira/browse/FLINK-37109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17912677#comment-17912677
]
Mingliang Liu commented on FLINK-37109:
---
This sounds useful to me. Could you attac
[
https://issues.apache.org/jira/browse/FLINK-29961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu closed FLINK-29961.
-
Resolution: Won't Fix
> Make referencing custom image clearer for Docker
> -
Mingliang Liu created FLINK-37812:
-
Summary: Fix broken links to Apache Avro in doc and code
Key: FLINK-37812
URL: https://issues.apache.org/jira/browse/FLINK-37812
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-37812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu resolved FLINK-37812.
---
Fix Version/s: 2.1.0
Resolution: Fixed
> Fix broken links to Apache Avro in doc and c
[
https://issues.apache.org/jira/browse/FLINK-36604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mingliang Liu resolved FLINK-36604.
---
Fix Version/s: 2.1.0
Resolution: Fixed
> StreamingJobGraphGenerator::setOperatorConfi
1 - 100 of 112 matches
Mail list logo
