Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

2024-05-06 Thread Roc Marshal
+1 (non-binding) Best, Regards. Yuepeng Pan Replied Message | From | Rui Fan<1996fan...@gmail.com> | | Date | 05/06/2024 11:28 | | To | dev | | Subject | Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0 | +1 (binding) Best, Rui On Mon, May 6, 2024 at 11:01 AM Yanfei Lei w

Re: [ANNOUNCE] Apache Paimon is graduated to Top Level Project

2024-03-28 Thread Roc Marshal
Congratulations ! Best, Yuepeng Pan At 2024-03-28 18:46:58, "Yuan Mei" wrote: >Congratulations > >Best >Yuan > >On Thu, Mar 28, 2024 at 5:35 PM Samrat Deb wrote: > >> Congratulations ! >> Great news >> >> Bests, >> Samrat >> >> On Thu, 28 Mar 2024 at 3:00 PM, Ahmed Hamdy wrote: >> >> > Congr

Re: [DISCUSS] FLIP-436: Introduce "SHOW CREATE CATALOG" Syntax

2024-03-14 Thread Roc Marshal
Hi, Yubin Thank you for initiating this discussion! +1 for the proposal. Best, Yuepeng Pan At 2024-03-14 18:57:35, "Ferenc Csaky" wrote: >Hi Yubin, > >Thank you for initiating this discussion! +1 for the proposal. > >I also think it makes sense to group the missing catalog related

[VOTE][RESULT] FLIP-370: Support Balanced Tasks Scheduling

2023-10-26 Thread Roc Marshal
Hi all, The voting time of FLIP-370[1]: Support Balanced Tasks Scheduling has passed. I'm closing the vote now. There were 6 +1 votes, 3 of which are binding: Zhu Zhu (binding) Yangze Guo (binding) Rui Fan (binding) Xiangyu Feng Yu Chen Yuepeng Pan There were no -1 votes. Thus FLIP-370 has bee

[VOTE] FLIP-370: Support Balanced Tasks Scheduling

2023-10-22 Thread Roc Marshal
Hi all, Thanks for all the feedback on FLIP-370[1][2]. I'd like to start a vote for FLIP-370. The vote will last for at least 72 hours (Oct. 26th at 10:00 A.M. GMT) unless there is an objection or insufficient votes. Thanks, Yuepeng Pan [1] https://cwiki.apache.org/confluence/display/FLINK/F

Re:[VOTE] Remove HCatalog connector

2022-10-13 Thread Roc Marshal
 +1 (non-binding) Thanks for driving. Best regards, Roc Marshal. At 2022-10-13 03:45:57, "Martijn Visser" wrote: >Hi everyone, > >Since no comments were made, I'm opening a vote to remove the HCatalog >connector [1] > >The voting period will be open at least 7

RE: Re: Re: Re: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

2022-08-09 Thread Roc Marshal
k API, > > but the FLIP only contains detailed information on the Source. Are you > > planning to add that to the FLIP before casting a vote? Because the > > discussion should definitely be resolved for both the Source and the Sink. > > > > Best regards, > > > >

RE: [VOTE] FLIP-251: Support collecting arbitrary number of streams

2022-07-20 Thread Roc Marshal
+1. (Non-binding) Thanks for driving this. Best Roc Marshal On 2022/07/19 08:26:15 Chesnay Schepler wrote: > I'd like to proceed with the vote for FLIP-251 [1], as no objections or > issues were raised in [2]. > > The vote will last for at least 72 hours unless there i

RE: Re: Re: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

2022-07-01 Thread Roc Marshal
the timely generation strategy to solve this problem? Looking forward to a better solution . Best regards, Roc Marshal On 2022/07/01 07:58:22 Dong Weike wrote: > Hi, > > Thank you for bringing this up, and I am +1 for this feature. > > IMO, one important thing that I would lik

RE: Re: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

2022-06-30 Thread Roc Marshal
Hi, Lijie. Thanks for the catching and sorry for the typo in sorting out the draft. I updated it. Best regards, Roc Marshal On 2022/07/01 02:24:56 Lijie Wang wrote: > Hi Roc, > > Thanks for driving the discussion. > > Could you describe in detail what the JdbcSourceSplit

RE: Re: [DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

2022-06-30 Thread Roc Marshal
e/display/FLINK/FLIP-202%3A+Introduce+ClickHouse+Connector Best regards, Roc Marshal On 2022/06/30 09:02:23 João Boto wrote: > Hi, > > On source we could improve the JdbcParameterValuesProvider.. to be defined as > a query(s) or something more dynamic. > The most time if your job

RE: [VOTE] FLIP-240: Introduce "ANALYZE TABLE" Syntax

2022-06-27 Thread Roc Marshal
+1(non-binding) Best, Roc Marshal On 2022/06/24 15:07:08 godfrey he wrote: > Hi everyone, > > Thanks for all the feedback so far. Based on the discussion[1] we seem > to have consensus, so I would like to start a vote on FLIP-240 for > which the FLIP has now also been updated[2]

[DISCUSS] FLIP-239: Port JDBC Connector Source to FLIP-27

2022-06-27 Thread Roc Marshal
] https://issues.apache.org/jira/browse/FLINK-25420 [3] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217386271 Best regards, Roc Marshal

Re:[VOTE] Creating an Apache Flink slack workspace

2022-05-19 Thread Roc Marshal
+1. (non-binding.) Best Regards Roc. At 2022-05-17 16:23:59, "Xintong Song" wrote: >Hi everyone, > >As previously discussed in [1], I would like to open a vote on creating an >Apache Flink slack workspace channel. > >The proposed actions include: >- Creating a dedicated slack workspace with t

[jira] [Created] (FLINK-24489) The size of entryCache in the SharedBuffer should be defined with a threshold

2021-10-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24489: --- Summary: The size of entryCache in the SharedBuffer should be defined with a threshold Key: FLINK-24489 URL: https://issues.apache.org/jira/browse/FLINK-24489 Project

[jira] [Created] (FLINK-24383) Remove the deprecated SlidingTimeWindows and TumblingTimeWindows.

2021-09-27 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24383: --- Summary: Remove the deprecated SlidingTimeWindows and TumblingTimeWindows. Key: FLINK-24383 URL: https://issues.apache.org/jira/browse/FLINK-24383 Project: Flink

About PR Review Help

2021-09-17 Thread Roc Marshal
Hi, Could someone help me to review this PR ? https://github.com/apache/flink/pull/16962 https://issues.apache.org/jira/browse/FLINK-15352 Thank you very much. Best, Roc.

[jira] [Created] (FLINK-24215) Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment

2021-09-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24215: --- Summary: Timeout exception in submitting job by RemoteStreamEnvironment/RemoteEnvironment Key: FLINK-24215 URL: https://issues.apache.org/jira/browse/FLINK-24215

[jira] [Created] (FLINK-24043) Reuse the code of 'check savepoint preconditions'.

2021-08-29 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-24043: --- Summary: Reuse the code of 'check savepoint preconditions'. Key: FLINK-24043 URL: https://issues.apache.org/jira/browse/FLINK-24043 Project: Flink

[jira] [Created] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.

2021-08-24 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23943: --- Summary: "/jobs/:jobid/stop" in REST API can't stop the target job. Key: FLINK-23943 URL: https://issues.apache.org/jira/browse/FLINK-23943

[jira] [Created] (FLINK-23909) Remove redundant variables and improve some style format in coding.

2021-08-22 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23909: --- Summary: Remove redundant variables and improve some style format in coding. Key: FLINK-23909 URL: https://issues.apache.org/jira/browse/FLINK-23909 Project: Flink

[jira] [Created] (FLINK-23716) Translate the 'Zipping Elements in a DataSet' page inito Chinese

2021-08-10 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23716: --- Summary: Translate the 'Zipping Elements in a DataSet' page inito Chinese Key: FLINK-23716 URL: https://issues.apache.org/jira/browse/FLINK-23716 Proj

Re:[ANNOUNCE] New Apache Flink Committer - Yuan Mei

2021-07-07 Thread Roc Marshal
Congratulations, Yuan! At 2021-07-08 01:21:40, "Yu Li" wrote: >Hi all, > >On behalf of the PMC, I’m very happy to announce Yuan Mei as a new Flink >committer. > >Yuan has been an active contributor for more than two years, with code >contributions on multiple components including ka

[jira] [Created] (FLINK-23028) Improve documentation for pages of SQL.

2021-06-17 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-23028: --- Summary: Improve documentation for pages of SQL. Key: FLINK-23028 URL: https://issues.apache.org/jira/browse/FLINK-23028 Project: Flink Issue Type

Apply for FLIP Wiki Page Edit Permission

2021-06-15 Thread Roc Marshal
Hi, I want to contribute to Flink, but I can't create FLIP wiki page now. Would someone please give me the confluence permission ? My Confluence ID is roc-marshal. Full name is RocMarshal. My JIRA ID is RocMarshal. Thank you . Best, Roc.

Question About 'SHOW COLUMNS' statement in SQL

2021-06-10 Thread Roc Marshal
Hello, Could someone help me to advance the jira FLINK-22885(https://issues.apache.org/jira/browse/FLINK-22885)? It has been at standstill for some time. Thank you. Best, Roc.

[jira] [Created] (FLINK-22934) Add instructions for using the " ' " escape syntax of SQL client

2021-06-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22934: --- Summary: Add instructions for using the " ' " escape syntax of SQL client Key: FLINK-22934 URL: https://issues.apache.org/jira/browse/FLINK-22934

[jira] [Created] (FLINK-22921) SQL Client can't resolve the escape of "'" correctly.

2021-06-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22921: --- Summary: SQL Client can't resolve the escape of "'" correctly. Key: FLINK-22921 URL: https://issues.apache.org/jira/browse/FLINK-22921 Project: F

[jira] [Created] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-06-05 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22885: --- Summary: Support 'SHOW COLUMNS'. Key: FLINK-22885 URL: https://issues.apache.org/jira/browse/FLINK-22885 Project: Flink Issue Type: I

[jira] [Created] (FLINK-22860) Supplementary 'HELP' command prompt message for SQL-Cli.

2021-06-02 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22860: --- Summary: Supplementary 'HELP' command prompt message for SQL-Cli. Key: FLINK-22860 URL: https://issues.apache.org/jira/browse/FLINK-22860 Project: Flink

[jira] [Created] (FLINK-22855) Translate the 'Overview of Python API' page into Chinese.

2021-06-02 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22855: --- Summary: Translate the 'Overview of Python API' page into Chinese. Key: FLINK-22855 URL: https://issues.apache.org/jira/browse/FLINK-22855 Proj

[jira] [Created] (FLINK-22854) Translate 'Apache Flink Documentation' index page to Chinese

2021-06-02 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22854: --- Summary: Translate 'Apache Flink Documentation' index page to Chinese Key: FLINK-22854 URL: https://issues.apache.org/jira/browse/FLINK-22854 Proj

Re:[VOTE] Release 1.13.1, release candidate #1

2021-05-26 Thread Roc Marshal
Hi Dawid, +1. Thank you for driving this release. I checked the following things: - downloaded and build source code - started cluster and succeed in jobs (flink applications defined by me) - checked diff of pom files between 1.13.1-rc1 and 1.13.0 Best, Roc. 在 2021-05-25

[jira] [Created] (FLINK-22609) Generify AllVerticesIterator.java

2021-05-08 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22609: --- Summary: Generify AllVerticesIterator.java Key: FLINK-22609 URL: https://issues.apache.org/jira/browse/FLINK-22609 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-22353) Introduce CPU metrics in TaskManager and JobManager

2021-04-19 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22353: --- Summary: Introduce CPU metrics in TaskManager and JobManager Key: FLINK-22353 URL: https://issues.apache.org/jira/browse/FLINK-22353 Project: Flink Issue Type

confluence permission apply

2021-04-16 Thread Roc Marshal
Hi, I want to contribute to Flink. Would someone please give me the confluence permission ? My Confluence ID is roc-marshal. Full name is RocMarshal. My JIRA ID is RocMarshal. Thank you . Best, Roc.

[jira] [Created] (FLINK-22296) Introduce Preconditions-util into Python API

2021-04-15 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-22296: --- Summary: Introduce Preconditions-util into Python API Key: FLINK-22296 URL: https://issues.apache.org/jira/browse/FLINK-22296 Project: Flink Issue Type

[jira] [Created] (FLINK-21042) Correct the error in the code example in page 'aggregate-functions'.

2021-01-19 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-21042: --- Summary: Correct the error in the code example in page 'aggregate-functions'. Key: FLINK-21042 URL: https://issues.apache.org/jira/browse/FLINK-21042 Proj

[jira] [Created] (FLINK-19394) Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese

2020-09-24 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-19394: --- Summary: Translate the 'Monitoring Checkpointing' page of 'Debugging & Monitoring' into Chinese Key: FLINK-19394 URL: https://issues.apache.org

[jira] [Created] (FLINK-19393) Translate the 'SQL Hints' page of 'Table API & SQL' into Chinese

2020-09-24 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-19393: --- Summary: Translate the 'SQL Hints' page of 'Table API & SQL' into Chinese Key: FLINK-19393 URL: https://issues.apache.org/jira/browse/FLINK-19393

Does Flink support such a feature currently?

2020-09-22 Thread Roc Marshal
Hi, everyone! When using flink sql DDL to create a mysql mapping table, does flink support the automatic rendering of the target table schema if we put no column-names in `create table table_name_mapping2mysql () with (...)`? If this feature is not supported, is it necessary

[jira] [Created] (FLINK-19043) Translate the page 'Logging' of 'Debugging & Monitoring' into Chinese

2020-08-25 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-19043: --- Summary: Translate the page 'Logging' of 'Debugging & Monitoring' into Chinese Key: FLINK-19043 URL: https://issues.apache.org/jira/browse/FLINK-19043

[jira] [Created] (FLINK-19036) Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese

2020-08-24 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-19036: --- Summary: Translate page 'Application Profiling & Debugging' of 'Debugging & Monitoring' into Chinese Key: FLINK-19036 URL: https://issues.apache

[jira] [Created] (FLINK-18975) Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese

2020-08-17 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18975: --- Summary: Translate the 'Execution Plans' page of "Application Development's Managing Execution" into Chinese Key: FLINK-18975 URL: https://issues.apache.or

[jira] [Created] (FLINK-18974) Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese

2020-08-17 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18974: --- Summary: Translate the 'User-Defined Functions' page of "Application Development's DataStream API" into Chinese Key: FLINK-18974 URL: https://issues.apa

[jira] [Created] (FLINK-18973) Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese

2020-08-17 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18973: --- Summary: Translate the 'History Server' page of 'Debugging & Monitoring' into Chinese Key: FLINK-18973 URL: https://issues.apache.org/jira/browse/FLINK-18

Re:[ANNOUNCE] New Flink Committer: David Anderson

2020-08-12 Thread Roc Marshal
Congratulations David! Best, Roc Marshal. At 2020-08-12 15:50:47, "Robert Metzger" wrote: >Hi everyone, > >On behalf of the PMC, I'm very happy to announce David Anderson as a new >Apache >Flink committer. > >David has been a Flink communi

[jira] [Created] (FLINK-18855) Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese

2020-08-07 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18855: --- Summary: Translate the "Cluster Execution" page of "Application Development's DataSet API" into Chinese Key: FLINK-18855 URL: https://issues.apache.or

[jira] [Created] (FLINK-18854) Translate the 'API Migration Guides' page of 'Application Development' into Chinese

2020-08-07 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18854: --- Summary: Translate the 'API Migration Guides' page of 'Application Development' into Chinese Key: FLINK-18854 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-18814) Translate 'Side Outputs' page of 'DataStream API' into Chinese

2020-08-04 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18814: --- Summary: Translate 'Side Outputs' page of 'DataStream API' into Chinese Key: FLINK-18814 URL: https://issues.apache.org/jira/browse/FLINK-18814

[jira] [Created] (FLINK-18813) Translate 'Local Installation' page of 'Try Flink' into Chinese

2020-08-04 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18813: --- Summary: Translate 'Local Installation' page of 'Try Flink' into Chinese Key: FLINK-18813 URL: https://issues.apache.org/jira/browse/FLINK-18813

[jira] [Created] (FLINK-18798) Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese

2020-08-02 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18798: --- Summary: Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese Key: FLINK-18798 URL: https://issues.apache

[jira] [Created] (FLINK-18505) correct the content of 'sourceSinks.zh.md'

2020-07-06 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18505: --- Summary: correct the content of 'sourceSinks.zh.md' Key: FLINK-18505 URL: https://issues.apache.org/jira/browse/FLINK-18505 Project: Flink Issue

[jira] [Created] (FLINK-18502) Add 'legacySourceSinks.zh.md' into the 'flink/docs/dev/table' directory

2020-07-06 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18502: --- Summary: Add 'legacySourceSinks.zh.md' into the 'flink/docs/dev/table' directory Key: FLINK-18502 URL: https://issues.apache.org/jira/browse/FLINK-18502

[jira] [Created] (FLINK-18457) Fix invalid links in "Detecting Patterns" page of "Streaming Concepts"

2020-07-01 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18457: --- Summary: Fix invalid links in "Detecting Patterns" page of "Streaming Concepts" Key: FLINK-18457 URL: https://issues.apache.org/jira/browse/FLINK-18457

Re: [Reminder] Prefer {% link %} tag in documentation

2020-06-30 Thread Roc Marshal
Hi, David. I am sorry for late reply. I will check pages which were translated by me according to your reply. Thank you so much. Best, Roc. | | Roc Marshal | | 邮箱:flin...@126.com | 签名由 网易邮箱大师 定制 On 06/30/2020 15:20, David Anderson wrote: Yes, it makes sense to rewrite img tags and

Re:Re: [Reminder] Prefer {% link %} tag in documentation

2020-06-26 Thread Roc Marshal
Hi everyone, There is a question about optimizing and translating documents. If the link target is an internal image, does the link method need to be set as the same way that link target is other pages. Such as : Should """ src="{{ site.baseurl }}/fig/stream_barriers.svg" """ be written

[jira] [Created] (FLINK-18423) Fix Prefer tag in document "Detecting Patterns" page of "Streaming Concepts"

2020-06-23 Thread Roc Marshal (Jira)
Roc Marshal created FLINK-18423: --- Summary: Fix Prefer tag in document "Detecting Patterns" page of "Streaming Concepts" Key: FLINK-18423 URL: https://issues.apache.org/jira/browse/FLINK-18423

Re:Re: Could someone help me to review PR[12727]?

2020-06-23 Thread Roc Marshal
Hi, @klion26.I have made some changes based on your suggestions, which is very helpful for improvement.And could you check it again for me if you have free time ?Thank you so much. 在 2020-06-23 14:10:48,"Congxian Qiu" 写道: >Hi Roc > >Thanks for your contribution. I've reviewed it and gave some c

Could someone help me to review PR[12727]?

2020-06-22 Thread Roc Marshal
Hi, all. I have finished the first draft of this translation(https://github.com/apache/flink/pull/12727). Could someone please review it for me? Thank you. Best Roc.

Request of Checking PR [FLINK-17291]

2020-05-05 Thread Roc Marshal
Hi, @klion26 . I have completed the translation of the page in PR(https://github.com/apache/flink/pull/11979) and made corresponding improvements according to the suggestions of community members. If you have free time, would you please check it for me? Thank you for your attention. Best,

Re: [DISCUSS] Introduce The Batch/Stream ExecutionEnvironment in Yarn mode

2020-05-05 Thread Roc Marshal
Sorry, I confused JIRA with email. The Attachment link: https://gitee.com/RocMarshal/resources4link/blob/master/README.md The JIRA ID: FLINK-17472 The JIRA link: https://issues.apache.org/jira/plugins/servlet/mobile#issue/FLINK-17472 Best, Roc | | Roc Marshal | | 邮箱:flin

Re:Re: [DISCUSS] Introduce The Batch/Stream ExecutionEnvironment in Yarn mode

2020-05-05 Thread Roc Marshal
rted https://link.medium.com/oppqD6dIg5 >> <https://t.co/PTouUYYTrv?amp=1> 2) Batch https://link.medium.com/3qumbwRIg5 >> <https://t.co/Yo9QAY0Joj?amp=1> 3) Streaming https:// >> link.medium.com/RBHa2lTIg5 <https://t.co/sUapN40tvI?amp=1> 4) Advanced >> usag

Re: The Questions about Submitting PR

2020-05-04 Thread Roc Marshal
Till, Thank you for your answers. Best regards, Roc | | Roc Marshal | | 邮箱:flin...@126.com | 签名由 网易邮箱大师 定制 On 05/05/2020 14:25, Till Rohrmann wrote: Hi Roc, afaik it can take a bit of time until the status of the PR is updated in accordance with the AZP results. As of a couple of days ago

The Questions about Submitting PR

2020-05-04 Thread Roc Marshal
attention. Best, Roc Marshal | | Roc Marshal | | 邮箱:flin...@126.com | 签名由 网易邮箱大师 定制

[DISCUSS] Introduce The Batch/Stream ExecutionEnvironment in Yarn mode

2020-05-01 Thread Roc Marshal
Hi all. Expect to have such a mode of submission. Build the job directly in the Environment, and then submit the job in yarn mode. Just like RemoteStreamEnvironment, as long as you specify the parameters of the yarn cluster (host, port) or yarn configuration directory and HADOOP_USER_NAME