Re: [REMINDER] Build docs before merging

2020-11-23 Thread Robert Metzger
Actually, the check_links.sh script is called in the nightly CI runs https://github.com/apache/flink/blob/master/tools/azure-pipelines/build-apache-repo.yml#L145 --> https://github.com/apache/flink/blob/master/tools/ci/docs.sh#L30+ It was just broken for a while, but fixed by Dian 2 weeks ago.

[jira] [Created] (FLINK-20316) update the deduplication section of query page

2020-11-23 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20316: -- Summary: update the deduplication section of query page Key: FLINK-20316 URL: https://issues.apache.org/jira/browse/FLINK-20316 Project: Flink Issue Type: Task

Re: [DISCUSS] Stop adding new bash-based e2e tests to Flink

2020-11-23 Thread Kevin Kwon
Hi :) For me, it's a bit unclear what it means by not using Docker in e2e tests in K8S context, since K8S require Docker by default Also, for for K8S test orchestration, wouldn't vanilla Python suffice? It has all the K8S, Docker client libraries supported natively by them Might just need to

[jira] [Created] (FLINK-20315) Optimize the compaction section for the document of table filesystem sink.

2020-11-23 Thread Yun Gao (Jira)
Yun Gao created FLINK-20315: --- Summary: Optimize the compaction section for the document of table filesystem sink. Key: FLINK-20315 URL: https://issues.apache.org/jira/browse/FLINK-20315 Project: Flink

[jira] [Created] (FLINK-20314) Flink SQL 多字段查询时异常

2020-11-23 Thread bugboy (Jira)
bugboy created FLINK-20314: -- Summary: Flink SQL 多字段查询时异常 Key: FLINK-20314 URL: https://issues.apache.org/jira/browse/FLINK-20314 Project: Flink Issue Type: Bug Components: Table SQL /

[jira] [Created] (FLINK-20313) Test the debezium-avro-confluent format

2020-11-23 Thread Jark Wu (Jira)
Jark Wu created FLINK-20313: --- Summary: Test the debezium-avro-confluent format Key: FLINK-20313 URL: https://issues.apache.org/jira/browse/FLINK-20313 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-20312) The documentation is incomplete

2020-11-23 Thread sxb (Jira)
sxb created FLINK-20312: --- Summary: The documentation is incomplete Key: FLINK-20312 URL: https://issues.apache.org/jira/browse/FLINK-20312 Project: Flink Issue Type: Improvement Components:

[jira] [Created] (FLINK-20310) Add Debezium, Canal, Raw support for Filesystem connector

2020-11-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20310: Summary: Add Debezium, Canal, Raw support for Filesystem connector Key: FLINK-20310 URL: https://issues.apache.org/jira/browse/FLINK-20310 Project: Flink

[jira] [Created] (FLINK-20311) E2E test for Debezium, Canal, Raw of Filesystem connector

2020-11-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-20311: Summary: E2E test for Debezium, Canal, Raw of Filesystem connector Key: FLINK-20311 URL: https://issues.apache.org/jira/browse/FLINK-20311 Project: Flink

[jira] [Created] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

2020-11-23 Thread Jark Wu (Jira)
Jark Wu created FLINK-20309: --- Summary: UnalignedCheckpointTestBase.execute is failed Key: FLINK-20309 URL: https://issues.apache.org/jira/browse/FLINK-20309 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20308) Liquid Exception: Could not find document 'dev/table/streaming/time_attributes.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/sql

2020-11-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20308: Summary: Liquid Exception: Could not find document 'dev/table/streaming/time_attributes.md' in tag 'link'. Make sure the document exists and the path is correct. in dev/table/sql/create.zh.md

[jira] [Created] (FLINK-20307) Cannot alias versioned table in a join

2020-11-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20307: Summary: Cannot alias versioned table in a join Key: FLINK-20307 URL: https://issues.apache.org/jira/browse/FLINK-20307 Project: Flink Issue Type:

Re: More issues with top-level build for Tika 1.25 rc1 - Waited more than 5 minutes for a SAXParser

2020-11-23 Thread Ken Krugler
Hi Arvid (and the dev list), Sorry - I was busy working on two open source projects at the same time, and messed up. The Tika dev list and the Flink dev list both show up as “dev” in Apple Email :( This also explains why I didn’t get a response from my fellow Tika devs... — Ken > On Nov 23,

[jira] [Created] (FLINK-20306) Accessing a versioned table as of time fails with a cryptic message

2020-11-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20306: Summary: Accessing a versioned table as of time fails with a cryptic message Key: FLINK-20306 URL: https://issues.apache.org/jira/browse/FLINK-20306 Project:

[jira] [Created] (FLINK-20305) Iterative job with maxWaitTimeMillis does not terminate

2020-11-23 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20305: - Summary: Iterative job with maxWaitTimeMillis does not terminate Key: FLINK-20305 URL: https://issues.apache.org/jira/browse/FLINK-20305 Project: Flink

[jira] [Created] (FLINK-20304) Fail hard when trying to run job with broadcast state in BATCH execution mode

2020-11-23 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-20304: - Summary: Fail hard when trying to run job with broadcast state in BATCH execution mode Key: FLINK-20304 URL: https://issues.apache.org/jira/browse/FLINK-20304

[jira] [Created] (FLINK-20303) Add a SmokeE2E test

2020-11-23 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-20303: Summary: Add a SmokeE2E test Key: FLINK-20303 URL: https://issues.apache.org/jira/browse/FLINK-20303 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-20302) Suggest DataStream API with BATCH execution mode in DataSet docs

2020-11-23 Thread Aljoscha Krettek (Jira)
Aljoscha Krettek created FLINK-20302: Summary: Suggest DataStream API with BATCH execution mode in DataSet docs Key: FLINK-20302 URL: https://issues.apache.org/jira/browse/FLINK-20302 Project:

[jira] [Created] (FLINK-20301) Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible

2020-11-23 Thread hehuiyuan (Jira)
hehuiyuan created FLINK-20301: - Summary: Flink sql 1.10 : Legacy Decimal and decimal for Array that is not Compatible Key: FLINK-20301 URL: https://issues.apache.org/jira/browse/FLINK-20301 Project:

[jira] [Created] (FLINK-20300) Create Flink 1.12 release notes

2020-11-23 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-20300: -- Summary: Create Flink 1.12 release notes Key: FLINK-20300 URL: https://issues.apache.org/jira/browse/FLINK-20300 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-20299) Update Chinese table overview

2020-11-23 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-20299: Summary: Update Chinese table overview Key: FLINK-20299 URL: https://issues.apache.org/jira/browse/FLINK-20299 Project: Flink Issue Type: Bug

Need input on creating s3 source DataStream to filter Json file before pass to actual reader

2020-11-23 Thread DEEP NARAYAN Singh
Hi Guys, As part of flink s3 source reader can we do filter on json file name containing date and time as mentioned below : [image: image.png] I am able to read all the json files under a specific date but my use case is to read selected hour and minutes json files based on date range as shown

Re: Temporal Table Ordering

2020-11-23 Thread Till Rohrmann
Hi Dominik, Are you using Flink's Table API or SQL? If yes, maybe you can share the program with us to see what exactly your user program is doing. Also it would help us if you have some example data that would help reproducing the problem. Moreover, which Flink version are you running? Cheers,

Temporal Table Ordering

2020-11-23 Thread Dominik Wosiński
Hey, I have a question about the ordering of the messages in the Temporal Table. I can observe that for one of my jobs the order of input is correct but the order of the output is not correct. Say I have two streams that both have *id* field which will be used to join and also for Kafka

[jira] [Created] (FLINK-20298) Replace usage of {{site.baseurl}} in flink documentation

2020-11-23 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-20298: Summary: Replace usage of {{site.baseurl}} in flink documentation Key: FLINK-20298 URL: https://issues.apache.org/jira/browse/FLINK-20298 Project: Flink

[jira] [Created] (FLINK-20297) Make `SerializerTestBase::getTestData` return List

2020-11-23 Thread Guowei Ma (Jira)
Guowei Ma created FLINK-20297: - Summary: Make `SerializerTestBase::getTestData` return List Key: FLINK-20297 URL: https://issues.apache.org/jira/browse/FLINK-20297 Project: Flink Issue Type:

Re: More issues with top-level build for Tika 1.25 rc1 - Waited more than 5 minutes for a SAXParser

2020-11-23 Thread Arvid Heise
Hi Ken, just to double check, did you intend to send this mail to the tika dev list? I actually don't know what to do with your email. Best, Arvid On Sat, Nov 21, 2020 at 11:43 PM Ken Krugler wrote: > Hi all, > > I got past the JCE issue, but now some tests are failing with timeouts. > > For

[jira] [Created] (FLINK-20296) Explanation of keyBy was broken by find/replace of deprecated forms of keyBy

2020-11-23 Thread David Anderson (Jira)
David Anderson created FLINK-20296: -- Summary: Explanation of keyBy was broken by find/replace of deprecated forms of keyBy Key: FLINK-20296 URL: https://issues.apache.org/jira/browse/FLINK-20296

[jira] [Created] (FLINK-20295) File Source lost data when reading from directories created by FileSystemTableSink with JSON format

2020-11-23 Thread Yun Gao (Jira)
Yun Gao created FLINK-20295: --- Summary: File Source lost data when reading from directories created by FileSystemTableSink with JSON format Key: FLINK-20295 URL: https://issues.apache.org/jira/browse/FLINK-20295

[jira] [Created] (FLINK-20294) Expose value format metadata in Kinesis table source

2020-11-23 Thread Timo Walther (Jira)
Timo Walther created FLINK-20294: Summary: Expose value format metadata in Kinesis table source Key: FLINK-20294 URL: https://issues.apache.org/jira/browse/FLINK-20294 Project: Flink Issue

[jira] [Created] (FLINK-20293) Remove the useless constructor of ContinuousFileMonitoringFunction

2020-11-23 Thread godfrey he (Jira)
godfrey he created FLINK-20293: -- Summary: Remove the useless constructor of ContinuousFileMonitoringFunction Key: FLINK-20293 URL: https://issues.apache.org/jira/browse/FLINK-20293 Project: Flink

[jira] [Created] (FLINK-20292) Avro format conflicts with Parquet and Orc

2020-11-23 Thread Yun Gao (Jira)
Yun Gao created FLINK-20292: --- Summary: Avro format conflicts with Parquet and Orc Key: FLINK-20292 URL: https://issues.apache.org/jira/browse/FLINK-20292 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-20291) Optimize the exception message of FileSystemTableSink when missing format dependencies

2020-11-23 Thread Yun Gao (Jira)
Yun Gao created FLINK-20291: --- Summary: Optimize the exception message of FileSystemTableSink when missing format dependencies Key: FLINK-20291 URL: https://issues.apache.org/jira/browse/FLINK-20291

[jira] [Created] (FLINK-20290) Duplicated output in FileSource continuous ITCase with TM failover

2020-11-23 Thread Andrey Zagrebin (Jira)
Andrey Zagrebin created FLINK-20290: --- Summary: Duplicated output in FileSource continuous ITCase with TM failover Key: FLINK-20290 URL: https://issues.apache.org/jira/browse/FLINK-20290 Project:

[jira] [Created] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

2020-11-23 Thread Jark Wu (Jira)
Jark Wu created FLINK-20289: --- Summary: Computed columns can be calculated after ChangelogNormalize to reduce shuffle Key: FLINK-20289 URL: https://issues.apache.org/jira/browse/FLINK-20289 Project: Flink