[jira] [Created] (FLINK-17567) Create a dedicated Python directory in release directory to place Python-related source and binary packages

2020-05-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17567: Summary: Create a dedicated Python directory in release directory to place Python-related source and binary packages Key: FLINK-17567 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-17568) Task may consume data after checkpoint barrier before performing checkpoint for unaligned checkpoint

2020-05-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-17568: --- Summary: Task may consume data after checkpoint barrier before performing checkpoint for unaligned checkpoint Key: FLINK-17568 URL: https://issues.apache.org/jira/browse/FLINK-17568

[jira] [Created] (FLINK-17569) to support ViewFileSystem when wait lease revoke of hadoop filesystem

2020-05-08 Thread konwu (Jira)
konwu created FLINK-17569: - Summary: to support ViewFileSystem when wait lease revoke of hadoop filesystem Key: FLINK-17569 URL: https://issues.apache.org/jira/browse/FLINK-17569 Project: Flink Issu

[jira] [Created] (FLINK-17570) BatchTableEnvironment#fromValues(Object... values) causes StackOverflowError

2020-05-08 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17570: - Summary: BatchTableEnvironment#fromValues(Object... values) causes StackOverflowError Key: FLINK-17570 URL: https://issues.apache.org/jira/browse/FLINK-17570 Project: Flin

[jira] [Created] (FLINK-17571) A better way to show the files used in currently checkpoints

2020-05-08 Thread Congxian Qiu(klion26) (Jira)
Congxian Qiu(klion26) created FLINK-17571: - Summary: A better way to show the files used in currently checkpoints Key: FLINK-17571 URL: https://issues.apache.org/jira/browse/FLINK-17571 Projec

[jira] [Created] (FLINK-17572) Remove checkpoint alignment buffered metric from webui

2020-05-08 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-17572: --- Summary: Remove checkpoint alignment buffered metric from webui Key: FLINK-17572 URL: https://issues.apache.org/jira/browse/FLINK-17572 Project: Flink Issue Ty

[jira] [Created] (FLINK-17573) There is duplicate source data in ProcessWindowFunction

2020-05-08 Thread Tammy zhang (Jira)
Tammy zhang created FLINK-17573: --- Summary: There is duplicate source data in ProcessWindowFunction Key: FLINK-17573 URL: https://issues.apache.org/jira/browse/FLINK-17573 Project: Flink Issue T

[jira] [Created] (FLINK-17574) Deduplicate the process execution logic in Flink

2020-05-08 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17574: -- Summary: Deduplicate the process execution logic in Flink Key: FLINK-17574 URL: https://issues.apache.org/jira/browse/FLINK-17574 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

2020-05-08 Thread Maxim Malykhin (Jira)
Maxim Malykhin created FLINK-17575: -- Summary: KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption. Key: FLINK-17575 URL: h

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

2020-05-08 Thread Dian Fu (Jira)
Dian Fu created FLINK-17576: --- Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are instable Key: FLINK-17576 URL: https://issues.apache.org/jira/browse/FLINK-17576 Project: Flink Issue Typ

[jira] [Created] (FLINK-17577) SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter

2020-05-08 Thread Danny Chen (Jira)
Danny Chen created FLINK-17577: -- Summary: SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter Key: FLINK-17577 URL: https://issues.apache.org/jira/browse/FLINK-17577 Pr

[jira] [Created] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

2020-05-08 Thread Tom Wells (Jira)
Tom Wells created FLINK-17578: - Summary: Union of 2 SideOutputs behaviour incorrect Key: FLINK-17578 URL: https://issues.apache.org/jira/browse/FLINK-17578 Project: Flink Issue Type: Bug

Re: What is the RocksDB local directory in flink checkpointing?

2020-05-08 Thread Yun Tang
Hi LakeShen You could refer to [1] and [2] to know the temporary directory in YARN, the related log could be "Setting directories for temporary files to: " or "Overriding Fink's temporary file directories with those specified in the Flink config: " [1] https://github.com/apache/flink/blob/0dd

[jira] [Created] (FLINK-17579) Set the resource id of taskexecutor from environment variable if possible in standalone mode

2020-05-08 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17579: -- Summary: Set the resource id of taskexecutor from environment variable if possible in standalone mode Key: FLINK-17579 URL: https://issues.apache.org/jira/browse/FLINK-17579

Re: What's the best practice to determine whether a job has finished or not?

2020-05-08 Thread Kurt Young
+dev Best, Kurt On Fri, May 8, 2020 at 3:35 PM Caizhi Weng wrote: > Hi Jeff, > > Thanks for the response. However I'm using executeAsync so that I can run > the job asynchronously and get a JobClient to monitor the job. JobListener > only works for synchronous execute method. Is there other w

[jira] [Created] (FLINK-17580) NPE in unaligned checkpoint for EndOfPartition events

2020-05-08 Thread Arvid Heise (Jira)
Arvid Heise created FLINK-17580: --- Summary: NPE in unaligned checkpoint for EndOfPartition events Key: FLINK-17580 URL: https://issues.apache.org/jira/browse/FLINK-17580 Project: Flink Issue Typ

[jira] [Created] (FLINK-17581) Update translation of S3 documentation

2020-05-08 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17581: -- Summary: Update translation of S3 documentation Key: FLINK-17581 URL: https://issues.apache.org/jira/browse/FLINK-17581 Project: Flink Issue Type: Task

Re: [VOTE] Release 1.10.1, release candidate #3

2020-05-08 Thread Robert Metzger
Thanks a lot for creating another RC! +1 (binding) - checked diff to last RC: https://github.com/apache/flink/compare/release-1.10.1-rc2...release-1.10.1-rc3 - kinesis dependency change is properly documented - started Flink locally (on Java11 :) ) - seems to be build off the specified commi

[jira] [Created] (FLINK-17582) Update quickstarts to use universal Kafka connector

2020-05-08 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-17582: Summary: Update quickstarts to use universal Kafka connector Key: FLINK-17582 URL: https://issues.apache.org/jira/browse/FLINK-17582 Project: Flink Issue Typ

[jira] [Created] (FLINK-17583) Allow option to store a savepoint's _metadata file separate from its data files

2020-05-08 Thread Steve Bairos (Jira)
Steve Bairos created FLINK-17583: Summary: Allow option to store a savepoint's _metadata file separate from its data files Key: FLINK-17583 URL: https://issues.apache.org/jira/browse/FLINK-17583 Proje

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

2020-05-08 Thread Fabian Hueske
I think we need the TEMPORAL TABLE syntax because they are conceptually more than just regular tables. In a addition to being a table that always holds the latest values (and can thereby serve as input to a continuous query), the system also needs to track the history of such a table to be able to

[jira] [Created] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch

2020-05-08 Thread Yaron Shani (Jira)
Yaron Shani created FLINK-17584: --- Summary: disableAutoTypeRegistration option does not work with Streaming API, only with Batch Key: FLINK-17584 URL: https://issues.apache.org/jira/browse/FLINK-17584 Pr

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

2020-05-08 Thread Kurt Young
All tables being described by Flink's DDL are dynamic tables. But dynamic table is more like a logical concept, but not physical things. Physically, dynamic table has two different forms, one is a materialized table which changes over time (e.g. Database table, HBase table), another form is stream

Would you please give me the permission as a contributor

2020-05-08 Thread ??????????
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is limaowei66.

Re: Would you please give me the permission as a contributor

2020-05-08 Thread Yangze Guo
Hi Maowei, Welcome to the community! Currently, there are no special permissions required to contribute to Flink. Just ping a committer if you want to work on some JIRA ticket and someone will assign the ticket to you. Here is some information about how to contribute to Flink [1]. [1] https://fl

[jira] [Created] (FLINK-17585) "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF

2020-05-08 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17585: - Summary: "PythonProgramOptions" changes the entry point class when user submit a Java sql job which contains Python UDF Key: FLINK-17585 URL: https://issues.apache.org/jira/browse/FLIN

[jira] [Created] (FLINK-17586) Due to the new behavior of the table planner the Python dependency management command line options does not work

2020-05-08 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-17586: - Summary: Due to the new behavior of the table planner the Python dependency management command line options does not work Key: FLINK-17586 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-17587) Filesystem streaming sink support partition commit (success file)

2020-05-08 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-17587: Summary: Filesystem streaming sink support partition commit (success file) Key: FLINK-17587 URL: https://issues.apache.org/jira/browse/FLINK-17587 Project: Flink

[jira] [Created] (FLINK-17588) Throw exception when hadoop jar is missing in flink scala's yarn mode.

2020-05-08 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17588: -- Summary: Throw exception when hadoop jar is missing in flink scala's yarn mode. Key: FLINK-17588 URL: https://issues.apache.org/jira/browse/FLINK-17588 Project: Flink

Re: [VOTE] Release 1.10.1, release candidate #3

2020-05-08 Thread Thomas Weise
Thanks for the RC! +1 (binding) - repeated benchmark runs On Fri, May 8, 2020 at 10:52 AM Robert Metzger wrote: > Thanks a lot for creating another RC! > > +1 (binding) > > - checked diff to last RC: > > https://github.com/apache/flink/compare/release-1.10.1-rc2...release-1.10.1-rc3 > - kin

[jira] [Created] (FLINK-17589) Extend StreamingFileSink to Support Streaming Hive Connector

2020-05-08 Thread Yun Gao (Jira)
Yun Gao created FLINK-17589: --- Summary: Extend StreamingFileSink to Support Streaming Hive Connector Key: FLINK-17589 URL: https://issues.apache.org/jira/browse/FLINK-17589 Project: Flink Issue Typ

[jira] [Created] (FLINK-17590) Add Bucket lifecycle listener to support acquiring bucket state

2020-05-08 Thread Yun Gao (Jira)
Yun Gao created FLINK-17590: --- Summary: Add Bucket lifecycle listener to support acquiring bucket state Key: FLINK-17590 URL: https://issues.apache.org/jira/browse/FLINK-17590 Project: Flink Issue

[jira] [Created] (FLINK-17591) TableEnvironmentITCase.testExecuteSqlAndToDataStream failed

2020-05-08 Thread Jark Wu (Jira)
Jark Wu created FLINK-17591: --- Summary: TableEnvironmentITCase.testExecuteSqlAndToDataStream failed Key: FLINK-17591 URL: https://issues.apache.org/jira/browse/FLINK-17591 Project: Flink Issue Type

[jira] [Created] (FLINK-17592) flink-table-planner doesn't compile on Scala 2.12

2020-05-08 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-17592: -- Summary: flink-table-planner doesn't compile on Scala 2.12 Key: FLINK-17592 URL: https://issues.apache.org/jira/browse/FLINK-17592 Project: Flink Issue T