[
https://issues.apache.org/jira/browse/FLINK-37283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-37283:
Description: As flink cdc yaml table input is "db.\.*.\.*", we need parse
dbname. (was: As flink
ouyangwulin created FLINK-37283:
---
Summary: Improved ability to split ‘db./.*./.*.’
Key: FLINK-37283
URL: https://issues.apache.org/jira/browse/FLINK-37283
Project: Flink
Issue Type: Improvement
ouyangwulin created FLINK-36895:
---
Summary: The JdbcSourceChunkSplitter#queryMin method passed a
parameter with tableName/coiumnName reversed.
Key: FLINK-36895
URL: https://issues.apache.org/jira/browse/FLINK-36895
ouyangwulin created FLINK-36812:
---
Summary: The flink jdbc connector's 'scan.partition.column'
supports the varchar field type.
Key: FLINK-36812
URL: https://issues.apache.org/jira/browse/FLINK-36812
Pro
[
https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17901604#comment-17901604
]
ouyangwulin commented on FLINK-35670:
-
I investigated the implementation, it is real
ouyangwulin created FLINK-36588:
---
Summary: flink catalog is supported in cdc yaml
Key: FLINK-36588
URL: https://issues.apache.org/jira/browse/FLINK-36588
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-36414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892034#comment-17892034
]
ouyangwulin commented on FLINK-36414:
-
Try to use flink-1.18
> NoSuchMethodError wh
[
https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1703#comment-1703
]
ouyangwulin commented on FLINK-35670:
-
[~m.orazow] Have you started the work? I che
[
https://issues.apache.org/jira/browse/FLINK-35670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888556#comment-17888556
]
ouyangwulin commented on FLINK-35670:
-
https://issues.apache.org/jira/browse/FLINK-3
[
https://issues.apache.org/jira/browse/FLINK-35740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867938#comment-17867938
]
ouyangwulin commented on FLINK-35740:
-
[~seung-min] As this ticket describe，I have
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin closed FLINK-35354.
---
Resolution: Fixed
master:302a69122538fdb76b98e73ebb3c83ee733a0c02
> Support host mapping in Flink t
ouyangwulin created FLINK-35459:
---
Summary: Use Incremental Source Framework in Flink CDC TiKV Source
Connector
Key: FLINK-35459
URL: https://issues.apache.org/jira/browse/FLINK-35459
Project: Flink
ouyangwulin created FLINK-35450:
---
Summary: Introduce Tikv pipeline DataSource
Key: FLINK-35450
URL: https://issues.apache.org/jira/browse/FLINK-35450
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-34841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849443#comment-17849443
]
ouyangwulin commented on FLINK-34841:
-
[~gongzhongqiang] Looks like a very good job,
[
https://issues.apache.org/jira/browse/FLINK-34688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17849441#comment-17849441
]
ouyangwulin commented on FLINK-34688:
-
When the size of the data is relatively large
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Summary: Update clause must EXCLUDED unique index (was: Improve the
performance of the update Pos
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Description:
When writing Postgres data using flinke-connector-jdbc, using upsert mode, As
docs '
[
https://issues.apache.org/jira/browse/FLINK-35360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848423#comment-17848423
]
ouyangwulin commented on FLINK-35360:
-
With many enterprises still running on yarn,
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin closed FLINK-35337.
---
Release Note: tikv version not supported
Resolution: Won't Fix
> Keep up with the latest versi
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35354:
Description:
In tidb production environment deployment, there are usually two kinds of
network: i
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35354:
Description:
In tidb production environment deployment, there are usually two kinds of
network: i
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35354:
Description:
In tidb production environment deployment, there are usually two kinds of
network: i
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35354:
Description: In tidb production environment deployment, there are usually
two kinds of network: in
[
https://issues.apache.org/jira/browse/FLINK-35354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-35354:
Summary: Support host mapping in Flink tikv cdc (was: [discuss] Support
host mapping in Flink tik
ouyangwulin created FLINK-35354:
---
Summary: [discuss] Support host mapping in Flink tikv cdc
Key: FLINK-35354
URL: https://issues.apache.org/jira/browse/FLINK-35354
Project: Flink
Issue Type: Im
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Affects Version/s: jdbc-3.1.2
> Improve the performance of the update Postgres database
>
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-34901:
Priority: Critical (was: Minor)
> Improve the performance of the update Postgres database
> -
[
https://issues.apache.org/jira/browse/FLINK-34901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17846235#comment-17846235
]
ouyangwulin commented on FLINK-34901:
-
Some versions of pgsql also give this error：
[
https://issues.apache.org/jira/browse/FLINK-35337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17845887#comment-17845887
]
ouyangwulin commented on FLINK-35337:
-
[~Leonard]， Our production environment has be
[
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
>
ouyangwulin created FLINK-35337:
---
Summary: Keep up with the latest version of tikv client
Key: FLINK-35337
URL: https://issues.apache.org/jira/browse/FLINK-35337
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-34722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829775#comment-17829775
]
ouyangwulin commented on FLINK-34722:
-
[~pietro97] I think it is a very useful prove
ouyangwulin created FLINK-34901:
---
Summary: Improve the performance of the update Postgres database
Key: FLINK-34901
URL: https://issues.apache.org/jira/browse/FLINK-34901
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-33319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17803379#comment-17803379
]
ouyangwulin commented on FLINK-33319:
-
[~gyfora] Could you assign this ticket to me
[
https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin closed FLINK-33491.
---
Resolution: Not A Problem
> Support json column validated
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17785468#comment-17785468
]
ouyangwulin commented on FLINK-33491:
-
This is my error, I didn't find the is json f
[
https://issues.apache.org/jira/browse/FLINK-33491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-33491:
Description: Just like the {{is_valid_json}} function in PostgreSQL, it
would be useful to have an
ouyangwulin created FLINK-33491:
---
Summary: Support json column validated
Key: FLINK-33491
URL: https://issues.apache.org/jira/browse/FLINK-33491
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17721745#comment-17721745
]
ouyangwulin commented on FLINK-27925:
-
[~huwh] tks, I will update.
> Avoid to crea
[
https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701118#comment-17701118
]
ouyangwulin edited comment on FLINK-29705 at 3/16/23 11:49 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701118#comment-17701118
]
ouyangwulin commented on FLINK-29705:
-
apiVersion: v1
kind: ServiceAccount
metadata:
[
https://issues.apache.org/jira/browse/FLINK-30231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654420#comment-17654420
]
ouyangwulin commented on FLINK-30231:
-
[~martijnvisser] Can you help me check it ou
[
https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654320#comment-17654320
]
ouyangwulin commented on FLINK-29705:
-
[~wangyang0918] Can assign this ticket for m
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649232#comment-17649232
]
ouyangwulin edited comment on FLINK-27925 at 12/19/22 12:31 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649232#comment-17649232
]
ouyangwulin commented on FLINK-27925:
-
In the case of large-scale start and stop job
[ https://issues.apache.org/jira/browse/FLINK-26541 ]
ouyangwulin deleted comment on FLINK-26541:
-
was (Author: ouyangwuli):
Please assign the ticket to me [~wangyang0918]
> SQL Client should support submitting SQL jobs in application mode
> -
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649023#comment-17649023
]
ouyangwulin commented on FLINK-26541:
-
Please assign the ticket to me [~wangyang0918
[
https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425441#comment-17425441
]
ouyangwulin edited comment on FLINK-24334 at 10/7/21, 9:44 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-24334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425441#comment-17425441
]
ouyangwulin commented on FLINK-24334:
-
Solving this problem can be divided into two
[
https://issues.apache.org/jira/browse/FLINK-24178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425392#comment-17425392
]
ouyangwulin commented on FLINK-24178:
-
[~frey] I guess, if the tm resource address e
[
https://issues.apache.org/jira/browse/FLINK-24315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416493#comment-17416493
]
ouyangwulin commented on FLINK-24315:
-
[~karmagyz] Can we configure parameters ‘kub
ouyangwulin created FLINK-24315:
---
Summary: Flink native on k8s wacther thread will down，when k8s api
server not work or network timeout
Key: FLINK-24315
URL: https://issues.apache.org/jira/browse/FLINK-24315
[
https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17187663#comment-17187663
]
ouyangwulin commented on FLINK-14986:
-
[~trohrmann] I have implement it, but Not hav
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086760#comment-17086760
]
ouyangwulin edited comment on FLINK-15641 at 4/19/20, 5:38 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17086760#comment-17086760
]
ouyangwulin commented on FLINK-15641:
-
[~fly_in_gis]，in progressing.
> Support to s
[
https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078050#comment-17078050
]
ouyangwulin edited comment on FLINK-15656 at 4/8/20, 10:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078050#comment-17078050
]
ouyangwulin edited comment on FLINK-15656 at 4/8/20, 10:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078050#comment-17078050
]
ouyangwulin commented on FLINK-15656:
-
I have implement init-container for download
[
https://issues.apache.org/jira/browse/FLINK-15656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060856#comment-17060856
]
ouyangwulin commented on FLINK-15656:
-
Ok, If the pod templement support sidecar co
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060854#comment-17060854
]
ouyangwulin commented on FLINK-15871:
-
[~felixzheng] [~fly_in_gis] Sidecar for log
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060654#comment-17060654
]
ouyangwulin edited comment on FLINK-15641 at 3/17/20, 6:00 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060654#comment-17060654
]
ouyangwulin commented on FLINK-15641:
-
[~fly_in_gis] As flink on k8s ,not native. I
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060649#comment-17060649
]
ouyangwulin commented on FLINK-15871:
-
[~felixzheng]
> As collect logs, I think
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060144#comment-17060144
]
ouyangwulin commented on FLINK-15641:
-
Ok I will complement it this week.
> Support
[
https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17060136#comment-17060136
]
ouyangwulin commented on FLINK-14986:
-
Last time, I am busy in push flink on k8s onl
[
https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041547#comment-17041547
]
ouyangwulin commented on FLINK-15400:
-
[~Leonard Xu] If configed 'connector.dynamicI
[
https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17041545#comment-17041545
]
ouyangwulin commented on FLINK-15400:
-
[~Leonard Xu]. Yes I have a design from blink
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17031314#comment-17031314
]
ouyangwulin commented on FLINK-15641:
-
[~fly_in_gis] ok， I will do this job
> Suppo
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029524#comment-17029524
]
ouyangwulin commented on FLINK-15641:
-
[~gjy] , I think I can do this work。 and I wi
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029522#comment-17029522
]
ouyangwulin commented on FLINK-15871:
-
Could assign this ticket for me?
> Support t
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17029503#comment-17029503
]
ouyangwulin commented on FLINK-15641:
-
[~fly_in_gis] A sidecar container is running
[
https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018774#comment-17018774
]
ouyangwulin commented on FLINK-14460:
-
I have try to implement sidecars and initcont
[
https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018771#comment-17018771
]
ouyangwulin commented on FLINK-15642:
-
Could assign this ticket for me?
> Support t
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17018770#comment-17018770
]
ouyangwulin commented on FLINK-15641:
-
Could assign this ticket for me?
> Support t
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006769#comment-17006769
]
ouyangwulin edited comment on FLINK-15378 at 1/3/20 2:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006769#comment-17006769
]
ouyangwulin edited comment on FLINK-15378 at 1/3/20 2:49 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007184#comment-17007184
]
ouyangwulin commented on FLINK-12382:
-
The program finished with the following excep
[
https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17007183#comment-17007183
]
ouyangwulin commented on FLINK-12382:
-
I have try zookeeper， But the error log seems
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006769#comment-17006769
]
ouyangwulin edited comment on FLINK-15378 at 1/2/20 12:36 PM:
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006769#comment-17006769
]
ouyangwulin commented on FLINK-15378:
-
[~pnowojski] thanks for your reply.
{noforma
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006568#comment-17006568
]
ouyangwulin commented on FLINK-15378:
-
[~fly_in_gis] Also， I need different kerberos
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006557#comment-17006557
]
ouyangwulin edited comment on FLINK-15378 at 1/2/20 3:27 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006557#comment-17006557
]
ouyangwulin edited comment on FLINK-15378 at 1/2/20 3:25 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006557#comment-17006557
]
ouyangwulin commented on FLINK-15378:
-
{code:java}
do I understand your problem cor
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004032#comment-17004032
]
ouyangwulin edited comment on FLINK-15378 at 12/27/19 9:52 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003237#comment-17003237
]
ouyangwulin edited comment on FLINK-15378 at 12/27/19 9:51 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17004032#comment-17004032
]
ouyangwulin commented on FLINK-15378:
-
[~fly_in_gis] https://issues.apache.org/jira/
[
https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003531#comment-17003531
]
ouyangwulin commented on FLINK-15400:
-
Please assign this for me
> elasticsearch si
[
https://issues.apache.org/jira/browse/FLINK-15400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15400:
Description:
>From
>user...@flink.apache.org([https://lists.apache.org/thread.html/ac4e0c068baeb3
ouyangwulin created FLINK-15400:
---
Summary: elasticsearch sink support dynamic index.
Key: FLINK-15400
URL: https://issues.apache.org/jira/browse/FLINK-15400
Project: Flink
Issue Type: New Featu
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003237#comment-17003237
]
ouyangwulin edited comment on FLINK-15378 at 12/26/19 5:58 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002704#comment-17002704
]
ouyangwulin edited comment on FLINK-15378 at 12/26/19 3:07 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003237#comment-17003237
]
ouyangwulin commented on FLINK-15378:
-
[~fly_in_gis]
>> For request 1,
Chang
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15378:
Description:
[As report from
maillist|[https://lists.apache.org/thread.html/7a6b1e341bde0ef632a82
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15378:
Description:
[As report from
maillist|[https://lists.apache.org/thread.html/7a6b1e341bde0ef632a82
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15378:
Description:
[As report from
maillist|[https://lists.apache.org/thread.html/7a6b1e341bde0ef632a82
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002719#comment-17002719
]
ouyangwulin commented on FLINK-15378:
-
[~pnowojski] When I read the code ClusterEntr
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15378:
Description:
Request 1: FileSystem plugins not effect the default yarn dependecies.
Request 2:
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17002704#comment-17002704
]
ouyangwulin commented on FLINK-15378:
-
Please assign the for me！
> StreamFileSystem
[
https://issues.apache.org/jira/browse/FLINK-15378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ouyangwulin updated FLINK-15378:
Description:
Request 1: FileSystem plugins not effect the default yarn dependecies.
Request 2:
1 - 100 of 132 matches
Mail list logo
