[jira] (FLINK-3237) Create AsynchronousKvStateSnapshot similar to AsynchronousStateHandle

Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-4407) Add DSL for specifying Window Triggers

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-4407) Add DSL for specifying Window Triggers

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-2284) Confusing/inconsistent PartitioningStrategy

Title: Message Title Aljoscha Krettek commented on FLINK-2284

[jira] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

Title: Message Title Aljoscha Krettek commented on FLINK-3715

[jira] (FLINK-3643) Improve Windowing

Title: Message Title Aljoscha Krettek closed an issue as Fixed

[jira] (FLINK-1098) flatArray() operator that converts arrays to elements

Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-4415) Enhance Trigger Interface with onFire()

Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] (FLINK-3715) Move Accumulating/Discarding from Trigger to WindowOperator

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-5480) User-provided hashes for operators

Title: Message Title Aljoscha Krettek commented on FLINK-5480

[jira] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

Title: Message Title Aljoscha Krettek closed an issue as Fixed

[jira] (FLINK-5456) Add docs about new state and checkpointing interfaces

Title: Message Title Aljoscha Krettek closed an issue as Fixed

[jira] (FLINK-5682) Fix scala version in flink-streaming-scala POM file

Title: Message Title Aljoscha Krettek commented on FLINK-5682

[jira] (FLINK-4272) Create a JobClient for job control and monitoring

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

Title: Message Title Aljoscha Krettek updated an issue

[jira] (FLINK-3606) Expose Configuration from RichFunctions

Title: Message Title Aljoscha Krettek closed an issue as Won't Fix

[jira] [Closed] (FLINK-5502) Add documentation about migrating functions from 1.1 to 1.2

[ https://issues.apache.org/jira/browse/FLINK-5502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5502. --- Resolution: Fixed Implemented on release-1.2: da6ac7b5f7caf14bb2a8581db2e405e0585f7872 on mas

[jira] [Created] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc

Aljoscha Krettek created FLINK-5709: --- Summary: Add Max Parallelism to Parallel Execution Doc Key: FLINK-5709 URL: https://issues.apache.org/jira/browse/FLINK-5709 Project: Flink Issue Type:

[jira] [Created] (FLINK-5713) Protect against NPE in WindowOperator window cleanup

Aljoscha Krettek created FLINK-5713: --- Summary: Protect against NPE in WindowOperator window cleanup Key: FLINK-5713 URL: https://issues.apache.org/jira/browse/FLINK-5713 Project: Flink Issu

[jira] [Closed] (FLINK-5709) Add Max Parallelism to Parallel Execution Doc

[ https://issues.apache.org/jira/browse/FLINK-5709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5709. --- Resolution: Fixed Added on release-1.2 in: 39e6049c576be2df1068f40acb6bc6060c4af5a5 on master

[jira] [Created] (FLINK-5720) Deprecate "Folding" in all of DataStream API

Aljoscha Krettek created FLINK-5720: --- Summary: Deprecate "Folding" in all of DataStream API Key: FLINK-5720 URL: https://issues.apache.org/jira/browse/FLINK-5720 Project: Flink Issue Type:

[jira] [Created] (FLINK-5721) Add FoldingState to State Documentation

Aljoscha Krettek created FLINK-5721: --- Summary: Add FoldingState to State Documentation Key: FLINK-5721 URL: https://issues.apache.org/jira/browse/FLINK-5721 Project: Flink Issue Type: Impro

[jira] [Closed] (FLINK-82) (Hash) Aggregators (fold style)

[ https://issues.apache.org/jira/browse/FLINK-82?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-82. - Resolution: Duplicate Superseded by FLINK-2237. > (Hash) Aggregators (fold style) > ---

[jira] [Updated] (FLINK-4602) Move RocksDB backend to proper package

[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4602: Summary: Move RocksDB backend to proper package (was: Move RocksDB backed to proper package

[jira] [Commented] (FLINK-4602) Move RocksDB backend to proper package

[ https://issues.apache.org/jira/browse/FLINK-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854246#comment-15854246 ] Aljoscha Krettek commented on FLINK-4602: - Noted, we should definitely keep it sep

[jira] [Updated] (FLINK-5719) Let LatencyMarkers completely bypass operators / chains

[ https://issues.apache.org/jira/browse/FLINK-5719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5719: Component/s: DataStream API > Let LatencyMarkers completely bypass operators / chains >

[jira] [Closed] (FLINK-5721) Add FoldingState to State Documentation

[ https://issues.apache.org/jira/browse/FLINK-5721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5721. --- Resolution: Fixed Fix Version/s: 1.2.1 1.3.0 Added on release-1.2 in

[jira] [Commented] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854309#comment-15854309 ] Aljoscha Krettek commented on FLINK-5717: - Then the fix should probably also be th

[jira] [Updated] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5717: Affects Version/s: (was: 2.0.0) 1.2.0 > NPE on SessionWindows wit

[jira] [Updated] (FLINK-5730) Users can concurrently modify state metadata of RocksDB asynchronous snapshots

[ https://issues.apache.org/jira/browse/FLINK-5730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5730: Component/s: State Backends, Checkpointing > Users can concurrently modify state metadata of

[jira] [Commented] (FLINK-5717) NPE on SessionWindows with ContinuousProcessingTimeTrigger

[ https://issues.apache.org/jira/browse/FLINK-5717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856260#comment-15856260 ] Aljoscha Krettek commented on FLINK-5717: - Yes, please go ahead. :-) > NPE on Ses

[jira] [Commented] (FLINK-5735) Non-overlapping sliding window is not deterministic

[ https://issues.apache.org/jira/browse/FLINK-5735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15856268#comment-15856268 ] Aljoscha Krettek commented on FLINK-5735: - A good first step would be to take the

[jira] [Created] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

Aljoscha Krettek created FLINK-5740: --- Summary: Make WrappingFunction an interface and move to flink-core Key: FLINK-5740 URL: https://issues.apache.org/jira/browse/FLINK-5740 Project: Flink

[jira] [Created] (FLINK-5741) Add tests for window function wrappers with RichFunctions

Aljoscha Krettek created FLINK-5741: --- Summary: Add tests for window function wrappers with RichFunctions Key: FLINK-5741 URL: https://issues.apache.org/jira/browse/FLINK-5741 Project: Flink

[jira] [Updated] (FLINK-5741) Add tests for window function wrappers with RichFunctions

[ https://issues.apache.org/jira/browse/FLINK-5741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5741: Priority: Blocker (was: Major) > Add tests for window function wrappers with RichFunctions

[jira] [Created] (FLINK-5743) Mark WindowedStream.aggregate* methods as PublicEvolving

Aljoscha Krettek created FLINK-5743: --- Summary: Mark WindowedStream.aggregate* methods as PublicEvolving Key: FLINK-5743 URL: https://issues.apache.org/jira/browse/FLINK-5743 Project: Flink

[jira] [Updated] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

[ https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5740: Description: Making it an interface and having an {{AbstractWrappingFunction}} will allow i

[jira] [Updated] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

[ https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5740: Priority: Blocker (was: Major) > Make WrappingFunction an interface and move to flink-core

[jira] [Updated] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

[ https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5740: Fix Version/s: 1.3.0 > Make WrappingFunction an interface and move to flink-core > -

[jira] [Created] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state

Aljoscha Krettek created FLINK-7623: --- Summary: Detecting whether an operator is restored doesn't work with chained state Key: FLINK-7623 URL: https://issues.apache.org/jira/browse/FLINK-7623 Project

[jira] [Updated] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state

[ https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7623: Attachment: StreamingJob.java Attached example code. > Detecting whether an operator is res

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7608: Priority: Blocker (was: Major) > LatencyGauge change to histogram metric > ---

[jira] [Commented] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166333#comment-16166333 ] Aljoscha Krettek commented on FLINK-7590: - Agreed! > Flink failed to flush and cl

[jira] [Updated] (FLINK-7590) Flink failed to flush and close the file system output stream for checkpointing because of s3 read timeout

[ https://issues.apache.org/jira/browse/FLINK-7590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7590: Priority: Major (was: Blocker) > Flink failed to flush and close the file system output str

[jira] [Updated] (FLINK-7606) CEP operator leaks state

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7606: Summary: CEP operator leaks state (was: Memory leak on NestedMapsStateTable) > CEP operato

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

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166340#comment-16166340 ] Aljoscha Krettek commented on FLINK-7606: - Will NFAs not be cleared when the allow

[jira] [Updated] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks

[ https://issues.apache.org/jira/browse/FLINK-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7607: Fix Version/s: 1.4.0 > Web Frontend Hangs with Large Numbers of Tasks >

[jira] [Assigned] (FLINK-7617) Remove string format in BitSet to improve the performance of BuildSideOuterjoin

[ https://issues.apache.org/jira/browse/FLINK-7617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-7617: --- Assignee: Jingsong Lee > Remove string format in BitSet to improve the performance of

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166370#comment-16166370 ] Aljoscha Krettek commented on FLINK-7589: - Yes, I think we cannot do much except w

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166387#comment-16166387 ] Aljoscha Krettek commented on FLINK-2646: - I thought about this and the new {{clos

[jira] [Assigned] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-4796: --- Assignee: Aljoscha Krettek > Add new Sink interface with access to more meta data > -

[jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166391#comment-16166391 ] Aljoscha Krettek commented on FLINK-4796: - Sorry, I didn't get what this workaroun

[jira] [Commented] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166394#comment-16166394 ] Aljoscha Krettek commented on FLINK-4796: - Ah I see, the workaround is for the NPE

[jira] [Closed] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4796. --- Resolution: Duplicate > Add new Sink interface with access to more meta data > ---

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

[ https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16166428#comment-16166428 ] Aljoscha Krettek commented on FLINK-4814: - Yes I think this is still a problem and

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

[ https://issues.apache.org/jira/browse/FLINK-7606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167635#comment-16167635 ] Aljoscha Krettek commented on FLINK-7606: - How do you mean? They could get the tim

[jira] [Commented] (FLINK-4814) Remove extra storage location for externalized checkpoint metadata

[ https://issues.apache.org/jira/browse/FLINK-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167638#comment-16167638 ] Aljoscha Krettek commented on FLINK-4814: - Yes, those are things I'm aware of and

[jira] [Commented] (FLINK-7589) org.apache.http.ConnectionClosedException: Premature end of Content-Length delimited message body (expected: 159764230; received: 64638536)

[ https://issues.apache.org/jira/browse/FLINK-7589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16167643#comment-16167643 ] Aljoscha Krettek commented on FLINK-7589: - I don't think we want to do that, no. H

[jira] [Reopened] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-4796: - > Add new Sink interface with access to more meta data > -

[jira] [Closed] (FLINK-4796) Add new Sink interface with access to more meta data

[ https://issues.apache.org/jira/browse/FLINK-4796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4796. --- Resolution: Won't Fix Introducing a new SinkInterface will make the workaround of the hybrid p

[jira] [Commented] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16168906#comment-16168906 ] Aljoscha Krettek commented on FLINK-7630: - +1 Looks good! > Allow passing a File

[jira] [Closed] (FLINK-6383) Add versioning for AbstractStreamOperator state

[ https://issues.apache.org/jira/browse/FLINK-6383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6383. --- Resolution: Won't Fix Closing this because we can worry about it once we actually break state

[jira] [Closed] (FLINK-6353) Restoring using CheckpointedRestoring does not work from 1.2 to 1.2

[ https://issues.apache.org/jira/browse/FLINK-6353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-6353. --- Resolution: Fixed > Restoring using CheckpointedRestoring does not work from 1.2 to 1.2 >

[jira] [Closed] (FLINK-4858) Remove Legacy Checkpointing Interfaces

[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4858. --- Resolution: Fixed Fix Version/s: 1.4.0 This was recently removed by [~srichter] > Remo

[jira] [Updated] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7635: Summary: Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction (was: suppo

[jira] [Commented] (FLINK-7635) Support sideOutput in ProcessWindowFunciton & ProcessAllWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16171770#comment-16171770 ] Aljoscha Krettek commented on FLINK-7635: - Sounds good! +1 The important thing is

[jira] [Closed] (FLINK-7630) Allow passing a File or an InputStream to ParameterTool.fromPropertiesFile()

[ https://issues.apache.org/jira/browse/FLINK-7630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7630. --- Resolution: Fixed Implemented on release-1.3 in 100951e279ad352f3b8921970217cd8edf14ac20 Impl

[jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Fix Version/s: 1.4.0 > RocksDB semi-async snapshot to S3AFileSystem fails >

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173277#comment-16173277 ] Aljoscha Krettek commented on FLINK-4228: - Moved to critical for the part about ch

[jira] [Updated] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-4228: Priority: Blocker (was: Major) > RocksDB semi-async snapshot to S3AFileSystem fails > -

[jira] [Commented] (FLINK-4228) RocksDB semi-async snapshot to S3AFileSystem fails

[ https://issues.apache.org/jira/browse/FLINK-4228?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16173278#comment-16173278 ] Aljoscha Krettek commented on FLINK-4228: - The other parts are not relevant anymor

[jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5372: Fix Version/s: 1.4.0 > Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() >

[jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-5372: Priority: Blocker (was: Major) > Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoin

[jira] [Closed] (FLINK-7553) Use new SinkFunction interface in FlinkKafkaProducer010

[ https://issues.apache.org/jira/browse/FLINK-7553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7553. --- Resolution: Fixed Implemented in 6886f638d70419e01ebdfc1cdbb6d834f3fb30b0 > Use new SinkFunct

[jira] [Closed] (FLINK-7552) Extend SinkFunction interface with SinkContext

[ https://issues.apache.org/jira/browse/FLINK-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7552. --- Resolution: Fixed Implemented in e7996b0d0ff5fe705a3830f3855f977cad4f0c44 > Extend SinkFuncti

[jira] [Closed] (FLINK-7442) Add option for using a child-first classloader for loading user code

[ https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7442. --- Resolution: Fixed Fix Version/s: 1.4.0 Implemented in a86b6468617f7078c375f6484975b5947

[jira] [Commented] (FLINK-7623) Detecting whether an operator is restored doesn't work with chained state

[ https://issues.apache.org/jira/browse/FLINK-7623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16174974#comment-16174974 ] Aljoscha Krettek commented on FLINK-7623: - I think that would be incorrect, becaus

[jira] [Updated] (FLINK-7666) ContinuousFileReaderOperator swallows chained watermarks

[ https://issues.apache.org/jira/browse/FLINK-7666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7666: Fix Version/s: 1.4.0 > ContinuousFileReaderOperator swallows chained watermarks > --

[jira] [Closed] (FLINK-7567) DataStream#iterate() on env.fromElements() / env.fromCollection() does not work

[ https://issues.apache.org/jira/browse/FLINK-7567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7567. --- Resolution: Fixed Fix Version/s: 1.4.0 Fixed in 345de772a9b6802beff2c9fa6e35da0884c9afd

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16176428#comment-16176428 ] Aljoscha Krettek commented on FLINK-7669: - How are your running your program? > o

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16176592#comment-16176592 ] Aljoscha Krettek commented on FLINK-7669: - And the fat-jar is built against 1.3.2

[jira] [Commented] (FLINK-3986) Rename readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180678#comment-16180678 ] Aljoscha Krettek commented on FLINK-3986: - We cannot yet work on this because chan

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16180679#comment-16180679 ] Aljoscha Krettek commented on FLINK-7669: - Did you rebuild the fat jar against the

[jira] [Updated] (FLINK-7675) LatestCompletedCheckpointExternalPathGauge should check if external path is exist

[ https://issues.apache.org/jira/browse/FLINK-7675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7675: Priority: Blocker (was: Major) > LatestCompletedCheckpointExternalPathGauge should check if

[jira] [Created] (FLINK-7700) State merging in RocksDB backend leaves old state

Aljoscha Krettek created FLINK-7700: --- Summary: State merging in RocksDB backend leaves old state Key: FLINK-7700 URL: https://issues.apache.org/jira/browse/FLINK-7700 Project: Flink Issue T

[jira] [Closed] (FLINK-2268) Provide Flink binary release without Hadoop

[ https://issues.apache.org/jira/browse/FLINK-2268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-2268. --- Resolution: Fixed Fix Version/s: 1.4.0 Implemented in 2b96c8d74b66228484e53a58907157086

[jira] [Closed] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-4048. --- Resolution: Fixed Fix Version/s: (was: 2.0.0) 1.4.0 Implemented

[jira] [Created] (FLINK-7729) Remove Scala 2.10 support; add Scala 2.12 support

Aljoscha Krettek created FLINK-7729: --- Summary: Remove Scala 2.10 support; add Scala 2.12 support Key: FLINK-7729 URL: https://issues.apache.org/jira/browse/FLINK-7729 Project: Flink Issue T

[jira] [Closed] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x

[ https://issues.apache.org/jira/browse/FLINK-7413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7413. --- Resolution: Won't Fix Closing for now as "won't fix" based on feedback. > Release Hadoop 2.8.

[jira] [Closed] (FLINK-7547) o.a.f.s.api.scala.async.AsyncFunction is not declared Serializable

[ https://issues.apache.org/jira/browse/FLINK-7547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7547. --- Resolution: Fixed Fix Version/s: 1.4.0 Resolved in 09df80f0078142b4c7667b237ef48c51ef02

[jira] [Updated] (FLINK-7692) Support user-defined variables in Metrics

[ https://issues.apache.org/jira/browse/FLINK-7692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7692: Summary: Support user-defined variables in Metrics (was: Support user-defined variables) >

[jira] [Closed] (FLINK-7700) State merging in RocksDB backend leaves old state

[ https://issues.apache.org/jira/browse/FLINK-7700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7700. --- Resolution: Fixed Fixed on release-1.3 in 31cd6db6a7d2f7d78aa05f6ff5fc82abbc79d042 e0bd8c060da

[jira] [Closed] (FLINK-5619) Consolidate State tests

[ https://issues.apache.org/jira/browse/FLINK-5619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-5619. --- Resolution: Fixed Assignee: Aljoscha Krettek Fix Version/s: 1.3.3

[jira] [Closed] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

[ https://issues.apache.org/jira/browse/FLINK-7721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7721. --- Resolution: Fixed Fix Version/s: (was: 1.2.2) Fixed on release-1.3 in b67bc4da568df

[jira] [Commented] (FLINK-7750) Strange behaviour in savepoints

[ https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16187910#comment-16187910 ] Aljoscha Krettek commented on FLINK-7750: - Is the folder you specify for the savep

[jira] [Updated] (FLINK-6118) Chained operators forward watermark without checking

[ https://issues.apache.org/jira/browse/FLINK-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-6118: Description: For operators that read from the network we have checks in place that verify t

[jira] [Commented] (FLINK-5241) Introduce AbstractStreamOperator get CloseableRegistry

[ https://issues.apache.org/jira/browse/FLINK-5241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16188009#comment-16188009 ] Aljoscha Krettek commented on FLINK-5241: - [~srichter] This is probably not releva

[jira] [Closed] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

[ https://issues.apache.org/jira/browse/FLINK-7721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-7721. --- Resolution: Fixed Fixed on master in c81a7e519bf3db2f9c5e62fadd7a3a4fb7692904 > StatusWaterma

[jira] [Reopened] (FLINK-7721) StatusWatermarkValve should output a new min watermark only if it was aggregated from aligned chhanels

[ https://issues.apache.org/jira/browse/FLINK-7721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reopened FLINK-7721: - Reopen to fix git commit hash > StatusWatermarkValve should output a new min watermark only i

<    4   5   6   7   8   9   10   11   12   13   >