[
https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537400#comment-17537400
]
zhisheng commented on FLINK-27576:
--
hi [~aitozi] , Have you started a PR?
> Flink will request new pod
[
https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-27576:
-
Description:
flink 1.12.0 enable the ha(zk) and checkpoint, when i use kubectl delete the jm
pod, the
zhisheng created FLINK-27576:
Summary: Flink will request new pod when jm pod is delete, but
will remove when TaskExecutor exceeded the idle timeout
Key: FLINK-27576
URL:
[
https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515674#comment-17515674
]
zhisheng commented on FLINK-26884:
--
[~martijnvisser] thanks your quickly reply, I get it.
> Move
[
https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514761#comment-17514761
]
zhisheng commented on FLINK-26884:
--
I've seen similar discussions in the dev mail before, I always
[
https://issues.apache.org/jira/browse/FLINK-26884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514758#comment-17514758
]
zhisheng commented on FLINK-26884:
--
hi, why move the es connector to external connector
[
https://issues.apache.org/jira/browse/FLINK-26601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-26601:
-
Description:
zhisheng created FLINK-26601:
Summary: Flink HBase HBaseRowDataAsyncLookupFunction threadPool
not close cause container has so many 'hbase-async-lookup-worker' thread
Key: FLINK-26601
URL:
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495933#comment-17495933
]
zhisheng commented on FLINK-26248:
--
[~wangyang0918] thank you very much, i closed this issue
> flink
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng closed FLINK-26248.
Resolution: Not A Bug
> flink job not recover from latest checkpoint on native k8s
>
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495867#comment-17495867
]
zhisheng commented on FLINK-26248:
--
thanks [~wangyang0918] , I have a question to ask you, if one of my
[
https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495865#comment-17495865
]
zhisheng commented on FLINK-20219:
--
thanks [~wangyang0918]
> Rethink the HA related ZNodes/ConfigMap
[
https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20219:
-
Attachment: image-2022-02-22-10-54-03-439.png
> Rethink the HA related ZNodes/ConfigMap clean up for
[
https://issues.apache.org/jira/browse/FLINK-20219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495831#comment-17495831
]
zhisheng commented on FLINK-20219:
--
[~wangyang0918] hello, I found out that it's not just the session
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-26248:
-
Attachment: image-2022-02-22-10-26-53-699.png
> flink job not recover from latest checkpoint on native
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494589#comment-17494589
]
zhisheng commented on FLINK-26248:
--
https://issues.apache.org/jira/browse/FLINK-19358
find this
>
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494573#comment-17494573
]
zhisheng edited comment on FLINK-26248 at 2/18/22, 12:28 PM:
-
thanks
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494573#comment-17494573
]
zhisheng edited comment on FLINK-26248 at 2/18/22, 12:26 PM:
-
thanks
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494573#comment-17494573
]
zhisheng edited comment on FLINK-26248 at 2/18/22, 12:25 PM:
-
thanks
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494573#comment-17494573
]
zhisheng commented on FLINK-26248:
--
thanks [~wangyang0918] quickly response, sorry , i just find that i
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-26248:
-
Description:
flink version: 1.12.0
ha: zk
mode: application mode
native k8s
1、if flink job start
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494550#comment-17494550
]
zhisheng commented on FLINK-26248:
--
delete the TM pod then the JM log:
{code:java}
2022-02-18
[
https://issues.apache.org/jira/browse/FLINK-26248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494543#comment-17494543
]
zhisheng commented on FLINK-26248:
--
start job shell:
{code:java}
./bin/flink run-application -p 1 -t
zhisheng created FLINK-26248:
Summary: flink job not recover from latest checkpoint on native k8s
Key: FLINK-26248
URL: https://issues.apache.org/jira/browse/FLINK-26248
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-25057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17449438#comment-17449438
]
zhisheng commented on FLINK-25057:
--
it seems like the https://issues.apache.org/jira/browse/FLINK-23725
zhisheng created FLINK-24528:
Summary: Flink HBase Asyc Lookup throw NPE if rowkey is null
Key: FLINK-24528
URL: https://issues.apache.org/jira/browse/FLINK-24528
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-20527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305921#comment-17305921
]
zhisheng commented on FLINK-20527:
--
+ 1 for this feature
> Support side output for late events in
zhisheng created FLINK-21493:
Summary: Flink Command Line Interface Document can add command
usage
Key: FLINK-21493
URL: https://issues.apache.org/jira/browse/FLINK-21493
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-21219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17276292#comment-17276292
]
zhisheng commented on FLINK-21219:
--
Duplicated in https://issues.apache.org/jira/browse/FLINK-10806
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272699#comment-17272699
]
zhisheng commented on FLINK-21143:
--
first, i config the `execution.target` in flink-conf.yaml, it is
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-17-00-38-661.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-17-00-01-553.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-16-58-43-372.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-16-56-47-400.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-16-55-06-104.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: image-2021-01-27-16-53-11-255.png
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272600#comment-17272600
]
zhisheng commented on FLINK-21143:
--
[~fly_in_gis] yes, the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: (was: flink-deploy-sql-client.log)
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272524#comment-17272524
]
zhisheng commented on FLINK-21143:
--
[~fly_in_gis] The job can be submitted successfully, and after
[
https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272522#comment-17272522
]
zhisheng commented on FLINK-21146:
--
[~jark] good (y)
> 【SQL】Flink SQL Client not support specify the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: flink-deploy-sql-client-.log
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272100#comment-17272100
]
zhisheng commented on FLINK-21143:
--
[^flink-deploy-sql-client-.log]
thanks [~xintongsong]
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Comment: was deleted
(was: [^flink-deploy-sql-client.log]
^thanks [~xintongsong] [~fly_in_gis]
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272083#comment-17272083
]
zhisheng commented on FLINK-21143:
--
[^flink-deploy-sql-client.log]
^thanks [~xintongsong]
[
https://issues.apache.org/jira/browse/FLINK-21143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-21143:
-
Attachment: flink-deploy-sql-client.log
> 【runtime】flink job use the lib jars instead of the
[
https://issues.apache.org/jira/browse/FLINK-21146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17272066#comment-17272066
]
zhisheng commented on FLINK-21146:
--
hi，[~jark] set a fixed configuration does not seem to be a very
zhisheng created FLINK-21146:
Summary: 【SQL】Flink SQL Client not support specify the queue to
submit the job
Key: FLINK-21146
URL: https://issues.apache.org/jira/browse/FLINK-21146
Project: Flink
zhisheng created FLINK-21143:
Summary: 【runtime】flink job use the lib jars instead of the
`yarn.provided.lib.dirs` config jars
Key: FLINK-21143
URL: https://issues.apache.org/jira/browse/FLINK-21143
[
https://issues.apache.org/jira/browse/FLINK-19944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17245909#comment-17245909
]
zhisheng commented on FLINK-19944:
--
hi [~neighborhood] do you start for this subtask?
> Support sink
[
https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243875#comment-17243875
]
zhisheng commented on FLINK-19946:
--
[~jark] get it
> Support sink parallelism configuration to Hbase
[
https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243866#comment-17243866
]
zhisheng commented on FLINK-20481:
--
[~873925...@qq.com] yes, i compile the mster branch
>
[
https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243866#comment-17243866
]
zhisheng edited comment on FLINK-20481 at 12/4/20, 9:11 AM:
[
https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20481:
-
Description:
MySQL table sql :
{code:java}
DROP TABLE IF EXISTS `yarn_app_logs_count`;
CREATE TABLE
zhisheng created FLINK-20481:
Summary: java.lang.ClassCastException: java.lang.Long cannot be
cast to java.lang.Integer
Key: FLINK-20481
URL: https://issues.apache.org/jira/browse/FLINK-20481
Project:
[
https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243746#comment-17243746
]
zhisheng commented on FLINK-19946:
--
[~ZhuShang] [~jark] hi, i find the HBaseUpsertTableSink doesn't use
[
https://issues.apache.org/jira/browse/FLINK-20473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17243673#comment-17243673
]
zhisheng commented on FLINK-20473:
--
+1
> when get metrics option, its hard to see the full name unless
[
https://issues.apache.org/jira/browse/FLINK-19943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242126#comment-17242126
]
zhisheng commented on FLINK-19943:
--
[~lzljs3620320] hi, this subtask will merge to 1.12?
> Support
[
https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17242045#comment-17242045
]
zhisheng commented on FLINK-20414:
--
[~jark] yes, i solved it, but the exception is not friendly, if the
[
https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng closed FLINK-20414.
Resolution: Fixed
> 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib does not exist
>
[
https://issues.apache.org/jira/browse/FLINK-20414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20414:
-
Summary: 【HBase】FileNotFoundException: File /tmp/hbase-deploy/hbase/lib
does not exist (was: 【HBase】)
zhisheng created FLINK-20414:
Summary: 【HBase】
Key: FLINK-20414
URL: https://issues.apache.org/jira/browse/FLINK-20414
Project: Flink
Issue Type: Bug
Components: Connectors / HBase
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233539#comment-17233539
]
zhisheng commented on FLINK-20143:
--
thanks [~fly_in_gis] , it works well now, thanks [~kkl0u] too, it
[
https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231377#comment-17231377
]
zhisheng commented on FLINK-20109:
--
could you please show you sql and ddl ？
>
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231369#comment-17231369
]
zhisheng edited comment on FLINK-20143 at 11/13/20, 10:51 AM:
--
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231369#comment-17231369
]
zhisheng commented on FLINK-20143:
--
{code:java}
22020-11-13 18:46:43,014 INFO
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231365#comment-17231365
]
zhisheng commented on FLINK-20143:
--
!image-2020-11-13-18-43-55-188.png!
does not has any log, i had
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20143:
-
Attachment: image-2020-11-13-18-43-55-188.png
> use `yarn.provided.lib.dirs` config deploy job failed
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231346#comment-17231346
]
zhisheng edited comment on FLINK-20143 at 11/13/20, 10:12 AM:
--
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231346#comment-17231346
]
zhisheng edited comment on FLINK-20143 at 11/13/20, 10:10 AM:
--
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20143:
-
Description:
use follow command deploy flink job to yarn failed
{code:java}
./bin/flink run -m
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231346#comment-17231346
]
zhisheng edited comment on FLINK-20143 at 11/13/20, 10:07 AM:
--
{code:java}
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231346#comment-17231346
]
zhisheng commented on FLINK-20143:
--
{code:java}
$ ./bin/flink run -t yarn-per-job
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231321#comment-17231321
]
zhisheng commented on FLINK-20143:
--
Are there any other methods to make job config
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231319#comment-17231319
]
zhisheng commented on FLINK-20143:
--
in our production environment，has many flink job，every job have the
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231317#comment-17231317
]
zhisheng commented on FLINK-20143:
--
{code:java}
./bin/flink run -m yarn-cluster -d
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231300#comment-17231300
]
zhisheng commented on FLINK-20143:
--
[~kkl0u] yes, -ytm and -yjm does not take effect，i create a issue
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231287#comment-17231287
]
zhisheng commented on FLINK-20143:
--
!image-2020-11-13-17-21-47-751.png!
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20143:
-
Attachment: image-2020-11-13-17-22-06-111.png
> use `yarn.provided.lib.dirs` config deploy job failed
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-20143:
-
Attachment: image-2020-11-13-17-21-47-751.png
> use `yarn.provided.lib.dirs` config deploy job failed
[
https://issues.apache.org/jira/browse/FLINK-20143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231284#comment-17231284
]
zhisheng commented on FLINK-20143:
--
[~kkl0u] it does not have jobmanager log and taskmanager log
> use
zhisheng created FLINK-20143:
Summary: use `yarn.provided.lib.dirs` config deploy job failed in
yarn per job mode
Key: FLINK-20143
URL: https://issues.apache.org/jira/browse/FLINK-20143
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-20109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17230623#comment-17230623
]
zhisheng commented on FLINK-20109:
--
Do you restart the sql client or restart the cluster after add the
[
https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228314#comment-17228314
]
zhisheng commented on FLINK-19973:
--
[~kkl0u] closed
> 【Flink-Deployment】YARN CLI Parameter doesn't
[
https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng closed FLINK-19973.
Resolution: Not A Bug
> 【Flink-Deployment】YARN CLI Parameter doesn't work when set `execution.target:
>
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng closed FLINK-19995.
Resolution: Won't Fix
> 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more than one
>
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17227133#comment-17227133
]
zhisheng commented on FLINK-19995:
--
I restart the SQL Client, but not the Flink Cluster, sloved now,
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Description:
when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run sql
job has an
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Description:
when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run sql
job has an
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Summary: 【Flink SQL Client】Use Flink Kafka Connector in SQL-Client has more
than one exception (was:
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Summary: 【Flink SQL Client】Use Flink Kafka Connector has more than one
exception (was: 【Flink SQL
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Attachment: image-2020-11-05-17-57-38-381.png
Description:
when i add
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Description:
when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run sql
job has an
[
https://issues.apache.org/jira/browse/FLINK-19995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19995:
-
Description:
when i add flink-sql-connector-kafka_2.11-1.12-SNAPSHOT.jar in lib, I run sql
job has an
zhisheng created FLINK-19995:
Summary: 【Flink SQL Client】Use Flink Kafka Connector has more one
exception
Key: FLINK-19995
URL: https://issues.apache.org/jira/browse/FLINK-19995
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19973:
-
Description:
when i use flink-sql-client to deploy job to yarn(per job mod), I set
`execution.target:
[
https://issues.apache.org/jira/browse/FLINK-19973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhisheng updated FLINK-19973:
-
Summary: 【Flink-Deployment】YARN CLI Parameter doesn't work when set
`execution.target: yarn-per-job`
zhisheng created FLINK-19973:
Summary: 【Flink-Deployment】YARN CLI Parameter doesn't work
Key: FLINK-19973
URL: https://issues.apache.org/jira/browse/FLINK-19973
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151727#comment-17151727
]
zhisheng commented on FLINK-18449:
--
In FlinkKafkaConsumer, the constructor method as the follow:
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151165#comment-17151165
]
zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM:
---
what about
[
https://issues.apache.org/jira/browse/FLINK-18449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17151165#comment-17151165
]
zhisheng edited comment on FLINK-18449 at 7/4/20, 4:23 AM:
---
what about
1 - 100 of 120 matches
Mail list logo
