[jira] [Created] (FLINK-10917) Bump up the version of codahale's metrics-core to 3.2.3 or higher

Dongwon Kim created FLINK-10917: --- Summary: Bump up the version of codahale's metrics-core to 3.2.3 or higher Key: FLINK-10917 URL: https://issues.apache.org/jira/browse/FLINK-10917 Project: Flink

[jira] [Updated] (FLINK-8418) Kafka08ITCase.testStartFromLatestOffsets() times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8418: - Fix Version/s: 1.8.0 > Kafka08ITCase.testStartFromLatestOffsets() times out on Travis >

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10435: -- Fix Version/s: 1.7.1 > Client sporadically hangs after Ctrl + C >

[jira] [Updated] (FLINK-10347) Kafka09SecuredRunITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10347: -- Fix Version/s: 1.8.0 > Kafka09SecuredRunITCase failed on Travis >

[jira] [Updated] (FLINK-10842) Waiting loops are broken in e2e/common.sh

[ https://issues.apache.org/jira/browse/FLINK-10842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10842: -- Fix Version/s: 1.8.0 > Waiting loops are broken in e2e/common.sh >

[jira] [Updated] (FLINK-10252) Handle oversized metric messges

[ https://issues.apache.org/jira/browse/FLINK-10252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10252: -- Fix Version/s: 1.7.1 > Handle oversized metric messges > --- > >

[jira] [Commented] (FLINK-10916) Include duplicated user-specified uid into error message

[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690851#comment-16690851 ] ASF GitHub Bot commented on FLINK-10916: Mododo opened a new pull request #7133: [FLINK-10916]

[jira] [Updated] (FLINK-10916) Include duplicated user-specified uid into error message

[ https://issues.apache.org/jira/browse/FLINK-10916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10916: --- Labels: easyfix newbie pull-request-available (was: easyfix newbie) > Include duplicated

[jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement

[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10079: -- Fix Version/s: 1.8.0 > Support external sink table in INSERT INTO statement >

[jira] [Updated] (FLINK-7982) Bump commons-configuration to 2.2

[ https://issues.apache.org/jira/browse/FLINK-7982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7982: - Fix Version/s: 1.8.0 > Bump commons-configuration to 2.2 > - > >

[jira] [Updated] (FLINK-10304) Remove deprecated AbstractYarnClusterDescriptor field

[ https://issues.apache.org/jira/browse/FLINK-10304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10304: -- Fix Version/s: 1.8.0 > Remove deprecated AbstractYarnClusterDescriptor field >

[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests

[ https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9680: - Fix Version/s: 1.8.0 > Reduce heartbeat timeout for E2E tests >

[jira] [Updated] (FLINK-7981) Bump commons-lang3 version to 3.6

[ https://issues.apache.org/jira/browse/FLINK-7981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7981: - Fix Version/s: 1.8.0 > Bump commons-lang3 version to 3.6 > - > >

[jira] [Updated] (FLINK-10106) Include test name in temp directory of e2e test

[ https://issues.apache.org/jira/browse/FLINK-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10106: -- Fix Version/s: 1.8.0 > Include test name in temp directory of e2e test >

[jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code

[ https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9776: - Fix Version/s: 1.8.0 > Interrupt TaskThread only while in User/Operator code >

[jira] [Updated] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable

[ https://issues.apache.org/jira/browse/FLINK-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9845: - Fix Version/s: 1.8.0 > Make InternalTimerService's timer processing interruptible/abortable >

[jira] [Updated] (FLINK-10226) Latency metrics can choke job-manager

[ https://issues.apache.org/jira/browse/FLINK-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10226: -- Fix Version/s: 1.8.0 > Latency metrics can choke job-manager >

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7991: - Fix Version/s: 1.8.0 > Cleanup kafka example jar filters > - > >

[jira] [Updated] (FLINK-8033) Build Flink with JDK 9

[ https://issues.apache.org/jira/browse/FLINK-8033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8033: - Fix Version/s: 1.8.0 > Build Flink with JDK 9 > -- > > Key:

[jira] [Updated] (FLINK-10718) Use IO executor in RpcService for message serialization

[ https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10718: -- Fix Version/s: 1.8.0 > Use IO executor in RpcService for message serialization >

[jira] [Updated] (FLINK-10517) Add stability test for the REST API

[ https://issues.apache.org/jira/browse/FLINK-10517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10517: -- Fix Version/s: 1.8.0 > Add stability test for the REST API >

[jira] [Updated] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7289: - Fix Version/s: 1.8.0 > Memory allocation of RocksDB can be problematic in container environments

[jira] [Updated] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6764: - Fix Version/s: 1.8.0 > Deduplicate stateless TypeSerializers when serializing composite >

[jira] [Updated] (FLINK-10343) Expose setCurrentKey method to streamRuntimeContext

[ https://issues.apache.org/jira/browse/FLINK-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10343: -- Fix Version/s: 1.8.0 > Expose setCurrentKey method to streamRuntimeContext >

[jira] [Updated] (FLINK-10385) Implement a waitUntilCondition utils

[ https://issues.apache.org/jira/browse/FLINK-10385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10385: -- Fix Version/s: 1.8.0 > Implement a waitUntilCondition utils >

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9228: - Fix Version/s: 1.8.0 > log details about task fail/task manager is shutting down >

[jira] [Updated] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot

[ https://issues.apache.org/jira/browse/FLINK-10132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10132: -- Fix Version/s: 1.8.0 > Incremental cleanup of local expired state with TTL discovered in full

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10292: -- Fix Version/s: 1.8.0 > Generate JobGraph in StandaloneJobClusterEntrypoint only once >

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10251: -- Fix Version/s: 1.8.0 > Handle oversized response messages in AkkaRpcActor >

[jira] [Updated] (FLINK-5505) Harmonize ZooKeeper configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5505: - Fix Version/s: 1.8.0 > Harmonize ZooKeeper configuration parameters >

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8416: - Fix Version/s: 1.8.0 > Kinesis consumer doc examples should demonstrate preferred default >

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6571: - Fix Version/s: 1.8.0 > InfiniteSource in SourceStreamOperatorTest should deal with >

[jira] [Updated] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7009: - Fix Version/s: 1.8.0 > dogstatsd mode in statsd reporter > - > >

[jira] [Updated] (FLINK-5513) Remove relocation of internal API classes

[ https://issues.apache.org/jira/browse/FLINK-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5513: - Fix Version/s: 1.8.0 > Remove relocation of internal API classes >

[jira] [Updated] (FLINK-7463) Release nascent workers on slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-7463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7463: - Fix Version/s: 1.8.0 > Release nascent workers on slot request timeout >

[jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9507: - Fix Version/s: 1.8.0 > Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9195: - Fix Version/s: 1.8.0 > Delete non-well-defined output methods on DataStream >

[jira] [Updated] (FLINK-8180) Refactor driver outputs

[ https://issues.apache.org/jira/browse/FLINK-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8180: - Fix Version/s: 1.8.0 > Refactor driver outputs > --- > >

[jira] [Updated] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7286: - Fix Version/s: 1.8.0 > Flink Dashboard fails to display bytes/records received by sources >

[jira] [Updated] (FLINK-6022) Don't serialise Schema when serialising Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6022: - Fix Version/s: 1.8.0 > Don't serialise Schema when serialising Avro GenericRecord >

[jira] [Updated] (FLINK-4399) Add support for oversized messages

[ https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4399: - Fix Version/s: 1.8.0 > Add support for oversized messages > -- >

[jira] [Updated] (FLINK-10268) Document update deployment/aws HADOOP_CLASSPATH

[ https://issues.apache.org/jira/browse/FLINK-10268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10268: -- Fix Version/s: 1.8.0 > Document update deployment/aws HADOOP_CLASSPATH >

[jira] [Updated] (FLINK-9462) Disentangle flink-json and flink-table

[ https://issues.apache.org/jira/browse/FLINK-9462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9462: - Fix Version/s: 1.8.0 > Disentangle flink-json and flink-table >

[jira] [Updated] (FLINK-9461) Disentangle flink-connector-kafka from flink-table and flink-json

[ https://issues.apache.org/jira/browse/FLINK-9461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9461: - Fix Version/s: 1.8.0 > Disentangle flink-connector-kafka from flink-table and flink-json >

[jira] [Updated] (FLINK-5479) Per-partition watermarks in FlinkKafkaConsumer should consider idle partitions

[ https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5479: - Fix Version/s: 1.8.0 > Per-partition watermarks in FlinkKafkaConsumer should consider idle

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9457: - Fix Version/s: 1.8.0 > Cancel container requests when cancelling pending slot allocations >

[jira] [Updated] (FLINK-6856) Eagerly check if serializer config snapshots are deserializable when snapshotting

[ https://issues.apache.org/jira/browse/FLINK-6856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6856: - Fix Version/s: 1.8.0 > Eagerly check if serializer config snapshots are deserializable when >

[jira] [Updated] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8357: - Fix Version/s: 1.8.0 > enable rolling in default log settings >

[jira] [Updated] (FLINK-6437) Move history server configuration to a separate file

[ https://issues.apache.org/jira/browse/FLINK-6437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6437: - Fix Version/s: 1.8.0 > Move history server configuration to a separate file >

[jira] [Updated] (FLINK-8918) Introduce Runtime Filter Join

[ https://issues.apache.org/jira/browse/FLINK-8918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8918: - Fix Version/s: 1.8.0 > Introduce Runtime Filter Join > - > >

[jira] [Updated] (FLINK-9959) Add JoinWindowFunction to allow access Window

[ https://issues.apache.org/jira/browse/FLINK-9959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9959: - Fix Version/s: 1.8.0 > Add JoinWindowFunction to allow access Window >

[jira] [Updated] (FLINK-9036) Add default value via suppliers

[ https://issues.apache.org/jira/browse/FLINK-9036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9036: - Fix Version/s: 1.8.0 > Add default value via suppliers > --- > >

[jira] [Updated] (FLINK-9478) Use Yarn application proxy to communicate with Flink cluster

[ https://issues.apache.org/jira/browse/FLINK-9478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9478: - Fix Version/s: 1.8.0 > Use Yarn application proxy to communicate with Flink cluster >

[jira] [Updated] (FLINK-10352) Bind Task's URLClassLoader to TaskExecutor's slot

[ https://issues.apache.org/jira/browse/FLINK-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10352: -- Fix Version/s: 1.8.0 > Bind Task's URLClassLoader to TaskExecutor's slot >

[jira] [Updated] (FLINK-8302) Support shift_left and shift_right in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8302: - Fix Version/s: 1.8.0 > Support shift_left and shift_right in TableAPI >

[jira] [Updated] (FLINK-9303) Unassign partitions from Kafka client if partitions become unavailable

[ https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9303: - Fix Version/s: 1.8.0 > Unassign partitions from Kafka client if partitions become unavailable >

[jira] [Updated] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active

[ https://issues.apache.org/jira/browse/FLINK-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10122: -- Fix Version/s: 1.8.0 > KafkaConsumer should use partitionable state over union state if

[jira] [Updated] (FLINK-10121) Introduce methods to remove registered operator states

[ https://issues.apache.org/jira/browse/FLINK-10121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10121: -- Fix Version/s: 1.8.0 > Introduce methods to remove registered operator states >

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6053: - Fix Version/s: 1.8.0 > Gauge should only take subclasses of Number, rather than everything >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: 1.8.0 > Reduce performance/stability impact of latency metrics >

[jira] [Updated] (FLINK-6763) Inefficient PojoSerializerConfigSnapshot serialization format

[ https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6763: - Fix Version/s: 1.8.0 > Inefficient PojoSerializerConfigSnapshot serialization format >

[jira] [Updated] (FLINK-9364) Add doc of the memory usage in flink

[ https://issues.apache.org/jira/browse/FLINK-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9364: - Fix Version/s: 1.8.0 > Add doc of the memory usage in flink >

[GitHub] dawidwys closed pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause

dawidwys closed pull request #7070: [FLINK-10625] Documentation for MATCH_RECOGNIZE clause URL: https://github.com/apache/flink/pull/7070 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this

[jira] [Created] (FLINK-10916) Include duplicated user-specified uid into error message

Kirill Mikheev created FLINK-10916: -- Summary: Include duplicated user-specified uid into error message Key: FLINK-10916 URL: https://issues.apache.org/jira/browse/FLINK-10916 Project: Flink

[jira] [Closed] (FLINK-10810) Update DataStreamUtils.reinterpretAsKeyedStream to state limitations

[ https://issues.apache.org/jira/browse/FLINK-10810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-10810. - Resolution: Invalid Fix Version/s: (was: 1.7.0) Properly fixed by FLINK-10809. >

[jira] [Updated] (FLINK-9870) Support field mapping and time attributes for table sinks

[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9870: - Fix Version/s: (was: 1.7.0) > Support field mapping and time attributes for table sinks >

[jira] [Updated] (FLINK-5505) Harmonize ZooKeeper configuration parameters

[ https://issues.apache.org/jira/browse/FLINK-5505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5505: - Fix Version/s: (was: 1.7.0) > Harmonize ZooKeeper configuration parameters >

[jira] [Updated] (FLINK-9364) Add doc of the memory usage in flink

[ https://issues.apache.org/jira/browse/FLINK-9364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9364: - Fix Version/s: (was: 1.7.0) > Add doc of the memory usage in flink >

[jira] [Updated] (FLINK-7958) Allow reporters to override the default delimiter

[ https://issues.apache.org/jira/browse/FLINK-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7958: - Fix Version/s: (was: 1.7.0) > Allow reporters to override the default delimiter >

[jira] [Updated] (FLINK-7009) dogstatsd mode in statsd reporter

[ https://issues.apache.org/jira/browse/FLINK-7009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7009: - Fix Version/s: (was: 1.7.0) > dogstatsd mode in statsd reporter >

[jira] [Updated] (FLINK-9193) Deprecate non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9193: - Fix Version/s: (was: 1.7.0) > Deprecate non-well-defined output methods on DataStream >

[jira] [Updated] (FLINK-10113) Drop support for pre 1.6 shared buffer state

[ https://issues.apache.org/jira/browse/FLINK-10113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10113: -- Fix Version/s: (was: 1.7.0) > Drop support for pre 1.6 shared buffer state >

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

[ https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9469: - Fix Version/s: (was: 1.7.0) > Add tests that cover PatternStream#flatSelect >

[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9195: - Fix Version/s: (was: 1.7.0) > Delete non-well-defined output methods on DataStream >

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7991: - Fix Version/s: (was: 1.7.0) > Cleanup kafka example jar filters >

[jira] [Updated] (FLINK-10226) Latency metrics can choke job-manager

[ https://issues.apache.org/jira/browse/FLINK-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10226: -- Fix Version/s: (was: 1.7.0) > Latency metrics can choke job-manager >

[jira] [Updated] (FLINK-8302) Support shift_left and shift_right in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8302: - Fix Version/s: (was: 1.7.0) > Support shift_left and shift_right in TableAPI >

[jira] [Updated] (FLINK-4399) Add support for oversized messages

[ https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4399: - Fix Version/s: (was: 1.7.0) > Add support for oversized messages >

[jira] [Updated] (FLINK-7829) Remove (or at least deprecate) DataStream.writeToFile/Csv

[ https://issues.apache.org/jira/browse/FLINK-7829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7829: - Fix Version/s: (was: 1.7.0) > Remove (or at least deprecate) DataStream.writeToFile/Csv >

[jira] [Updated] (FLINK-10106) Include test name in temp directory of e2e test

[ https://issues.apache.org/jira/browse/FLINK-10106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10106: -- Fix Version/s: (was: 1.7.0) > Include test name in temp directory of e2e test >

[jira] [Updated] (FLINK-7087) Implement Flip-6 container entry point

[ https://issues.apache.org/jira/browse/FLINK-7087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7087: - Fix Version/s: (was: 1.7.0) > Implement Flip-6 container entry point >

[jira] [Updated] (FLINK-6764) Deduplicate stateless TypeSerializers when serializing composite TypeSerializers

[ https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6764: - Fix Version/s: (was: 1.7.0) > Deduplicate stateless TypeSerializers when serializing

[jira] [Updated] (FLINK-7463) Release nascent workers on slot request timeout

[ https://issues.apache.org/jira/browse/FLINK-7463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7463: - Fix Version/s: (was: 1.7.0) > Release nascent workers on slot request timeout >

[jira] [Updated] (FLINK-5513) Remove relocation of internal API classes

[ https://issues.apache.org/jira/browse/FLINK-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5513: - Fix Version/s: (was: 1.7.0) > Remove relocation of internal API classes >

[jira] [Updated] (FLINK-8416) Kinesis consumer doc examples should demonstrate preferred default credentials provider

[ https://issues.apache.org/jira/browse/FLINK-8416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8416: - Fix Version/s: (was: 1.7.0) > Kinesis consumer doc examples should demonstrate preferred

[jira] [Updated] (FLINK-10352) Bind Task's URLClassLoader to TaskExecutor's slot

[ https://issues.apache.org/jira/browse/FLINK-10352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10352: -- Fix Version/s: (was: 1.7.0) > Bind Task's URLClassLoader to TaskExecutor's slot >

[jira] [Updated] (FLINK-10718) Use IO executor in RpcService for message serialization

[ https://issues.apache.org/jira/browse/FLINK-10718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10718: -- Fix Version/s: (was: 1.7.0) > Use IO executor in RpcService for message serialization >

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6571: - Fix Version/s: (was: 1.7.0) > InfiniteSource in SourceStreamOperatorTest should deal with >

[jira] [Updated] (FLINK-10612) Run rat-plugin separately for each module

[ https://issues.apache.org/jira/browse/FLINK-10612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10612: -- Fix Version/s: (was: 1.7.0) > Run rat-plugin separately for each module >

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6053: - Fix Version/s: (was: 1.7.0) > Gauge should only take subclasses of Number, rather than

[jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement

[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10079: -- Fix Version/s: (was: 1.7.0) > Support external sink table in INSERT INTO statement >

[jira] [Updated] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active

[ https://issues.apache.org/jira/browse/FLINK-10122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10122: -- Fix Version/s: (was: 1.7.0) > KafkaConsumer should use partitionable state over union

[jira] [Updated] (FLINK-8180) Refactor driver outputs

[ https://issues.apache.org/jira/browse/FLINK-8180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-8180: - Fix Version/s: (was: 1.7.0) > Refactor driver outputs > --- > >

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9228: - Fix Version/s: (was: 1.7.0) > log details about task fail/task manager is shutting down >

[jira] [Updated] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

[ https://issues.apache.org/jira/browse/FLINK-10002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10002: -- Fix Version/s: (was: 1.7.0) > WebUI shows logs unfriendly, especially when the amount of

[jira] [Updated] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9507: - Fix Version/s: (was: 1.7.0) > Introduce ReduceFunction to CEP to minor the cost for

[jira] [Updated] (FLINK-9675) Avoid FileInputStream/FileOutputStream

[ https://issues.apache.org/jira/browse/FLINK-9675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9675: - Fix Version/s: (was: 1.7.0) > Avoid FileInputStream/FileOutputStream >

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10241: -- Fix Version/s: (was: 1.7.0) > Reduce performance/stability impact of latency metrics >

[jira] [Updated] (FLINK-6022) Don't serialise Schema when serialising Avro GenericRecord

[ https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6022: - Fix Version/s: (was: 1.7.0) > Don't serialise Schema when serialising Avro GenericRecord >

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9228: - Fix Version/s: 1.7.1 > log details about task fail/task manager is shutting down >

  1   2   3   4   5   >