[jira] [Updated] (FLINK-5440) Misleading error message when migrating and scaling down from savepoint

[ https://issues.apache.org/jira/browse/FLINK-5440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5440: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Misleading erro

[jira] [Updated] (FLINK-5405) Add streaming connection to twitter through a internet proxy

[ https://issues.apache.org/jira/browse/FLINK-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5405: Labels: easyfix (was: auto-closed easyfix) Priority: Not a Priority (was: Minor) >

[jira] [Updated] (FLINK-4493) Unify the snapshot output format for keyed-state backends

[ https://issues.apache.org/jira/browse/FLINK-4493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4493: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Unify the snaps

[jira] [Updated] (FLINK-19883) Support "IF EXISTS" in DDL for ALTER TABLE

[ https://issues.apache.org/jira/browse/FLINK-19883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19883: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Support "IF

[jira] [Updated] (FLINK-6220) Fine-grained copy-on-write for Heap(Map/List)States in CopyOnWriteStateTable

[ https://issues.apache.org/jira/browse/FLINK-6220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6220: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Fine-grained co

[jira] [Updated] (FLINK-16481) Improved FlinkkafkaConnector support for dynamically increasing capacity

[ https://issues.apache.org/jira/browse/FLINK-16481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16481: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Improved Fli

[jira] [Updated] (FLINK-5726) Add the RocketMQ plugin for the Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-5726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5726: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-19283) Allow subclasses to override/extend FlinkKafkaConsumerBase checkpoint methods

[ https://issues.apache.org/jira/browse/FLINK-19283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19283: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Allow subcla

[jira] [Updated] (FLINK-11416) DISTINCT on a JOIN inside of an UNION is not working

[ https://issues.apache.org/jira/browse/FLINK-11416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11416: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > DISTINCT on

[jira] [Updated] (FLINK-4266) Cassandra SplitOver Statebackend

[ https://issues.apache.org/jira/browse/FLINK-4266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4266: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-16872) Flink UI shows server error on selecting back pressure on a batch job

[ https://issues.apache.org/jira/browse/FLINK-16872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16872: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Flink UI sho

[jira] [Updated] (FLINK-11748) Optimize savepoint: Remove the task states and KeyedState into increments.

[ https://issues.apache.org/jira/browse/FLINK-11748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11748: - Labels: pull-request-available (was: auto-closed pull-request-available) Priority:

[jira] [Updated] (FLINK-18845) class not found exception when i use sql client to try mysql as datasource.

[ https://issues.apache.org/jira/browse/FLINK-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18845: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > class not fo

[jira] [Updated] (FLINK-11660) Implement HadoopReduceFunctionITCase for new Hadoop API

[ https://issues.apache.org/jira/browse/FLINK-11660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11660: - Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority

[jira] [Updated] (FLINK-8641) Move BootstrapTools#getTaskManagerShellCommand to flink-yarn

[ https://issues.apache.org/jira/browse/FLINK-8641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8641: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Move BootstrapT

[jira] [Updated] (FLINK-12593) Revise the document for CEP

[ https://issues.apache.org/jira/browse/FLINK-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12593: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Revise the d

[jira] [Updated] (FLINK-16453) A test failure in KafkaTest

[ https://issues.apache.org/jira/browse/FLINK-16453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16453: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > A test failu

[jira] [Updated] (FLINK-3625) Graph algorithms to permute graph labels and edges

[ https://issues.apache.org/jira/browse/FLINK-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3625: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-4295) CoGroupGroupSortTranslationTest#testGroupSortTuplesDefaultCoGroup fails to run

[ https://issues.apache.org/jira/browse/FLINK-4295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4295: Labels: test-stability (was: auto-closed test-stability) Priority: Not a Priority (w

[jira] [Updated] (FLINK-17584) disableAutoTypeRegistration option does not work with Streaming API, only with Batch

[ https://issues.apache.org/jira/browse/FLINK-17584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17584: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > disableAutoT

[jira] [Updated] (FLINK-1256) Use Kryo for user code object serialization

[ https://issues.apache.org/jira/browse/FLINK-1256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1256: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Use Kryo for us

[jira] [Updated] (FLINK-9328) RocksDBStateBackend might use PlaceholderStreamStateHandle to restore due to StateBackendTestBase class not register snapshots in some UTs

[ https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9328: Labels: pull-request-available stale-assigned (was: auto-closed pull-request-available s

[jira] [Updated] (FLINK-5765) Add noindex meta tag for older docs

[ https://issues.apache.org/jira/browse/FLINK-5765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5765: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add noindex met

[jira] [Updated] (FLINK-19209) Single bucket

[ https://issues.apache.org/jira/browse/FLINK-19209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19209: - Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority

[jira] [Updated] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-3119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3119: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Remove dependen

[jira] [Updated] (FLINK-5973) check whether the direct memory size is always correctly calculated

[ https://issues.apache.org/jira/browse/FLINK-5973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5973: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > check whether t

[jira] [Updated] (FLINK-17409) SqlCreateView's SqlParserPos return wrong value

[ https://issues.apache.org/jira/browse/FLINK-17409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17409: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > SqlCreateVie

[jira] [Updated] (FLINK-19359) Restore from Checkpoint fails if checkpoint folders is corrupt/partial

[ https://issues.apache.org/jira/browse/FLINK-19359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19359: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Restore from

[jira] [Updated] (FLINK-17583) Allow option to store a savepoint's _metadata file separate from its data files

[ https://issues.apache.org/jira/browse/FLINK-17583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17583: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Allow option

[jira] [Updated] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories

[ https://issues.apache.org/jira/browse/FLINK-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1268: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > FileOutputForma

[jira] [Updated] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

[ https://issues.apache.org/jira/browse/FLINK-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10391: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > MillisOfDay

[jira] [Updated] (FLINK-14810) It's weird that copy julianDateFloor from DateTimeUtils and change the implementation

[ https://issues.apache.org/jira/browse/FLINK-14810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14810: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > It's weird t

[jira] [Updated] (FLINK-14354) Provide interfaces instead of abstract classes in org.apache.flink.state.api.functions

[ https://issues.apache.org/jira/browse/FLINK-14354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14354: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Provide inte

[jira] [Updated] (FLINK-3961) Possibility to write output to multiple locations based on partitions

[ https://issues.apache.org/jira/browse/FLINK-3961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3961: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Possibility to

[jira] [Updated] (FLINK-1092) Allow operations, other than join and cogroup, on the solution set

[ https://issues.apache.org/jira/browse/FLINK-1092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1092: Labels: feature (was: auto-closed feature) Priority: Not a Priority (was: Minor) >

[jira] [Updated] (FLINK-3966) AvroTypeInfo does not work with readonly avro specific records

[ https://issues.apache.org/jira/browse/FLINK-3966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3966: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > AvroTypeInfo do

[jira] [Updated] (FLINK-2910) Reorganize / Combine Gelly tests

[ https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2910: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-7687) Clarify the master and slaves files are not necessary unless using the cluster start/stop scripts

[ https://issues.apache.org/jira/browse/FLINK-7687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7687: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Clarify the mas

[jira] [Updated] (FLINK-15580) Add baseurl to docs/build_docs.sh

[ https://issues.apache.org/jira/browse/FLINK-15580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15580: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add baseurl

[jira] [Updated] (FLINK-8197) Support include conf directories in flink config

[ https://issues.apache.org/jira/browse/FLINK-8197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8197: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Support include

[jira] [Updated] (FLINK-7634) Add option to create a savepoint while canceling a job in the dashboard

[ https://issues.apache.org/jira/browse/FLINK-7634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7634: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add option to c

[jira] [Updated] (FLINK-17966) Documentation improvement of checkpointing API

[ https://issues.apache.org/jira/browse/FLINK-17966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17966: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Documentatio

[jira] [Updated] (FLINK-13871) Consolidate isRunning, canceled, isFinished fields in StreamTask and SourceStreamTask

[ https://issues.apache.org/jira/browse/FLINK-13871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13871: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Consolidate

[jira] [Updated] (FLINK-9040) JobVertex#setMaxParallelism does not validate argument

[ https://issues.apache.org/jira/browse/FLINK-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9040: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > JobVertex#setMa

[jira] [Updated] (FLINK-19198) Invalid default value for consume-start-offset in Hive streaming

[ https://issues.apache.org/jira/browse/FLINK-19198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19198: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Invalid defa

[jira] [Updated] (FLINK-8951) Support OVER windows PARTITION BY (rounded) timestamp

[ https://issues.apache.org/jira/browse/FLINK-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8951: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-7384) Unify event and processing time handling in the AbstractKeyedCEPPatternOperator.

[ https://issues.apache.org/jira/browse/FLINK-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7384: Labels: pull-request-available (was: auto-closed pull-request-available) Priority: No

[jira] [Updated] (FLINK-5707) Find better keys for backend configuration parameters for state backends

[ https://issues.apache.org/jira/browse/FLINK-5707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5707: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Find better key

[jira] [Updated] (FLINK-9264) Add method Writer[A]#contramap[B](f: B => A): Writer[B]

[ https://issues.apache.org/jira/browse/FLINK-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9264: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-10037) Document details event time behavior in a single location

[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10037: - Labels: pull-request-available stale-assigned (was: auto-closed pull-request-availabl

[jira] [Updated] (FLINK-4992) Expose String parameter for timers in Timely functions and TimerService

[ https://issues.apache.org/jira/browse/FLINK-4992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4992: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Expose String p

[jira] [Updated] (FLINK-10272) using Avro's DateConversion causes ClassNotFoundException on Hadoop bundle

[ https://issues.apache.org/jira/browse/FLINK-10272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10272: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > using Avro's

[jira] [Updated] (FLINK-14896) Kinesis connector doesn't shade jackson dependency

[ https://issues.apache.org/jira/browse/FLINK-14896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14896: - Labels: pull-request-available (was: auto-closed pull-request-available) Priority:

[jira] [Updated] (FLINK-6045) FLINK_CONF_DIR has to be set even though specifying --configDir

[ https://issues.apache.org/jira/browse/FLINK-6045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6045: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > FLINK_CONF_DIR

[jira] [Updated] (FLINK-7628) Add cookbooks to the documentation

[ https://issues.apache.org/jira/browse/FLINK-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7628: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-1258) Merge iterative and non-iterative tasks

[ https://issues.apache.org/jira/browse/FLINK-1258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1258: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Merge iterative

[jira] [Updated] (FLINK-13200) Improve the generated code for if statements

[ https://issues.apache.org/jira/browse/FLINK-13200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13200: - Labels: pull-request-available stale-assigned (was: auto-closed pull-request-availabl

[jira] [Updated] (FLINK-10561) Flink doesn't start locally if remove log package

[ https://issues.apache.org/jira/browse/FLINK-10561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10561: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Flink doesn'

[jira] [Updated] (FLINK-20635) Scala REPL with java.lang.NoSuchMethod: Errorjava.lang.NoSuchMethodError

[ https://issues.apache.org/jira/browse/FLINK-20635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20635: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Scala REPL w

[jira] [Updated] (FLINK-8437) SideOutput() API is ambiguous

[ https://issues.apache.org/jira/browse/FLINK-8437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8437: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-12320) Flink bucketing sink restart with save point cause data loss when using SequenceFile.CompressionType.BLOCK

[ https://issues.apache.org/jira/browse/FLINK-12320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12320: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Flink bucket

[jira] [Updated] (FLINK-14828) When double-click the jobId, the selected data is a little more

[ https://issues.apache.org/jira/browse/FLINK-14828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14828: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > When double-

[jira] [Updated] (FLINK-6946) Same access to time in process functions for all-windows as keyed windows

[ https://issues.apache.org/jira/browse/FLINK-6946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6946: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Same access to

[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 ] Konstantin Knauf updated FLINK-9228: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > log details abo

[jira] [Updated] (FLINK-2190) Enhance stream decoration/compression extensibility

[ https://issues.apache.org/jira/browse/FLINK-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2190: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-3542) FlinkKafkaConsumer09 cannot handle changing number of partitions

[ https://issues.apache.org/jira/browse/FLINK-3542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3542: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > FlinkKafkaConsu

[jira] [Updated] (FLINK-16640) Expose listStatus latency in flink filesystem

[ https://issues.apache.org/jira/browse/FLINK-16640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16640: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Expose listS

[jira] [Updated] (FLINK-2693) Refactor InvalidTypesException to be checked

[ https://issues.apache.org/jira/browse/FLINK-2693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2693: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Refactor Invali

[jira] [Updated] (FLINK-19537) Processed in-flight bytes metric is not accurate

[ https://issues.apache.org/jira/browse/FLINK-19537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19537: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Processed in

[jira] [Updated] (FLINK-1509) Streaming Group Reduce Combiner

[ https://issues.apache.org/jira/browse/FLINK-1509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1509: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Streaming Group

[jira] [Updated] (FLINK-4438) FlinkML Quickstart Guide implies incorrect type for test data

[ https://issues.apache.org/jira/browse/FLINK-4438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4438: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > FlinkML Quickst

[jira] [Updated] (FLINK-5200) Display recovery information in Webfrontend

[ https://issues.apache.org/jira/browse/FLINK-5200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5200: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Display recover

[jira] [Updated] (FLINK-6889) Improve Path parsing for Windows paths with scheme

[ https://issues.apache.org/jira/browse/FLINK-6889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6889: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Improve Path pa

[jira] [Updated] (FLINK-4761) Web UI can't display large log files

[ https://issues.apache.org/jira/browse/FLINK-4761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4761: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Web UI can't di

[jira] [Updated] (FLINK-8141) Add AppendStreamTableSink for bucketed ORC files

[ https://issues.apache.org/jira/browse/FLINK-8141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8141: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add AppendStrea

[jira] [Updated] (FLINK-14597) Move tests of MapView and ListView from flink-table-planner to flink-table-common

[ https://issues.apache.org/jira/browse/FLINK-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14597: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Move tests o

[jira] [Updated] (FLINK-12044) Flink CEP discards events as late if they have timestamps <= 0

[ https://issues.apache.org/jira/browse/FLINK-12044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12044: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Flink CEP di

[jira] [Updated] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-12215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12215: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Introduce Sq

[jira] [Updated] (FLINK-17574) Deduplicate the process execution logic in Flink

[ https://issues.apache.org/jira/browse/FLINK-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17574: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Deduplicate

[jira] [Updated] (FLINK-15475) Add isOutputTypeUsed() API to Transformation

[ https://issues.apache.org/jira/browse/FLINK-15475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15475: - Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority

[jira] [Updated] (FLINK-6912) Consider changing the RichFunction#open method signature to take no arguments.

[ https://issues.apache.org/jira/browse/FLINK-6912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6912: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Consider changi

[jira] [Updated] (FLINK-5547) Move checks for DataSetRel validity into constructor

[ https://issues.apache.org/jira/browse/FLINK-5547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5547: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Move checks for

[jira] [Updated] (FLINK-17444) StreamingFileSink Azure HadoopRecoverableWriter class missing.

[ https://issues.apache.org/jira/browse/FLINK-17444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17444: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > StreamingFil

[jira] [Reopened] (FLINK-4335) Add jar id, and job parameters information to job status rest call

[ https://issues.apache.org/jira/browse/FLINK-4335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reopened FLINK-4335: - Re-opening in accordance with https://issues.apache.org/jira/browse/FLINK-23206. > Add jar i

[jira] [Updated] (FLINK-10148) flink cancel withSavepoint does not seem to use akka properties from flink-conf.yaml with Flink 1.6.0 as with flink 1.4.x

[ https://issues.apache.org/jira/browse/FLINK-10148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10148: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > flink cancel

[jira] [Updated] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14110: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Deleting sta

[jira] [Updated] (FLINK-9165) Improve CassandraSinkBase to send Collections

[ https://issues.apache.org/jira/browse/FLINK-9165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9165: Labels: easyfix feature (was: auto-closed easyfix feature) Priority: Not a Priority

[jira] [Updated] (FLINK-10844) ArrayIndexOutOfBoundsException during checkpoint (Flink 1.5.2)

[ https://issues.apache.org/jira/browse/FLINK-10844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10844: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > ArrayIndexOu

[jira] [Updated] (FLINK-9971) Add more extensive documentation for operations that combine datastreams

[ https://issues.apache.org/jira/browse/FLINK-9971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9971: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add more extens

[jira] [Updated] (FLINK-13956) Add sequence file format with repeated sync blocks

[ https://issues.apache.org/jira/browse/FLINK-13956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13956: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add sequence

[jira] [Updated] (FLINK-11824) Event-time attribute cannot have same name as in original format

[ https://issues.apache.org/jira/browse/FLINK-11824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11824: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Event-time a

[jira] [Updated] (FLINK-5953) Sample Kinesis Scala code doesn't work

[ https://issues.apache.org/jira/browse/FLINK-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5953: Labels: documentation kinesis scala (was: auto-closed documentation kinesis scala) P

[jira] [Updated] (FLINK-9422) Dedicated DISTINCT operator for streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9422: Labels: stale-assigned (was: auto-closed stale-assigned) Priority: Not a Priority (w

[jira] [Updated] (FLINK-8314) Add support for Kinesis Firehose

[ https://issues.apache.org/jira/browse/FLINK-8314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8314: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Add support for

[jira] [Updated] (FLINK-14238) ParquetPojoInputFormat logging bug

[ https://issues.apache.org/jira/browse/FLINK-14238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14238: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > ParquetPojoI

[jira] [Updated] (FLINK-3076) Display channel exchange mode in the plan visualizer

[ https://issues.apache.org/jira/browse/FLINK-3076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3076: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Display channel

[jira] [Updated] (FLINK-1240) We cannot use sortGroup on a global reduce

[ https://issues.apache.org/jira/browse/FLINK-1240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1240: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > We cannot use s

[jira] [Updated] (FLINK-2193) Partial shuffling

[ https://issues.apache.org/jira/browse/FLINK-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2193: Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > Partial shuffli

[jira] [Updated] (FLINK-12259) Improve debuggability of method invocation failures in OptimizerPlanEnvironment

[ https://issues.apache.org/jira/browse/FLINK-12259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12259: - Labels: pull-request-available stale-assigned (was: auto-closed pull-request-availabl

[jira] [Updated] (FLINK-11204) flink start-scala-shell.sh do not work in security mode with kerberos authentication.

[ https://issues.apache.org/jira/browse/FLINK-11204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-11204: - Labels: (was: auto-closed) Priority: Not a Priority (was: Minor) > flink start-

<    2   3   4   5   6   7   8   9   10   11   >