flink setup errors

I tried to setup flink locally as mentioned in the link https://ci.apache.org/projects/flink/flink-docs-stable/dev/projectsetup/java_api_quickstart.html . I ended getting the following error [INFO] Generating project in Interactive mode [WARNING] No archetype found in remote catalog. Defaulting

Re: [DISCUSS] Add a material web page under "https://flink.apache.org/"

Thanks, everyone for the feedback and suggestions! I was thinking about whether to call the external site as " flink-learning.org"? If nobody disagrees upon this whole idea, we will start with a demo of the least functionalities discussed - several collections of learning materials (videos,

[RESULT][VOTE] FLIP-126: FLIP-126: Unify (and separate) Watermark Assigners

Hi all, The voting time for FLIP-126 [1] has passed. I'm closing the vote now. Including my implicit vote, there were 3 + 1 votes, 3 of which are binding: - Stephan (binding) - Dawid (binding) - Aljoscha (binding) There were no -1 votes. Thus, changes have been accepted. I'll update the FLIP

Ask questions

Hello： I have a question and I really want to ask everyone。 I submitted a flink batch processing task in DolphinShceduler. After the flink task, the sql operation was performed. The sql operation failed, but the flink task was successful. How can I solve this problem? The code is roughly as

Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary compatible across bug fix releases (x.y.u and x.y.v)

+1 On Mon, May 18, 2020 at 11:47 AM Xintong Song wrote: > +1 (non-binding) > > Thank you~ > > Xintong Song > > > > On Mon, May 18, 2020 at 10:58 AM Leonard Xu wrote: > > > +1 (non-binding) > > > > Best, > > Leonard Xu > > > 在 2020年5月17日，00:30，Zhu Zhu 写道： > > > > > > +1 > > > > > > Thanks, > >

Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary compatible across bug fix releases (x.y.u and x.y.v)

+1 (non-binding) Thank you~ Xintong Song On Mon, May 18, 2020 at 10:58 AM Leonard Xu wrote: > +1 (non-binding) > > Best, > Leonard Xu > > 在 2020年5月17日，00:30，Zhu Zhu 写道： > > > > +1 > > > > Thanks, > > Zhu Zhu > > > > Yun Tang 于2020年5月16日周六 下午11:18写道： > > > >> > >> +1 (non-binding) > >> >

[jira] [Created] (FLINK-17786) Cannot switch dialect in SQL CLI

Rui Li created FLINK-17786: -- Summary: Cannot switch dialect in SQL CLI Key: FLINK-17786 URL: https://issues.apache.org/jira/browse/FLINK-17786 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-17785) Refactor orc shim to create a OrcShimFactory in hive

Jingsong Lee created FLINK-17785: Summary: Refactor orc shim to create a OrcShimFactory in hive Key: FLINK-17785 URL: https://issues.apache.org/jira/browse/FLINK-17785 Project: Flink Issue

[jira] [Created] (FLINK-17784) Better detection for parquet and orc in hive

Jingsong Lee created FLINK-17784: Summary: Better detection for parquet and orc in hive Key: FLINK-17784 URL: https://issues.apache.org/jira/browse/FLINK-17784 Project: Flink Issue Type:

Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary compatible across bug fix releases (x.y.u and x.y.v)

+1 (non-binding) Best, Leonard Xu > 在 2020年5月17日，00:30，Zhu Zhu 写道： > > +1 > > Thanks, > Zhu Zhu > > Yun Tang 于2020年5月16日周六 下午11:18写道： > >> >> +1 (non-binding) >> >> Yun Tang >> >> From: Benchao Li >> Sent: Saturday, May 16, 2020 22:00 >> To: dev >>

Re: [ANNOUNCE] Apache Flink 1.10.1 released

Thanks Yu for being the release manager, and everyone else who made this possible. Best, Leonard Xu > 在 2020年5月18日，10:43，Zhu Zhu 写道： > > Thanks Yu for being the release manager. Thanks everyone who made this > release possible! > > Thanks, > Zhu Zhu > > Benchao Li

[jira] [Created] (FLINK-17783) Add array,map,row types support for orc row writer

Jingsong Lee created FLINK-17783: Summary: Add array,map,row types support for orc row writer Key: FLINK-17783 URL: https://issues.apache.org/jira/browse/FLINK-17783 Project: Flink Issue

[jira] [Created] (FLINK-17782) Add array,map,row types support for parquet row writer

Jingsong Lee created FLINK-17782: Summary: Add array,map,row types support for parquet row writer Key: FLINK-17782 URL: https://issues.apache.org/jira/browse/FLINK-17782 Project: Flink Issue

Re: [ANNOUNCE] Apache Flink 1.10.1 released

Thanks Yu for being the release manager. Thanks everyone who made this release possible! Thanks, Zhu Zhu Benchao Li 于2020年5月15日周五 下午7:51写道： > Thanks Yu for the great work, and everyone else who made this possible. > > Dian Fu 于2020年5月15日周五 下午6:55写道： > >> Thanks Yu for managing this release

[jira] [Created] (FLINK-17781) OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread

Stephan Ewen created FLINK-17781: Summary: OperatorCoordinator Context must support calls from thread other than JobMaster Main Thread Key: FLINK-17781 URL: https://issues.apache.org/jira/browse/FLINK-17781

[jira] [Created] (FLINK-17780) Add task name to log statements of ChannelStateWriter

Arvid Heise created FLINK-17780: --- Summary: Add task name to log statements of ChannelStateWriter Key: FLINK-17780 URL: https://issues.apache.org/jira/browse/FLINK-17780 Project: Flink Issue

[jira] [Created] (FLINK-17779) Orc file format support filter push down

Jingsong Lee created FLINK-17779: Summary: Orc file format support filter push down Key: FLINK-17779 URL: https://issues.apache.org/jira/browse/FLINK-17779 Project: Flink Issue Type:

[jira] [Created] (FLINK-17778) [umbrella] FileSystemTableFactory improve

Jingsong Lee created FLINK-17778: Summary: [umbrella] FileSystemTableFactory improve Key: FLINK-17778 URL: https://issues.apache.org/jira/browse/FLINK-17778 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17777) Make Mesos Jepsen Tests pass with Hadoop-free Flink

Gary Yao created FLINK-1: Summary: Make Mesos Jepsen Tests pass with Hadoop-free Flink Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17776) Add documentation for DDL in hive dialect

Jingsong Lee created FLINK-17776: Summary: Add documentation for DDL in hive dialect Key: FLINK-17776 URL: https://issues.apache.org/jira/browse/FLINK-17776 Project: Flink Issue Type:

[jira] [Created] (FLINK-17775) Cannot set batch job name when using collect

Nikola created FLINK-17775: -- Summary: Cannot set batch job name when using collect Key: FLINK-17775 URL: https://issues.apache.org/jira/browse/FLINK-17775 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17774) Support all kinds of changes for select result

godfrey he created FLINK-17774: -- Summary: Support all kinds of changes for select result Key: FLINK-17774 URL: https://issues.apache.org/jira/browse/FLINK-17774 Project: Flink Issue Type:

[jira] [Created] (FLINK-17773) Update documentation for new WatermarkGenerator/WatermarkStrategies

Aljoscha Krettek created FLINK-17773: Summary: Update documentation for new WatermarkGenerator/WatermarkStrategies Key: FLINK-17773 URL: https://issues.apache.org/jira/browse/FLINK-17773 Project:

[jira] [Created] (FLINK-17772) test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner

Robert Metzger created FLINK-17772: -- Summary: test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner Key: FLINK-17772 URL: https://issues.apache.org/jira/browse/FLINK-17772

[jira] [Created] (FLINK-17771) "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11

Robert Metzger created FLINK-17771: -- Summary: "PyFlink end-to-end test" fails with "The output result: [] is not as expected: [2, 3, 4]!" on Java11 Key: FLINK-17771 URL:

[jira] [Created] (FLINK-17770) TPC-DS end-to-end test (Blink planner) fails with AskTimeoutException

Robert Metzger created FLINK-17770: -- Summary: TPC-DS end-to-end test (Blink planner) fails with AskTimeoutException Key: FLINK-17770 URL: https://issues.apache.org/jira/browse/FLINK-17770 Project:

Re: [DISCUSS] FLIP-84 Feedback Summary

+1 Best, Jingsong Lee On Sun, May 17, 2020 at 3:42 PM Kurt Young wrote: > +1 from my side. > > Best, > Kurt > > > On Sun, May 17, 2020 at 12:41 PM godfrey he wrote: > > > hi everyone, > > > > I would like to bring up another topic about the return value of > > TableResult#collect() method. >

Re: [DISCUSS] FLIP-84 Feedback Summary

+1 from my side. Best, Kurt On Sun, May 17, 2020 at 12:41 PM godfrey he wrote: > hi everyone, > > I would like to bring up another topic about the return value of > TableResult#collect() method. > Currently, the return type is `Iterator`, we meet some problems when > implementing

[jira] [Created] (FLINK-17769) Wrong order of log events on a task failure

Robert Metzger created FLINK-17769: -- Summary: Wrong order of log events on a task failure Key: FLINK-17769 URL: https://issues.apache.org/jira/browse/FLINK-17769 Project: Flink Issue Type: