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

Hi Yazdan, that is the expected behaviour. If the system cannot allocate enough slots it will fail with a NoResourceAvailableException after the slot.request.timeout has been exceeded. Cheers, Till On Wed, Jul 11, 2018 at 7:44 PM Yaz Sh wrote: > +1 > > - Verified the signatures for all binary

[jira] [Created] (FLINK-9830) submit job to yarn-flink cluster base on java API

Li Lei created FLINK-9830: - Summary: submit job to yarn-flink cluster base on java API Key: FLINK-9830 URL: https://issues.apache.org/jira/browse/FLINK-9830 Project: Flink Issue Type: Bug C

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

+1 (binding) - verified again the signatures and hashes > On 12. Jul 2018, at 09:54, Till Rohrmann wrote: > > Hi Yazdan, > > that is the expected behaviour. If the system cannot allocate enough slots > it will fail with a NoResourceAvailableException after > the slot.request.timeout has been e

Re: CoreOptions.TMP_DIRS bug

Hi Oleksandr, sorry for my late reply. This sounds indeed like a bug. Thanks for opening FLINK-9762 and the corresponding PR. I'll give it a review shortly so that we can include it in Flink 1.6. Cheers, Till On Mon, Jul 2, 2018 at 2:31 PM Oleksandr Nitavskyi wrote: > Hello guys, > > We have d

[jira] [Created] (FLINK-9831) Too many open files for RocksDB

Sayat Satybaldiyev created FLINK-9831: - Summary: Too many open files for RocksDB Key: FLINK-9831 URL: https://issues.apache.org/jira/browse/FLINK-9831 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9832) Allow commas in job submission query params

Ufuk Celebi created FLINK-9832: -- Summary: Allow commas in job submission query params Key: FLINK-9832 URL: https://issues.apache.org/jira/browse/FLINK-9832 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9833) Add a SQL Client end-to-end test

Timo Walther created FLINK-9833: --- Summary: Add a SQL Client end-to-end test Key: FLINK-9833 URL: https://issues.apache.org/jira/browse/FLINK-9833 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-9834) Unable to support scala BasicArrayTypeInfo

buptljy created FLINK-9834: -- Summary: Unable to support scala BasicArrayTypeInfo Key: FLINK-9834 URL: https://issues.apache.org/jira/browse/FLINK-9834 Project: Flink Issue Type: Bug Compon

Re: [jira] [Created] (FLINK-9832) Allow commas in job submission query params

A got a similar issue that single quote ‘ get removed too. See if you can reproduce. Sent from my iPhone > On Jul 12, 2018, at 05:33, Ufuk Celebi (JIRA) wrote: > > Ufuk Celebi created FLINK-9832: > -- > > Summary: Allow commas in job submission quer

[jira] [Created] (FLINK-9836) Add template for vote canceling to release guide

Chesnay Schepler created FLINK-9836: --- Summary: Add template for vote canceling to release guide Key: FLINK-9836 URL: https://issues.apache.org/jira/browse/FLINK-9836 Project: Flink Issue Ty

[RESULT] [VOTE] Release 1.5.1, release candidate #3

I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * vino * Yaz * Till (binding) * Aljoscha (binding) * Chesnay (binding) There are no disapproving votes. Thanks everyone!

[jira] [Created] (FLINK-9835) Add template for release announcement to release guide

Chesnay Schepler created FLINK-9835: --- Summary: Add template for release announcement to release guide Key: FLINK-9835 URL: https://issues.apache.org/jira/browse/FLINK-9835 Project: Flink Is

[RESULT] [VOTE] Release 1.2.3, release candidate #3

I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * vino * Yaz * Till (binding) * Aljoscha (binding) * Chesnay (binding) There are no disapproving votes. Thanks everyone!

Re: [RESULT] [VOTE] Release 1.2.3, release candidate #3

Please ignore, i messed up the subject line... On 12.07.2018 13:29, Chesnay Schepler wrote: I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 3 of which are binding: * vino * Yaz * Till (binding) * Aljoscha (binding) * Chesnay (binding) There a

Re: Adding a part suffix setter to the BucketingSink

Hi Lakshmi, Since Flink-1.5 you have the ability to set the part suffix. As you said, you only want the .gzip to be the suffix of the final (or “completed”) part files, which is exactly what is currently supported. If you want also intermediate files to have this suffix, then you can always set

[jira] [Created] (FLINK-9837) Display the job description in the Flink web UI

vinoyang created FLINK-9837: --- Summary: Display the job description in the Flink web UI Key: FLINK-9837 URL: https://issues.apache.org/jira/browse/FLINK-9837 Project: Flink Issue Type: Improvement

Re: Adding a part suffix setter to the BucketingSink

Hi Kostas, good job! 2018-07-12 19:40 GMT+08:00 Kostas Kloudas : > Hi Lakshmi, > > Since Flink-1.5 you have the ability to set the part suffix. > As you said, you only want the .gzip to be the suffix of the final (or > “completed”) part files, which is exactly what is currently supported. > > If

[jira] [Created] (FLINK-9838) Slot request failed Exceptions after completing a job

Nico Kruber created FLINK-9838: -- Summary: Slot request failed Exceptions after completing a job Key: FLINK-9838 URL: https://issues.apache.org/jira/browse/FLINK-9838 Project: Flink Issue Type: B

Re: Adding a part suffix setter to the BucketingSink

Hi Kostas, Thank you for replying. I am already using the ability to set part suffix. I was not aware of this issue - https://issues.apache.org/ jira/browse/FLINK-9603. Thanks for pointing out, I'll make sure to use the 1.5.3 version of the sink. Thanks Lakshmi On Thu, Jul 12, 2018 at 4:55 AM,

Re: Adding a part suffix setter to the BucketingSink

Hi Lakshmi, I meant Flink 1.5.1 (not 1.5.3) which was recently released. Cheers, Kostas > On Jul 12, 2018, at 7:34 PM, Lakshmi Gururaja Rao wrote: > > Hi Kostas, > > Thank you for replying. I am already using the ability to set part suffix. > I was not aware of this issue - https://issues.apa