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

2020-05-17 Thread Robert Metzger (Jira)
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: B

Re: [DISCUSS] FLIP-84 Feedback Summary

2020-05-17 Thread Kurt Young
+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 FLINK-14807[1

Re: [DISCUSS] FLIP-84 Feedback Summary

2020-05-17 Thread Jingsong Li
+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. > >

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

2020-05-17 Thread Robert Metzger (Jira)
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: Fl

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

2020-05-17 Thread Robert Metzger (Jira)
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: https://issues.apache.org/jira/browse/FLIN

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

2020-05-17 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17772: -- Summary: test_pandas_udf.py: NoClassDefFoundError RowDataArrowPythonScalarFunctionRunner Key: FLINK-17772 URL: https://issues.apache.org/jira/browse/FLINK-17772 P

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

2020-05-17 Thread Aljoscha Krettek (Jira)
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-17774) Support all kinds of changes for select result

2020-05-17 Thread godfrey he (Jira)
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: Sub-ta

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

2020-05-17 Thread Nikola (Jira)
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 Co

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

2020-05-17 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17776: Summary: Add documentation for DDL&DML in hive dialect Key: FLINK-17776 URL: https://issues.apache.org/jira/browse/FLINK-17776 Project: Flink Issue Type: Sub

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

2020-05-17 Thread Gary Yao (Jira)
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-17778) [umbrella] FileSystemTableFactory improve

2020-05-17 Thread Jingsong Lee (Jira)
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-17779) Orc file format support filter push down

2020-05-17 Thread Jingsong Lee (Jira)
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: Sub-task

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

2020-05-17 Thread Arvid Heise (Jira)
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 Typ

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

2020-05-17 Thread Stephan Ewen (Jira)
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

Re: [ANNOUNCE] Apache Flink 1.10.1 released

2020-05-17 Thread Zhu Zhu
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 and

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

2020-05-17 Thread Jingsong Lee (Jira)
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

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

2020-05-17 Thread Jingsong Lee (Jira)
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 Type

Re: [ANNOUNCE] Apache Flink 1.10.1 released

2020-05-17 Thread Leonard Xu
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 mailto:libenc...@gmail.co

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

2020-05-17 Thread Leonard Xu
+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 >> Subjec

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

2020-05-17 Thread Jingsong Lee (Jira)
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: Impr

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

2020-05-17 Thread Jingsong Lee (Jira)
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 Ty

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

2020-05-17 Thread Rui Li (Jira)
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: Ta

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

2020-05-17 Thread Xintong Song
+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) > >> > >>

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

2020-05-17 Thread Tzu-Li (Gordon) Tai
+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, > >

Ask questions

2020-05-17 Thread 魏烽
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 foll

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

2020-05-17 Thread Aljoscha Krettek
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

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

2020-05-17 Thread Yuan Mei
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, ppts,

flink setup errors

2020-05-17 Thread Prasanna kumar
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

[jira] [Created] (FLINK-17787) BucketStateSerializerTest fails on output mismatch

2020-05-17 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17787: -- Summary: BucketStateSerializerTest fails on output mismatch Key: FLINK-17787 URL: https://issues.apache.org/jira/browse/FLINK-17787 Project: Flink Issue

[jira] [Created] (FLINK-17788) scala shell in yarn mode is broken

2020-05-17 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17788: -- Summary: scala shell in yarn mode is broken Key: FLINK-17788 URL: https://issues.apache.org/jira/browse/FLINK-17788 Project: Flink Issue Type: Bug Comp

Re: flink setup errors

2020-05-17 Thread Chesnay Schepler
This looks like a connectivity issue to maven central. If you follow the http address you also get a 501 HTTPS required error, so maybe adjust the URL in your settings.xml to use https. On 18/05/2020 07:12, Prasanna kumar wrote: I tried to setup flink locally as mentioned in the link https://

Re: [ANNOUNCE] Apache Flink 1.10.1 released

2020-05-17 Thread Yangze Guo
Thanks Yu for the great job. Congrats everyone who made this release possible. Best, Yangze Guo On Mon, May 18, 2020 at 10:57 AM Leonard Xu wrote: > > > Thanks Yu for being the release manager, and everyone else who made this > possible. > > Best, > Leonard Xu > > 在 2020年5月18日,10:43,Zhu Zhu 写道:

Re: Running individual test files taking too long

2020-05-17 Thread Chesnay Schepler
When IntelliJ runs a test it executes a new java process and passes the required class path as a semi-colon created list. The class path contains the absolute path to various jars in your maven .m2 repository. Depending on what this path is, that command might become quite long, enough to no lon

[jira] [Created] (FLINK-17789) DelegatingConfiguration should remove prefix instead of add prefix in toMap

2020-05-17 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17789: Summary: DelegatingConfiguration should remove prefix instead of add prefix in toMap Key: FLINK-17789 URL: https://issues.apache.org/jira/browse/FLINK-17789 Project:

[jira] [Created] (FLINK-17790) flink-connector-kafka-base does not compile on Java11

2020-05-17 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17790: -- Summary: flink-connector-kafka-base does not compile on Java11 Key: FLINK-17790 URL: https://issues.apache.org/jira/browse/FLINK-17790 Project: Flink Iss

Re: Ask questions

2020-05-17 Thread Chesnay Schepler
Image attachments do not work on this mailing list; please re-send the question with the code as text. On 18/05/2020 06:51, 魏烽 wrote: 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 opera

[jira] [Created] (FLINK-17791) Combine collecting sink and iterator to support collecting query results under all execution and network environments

2020-05-17 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-17791: --- Summary: Combine collecting sink and iterator to support collecting query results under all execution and network environments Key: FLINK-17791 URL: https://issues.apache.org/jira/b