Shengnan YU created FLINK-32562:
---
Summary: FileSink Compactor Service should not use FileWriter from
Sink for OutputStreamBasedFileCompactor
Key: FLINK-32562
URL: https://issues.apache.org/jira/browse/FLINK-32562
[
https://issues.apache.org/jira/browse/FLINK-21319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477541#comment-17477541
]
Shengnan YU commented on FLINK-21319:
-
I got this problem when I use flink with hudi. I found
[
https://issues.apache.org/jira/browse/FLINK-24391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-24391:
Description: Sometimes we only need to extract some columns of the json
message for indexing but
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU edited comment on FLINK-23933 at 9/28/21, 7:38 AM:
---
I also
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU edited comment on FLINK-23933 at 9/28/21, 7:38 AM:
---
I also
[
https://issues.apache.org/jira/browse/FLINK-24391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-24391:
Description: Sometimes we only need to extra some columns of the json
message for indexing but
Shengnan YU created FLINK-24391:
---
Summary: flink-json formats should support an option to extract
the raw message into a column
Key: FLINK-24391
URL: https://issues.apache.org/jira/browse/FLINK-24391
[
https://issues.apache.org/jira/browse/FLINK-23933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421218#comment-17421218
]
Shengnan YU commented on FLINK-23933:
-
I also advise that an option to extract the raw message into
Shengnan YU created FLINK-23933:
---
Summary: flink-json formats support a option to parse nested json
as a String
Key: FLINK-23933
URL: https://issues.apache.org/jira/browse/FLINK-23933
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-16266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17398048#comment-17398048
]
Shengnan YU commented on FLINK-16266:
-
Any update on this issue?
> es6 & 7 table sql connector
Shengnan YU created FLINK-18939:
---
Summary: Sort-partition result is incorrect when use Bigdecimal as
Key
Key: FLINK-18939
URL: https://issues.apache.org/jira/browse/FLINK-18939
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059695#comment-17059695
]
Shengnan YU commented on FLINK-14938:
-
The easiest way to solve this issue is to use
[
https://issues.apache.org/jira/browse/FLINK-6417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035150#comment-17035150
]
Shengnan YU commented on FLINK-6417:
Any update on this future? If none, could you assign the ticket
[
https://issues.apache.org/jira/browse/FLINK-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-14938:
Description:
When use Elasticsearch connector failure handler (from official example) to
[
https://issues.apache.org/jira/browse/FLINK-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981381#comment-16981381
]
Shengnan YU commented on FLINK-14938:
-
If it is a bug, could please assign this ticket to me to
[
https://issues.apache.org/jira/browse/FLINK-14938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-14938:
Description:
When use Elasticsearch connector failure handler (from official example) to
Shengnan YU created FLINK-14938:
---
Summary: Flink elasticsearch failure handler re-add indexrequest
causes ConcurrentModificationException
Key: FLINK-14938
URL: https://issues.apache.org/jira/browse/FLINK-14938
[
https://issues.apache.org/jira/browse/FLINK-13298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917791#comment-16917791
]
Shengnan YU commented on FLINK-13298:
-
Hi [~phoenixjiangnan] I cant found docs of Hive-integration
[
https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911025#comment-16911025
]
Shengnan YU commented on FLINK-7860:
Is there any plan for this improvement?
> Support YARN proxy
[
https://issues.apache.org/jira/browse/FLINK-13701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-13701:
Affects Version/s: 1.9.0
> KafkaTableSourceSink doesn't support topic pattern
>
Shengnan YU created FLINK-13701:
---
Summary: KafkaTableSourceSink doesn't support topic pattern
Key: FLINK-13701
URL: https://issues.apache.org/jira/browse/FLINK-13701
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-4873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16902719#comment-16902719
]
Shengnan YU commented on FLINK-4873:
Is this ticket abandoned? Actually I need this feature.
> Add
[
https://issues.apache.org/jira/browse/FLINK-13298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888741#comment-16888741
]
Shengnan YU commented on FLINK-13298:
-
[~phoenixjiangnan] Hi, I have finished the translation
[
https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887666#comment-16887666
]
Shengnan YU commented on FLINK-13086:
-
[~phoenixjiangnan]Sure I will do it
> add Chinese
[
https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885759#comment-16885759
]
Shengnan YU commented on FLINK-13086:
-
yes I'm glad to do that if having chance
> add Chinese
[
https://issues.apache.org/jira/browse/FLINK-13086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878276#comment-16878276
]
Shengnan YU commented on FLINK-13086:
-
I am willing to contribute the translation. Could you please
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824781#comment-16824781
]
Shengnan YU commented on FLINK-11848:
-
It does not work, I have looked up the source code. Flink
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-11654:
Comment: was deleted
(was: Hi, I got the same problem, any updated solution here?)
> Multiple
[
https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16815006#comment-16815006
]
Shengnan YU commented on FLINK-11654:
-
Hi, I got the same problem, any updated solution here?
>
Shengnan YU created FLINK-11928:
---
Summary: Create a Compression string writer for
flink-connectors-filesystem
Key: FLINK-11928
URL: https://issues.apache.org/jira/browse/FLINK-11928
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16790236#comment-16790236
]
Shengnan YU commented on FLINK-11848:
-
It seems to be a kafka client problem. The kafka consumer
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16789326#comment-16789326
]
Shengnan YU commented on FLINK-11848:
-
I have added example in the description, can you reproduce
[
https://issues.apache.org/jira/browse/FLINK-11848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengnan YU updated FLINK-11848:
Description:
Recently we are doing some streaming jobs with apache flink. There are multiple
Shengnan YU created FLINK-11848:
---
Summary: Delete outdated kafka topics caused
UNKNOWN_TOPIC_EXCEPTIION
Key: FLINK-11848
URL: https://issues.apache.org/jira/browse/FLINK-11848
Project: Flink
34 matches
Mail list logo
