[jira] [Created] (FLINK-20340) Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter

2020-11-24 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20340: Summary: Use StreamFormat instead of DelimitedInputFormat in DeserializationSchemaAdapter Key: FLINK-20340 URL: https://issues.apache.org/jira/browse/FLINK-20340

[jira] [Created] (FLINK-20339) `FileWriter` support to load StreamingFileSink's state.

2020-11-24 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20339: - Summary: `FileWriter` support to load StreamingFileSink's state. Key: FLINK-20339 URL: https://issues.apache.org/jira/browse/FLINK-20339 Project: Flink Issue

[jira] [Created] (FLINK-20338) Make the SinkWriter load previous sink's state.

2020-11-24 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20338: - Summary: Make the SinkWriter load previous sink's state. Key: FLINK-20338 URL: https://issues.apache.org/jira/browse/FLINK-20338 Project: Flink Issue Type:

[jira] [Created] (FLINK-20337) Make migrate `StreamingFileSink` to `FileSink` possible

2020-11-24 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20337: - Summary: Make migrate `StreamingFileSink` to `FileSink` possible Key: FLINK-20337 URL: https://issues.apache.org/jira/browse/FLINK-20337 Project: Flink Issue

[jira] [Created] (FLINK-20336) RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types

2020-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20336: --- Summary: RequestReplyFunction should not silently ignore UNRECOGNIZED state value mutations types Key: FLINK-20336 URL:

[jira] [Created] (FLINK-20335) Remove support for eager state specifications in module YAML definitions

2020-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20335: --- Summary: Remove support for eager state specifications in module YAML definitions Key: FLINK-20335 URL: https://issues.apache.org/jira/browse/FLINK-20335

[jira] [Created] (FLINK-20334) Introduce function endpoint path templating in module YAML specifications

2020-11-24 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-20334: --- Summary: Introduce function endpoint path templating in module YAML specifications Key: FLINK-20334 URL: https://issues.apache.org/jira/browse/FLINK-20334

[jira] [Created] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

2020-11-24 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-20333: - Summary: Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs. Key: FLINK-20333 URL: https://issues.apache.org/jira/browse/FLINK-20333

[jira] [Created] (FLINK-20332) Add workers recovered from previous attempt to pending resources

2020-11-24 Thread Xintong Song (Jira)
Xintong Song created FLINK-20332: Summary: Add workers recovered from previous attempt to pending resources Key: FLINK-20332 URL: https://issues.apache.org/jira/browse/FLINK-20332 Project: Flink

[jira] [Created] (FLINK-20331) UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)"

2020-11-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-20331: --- Summary: UnalignedCheckpointITCase.execute failed with "Sequence number for checkpoint 20 is not known (it was likely been overwritten by a newer checkpoint 21)" Key: FLINK-20331 URL:

[jira] [Created] (FLINK-20330) Flink connector has error in support hive external tables (hbase or es)

2020-11-24 Thread liu (Jira)
liu created FLINK-20330: --- Summary: Flink connector has error in support hive external tables (hbase or es) Key: FLINK-20330 URL: https://issues.apache.org/jira/browse/FLINK-20330 Project: Flink Issue

[jira] [Created] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2020-11-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-20329: --- Summary: Elasticsearch7DynamicSinkITCase hangs Key: FLINK-20329 URL: https://issues.apache.org/jira/browse/FLINK-20329 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20328) UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available"

2020-11-24 Thread Dian Fu (Jira)
Dian Fu created FLINK-20328: --- Summary: UnalignedCheckpointITCase.execute failed with "Insufficient number of network buffers: required 1, but only 0 available" Key: FLINK-20328 URL:

[jira] [Created] (FLINK-20327) The Hive's read/write page should redirect to SQL Fileystem connector

2020-11-24 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20327: Summary: The Hive's read/write page should redirect to SQL Fileystem connector Key: FLINK-20327 URL: https://issues.apache.org/jira/browse/FLINK-20327

[jira] [Created] (FLINK-20326) Broken links to "How to define LookupableTableSource"

2020-11-24 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20326: Summary: Broken links to "How to define LookupableTableSource" Key: FLINK-20326 URL: https://issues.apache.org/jira/browse/FLINK-20326 Project: Flink

Re: [REMINDER] Build docs before merging

2020-11-24 Thread Jark Wu
Yes. I have opened a pull request: https://github.com/apache/flink/pull/14204 Best, Jark On Tue, 24 Nov 2020 at 17:38, Robert Metzger wrote: > Yes, that should be very easy to do. Just move the docs_404_check to the > "ci" stage in "build-apache-repo.yml". Maybe it makes sense to extend the >

[jira] [Created] (FLINK-20325) Move docs_404_check to CI stage

2020-11-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-20325: --- Summary: Move docs_404_check to CI stage Key: FLINK-20325 URL: https://issues.apache.org/jira/browse/FLINK-20325 Project: Flink Issue Type: Test Components:

[jira] [Created] (FLINK-20324) Support customizing of containers for native kubernetes setup

2020-11-24 Thread Boris Lublinsky (Jira)
Boris Lublinsky created FLINK-20324: --- Summary: Support customizing of containers for native kubernetes setup Key: FLINK-20324 URL: https://issues.apache.org/jira/browse/FLINK-20324 Project: Flink

[jira] [Created] (FLINK-20323) CorrelateSortToRankRule cannot deal with multiple groupings

2020-11-24 Thread Timo Walther (Jira)
Timo Walther created FLINK-20323: Summary: CorrelateSortToRankRule cannot deal with multiple groupings Key: FLINK-20323 URL: https://issues.apache.org/jira/browse/FLINK-20323 Project: Flink

[jira] [Created] (FLINK-20322) Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint.enabled

2020-11-24 Thread godfrey he (Jira)
godfrey he created FLINK-20322: -- Summary: Rename table.optimizer.union-all-as-breakpoint-disabled to table.optimizer.union-all-as-breakpoint.enabled Key: FLINK-20322 URL:

Re: [DISCUSS] Move license check utility to a new repository to share it with flink-statefun

2020-11-24 Thread Robert Metzger
Thanks a lot for your response, and sorry for my late response. how do you intend downstream CIs in flink / flink-statefun to be using > this? > Would there be released artifacts from `flink-project-utils` to expose > each tool (e.g. the `LicenseChecker`)? My idea was that flink and

[jira] [Created] (FLINK-20321) Get NPE when using AvroDeserializationSchema to deserialize null input

2020-11-24 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-20321: - Summary: Get NPE when using AvroDeserializationSchema to deserialize null input Key: FLINK-20321 URL: https://issues.apache.org/jira/browse/FLINK-20321 Project:

[jira] [Created] (FLINK-20320) Support start SQL Client with an initialization SQL file

2020-11-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-20320: --- Summary: Support start SQL Client with an initialization SQL file Key: FLINK-20320 URL: https://issues.apache.org/jira/browse/FLINK-20320 Project: Flink Issue Type:

[jira] [Created] (FLINK-20319) Improving the visitor pattern for operations

2020-11-24 Thread Jira
Ingo Bürk created FLINK-20319: - Summary: Improving the visitor pattern for operations Key: FLINK-20319 URL: https://issues.apache.org/jira/browse/FLINK-20319 Project: Flink Issue Type:

[jira] [Created] (FLINK-20318) Fix cast question for properies() method in kafka ConnectorDescriptor

2020-11-24 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-20318: - Summary: Fix cast question for properies() method in kafka ConnectorDescriptor Key: FLINK-20318 URL: https://issues.apache.org/jira/browse/FLINK-20318 Project: Flink

Re: [REMINDER] Build docs before merging

2020-11-24 Thread Robert Metzger
Yes, that should be very easy to do. Just move the docs_404_check to the "ci" stage in "build-apache-repo.yml". Maybe it makes sense to extend the build_properties.sh check to test if the change includes any docs changes. If not, we could skip the check to save some resources. Do you want to open

[jira] [Created] (FLINK-20317) Update Format Overview page to mention the supported connector for upsert-kafka

2020-11-24 Thread Jark Wu (Jira)
Jark Wu created FLINK-20317: --- Summary: Update Format Overview page to mention the supported connector for upsert-kafka Key: FLINK-20317 URL: https://issues.apache.org/jira/browse/FLINK-20317 Project:

Re: [REMINDER] Build docs before merging

2020-11-24 Thread Jark Wu
Is it possible to move it to PR CI? I have seen many documentation link issues these days. Best, Jark On Tue, 24 Nov 2020 at 15:56, Robert Metzger wrote: > Actually, the check_links.sh script is called in the nightly CI runs > > >