[jira] [Updated] (FLINK-6726) Allow setting Timers in ProcessWindowFunction

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

[jira] [Updated] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1707: Labels: algorithm pull-request-available requires-design-doc stale-assigned (was:

[jira] [Updated] (FLINK-9600) Add DataStream transformation variants that pass timestamp to the user function

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

[jira] [Updated] (FLINK-6947) Warn user when assigning timestamps/watermarks after a union

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

[jira] [Updated] (FLINK-10464) TimeIndicatorRelDataType: digest can not describe a type completely.

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

[jira] [Updated] (FLINK-20090) Expose SlotId / SlotSharingGroup in Rest API

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

[jira] [Updated] (FLINK-15111) java.lang.RuntimeException for KafkaPartitionDiscoverer.getAllPartitionsForTopics(KafkaPartitionDiscoverer.java:80) when using SASL_SSL

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

[jira] [Updated] (FLINK-16038) Expose hitRate metric for JDBCLookupFunction

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

[jira] [Updated] (FLINK-14097) Optimize AsyncWaitOperator to process more than one element per mailbox letter

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

[jira] [Updated] (FLINK-2921) Add online documentation of sample methods

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

[jira] [Updated] (FLINK-5711) Deserialization schema that gives has full kafka log information

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

[jira] [Updated] (FLINK-1885) Bulk mode for gelly

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

[jira] [Updated] (FLINK-14933) translate "Data Streaming Fault Tolerance" page in to Chinese

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

[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

[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

[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

[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

[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

[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

[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

[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

[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)

[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

[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

[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

[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

[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

[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

[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) >

[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

[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

[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

[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

[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

[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) >

[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

[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

[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) >

[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

[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

[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

[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

[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

[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

[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) >

[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

[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) >

[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

[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

[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:

[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

[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

[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

[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

[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

[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)

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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) >

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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

[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) >

[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

[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

[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

[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

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