[jira] [Created] (FLINK-10684) Improve the CSV reading process

Xingcan Cui created FLINK-10684: --- Summary: Improve the CSV reading process Key: FLINK-10684 URL: https://issues.apache.org/jira/browse/FLINK-10684 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-10683) Error while executing BLOB connection. java.io.IOException: Unknown operation

Yee created FLINK-10683: --- Summary: Error while executing BLOB connection. java.io.IOException: Unknown operation Key: FLINK-10683 URL: https://issues.apache.org/jira/browse/FLINK-10683 Project: Flink

[jira] [Created] (FLINK-10682) EOFException occurs during deserialization of Avro class

Ben La Monica created FLINK-10682: - Summary: EOFException occurs during deserialization of Avro class Key: FLINK-10682 URL: https://issues.apache.org/jira/browse/FLINK-10682 Project: Flink

[jira] [Created] (FLINK-10681) elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA installed

Till Rohrmann created FLINK-10681: - Summary: elasticsearch6.ElasticsearchSinkITCase fails if wrong JNA installed Key: FLINK-10681 URL: https://issues.apache.org/jira/browse/FLINK-10681 Project: Flink

[jira] [Created] (FLINK-10680) Unable to set negative offsets for TumblingEventTimeWindow

Paul Lin created FLINK-10680: Summary: Unable to set negative offsets for TumblingEventTimeWindow Key: FLINK-10680 URL: https://issues.apache.org/jira/browse/FLINK-10680 Project: Flink Issue

Re: Question over Incremental Snapshot vs Full Snapshot in rocksDb state backend

Hi Chandan, > 1. Why did we took 2 different approaches using different RocksDB apis ? > We could have used Checkpoint api of RocksDB for fullSnapshot as well . The reason here is partially historical. Full snapshot in RocksDB backend was implemented before incremental and rescaling for

[jira] [Created] (FLINK-10679) Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code

Tzu-Li (Gordon) Tai created FLINK-10679: --- Summary: Let TypeSerializerSchemaCompatibility.resolveSchemaCompatibility() be the entry point for compatibility checks in framework code Key: FLINK-10679 URL:

Re: Reverse the order of fields in Flink SQL

Hi Yinhua, This is actually a bug in Flink table, you can check this issue https://issues.apache.org/jira/browse/FLINK-10290 . I opened a PR for this issue a couple of days ago, but there is still some problem so it’s not ready to be merged.

[jira] [Created] (FLINK-10678) Add a switch to run_test to configure if logs should be checked for errors/excepions

Dawid Wysakowicz created FLINK-10678: Summary: Add a switch to run_test to configure if logs should be checked for errors/excepions Key: FLINK-10678 URL: https://issues.apache.org/jira/browse/FLINK-10678

[jira] [Created] (FLINK-10677) Setup hadoop-free E2E test cron job

Chesnay Schepler created FLINK-10677: Summary: Setup hadoop-free E2E test cron job Key: FLINK-10677 URL: https://issues.apache.org/jira/browse/FLINK-10677 Project: Flink Issue Type:

Re: [VOTE] Release 1.6.2, release candidate #1

+1 - ran a local cluster - submitted multiple jobs through WebUI - verified availability of metrics - verified that latency marks are still enabled by default but configurable via configuration On 18.10.2018 13:18, Chesnay Schepler wrote: Hi everyone, Please review and vote on the release

Re: [VOTE] Release 1.5.5, release candidate #1

+1 - ran a local cluster - submitted multiple jobs through WebUI - verified availability of metrics - verified that latency marks are still enabled by default but configurable via configuration On 18.10.2018 13:17, Chesnay Schepler wrote: Hi everyone, Please review and vote on the release

Re: [VOTE] Release 1.5.5, release candidate #1

Thanks Chesnay for the investigation. Your explanations work in my case as well. Therefore I give +1. On 19/10/2018 13:19, Chesnay Schepler wrote: > See the JIRA for details. > > On 19.10.2018 13:18, Chesnay Schepler wrote: >> This is likely not a new issue and existed since FLINK-9234 was >>

[jira] [Created] (FLINK-10676) Add 'as' method for OverWindowWithOrderBy in Java API

sunjincheng created FLINK-10676: --- Summary: Add 'as' method for OverWindowWithOrderBy in Java API Key: FLINK-10676 URL: https://issues.apache.org/jira/browse/FLINK-10676 Project: Flink Issue

[jira] [Created] (FLINK-10675) Fix dependency issues in sql & table integration

Dawid Wysakowicz created FLINK-10675: Summary: Fix dependency issues in sql & table integration Key: FLINK-10675 URL: https://issues.apache.org/jira/browse/FLINK-10675 Project: Flink

[jira] [Created] (FLINK-10674) DistinctAccumulator.remove lead to NPE

ambition created FLINK-10674: Summary: DistinctAccumulator.remove lead to NPE Key: FLINK-10674 URL: https://issues.apache.org/jira/browse/FLINK-10674 Project: Flink Issue Type: Bug