Bulk Operation

  1. Choose Issues
  2. Choose Operation
  3. Operation Details
  4. Confirmation

Step 1 of 4: Choose Issues


T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due
Bug FLINK-12303

Scala 2.12 lambdas does not work in event classes inside streams.

Unassigned Matěj Novotný Minor Open Unresolved  
Bug FLINK-12113

User code passing to fromCollection(Iterator, Class) not cleaned

Guowei Ma yankai zhang Major Open Unresolved  
Bug FLINK-12093

Apache Flink:Active MQ consumer job is getting finished after first message consume.

Unassigned shiv kumar Major Open Unresolved  
Improvement FLINK-12092

Doc of when `onTimer(...)` is called is inaccurate

Unassigned Ling Wang Minor Open Unresolved  
Improvement FLINK-12086

AsyncFunction - Add access to a user defined Object for cleanup on timeout

Unassigned Felix Wollschläger Major Open Unresolved  
Bug FLINK-12083

Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath.

Unassigned kelun wang Major Closed Invalid  
Bug FLINK-12072

Unable to Capture Metrics of AsyncIO

Unassigned sravan.korumilli Minor Closed Not A Bug  
New Feature FLINK-12047

Savepoint connector to read / write / process savepoints

Kostas Kloudas Tzu-Li (Gordon) Tai Major Open Unresolved  
Bug FLINK-12012

BroadcastStateITCase does not use Test Environments

Stephan Ewen Stephan Ewen Minor Closed Fixed  
New Feature FLINK-12005

[State TTL] Event time support

Yu Li Andrey Zagrebin Major Open Unresolved  
Improvement FLINK-12004

Consider about POJO using method chaining when extract TypeInformation

Unassigned jiawei chen Major Open Unresolved  
Improvement FLINK-11909

Provide default failure/timeout/backoff handling strategy for AsyncIO functions

Rong Rong Rong Rong Major Open Unresolved  
Sub-task FLINK-11889

FLINK-11458 Remove "stop" signal along with Stoppable interfaces

Kostas Kloudas Aljoscha Krettek Major Closed Fixed  
Bug FLINK-11867

Fix empty path check in StreamExEnv#readTextFile

Tom Goong Tom Goong Major Closed Fixed  
Improvement FLINK-11852

Improve Processing function example

TANG Wen-hui Flavio Pompermaier Minor Open Unresolved  
Improvement FLINK-11817

Update fold() example to use aggregate() instead

leesf Michael Holler Minor Closed Fixed  
Bug FLINK-11774

IllegalArgumentException in HeapPriorityQueueSet

Unassigned Kirill Vainer Major Open Unresolved  
Bug FLINK-11772

InternalTimerServiceSerializationProxy should not be serializing timers' key / namespace serializers anymore

Tzu-Li (Gordon) Tai Tzu-Li (Gordon) Tai Blocker Closed Fixed  
Sub-task FLINK-11765

FLINK-11756 Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.8

vinoyang vinoyang Blocker Open Unresolved  
Sub-task FLINK-11763

FLINK-11756 Update AbstractKeyedOperatorRestoreTestBase for 1.8

vinoyang vinoyang Blocker Open Unresolved  
Sub-task FLINK-11762

FLINK-11756 Update WindowOperatorMigrationTest for 1.8

vinoyang vinoyang Blocker Open Unresolved  
Improvement FLINK-11706

Add the SumFunction to support KeyedStream.sum with field which is array

wangpeibin wangpeibin Minor Closed Won't Do  
Improvement FLINK-11689

Code clean for StreamingJobGraphGenerator

Unassigned shiwuliang Minor Closed Fixed  
Task FLINK-11687

Remove useless code in StreamingJobGraphGenerator

wangsan wangsan Major Closed Duplicate  
Improvement FLINK-11653

Add configuration to enforce custom UID's on datastream

Seth Wiesman Seth Wiesman Minor Closed Fixed  
Bug FLINK-11640

Caused by: java.lang.IllegalStateException: No operators defined in streaming topology. Cannot execute.

Unassigned thinktothings Minor Closed Not A Problem  
Improvement FLINK-11619

Make ScheduleMode configurable via user code or configuration file

yuqi yuqi Major Open Unresolved  
Improvement FLINK-11523

TestHarness should provide way to configure TypeSerailizers for side output

Unassigned Alexey Trenikhin Major Open Unresolved  
Improvement FLINK-11510

Add the MultiFieldSumAggregator to support KeyedStream.sum(int[] positionToSums )

wangpeibin wangpeibin Minor Closed Won't Do  
Improvement FLINK-11456

Improve window operator with sliding window assigners

vinoyang Rong Rong Major Closed Invalid  
New Feature FLINK-11454

Support MergedStream operation

Rong Rong Rong Rong Major Open Unresolved  
New Feature FLINK-11453

Support SliceStream with forwardable pane info

Rong Rong Rong Rong Major Closed Invalid  
Improvement FLINK-11409

Make `ProcessFunction`, `ProcessWindowFunction` and etc. pure interfaces

Kezhu Wang Kezhu Wang Major Open Unresolved  
Bug FLINK-11408

ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

Unassigned Cristian Major Open Unresolved  
Improvement FLINK-11397

Speed up initialization of AbstractStreamOperatorTestHarness

Unassigned TisonKun Major Closed Cannot Reproduce  
Bug FLINK-11326

Allow negative offsets in window assigners

Kezhu Wang TANG Wen-hui Major Closed Fixed  
Bug FLINK-11325

Flink Consumer Kafka Topic Not Found ConsumerID

Unassigned dengjie Major Closed Not A Bug  
Improvement FLINK-11311

StreamSource implements StreamOperator interface multiple times.

Benchao Li Benchao Li Trivial Closed Fixed  
Improvement FLINK-11286

Support to send StreamStatus.IDLE for non-source operators

vinoyang vinoyang Major Open Unresolved  
Improvement FLINK-11283

Add keyed CoProcessFunction that allows accessing key

vinoyang Truong Duc Kien Major In Progress Unresolved  
New Feature FLINK-11276

Sliding Window Optimization

Rong Rong Rong Rong Major Open Unresolved  
Improvement FLINK-11255

RemoteStreamEnvironment should be able to execute in detached mode

Unassigned Benjamin Lee Minor Open Unresolved  
Improvement FLINK-11231

Unified the definition of Java DataStream and Scala DataStream interface for set parallelism

Unassigned sunjincheng Major Closed Incomplete  
Improvement FLINK-11226

Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream

vinoyang Albert Bikeev Major In Progress Unresolved  
Bug FLINK-11211

ReinterpretDataStreamAsKeyedStreamITCase failed on Travis

Unassigned Chesnay Schepler Major Closed Duplicate  
New Feature FLINK-11198

Access to MetricGroup in an AggregateFunction(Non Rich)

Hequn Cheng Chirag Dewan Major Open Unresolved  
New Feature FLINK-11186

Event-time balancing for multiple Kafka partitions

Unassigned Tom Schamberger Major Open Unresolved  
Sub-task FLINK-11153

FLINK-8033 Remove UdfAnalyzer

Chesnay Schepler Gary Yao Major Closed Fixed  
Bug FLINK-11128

Methods of org.apache.flink.table.expressions.Expression are private[flink]

vinoyang Denys Fakhritdinov Critical Closed Not A Bug  
Improvement FLINK-11090

Remove unused parameter in WindowedStream.aggregate()

Hequn Cheng Hequn Cheng Major Closed Fixed