[RESULT] [VOTE] Release 1.8.1, release candidate #1

I'm happy to announce that we have unanimously approved the 1.8.1 release. There are 5 approving votes, 3 of which are binding: * Hequn * Jark * Jincheng * Gordon * Aljoscha There are no disapproving votes. Thanks everyone!

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

Thanks to everyone for checking the release and voting! I’ll tally the results in a separate email. Aljoscha Krettek 于2019年7月1日周一 下午6:05写道： > +1 (binding) > > - I checked the diff in the POM files since 1.8.0 and they look good, > i.e. no new dependencies that could lead to licensing problems

[DISCUSS] Publish the PyFlink into PyPI

Hi all, With the effort of FLIP-38 [1], the Python Table API(without UDF support for now) will be supported in the coming release-1.9. As described in "Build PyFlink"[2], if users want to use the Python Table API, they can manually install it using the command: "cd flink-python && python3

Re: [DISCUSS] solve unstable build capacity problem on TravisCI

By looking at the git history of the Jenkins script, its core part was finished in March 2017 (and only two minor update in 2017/2018), so it's been running for over two years now and feels like Zepplin community has been quite happy with it. @Jeff Zhang can you share your insights and user

[jira] [Created] (FLINK-13050) Counting more checkpoint failure reason in CheckpointFailureManager

vinoyang created FLINK-13050: Summary: Counting more checkpoint failure reason in CheckpointFailureManager Key: FLINK-13050 URL: https://issues.apache.org/jira/browse/FLINK-13050 Project: Flink

[jira] [Created] (FLINK-13049) Port planner expressions to blink-planner from flink-planner

Jingsong Lee created FLINK-13049: Summary: Port planner expressions to blink-planner from flink-planner Key: FLINK-13049 URL: https://issues.apache.org/jira/browse/FLINK-13049 Project: Flink

Contributor permission

Dear Flink community: Per an earlier discussion thread, I created FLINK-13027 and would like to contribute to it. Is it possible to grant me the Contributor access? *yxu-apache * Thanks in advance. - Ying PS: I had

[jira] [Created] (FLINK-13048) support decimal in Flink's integration with Hive user defined functions

Bowen Li created FLINK-13048: Summary: support decimal in Flink's integration with Hive user defined functions Key: FLINK-13048 URL: https://issues.apache.org/jira/browse/FLINK-13048 Project: Flink

[jira] [Created] (FLINK-13047) Fix the Optional.orElse() usage issue in DatabaseCalciteSchema

Xuefu Zhang created FLINK-13047: --- Summary: Fix the Optional.orElse() usage issue in DatabaseCalciteSchema Key: FLINK-13047 URL: https://issues.apache.org/jira/browse/FLINK-13047 Project: Flink

[jira] [Created] (FLINK-13046) rename hive-site-path to hive-conf-dir to be consistent with standard name in Hive

Bowen Li created FLINK-13046: Summary: rename hive-site-path to hive-conf-dir to be consistent with standard name in Hive Key: FLINK-13046 URL: https://issues.apache.org/jira/browse/FLINK-13046 Project:

Re: Flink 1.6.4 Issue on RocksDB incremental checkpoints and fs.default-scheme

Hi Andrea Unfortunately, the tm log provided is not the task manager in which RocksDBStateBackend first failed. All tasks on this task manager are actually canceled by job manager, you could find a lot of "Attempting to cancel task" before any task failed. >From your latest description, this

[jira] [Created] (FLINK-13045) Move Scala expression DSL to flink-table-api-scala

Timo Walther created FLINK-13045: Summary: Move Scala expression DSL to flink-table-api-scala Key: FLINK-13045 URL: https://issues.apache.org/jira/browse/FLINK-13045 Project: Flink Issue

Re: Flink 1.6.4 Issue on RocksDB incremental checkpoints and fs.default-scheme

Hi Andrea The error happens when Flink try to verify whether your local backup directory existed[1]. If you could reproduce this, would you please share your configuration to RocksDBStateBackend, and what `fs.default-scheme` have you configured. Taskmanager log with more details is also very

[jira] [Created] (FLINK-13044) Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions

Sebastian J. created FLINK-13044: Summary: Shading of AWS SDK in flink-s3-fs-hadoop results in ClassNotFoundExceptions Key: FLINK-13044 URL: https://issues.apache.org/jira/browse/FLINK-13044 Project:

Contributor permission

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is 知一, and full name is QinChao. Thanks QinChao 秦超 中国，浙江省，杭州市 邮箱：chaos...@outlook.com 电话：+86-18668011290 Chao Qin HangZhou，ZheJiang Province，China

Fwd: Flink 1.6.4 Issue on RocksDB incremental checkpoints and fs.default-scheme

Dear community, I am running through the following issue. whenever I use rocksdb as state backend along with incremental checkpoints, I get the following error: *Caused by: java.lang.Exception: Could not materialize checkpoint 1 for operator Service Join SuperService (6/8).

[jira] [Created] (FLINK-13043) Fix the bug of parsing Dewey number from string

Liya Fan created FLINK-13043: Summary: Fix the bug of parsing Dewey number from string Key: FLINK-13043 URL: https://issues.apache.org/jira/browse/FLINK-13043 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13042) Make slot sharing configurable on ExecutionConfig

Biao Liu created FLINK-13042: Summary: Make slot sharing configurable on ExecutionConfig Key: FLINK-13042 URL: https://issues.apache.org/jira/browse/FLINK-13042 Project: Flink Issue Type:

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

+1 (binding) - I checked the diff in the POM files since 1.8.0 and they look good, i.e. no new dependencies that could lead to licensing problems > On 1. Jul 2019, at 10:02, Tzu-Li (Gordon) Tai wrote: > > +1 (binding) > > - checked signatures and hashes > - built from source without

[jira] [Created] (FLINK-13041) Make ScheduleMode configurable on ExecutionConfig

Aljoscha Krettek created FLINK-13041: Summary: Make ScheduleMode configurable on ExecutionConfig Key: FLINK-13041 URL: https://issues.apache.org/jira/browse/FLINK-13041 Project: Flink

[jira] [Created] (FLINK-13040) promote blink configOptions and add these config descriptions to document

XuPingyong created FLINK-13040: -- Summary: promote blink configOptions and add these config descriptions to document Key: FLINK-13040 URL: https://issues.apache.org/jira/browse/FLINK-13040 Project: Flink

Re: [DISCUSS]Support Upsert mode for Streaming Non-window FlatAggregate

Hi Kurt, Thanks for your questions. Here are my thoughts. > if I want to write such kind function, should I make sure that this function is used with some keys? The key information may not be used. We can also use RetractSink to emit the table directly. > If I need a use case to calculate topn

[jira] [Created] (FLINK-13039) Clean up thrown exception lists of `ResultSubpartitionView#getNextBuffer`

Piotr Nowojski created FLINK-13039: -- Summary: Clean up thrown exception lists of `ResultSubpartitionView#getNextBuffer` Key: FLINK-13039 URL: https://issues.apache.org/jira/browse/FLINK-13039

[jira] [Created] (FLINK-13038) CEP WITHIN don’t support interval expression

Danny created FLINK-13038: - Summary: CEP WITHIN don’t support interval expression Key: FLINK-13038 URL: https://issues.apache.org/jira/browse/FLINK-13038 Project: Flink Issue Type: Bug

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

+1 (binding) - checked signatures and hashes - built from source without skipping tests (without Hadoop, Scala 2.12) - no new dependencies were added since 1.8.0 - ran the end-to-end tests locally once, and in a loop specifically for Kafka tests (to cover FLINK-11987) - announcement PR for

[jira] [Created] (FLINK-13037) Translate "Concepts -> Glossary" page into Chinese

Konstantin Knauf created FLINK-13037: Summary: Translate "Concepts -> Glossary" page into Chinese Key: FLINK-13037 URL: https://issues.apache.org/jira/browse/FLINK-13037 Project: Flink

[jira] [Created] (FLINK-13036) Elasticsearch ActionRequestFailureHandler can access RuntimeContext

FaxianZhao created FLINK-13036: -- Summary: Elasticsearch ActionRequestFailureHandler can access RuntimeContext Key: FLINK-13036 URL: https://issues.apache.org/jira/browse/FLINK-13036 Project: Flink

[jira] [Created] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts

Wong created FLINK-13035: Summary: LocalStreamEnvironment shall launch actuall task solts Key: FLINK-13035 URL: https://issues.apache.org/jira/browse/FLINK-13035 Project: Flink Issue Type: Wish