[VOTE] FLIP-134: DataStream Semantics for Bounded Input

Hi all, After the discussion in [1], I would like to open a voting thread for FLIP-134 [2] which discusses the semantics that the DataStream API will expose when applied on a bounded input. The vote will be open until 27th August (72h), unless there is an objection or not enough votes. Cheers, K

Re: [DISCUSS] Planning Release 1.3

+1 On Feb 6, 2017 20:19, "Robert Metzger" wrote: > Hi, > according to our recent time-based releases discussion, I came up with the > following deadlines for the upcoming 1.3 release: > > *Feature freeze (branch forking)*: 1 May 2017 > *Code freeze (first voting RC)*: 15 May 2017 > *Release da

Re: [DISCUSS] Feature Freeze

The only thing that I want to add in the features to be added for 1.3 is the NOT pattern for the CEP library. There is an open PR here: https://github.com/apache/flink/pull/3798 which is not far from getting in. Kostas > On May 2, 2017, at 12:10 PM,

Re: [DISCUSS] What is a "Blocker" in our JIRA?

Hi Robert, Thanks for clarifying this so that we all have a common definition of what is a blocker. The only thing I would disagree, and only is some cases, is the documentation part. I think that in some cases, things that have to do with documentation can and should become blockers. Mainly t

Re: [DISCUSS] Feature Freeze

Hi Robert, Thanks for starting the process! My only remark is that given that the master is unstable, does it make sense to create an RC0? Kostas > On May 8, 2017, at 8:52 AM, Robert Metzger wrote: > > Great! > It also looks like the other big features made it also into master this > weeken

Re: ListState to List

Hi Radu, Why not using a ValueState that inside stored the whole list. Whenever you state#get() you get the whole list and you can sort it. Kostas > On May 18, 2017, at 3:31 AM, Radu Tudoran wrote: > > Hi Aljoscha, > > Thanks for the clarification. I understand that there might be advantage

Re: [DISCUSS] Reorganize Table API / SQL documentation

A big +1 as well. > On May 18, 2017, at 1:55 PM, Ufuk Celebi wrote: > > On Thu, May 18, 2017 at 1:52 PM, Till Rohrmann wrote: >> I think we have a history of creating too long monolithic documentation >> pages which are hard to digest. So a big +1 for splitting the Table API/SQL >> documentatio

[DISCUSS] Backwards compatibility policy.

Hi all, As we are getting closer to releasing Flink-1.3, I would like to open a discussion on how far back we provide backwards compatibility for. The reason for opening the discussion is that i) for the users and for the adoption of the project, it is good to have an explicitely stated policy

Re: [DISCUSS] Backwards compatibility policy.

backwards-compatibilitiy > we're talking about here. As in are we talking about APIs or savepoints? > > On 20.05.2017 19:09, Kostas Kloudas wrote: >> Hi all, >> >> As we are getting closer to releasing Flink-1.3, I would like to open a >> discussion >> o

Re: [DISCUSS] Release 1.3.0 RC1 (Non voting, testing release candidate)

Thanks Robert for pushing this. This is going to be a voting RC? Kostas > On May 24, 2017, at 3:16 PM, Robert Metzger wrote: > > Great! > The fixes are in, and I'm now building the RC2 (There are currently no > blockers in our JIRA) > > On Tue, May 23, 2017 at 9:37 PM, Stefan Richter > wrote:

Re: [DISCUSS] Backwards compatibility policy.

o pile up and pollute the actual codebase if >> we try to always be compatible with all previous versions. >>> >>> Cheers, >>> Gordon >>> >>> >>> On 21 May 2017 at 2:24:53 AM, Kostas Kloudas ( >> k.klou...@data-artisans.com) wrote: &

Re: [VOTE] Release Apache Flink 1.3.0 (RC3)

Hi all, I also tend to agree with the argument that says a release should be out as soon as possible, given that 1) it improves usability/functionality and 2) at a minimum, it does not include new known bugs. The arguments are more or less aligned with Nico’s response on the matter. Focusing on

Re: [RESULT][VOTE] Release Apache Flink 1.3.0 (RC3)

> Am 31.05.2017 um 11:02 schrieb Gyula Fóra : >>>>>> >>>>>> Hi All, >>>>>> >>>>>> I also lean towards getting the release out as soon as possible >> given >>>>> that >>>>>> it had been de

Re: [DISCUSS]: Integrating Flink Table API & SQL with CEP

Thanks a lot for opening the discussion! This is a really interesting idea that has been in our heads since the first implementation of the CEP library. A big +1 for moving forward with this. And as for the design document, I will definitely have a look and comment there. Kostas > On Jun 7,

Re: [ANNOUNCE] New committer: Dawid Wysakowicz

Congratulations Dawid! Nice to have you in the team as a committer this time! Kostas > On Jun 19, 2017, at 10:40 AM, Till Rohrmann wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Dawid Wysakowicz as a new > Flink committer! > > Dawid has been a community member

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan! More hands are always welcomed! Kostas On Jun 21, 2017 22:45, "Greg Hogan" wrote: > Congrats and welcome, Shaoxuan! > > > > On Jun 21, 2017, at 4:19 PM, Fabian Hueske wrote: > > > > Hi everybody, > > > > On behalf of the PMC, I'm very happy to announce that Shaoxuan W

Re: [DISCUSS] Backwards compatibility policy.

joscha >>>> On 24. May 2017, at 17:58, Ted Yu wrote: >>>> >>>> bq. about having LTS versions once a year >>>> >>>> +1 to the above. >>>> >>>> There may be various reasons users don't want to upgrade (after new &

Re: [ANNOUNCE] New Flink PMC member: Chesnay Schepler

Congratulations Chesnay! > On Jul 28, 2017, at 4:05 PM, Greg Hogan wrote: > > Developers, > > On behalf of the Flink PMC I am delighted to announce Chesnay Schepler as a > member of the Flink PMC. > > Chesnay is a longtime contributor, reviewer, and committer whose breadth of > work and know

Re: [POLL] Dropping savepoint format compatibility for 1.1.x in the Flink 1.4.0 release

+1 > On Aug 2, 2017, at 3:16 PM, Till Rohrmann wrote: > > +1 > > On Wed, Aug 2, 2017 at 9:12 AM, Stefan Richter > wrote: > >> +1 >> >> Am 28.07.2017 um 16:03 schrieb Stephan Ewen : >> >> Seems like no one raised a concern so far about dropping the savepoint >> format compatibility for 1.1 i

Re: [DISCUSS] Stop serving docs for Flink version prior to 1.0

Hi Ufuk, +1 I think that this is a nice change! Thanks Ufuk for opening the discussion. I think that broken/redirect links are not an issue, as either way the information provided is far outdated (== wrong). As for the warning, we cannot put it in the header instead of the footer? Sth like,

Re: [jira] [Commented] (FLINK-7606) CEP operator leaks state

Yes. In general, and for every keyed state, the amount of state you store is proportional to the number of active keys that you expect to have. On Sep 15, 2017 5:33 PM, "Paolo Rendano (JIRA)" wrote: > > [ https://issues.apache.org/jira/browse/FLINK-7606?page= > com.atlassian.jira.plugin.syst

Re: [DISCUSS] Dropping Scala 2.10

+1 > On Sep 20, 2017, at 2:26 PM, Stefan Richter > wrote: > > +1

Re: [DISCUSS] Dropping Scala 2.10

+ 1 > On Sep 20, 2017, at 2:26 PM, Stefan Richter > wrote: > > +1

Re: Get pattern events

Hi Erdem, Could you share also your pattern? If the “first” pattern has no quantifier, then it is expected to have only one event. Kostas > On Oct 10, 2017, at 4:22 PM, Erdem erdfem wrote: > > Hello, > > I want to take get pattern events. I use below code. When debug, context > has one event

Re: Get pattern events

Also this topic seems to be more suitable for the user mailing, and not the dev one. Could you move the discussion there? Thanks, Kostas > On Oct 10, 2017, at 4:29 PM, Kostas Kloudas > wrote: > > Hi Erdem, > > Could you share also your pattern? > If the “first” patt

Re: Get pattern events

10-10 17:30 GMT+03:00 Kostas Kloudas : > >> Also this topic seems to be more suitable for the user mailing, and not >> the dev one. >> Could you move the discussion there? >> >> Thanks, >> Kostas >> >>> On Oct 10, 2017, at 4:29 PM, Kostas Kloud

Re: [ANNOUNCE] New committer: Haohui Mai

Congratulations! > On Nov 2, 2017, at 9:12 AM, Matthias J. Sax wrote: > > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 11/1/17 9:40 PM, Dawid Wysakowicz wrote: >> Congratulations! >> >> 01.11.2017 7:45 PM "Stephan Ewen" napisał(a): >> >>> Congrats and welcome! >>>

Re: CEP: Dynamic Patterns

Hi Rafi, Currently this is unfortunately not supported out of the box. To support this, we need 2 features with one having to be added in Flink itself, and the other to the CEP library. The first one is broadcast state and the ability to connect keyed and non-keyed streams. This one is to be add

Re: CEP: Dynamic Patterns

al stopping/ restarting. I do not know if Ufuk has something to add to this. Hope this helps, Kostas > On Dec 28, 2017, at 2:57 PM, Kostas Kloudas > wrote: > > Hi Rafi, > > Currently this is unfortunately not supported out of the box. > To support this, we need 2 features with

Re: [DISCUSS] Releasing Flink 1.5.0

Hi Aljoscha, I believe that support for Broadcast State should also be in 1.5. There is an open PR https://github.com/apache/flink/pull/5230 for that and there are some pending issues related to scala api and documentation. Thanks, Kostas > On Feb 5,

Re: [DISCUSS] Releasing Flink 1.5.0

oesn't make sense to release 1.5 now. >>>> >>>> Given the large scope of these features I would very much prefer to have >>>> them active on master for a while before a feature-freeze >>>> to expose them to a wider audience. >>>> >&g

Re: HAQueryableStateRocksDBBackendITCase test cause outofmemoryerror and never stop

Hi Minglei, Can you send us where the execution is when it hangs? Threaddump, what objects are created, or whatever can help track down the problem. Thanks, Kostas > On Feb 21, 2018, at 9:07 AM, mingleizhang wrote: > > Hi, > I run HAQueryableStateRocksDBBackendITCase#testValueStateDefault te

Re: [DISCUSS] Implement end-to-end tests in Java

Hi Timo, Thanks for opening this. I agree that bash is not the best tool for all the reasons that you mention plus: 1) it is difficult to write re-usable code 2) there are a lot of ways to express the same thing and difficult to build “best practices” (as it should be in a community proj

Re: [Proposal] CEP library changes - review request

Hi Shailesh, Your solution may fit your use case, but as Dawid mentioned earlier, it makes a lot of assumptions about the input. From a look at your PoC: 1) You assume no late data (you do not drop anything) and no out-of-orderness. 2) You mix the two notions of time (event and processing). 3)

Re: [jira] [Created] (FLINK-9164) times(#,#) quantifier does not seem to work

Hi Romain, What if you remove the AfterMatchSkipStrategy.skipPastLastEvent()? Kostas > On Apr 12, 2018, at 1:19 PM, Romain Revol (JIRA) wrote: > > AfterMatchSkipStrategy.skipPastLastEvent()

Re: Flink 1.3.2 with CEP Pattern, Memory usage increases results in OOM

Hi Abiramalakshmi, Thanks for reporting this! As a starting point I would recommend: 1) use RocksDB as your backend, so that state is not accumulated in memory 2) enable incremental checkpoints 3) the “new IterativeCondition() {…}” can become “new SimpleCondition() {}”, as this is more eff

[jira] [Created] (FLINK-13103) Graceful Shutdown Handling by UDFs

Kostas Kloudas created FLINK-13103: -- Summary: Graceful Shutdown Handling by UDFs Key: FLINK-13103 URL: https://issues.apache.org/jira/browse/FLINK-13103 Project: Flink Issue Type

[jira] [Created] (FLINK-13275) Race condition in SourceStreamTaskTest.finishingIgnoresExceptions()

Kostas Kloudas created FLINK-13275: -- Summary: Race condition in SourceStreamTaskTest.finishingIgnoresExceptions() Key: FLINK-13275 URL: https://issues.apache.org/jira/browse/FLINK-13275 Project

[jira] [Created] (FLINK-13307) SourceStreamTaskTest test instability.

Kostas Kloudas created FLINK-13307: -- Summary: SourceStreamTaskTest test instability. Key: FLINK-13307 URL: https://issues.apache.org/jira/browse/FLINK-13307 Project: Flink Issue Type

[jira] [Created] (FLINK-13440) Add test that fails job when sync savepoint is discarded.

Kostas Kloudas created FLINK-13440: -- Summary: Add test that fails job when sync savepoint is discarded. Key: FLINK-13440 URL: https://issues.apache.org/jira/browse/FLINK-13440 Project: Flink

[jira] [Created] (FLINK-13605) AsyncDataStreamITCase. testUnorderedWait failed on Travis

Kostas Kloudas created FLINK-13605: -- Summary: AsyncDataStreamITCase. testUnorderedWait failed on Travis Key: FLINK-13605 URL: https://issues.apache.org/jira/browse/FLINK-13605 Project: Flink

[jira] [Created] (FLINK-13713) Remove legacy Package interface.

Kostas Kloudas created FLINK-13713: -- Summary: Remove legacy Package interface. Key: FLINK-13713 URL: https://issues.apache.org/jira/browse/FLINK-13713 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13714) Remove Package-related code.

Kostas Kloudas created FLINK-13714: -- Summary: Remove Package-related code. Key: FLINK-13714 URL: https://issues.apache.org/jira/browse/FLINK-13714 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13715) Remove Package-related english documentation.

Kostas Kloudas created FLINK-13715: -- Summary: Remove Package-related english documentation. Key: FLINK-13715 URL: https://issues.apache.org/jira/browse/FLINK-13715 Project: Flink Issue Type

[jira] [Created] (FLINK-13716) Remove Package-related chinese documentation

Kostas Kloudas created FLINK-13716: -- Summary: Remove Package-related chinese documentation Key: FLINK-13716 URL: https://issues.apache.org/jira/browse/FLINK-13716 Project: Flink Issue Type

[jira] [Created] (FLINK-13941) Prevent data-loss by not cleaning up small part files from S3.

Kostas Kloudas created FLINK-13941: -- Summary: Prevent data-loss by not cleaning up small part files from S3. Key: FLINK-13941 URL: https://issues.apache.org/jira/browse/FLINK-13941 Project: Flink

[jira] [Created] (FLINK-13946) Remove deactivated JobSession-related code.

Kostas Kloudas created FLINK-13946: -- Summary: Remove deactivated JobSession-related code. Key: FLINK-13946 URL: https://issues.apache.org/jira/browse/FLINK-13946 Project: Flink Issue Type

[jira] [Created] (FLINK-13954) Clean up ExecutionEnvironment / JobSubmission code paths

Kostas Kloudas created FLINK-13954: -- Summary: Clean up ExecutionEnvironment / JobSubmission code paths Key: FLINK-13954 URL: https://issues.apache.org/jira/browse/FLINK-13954 Project: Flink

[jira] [Created] (FLINK-13959) Consolidate DetachedEnvironment and ContextEnvironment

Kostas Kloudas created FLINK-13959: -- Summary: Consolidate DetachedEnvironment and ContextEnvironment Key: FLINK-13959 URL: https://issues.apache.org/jira/browse/FLINK-13959 Project: Flink

[jira] [Created] (FLINK-13972) Move PreviewPlanEnvironment to flink-tests

Kostas Kloudas created FLINK-13972: -- Summary: Move PreviewPlanEnvironment to flink-tests Key: FLINK-13972 URL: https://issues.apache.org/jira/browse/FLINK-13972 Project: Flink Issue Type

[jira] [Created] (FLINK-15926) Add DataStream.broadcast(StateDescriptor) to available transformations docs

Kostas Kloudas created FLINK-15926: -- Summary: Add DataStream.broadcast(StateDescriptor) to available transformations docs Key: FLINK-15926 URL: https://issues.apache.org/jira/browse/FLINK-15926

[jira] [Created] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint.

Kostas Kloudas created FLINK-16369: -- Summary: Allow the StreamingFileSink to restore from a previous (old) savepoint. Key: FLINK-16369 URL: https://issues.apache.org/jira/browse/FLINK-16369 Project

[jira] [Created] (FLINK-16654) Implement Application Mode according to FLIP-85

Kostas Kloudas created FLINK-16654: -- Summary: Implement Application Mode according to FLIP-85 Key: FLINK-16654 URL: https://issues.apache.org/jira/browse/FLINK-16654 Project: Flink Issue

[jira] [Created] (FLINK-16655) Introduce the EmbeddedExecutor

Kostas Kloudas created FLINK-16655: -- Summary: Introduce the EmbeddedExecutor Key: FLINK-16655 URL: https://issues.apache.org/jira/browse/FLINK-16655 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16656) Introduce the DispatcherBootstrap

Kostas Kloudas created FLINK-16656: -- Summary: Introduce the DispatcherBootstrap Key: FLINK-16656 URL: https://issues.apache.org/jira/browse/FLINK-16656 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16657) Wire the EmbeddedExecutor to the Web Submission logic.

Kostas Kloudas created FLINK-16657: -- Summary: Wire the EmbeddedExecutor to the Web Submission logic. Key: FLINK-16657 URL: https://issues.apache.org/jira/browse/FLINK-16657 Project: Flink

[jira] [Created] (FLINK-16658) Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint.

Kostas Kloudas created FLINK-16658: -- Summary: Wire the EmbeddedExecutor to the StandaloneClusterEntrypoint. Key: FLINK-16658 URL: https://issues.apache.org/jira/browse/FLINK-16658 Project: Flink

[jira] [Created] (FLINK-16660) Introduce the ApplicationDispatcherBootstrap

Kostas Kloudas created FLINK-16660: -- Summary: Introduce the ApplicationDispatcherBootstrap Key: FLINK-16660 URL: https://issues.apache.org/jira/browse/FLINK-16660 Project: Flink Issue Type

[jira] [Created] (FLINK-16661) Introduce the YarnApplicationClusterEntrypoint

Kostas Kloudas created FLINK-16661: -- Summary: Introduce the YarnApplicationClusterEntrypoint Key: FLINK-16661 URL: https://issues.apache.org/jira/browse/FLINK-16661 Project: Flink Issue

[jira] [Created] (FLINK-14157) Temporarily remove S3 StreamingFileSink end-to-end test

Kostas Kloudas created FLINK-14157: -- Summary: Temporarily remove S3 StreamingFileSink end-to-end test Key: FLINK-14157 URL: https://issues.apache.org/jira/browse/FLINK-14157 Project: Flink

[jira] [Created] (FLINK-14376) Introduce the Executor abstraction (FLIP-73)

Kostas Kloudas created FLINK-14376: -- Summary: Introduce the Executor abstraction (FLIP-73) Key: FLINK-14376 URL: https://issues.apache.org/jira/browse/FLINK-14376 Project: Flink Issue Type

[jira] [Created] (FLINK-14377) Translate ProgramOptions relevant for job execution to ConfigOptions.

Kostas Kloudas created FLINK-14377: -- Summary: Translate ProgramOptions relevant for job execution to ConfigOptions. Key: FLINK-14377 URL: https://issues.apache.org/jira/browse/FLINK-14377 Project

[jira] [Created] (FLINK-14501) Move ClusteDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory

Kostas Kloudas created FLINK-14501: -- Summary: Move ClusteDescriptor/ClusterSpecification creation from the CustomCommandLine to a ClusterClientFactory Key: FLINK-14501 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-14502) Make ClusterDescriptor/ClusterSpecification creation configuration-based.

Kostas Kloudas created FLINK-14502: -- Summary: Make ClusterDescriptor/ClusterSpecification creation configuration-based. Key: FLINK-14502 URL: https://issues.apache.org/jira/browse/FLINK-14502

[jira] [Created] (FLINK-14548) Many tests in the nightly fail during cancellation.

Kostas Kloudas created FLINK-14548: -- Summary: Many tests in the nightly fail during cancellation. Key: FLINK-14548 URL: https://issues.apache.org/jira/browse/FLINK-14548 Project: Flink

[jira] [Created] (FLINK-14657) Generalize and move YarnConfigUtils from flink-yarn to flink-core

Kostas Kloudas created FLINK-14657: -- Summary: Generalize and move YarnConfigUtils from flink-yarn to flink-core Key: FLINK-14657 URL: https://issues.apache.org/jira/browse/FLINK-14657 Project: Flink

[jira] [Created] (FLINK-14745) Put job jars from PackagedProgram to Configuration

Kostas Kloudas created FLINK-14745: -- Summary: Put job jars from PackagedProgram to Configuration Key: FLINK-14745 URL: https://issues.apache.org/jira/browse/FLINK-14745 Project: Flink Issue

[jira] [Created] (FLINK-14758) Add Executor-related interfaces and utilities

Kostas Kloudas created FLINK-14758: -- Summary: Add Executor-related interfaces and utilities Key: FLINK-14758 URL: https://issues.apache.org/jira/browse/FLINK-14758 Project: Flink Issue Type

[jira] [Created] (FLINK-14829) Add test that verifies that the CLI sets the correct classloader.

Kostas Kloudas created FLINK-14829: -- Summary: Add test that verifies that the CLI sets the correct classloader. Key: FLINK-14829 URL: https://issues.apache.org/jira/browse/FLINK-14829 Project: Flink

[jira] [Created] (FLINK-14850) Refactor Executor interface and introduce a minimal JobClient interface

Kostas Kloudas created FLINK-14850: -- Summary: Refactor Executor interface and introduce a minimal JobClient interface Key: FLINK-14850 URL: https://issues.apache.org/jira/browse/FLINK-14850 Project

[jira] [Created] (FLINK-14851) Make the (Stream)ContextEnvironment use the Executors

Kostas Kloudas created FLINK-14851: -- Summary: Make the (Stream)ContextEnvironment use the Executors Key: FLINK-14851 URL: https://issues.apache.org/jira/browse/FLINK-14851 Project: Flink

[jira] [Created] (FLINK-14972) Implement RemoteExecutor as a new Executor

Kostas Kloudas created FLINK-14972: -- Summary: Implement RemoteExecutor as a new Executor Key: FLINK-14972 URL: https://issues.apache.org/jira/browse/FLINK-14972 Project: Flink Issue Type

[jira] [Created] (FLINK-15033) Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048)

Kostas Kloudas created FLINK-15033: -- Summary: Remove unused RemoteEnvirnment.executeRemotely() (FLINK-11048) Key: FLINK-15033 URL: https://issues.apache.org/jira/browse/FLINK-15033 Project: Flink

[jira] [Created] (FLINK-15039) Remove default close() implementation from ClusterClient

Kostas Kloudas created FLINK-15039: -- Summary: Remove default close() implementation from ClusterClient Key: FLINK-15039 URL: https://issues.apache.org/jira/browse/FLINK-15039 Project: Flink

[jira] [Created] (FLINK-15041) Remove default close() implementation from JobClient

Kostas Kloudas created FLINK-15041: -- Summary: Remove default close() implementation from JobClient Key: FLINK-15041 URL: https://issues.apache.org/jira/browse/FLINK-15041 Project: Flink

[jira] [Created] (FLINK-15042) Fix python compatibility by excluding the Env.executeAsync() (FLINK-14854)

Kostas Kloudas created FLINK-15042: -- Summary: Fix python compatibility by excluding the Env.executeAsync() (FLINK-14854) Key: FLINK-15042 URL: https://issues.apache.org/jira/browse/FLINK-15042

[jira] [Created] (FLINK-15118) Make flink-scala-shell use Executors

Kostas Kloudas created FLINK-15118: -- Summary: Make flink-scala-shell use Executors Key: FLINK-15118 URL: https://issues.apache.org/jira/browse/FLINK-15118 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-15119) Remove PlanExecutor and its subclasses

Kostas Kloudas created FLINK-15119: -- Summary: Remove PlanExecutor and its subclasses Key: FLINK-15119 URL: https://issues.apache.org/jira/browse/FLINK-15119 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-15120) Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID

Kostas Kloudas created FLINK-15120: -- Summary: Make FlinkYarnCli#isActive() & #getApplicationId() respect config APPLICATION_ID Key: FLINK-15120 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-15179) Kubernetes should not have a CustomCommandLine.

Kostas Kloudas created FLINK-15179: -- Summary: Kubernetes should not have a CustomCommandLine. Key: FLINK-15179 URL: https://issues.apache.org/jira/browse/FLINK-15179 Project: Flink Issue

[jira] [Created] (FLINK-15195) Remove unu

Kostas Kloudas created FLINK-15195: -- Summary: Remove unu Key: FLINK-15195 URL: https://issues.apache.org/jira/browse/FLINK-15195 Project: Flink Issue Type: Sub-task Reporter

[jira] [Created] (FLINK-15260) Uniformize Kubernetes executor name with the rest

Kostas Kloudas created FLINK-15260: -- Summary: Uniformize Kubernetes executor name with the rest Key: FLINK-15260 URL: https://issues.apache.org/jira/browse/FLINK-15260 Project: Flink Issue

[jira] [Created] (FLINK-15273) Complete and Update Documentation

Kostas Kloudas created FLINK-15273: -- Summary: Complete and Update Documentation Key: FLINK-15273 URL: https://issues.apache.org/jira/browse/FLINK-15273 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15274) Update Filesystem documentation to reflect changes in shading

Kostas Kloudas created FLINK-15274: -- Summary: Update Filesystem documentation to reflect changes in shading Key: FLINK-15274 URL: https://issues.apache.org/jira/browse/FLINK-15274 Project: Flink

[jira] [Created] (FLINK-15275) Update CLI documentation to include only current valid options

Kostas Kloudas created FLINK-15275: -- Summary: Update CLI documentation to include only current valid options Key: FLINK-15275 URL: https://issues.apache.org/jira/browse/FLINK-15275 Project: Flink

[jira] [Created] (FLINK-15276) Update CLI documentation to reflect the addition of the ExecutorCLI

Kostas Kloudas created FLINK-15276: -- Summary: Update CLI documentation to reflect the addition of the ExecutorCLI Key: FLINK-15276 URL: https://issues.apache.org/jira/browse/FLINK-15276 Project

[jira] [Created] (FLINK-15278) Update StreamingFileSink documentation

Kostas Kloudas created FLINK-15278: -- Summary: Update StreamingFileSink documentation Key: FLINK-15278 URL: https://issues.apache.org/jira/browse/FLINK-15278 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-15279) Document new `executeAsync()` method and the newly introduced `JobClient`

Kostas Kloudas created FLINK-15279: -- Summary: Document new `executeAsync()` method and the newly introduced `JobClient` Key: FLINK-15279 URL: https://issues.apache.org/jira/browse/FLINK-15279

[jira] [Created] (FLINK-15292) Rename Executor interface to PipelineExecutor

Kostas Kloudas created FLINK-15292: -- Summary: Rename Executor interface to PipelineExecutor Key: FLINK-15292 URL: https://issues.apache.org/jira/browse/FLINK-15292 Project: Flink Issue Type

[jira] [Created] (FLINK-15687) Potential test instabilities due to concurrent access to TaskSlotTable.

Kostas Kloudas created FLINK-15687: -- Summary: Potential test instabilities due to concurrent access to TaskSlotTable. Key: FLINK-15687 URL: https://issues.apache.org/jira/browse/FLINK-15687 Project

[jira] [Created] (FLINK-15805) StreamingFileSink on S3 fails when firing processing time timers after recovery.

Kostas Kloudas created FLINK-15805: -- Summary: StreamingFileSink on S3 fails when firing processing time timers after recovery. Key: FLINK-15805 URL: https://issues.apache.org/jira/browse/FLINK-15805

[jira] [Created] (FLINK-9903) Add support for bulk writers.

Kostas Kloudas created FLINK-9903: - Summary: Add support for bulk writers. Key: FLINK-9903 URL: https://issues.apache.org/jira/browse/FLINK-9903 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9921) Update the rolling policy interface.

Kostas Kloudas created FLINK-9921: - Summary: Update the rolling policy interface. Key: FLINK-9921 URL: https://issues.apache.org/jira/browse/FLINK-9921 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9994) IntervalJoinOperator#Context#getTimestamp does not return the Max timestamp.

Kostas Kloudas created FLINK-9994: - Summary: IntervalJoinOperator#Context#getTimestamp does not return the Max timestamp. Key: FLINK-9994 URL: https://issues.apache.org/jira/browse/FLINK-9994 Project

[jira] [Created] (FLINK-10027) Add logging to the StreamingFileSink

Kostas Kloudas created FLINK-10027: -- Summary: Add logging to the StreamingFileSink Key: FLINK-10027 URL: https://issues.apache.org/jira/browse/FLINK-10027 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-10029) Refactor the code for better separation of concerns.

Kostas Kloudas created FLINK-10029: -- Summary: Refactor the code for better separation of concerns. Key: FLINK-10029 URL: https://issues.apache.org/jira/browse/FLINK-10029 Project: Flink

[jira] [Created] (FLINK-10097) More tests to increase StreamingFileSink test coverage

Kostas Kloudas created FLINK-10097: -- Summary: More tests to increase StreamingFileSink test coverage Key: FLINK-10097 URL: https://issues.apache.org/jira/browse/FLINK-10097 Project: Flink

[jira] [Created] (FLINK-10522) Check if RecoverableWriter supportsResume and accordingly.

Kostas Kloudas created FLINK-10522: -- Summary: Check if RecoverableWriter supportsResume and accordingly. Key: FLINK-10522 URL: https://issues.apache.org/jira/browse/FLINK-10522 Project: Flink

[jira] [Created] (FLINK-10529) Add flink-s3-fs-base to the connectors in the travis stage file.

Kostas Kloudas created FLINK-10529: -- Summary: Add flink-s3-fs-base to the connectors in the travis stage file. Key: FLINK-10529 URL: https://issues.apache.org/jira/browse/FLINK-10529 Project: Flink

[jira] [Created] (FLINK-10530) ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis.

Kostas Kloudas created FLINK-10530: -- Summary: ProcessFailureCancelingITCase.testCancelingOnProcessFailure failed on Travis. Key: FLINK-10530 URL: https://issues.apache.org/jira/browse/FLINK-10530

<    1   2   3   4   5   >