[FLINK - 9503] Starter task

Hi devs, I've been using Flink for about a year now. I was wondering if I could start contributing with this sub-task: https://issues.apache.org/jira/browse/FLINK-9503 related to this Task: https://issues.apache.org/jira/browse/FLINK-2032 Can someone give me permissions in jira to assign the s

[jira] [Created] (FLINK-9503) Migrate integration tests for iterative aggregators

Deepak Sharma created FLINK-9503: Summary: Migrate integration tests for iterative aggregators Key: FLINK-9503 URL: https://issues.apache.org/jira/browse/FLINK-9503 Project: Flink Issue Type:

[jira] [Created] (FLINK-9502) Use generic parameter search for user-define functions when argument contains Object type

Rong Rong created FLINK-9502: Summary: Use generic parameter search for user-define functions when argument contains Object type Key: FLINK-9502 URL: https://issues.apache.org/jira/browse/FLINK-9502 Proje

[jira] [Created] (FLINK-9501) Allow Object.class type in user-define functions as parameter types but not result types

Rong Rong created FLINK-9501: Summary: Allow Object.class type in user-define functions as parameter types but not result types Key: FLINK-9501 URL: https://issues.apache.org/jira/browse/FLINK-9501 Projec

[jira] [Created] (FLINK-9500) FileUploadHandler does not handle EmptyLastHttpContent

Chesnay Schepler created FLINK-9500: --- Summary: FileUploadHandler does not handle EmptyLastHttpContent Key: FLINK-9500 URL: https://issues.apache.org/jira/browse/FLINK-9500 Project: Flink Is

[jira] [Created] (FLINK-9499) Allow REST API for running a job to provide job configuration as body of POST request

Esteban Serrano created FLINK-9499: -- Summary: Allow REST API for running a job to provide job configuration as body of POST request Key: FLINK-9499 URL: https://issues.apache.org/jira/browse/FLINK-9499

[jira] [Created] (FLINK-9498) Disable dependency convergence for "flink-end-to-end-tests"

Hai Zhou created FLINK-9498: --- Summary: Disable dependency convergence for "flink-end-to-end-tests" Key: FLINK-9498 URL: https://issues.apache.org/jira/browse/FLINK-9498 Project: Flink Issue Type:

[jira] [Created] (FLINK-9497) Job Configuration showing the password in plain text

Vinay created FLINK-9497: Summary: Job Configuration showing the password in plain text Key: FLINK-9497 URL: https://issues.apache.org/jira/browse/FLINK-9497 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9496) Job created time is reset after restart

Abhinav Bajaj created FLINK-9496: Summary: Job created time is reset after restart Key: FLINK-9496 URL: https://issues.apache.org/jira/browse/FLINK-9496 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9495) Implement ResourceManager for Kubernetes

Elias Levy created FLINK-9495: - Summary: Implement ResourceManager for Kubernetes Key: FLINK-9495 URL: https://issues.apache.org/jira/browse/FLINK-9495 Project: Flink Issue Type: Improvement

[ANNOUNCE] Flink Forward Berlin 2018 - Call for Presentations extended until June 11

Hi everybody, Due to popular demand, we've extended the Call for Presentations for Flink Forward Berlin 2018 by one week. The call will close on *Monday, June 11* (11:59pm CEST). Please submit a proposal to present your Flink and Stream Processing use case, experiences, and best practices in Berl

[jira] [Created] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship

Till Rohrmann created FLINK-9494: Summary: Race condition in Dispatcher with concurrent granting and revoking of leaderhship Key: FLINK-9494 URL: https://issues.apache.org/jira/browse/FLINK-9494 Proje

[jira] [Created] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

Till Rohrmann created FLINK-9493: Summary: Forward exception when releasing a TaskManager at the SlotPool Key: FLINK-9493 URL: https://issues.apache.org/jira/browse/FLINK-9493 Project: Flink

[jira] [Created] (FLINK-9492) Failed to build RexCall with SqlDatetimeSubtractionOperator

yuqi created FLINK-9492: --- Summary: Failed to build RexCall with SqlDatetimeSubtractionOperator Key: FLINK-9492 URL: https://issues.apache.org/jira/browse/FLINK-9492 Project: Flink Issue Type: Bug

Re: Failure restarting Flink 1.5.0 job from checkpoint

Thanks for reporting the issue Ken. This looks indeed very strange and we need to investigate how this can happen. Cheers, Till On Thu, May 31, 2018 at 8:07 PM, Ken Krugler wrote: > Hi Aljoscha, > > Yes, looks that way, thanks the issue reference - I’d checked Jira few > days ago, looks like FL

[jira] [Created] (FLINK-9491) Implement timer service based on RocksDB

Stefan Richter created FLINK-9491: - Summary: Implement timer service based on RocksDB Key: FLINK-9491 URL: https://issues.apache.org/jira/browse/FLINK-9491 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5

Stefan Richter created FLINK-9490: - Summary: Provide backwards compatibility for timer state of Flink 1.5 Key: FLINK-9490 URL: https://issues.apache.org/jira/browse/FLINK-9490 Project: Flink

[jira] [Created] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

Stefan Richter created FLINK-9489: - Summary: Checkpoint timers as part of managed keyed state instead of raw keyed state Key: FLINK-9489 URL: https://issues.apache.org/jira/browse/FLINK-9489 Project:

[jira] [Created] (FLINK-9488) Create common entry point for master and workers

Till Rohrmann created FLINK-9488: Summary: Create common entry point for master and workers Key: FLINK-9488 URL: https://issues.apache.org/jira/browse/FLINK-9488 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots

Stefan Richter created FLINK-9487: - Summary: Prepare InternalTimerHeap for asynchronous snapshots Key: FLINK-9487 URL: https://issues.apache.org/jira/browse/FLINK-9487 Project: Flink Issue Ty

[jira] [Created] (FLINK-9486) Introduce TimerState in keyed state backend

Stefan Richter created FLINK-9486: - Summary: Introduce TimerState in keyed state backend Key: FLINK-9486 URL: https://issues.apache.org/jira/browse/FLINK-9486 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-9485) Improving Flink’s timer management for large state

Stefan Richter created FLINK-9485: - Summary: Improving Flink’s timer management for large state Key: FLINK-9485 URL: https://issues.apache.org/jira/browse/FLINK-9485 Project: Flink Issue Type

[TABLE][SQL] Unify UniqueKeyExtractor and DataStreamRetractionRules

Hi, Recently I was looking into upserts and upserts sources in Flink and while doing so, I noticed some potential room for improvement/simplification. Currently there are 3 optimiser rules in DataStreamRetractionRules that work in three stages followed by UniqueKeyExtractor plan node visitor to

Re: [SQL] [CALCITE] not applicable function for TIME

Thank you:) 2018-06-01 13:18 GMT+03:00 Fabian Hueske : > Done :-) > > 2018-06-01 12:12 GMT+02:00 Viktor Vlasov : > > > Could someone assign me to the created > > https://issues.apache.org/jira/browse/FLINK-9482? > > > > 2018-05-31 17:48 GMT+03:00 Viktor Vlasov >: > > > > > Thank you Shuyi, I wil

Re: [SQL] [CALCITE] not applicable function for TIME

Done :-) 2018-06-01 12:12 GMT+02:00 Viktor Vlasov : > Could someone assign me to the created > https://issues.apache.org/jira/browse/FLINK-9482? > > 2018-05-31 17:48 GMT+03:00 Viktor Vlasov : > > > Thank you Shuyi, I will investigate these issues. > > > > 2018-05-31 17:42 GMT+03:00 Shuyi Chen : >

Re: [SQL] [CALCITE] not applicable function for TIME

Could someone assign me to the created https://issues.apache.org/jira/browse/FLINK-9482? 2018-05-31 17:48 GMT+03:00 Viktor Vlasov : > Thank you Shuyi, I will investigate these issues. > > 2018-05-31 17:42 GMT+03:00 Shuyi Chen : > >> I think you might find some context in these 2 PRs in Flink & Ca