[jira] [Updated] (FLINK-4830) Show latency statistics in web interface

[ https://issues.apache.org/jira/browse/FLINK-4830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4830: -- Priority: Minor (was: Major) > Show latency statistics in web interface >

[jira] [Updated] (FLINK-12992) All host(s) tried for query failed (tried com.datastax.driver.core.exceptions.TransportException: Error writing...)

[ https://issues.apache.org/jira/browse/FLINK-12992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12992: --- Priority: Major (was: Critical) > All host(s) tried for query failed (tried >

[jira] [Commented] (FLINK-5151) Add discussion about object mutations to heap-based state backend docs.

[ https://issues.apache.org/jira/browse/FLINK-5151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336827#comment-17336827 ] Flink Jira Bot commented on FLINK-5151: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-6472) BoundedOutOfOrdernessTimestampExtractor does not bound out of orderliness

[ https://issues.apache.org/jira/browse/FLINK-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6472: -- Priority: Minor (was: Major) > BoundedOutOfOrdernessTimestampExtractor does not bound out of

[jira] [Updated] (FLINK-4568) Replace ActorGateway in WebRuntimeMonitor

[ https://issues.apache.org/jira/browse/FLINK-4568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4568: -- Labels: auto-deprioritized-major (was: stale-major) > Replace ActorGateway in

[jira] [Updated] (FLINK-9831) Too many open files for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9831: -- Priority: Minor (was: Major) > Too many open files for RocksDB >

[jira] [Commented] (FLINK-5986) Add forwarded field annotations to batch (window) aggregate operators

[ https://issues.apache.org/jira/browse/FLINK-5986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336793#comment-17336793 ] Flink Jira Bot commented on FLINK-5986: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-4558) Add support for synchronizing streams

[ https://issues.apache.org/jira/browse/FLINK-4558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4558: -- Labels: auto-deprioritized-major (was: stale-major) > Add support for synchronizing streams >

[jira] [Updated] (FLINK-1904) Add cross() to Table API

[ https://issues.apache.org/jira/browse/FLINK-1904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1904: -- Labels: auto-deprioritized-major (was: stale-major) > Add cross() to Table API >

[jira] [Commented] (FLINK-2350) Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336914#comment-17336914 ] Flink Jira Bot commented on FLINK-2350: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-17486) ClassCastException when checkpointing AVRO SpecificRecord with decimal fields

[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336965#comment-17336965 ] Flink Jira Bot commented on FLINK-17486: This issue was labeled "stale-critical" 7 ago and has

[jira] [Updated] (FLINK-2147) Approximate calculation of frequencies in data streams

[ https://issues.apache.org/jira/browse/FLINK-2147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2147: -- Labels: approximate auto-deprioritized-major statistics (was: approximate stale-major

[jira] [Updated] (FLINK-6075) ORDER BY *time ASC

[ https://issues.apache.org/jira/browse/FLINK-6075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6075: -- Priority: Minor (was: Major) > ORDER BY *time ASC > -- > >

[jira] [Updated] (FLINK-13604) All kinds of problem when conversion from Logical type to DataType

[ https://issues.apache.org/jira/browse/FLINK-13604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13604: --- Labels: auto-deprioritized-critical (was: stale-critical) > All kinds of problem when

[jira] [Commented] (FLINK-10658) org.apache.flink.util.FlinkException: Releasing shared slot parent.

[ https://issues.apache.org/jira/browse/FLINK-10658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336563#comment-17336563 ] Flink Jira Bot commented on FLINK-10658: This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-3110) Add support for partition-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3110: -- Priority: Minor (was: Major) > Add support for partition-centric iterations >

[jira] [Commented] (FLINK-6767) Cannot load user class on local environment

[ https://issues.apache.org/jira/browse/FLINK-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336986#comment-17336986 ] Flink Jira Bot commented on FLINK-6767: --- This issue was labeled "stale-critical" 7 ago and has not

[jira] [Commented] (FLINK-9173) RestClient - Received response is abnormal

[ https://issues.apache.org/jira/browse/FLINK-9173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336638#comment-17336638 ] Flink Jira Bot commented on FLINK-9173: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-3549) Make streaming examples more streaming

[ https://issues.apache.org/jira/browse/FLINK-3549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3549: -- Labels: auto-deprioritized-major (was: stale-major) > Make streaming examples more streaming

[jira] [Updated] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10167: --- Labels: auto-deprioritized-major (was: stale-major) > SessionWindows not compatible with

[jira] [Updated] (FLINK-5901) DAG can not show properly in IE

[ https://issues.apache.org/jira/browse/FLINK-5901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5901: -- Labels: auto-deprioritized-critical (was: stale-critical) > DAG can not show properly in IE >

[jira] [Commented] (FLINK-3394) Clear up the contract of MutableObjectIterator.next(reuse)

[ https://issues.apache.org/jira/browse/FLINK-3394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336992#comment-17336992 ] Flink Jira Bot commented on FLINK-3394: --- This issue was labeled "stale-critical" 7 ago and has not

[jira] [Updated] (FLINK-6239) Sharing of State Across Operators

[ https://issues.apache.org/jira/browse/FLINK-6239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6239: -- Priority: Minor (was: Major) > Sharing of State Across Operators >

[jira] [Commented] (FLINK-8380) Dynamic BucketingSink paths based on ingested Kafka topics

[ https://issues.apache.org/jira/browse/FLINK-8380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336670#comment-17336670 ] Flink Jira Bot commented on FLINK-8380: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-6218) Not able to access the rows in table after converting dataset to table after using registerdataset

[ https://issues.apache.org/jira/browse/FLINK-6218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336776#comment-17336776 ] Flink Jira Bot commented on FLINK-6218: --- This issue was labeled "stale-major" 7 ago and has not

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

[ https://issues.apache.org/jira/browse/FLINK-4399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336860#comment-17336860 ] Flink Jira Bot commented on FLINK-4399: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-5422) Check for name collisions in the Rolling/BucketingSink

[ https://issues.apache.org/jira/browse/FLINK-5422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336817#comment-17336817 ] Flink Jira Bot commented on FLINK-5422: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-9980) wiki-edits quickstart docs aren't clear enough

[ https://issues.apache.org/jira/browse/FLINK-9980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9980: -- Labels: auto-deprioritized-major (was: stale-major) > wiki-edits quickstart docs aren't clear

[jira] [Commented] (FLINK-6647) Fail-fast on invalid RocksDBStateBackend configuration

[ https://issues.apache.org/jira/browse/FLINK-6647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336748#comment-17336748 ] Flink Jira Bot commented on FLINK-6647: --- This issue was labeled "stale-major" 7 ago and has not

[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 ] Flink Jira Bot updated FLINK-9457: -- Priority: Minor (was: Major) > Cancel container requests when cancelling pending slot

[jira] [Updated] (FLINK-7291) Incorrect return value of getArity() in ListTypeInfo and MapTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-7291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7291: -- Priority: Minor (was: Major) > Incorrect return value of getArity() in ListTypeInfo and

[jira] [Updated] (FLINK-6458) Support NOT patterns with preceding OPTIONALS

[ https://issues.apache.org/jira/browse/FLINK-6458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6458: -- Labels: auto-deprioritized-major (was: stale-major) > Support NOT patterns with preceding

[jira] [Commented] (FLINK-6116) Watermarks don't work when unioning with same DataStream

[ https://issues.apache.org/jira/browse/FLINK-6116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336989#comment-17336989 ] Flink Jira Bot commented on FLINK-6116: --- This issue was labeled "stale-critical" 7 ago and has not

[jira] [Updated] (FLINK-8185) Make first level flattening optional for input and output

[ https://issues.apache.org/jira/browse/FLINK-8185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8185: -- Priority: Minor (was: Major) > Make first level flattening optional for input and output >

[jira] [Commented] (FLINK-987) Extend TypeSerializers and -Comparators to work directly on Memory Segments

[ https://issues.apache.org/jira/browse/FLINK-987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336926#comment-17336926 ] Flink Jira Bot commented on FLINK-987: -- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-18648) KafkaITCase.testStartFromGroupOffsets times out on azure

[ https://issues.apache.org/jira/browse/FLINK-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18648: --- Priority: Major (was: Critical) > KafkaITCase.testStartFromGroupOffsets times out on azure

[jira] [Commented] (FLINK-16861) Adding delegation token to the AM container Failed

[ https://issues.apache.org/jira/browse/FLINK-16861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336255#comment-17336255 ] Flink Jira Bot commented on FLINK-16861: This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-6458) Support NOT patterns with preceding OPTIONALS

[ https://issues.apache.org/jira/browse/FLINK-6458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336762#comment-17336762 ] Flink Jira Bot commented on FLINK-6458: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-9050) Expose operator IO counter metrics

[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9050: -- Priority: Minor (was: Major) > Expose operator IO counter metrics >

[jira] [Updated] (FLINK-9843) Build website automatically

[ https://issues.apache.org/jira/browse/FLINK-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9843: -- Labels: auto-deprioritized-major (was: stale-major) > Build website automatically >

[jira] [Updated] (FLINK-9189) Add a SBT Quickstart

[ https://issues.apache.org/jira/browse/FLINK-9189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9189: -- Labels: auto-deprioritized-major (was: stale-major) > Add a SBT Quickstart >

[jira] [Commented] (FLINK-5891) ConnectedComponents is broken when object reuse enabled

[ https://issues.apache.org/jira/browse/FLINK-5891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336797#comment-17336797 ] Flink Jira Bot commented on FLINK-5891: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-10039) FlinkKafkaProducer - Serializer Error

[ https://issues.apache.org/jira/browse/FLINK-10039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10039: --- Priority: Minor (was: Major) > FlinkKafkaProducer - Serializer Error >

[jira] [Commented] (FLINK-6765) PojoSerializer returns wrong ConvertDeserializer when migration is required

[ https://issues.apache.org/jira/browse/FLINK-6765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336745#comment-17336745 ] Flink Jira Bot commented on FLINK-6765: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-6866) ClosureCleaner.clean fails for scala's JavaConverters wrapper classes

[ https://issues.apache.org/jira/browse/FLINK-6866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6866: -- Labels: auto-deprioritized-major (was: stale-major) > ClosureCleaner.clean fails for scala's

[jira] [Updated] (FLINK-13736) Support count window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13736: --- Priority: Minor (was: Major) > Support count window with blink planner in batch mode >

[jira] [Updated] (FLINK-11927) Code clean up and refactor BinaryHashTable and LongHybridHashTable

[ https://issues.apache.org/jira/browse/FLINK-11927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11927: --- Priority: Minor (was: Major) > Code clean up and refactor BinaryHashTable and

[jira] [Updated] (FLINK-2350) Deprecate the stream open timeouts in FileInputFormat and FileOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2350: -- Labels: auto-deprioritized-major (was: stale-major) > Deprecate the stream open timeouts in

[jira] [Updated] (FLINK-10409) Collection data sink does not propagate exceptions

[ https://issues.apache.org/jira/browse/FLINK-10409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10409: --- Priority: Minor (was: Major) > Collection data sink does not propagate exceptions >

[jira] [Commented] (FLINK-2023) TypeExtractor does not work for (some) Scala Classes

[ https://issues.apache.org/jira/browse/FLINK-2023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336922#comment-17336922 ] Flink Jira Bot commented on FLINK-2023: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-6016) Newlines should be valid in quoted strings in CSV

[ https://issues.apache.org/jira/browse/FLINK-6016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6016: -- Priority: Minor (was: Major) > Newlines should be valid in quoted strings in CSV >

[jira] [Commented] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration

[ https://issues.apache.org/jira/browse/FLINK-3983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336870#comment-17336870 ] Flink Jira Bot commented on FLINK-3983: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-16716) Update Roadmap after Flink 1.10 release

[ https://issues.apache.org/jira/browse/FLINK-16716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16716: --- Labels: auto-deprioritized-critical (was: stale-critical) > Update Roadmap after Flink

[jira] [Commented] (FLINK-18262) PyFlink end-to-end test stalls

[ https://issues.apache.org/jira/browse/FLINK-18262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336960#comment-17336960 ] Flink Jira Bot commented on FLINK-18262: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

[ https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336865#comment-17336865 ] Flink Jira Bot commented on FLINK-4015: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-4578) AggregateOperator incorrectly sets ForwardedField with nested composite types

[ https://issues.apache.org/jira/browse/FLINK-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4578: -- Priority: Minor (was: Major) > AggregateOperator incorrectly sets ForwardedField with nested

[jira] [Commented] (FLINK-9175) Flink CEP with Checkpointing alway failed

[ https://issues.apache.org/jira/browse/FLINK-9175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336984#comment-17336984 ] Flink Jira Bot commented on FLINK-9175: --- This issue was labeled "stale-critical" 7 ago and has not

[jira] [Commented] (FLINK-6296) Retrieving execution plan fails succeeding execution attempt

[ https://issues.apache.org/jira/browse/FLINK-6296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336769#comment-17336769 ] Flink Jira Bot commented on FLINK-6296: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11484: --- Labels: auto-deprioritized-major blink (was: blink stale-major) > Blink

[jira] [Commented] (FLINK-6970) Add support for late data updates to group window aggregates

[ https://issues.apache.org/jira/browse/FLINK-6970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336734#comment-17336734 ] Flink Jira Bot commented on FLINK-6970: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

[ https://issues.apache.org/jira/browse/FLINK-20067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20067: --- Priority: Major (was: Critical) > "Resuming Savepoint (file, sync, scale up) end-to-end

[jira] [Updated] (FLINK-5263) Add docs about JVM sharing between tasks

[ https://issues.apache.org/jira/browse/FLINK-5263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5263: -- Labels: auto-deprioritized-major (was: stale-major) > Add docs about JVM sharing between

[jira] [Commented] (FLINK-20067) "Resuming Savepoint (file, sync, scale up) end-to-end test" failed with "Could not stop with a savepoint job"

[ https://issues.apache.org/jira/browse/FLINK-20067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336947#comment-17336947 ] Flink Jira Bot commented on FLINK-20067: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-3110) Add support for partition-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-3110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336900#comment-17336900 ] Flink Jira Bot commented on FLINK-3110: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-18580) Incomplete conversion for MySQL types

[ https://issues.apache.org/jira/browse/FLINK-18580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336957#comment-17336957 ] Flink Jira Bot commented on FLINK-18580: This issue was labeled "stale-critical" 7 ago and has

[jira] [Updated] (FLINK-9797) Separate state serializers from network serializers

[ https://issues.apache.org/jira/browse/FLINK-9797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9797: -- Labels: auto-deprioritized-major (was: stale-major) > Separate state serializers from network

[jira] [Updated] (FLINK-6814) Store information about whether or not a registered state is queryable in checkpoints

[ https://issues.apache.org/jira/browse/FLINK-6814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6814: -- Labels: auto-deprioritized-major (was: stale-major) > Store information about whether or not

[jira] [Updated] (FLINK-6291) Internal Timer service cannot be "removed"

[ https://issues.apache.org/jira/browse/FLINK-6291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6291: -- Priority: Minor (was: Major) > Internal Timer service cannot be "removed" >

[jira] [Updated] (FLINK-10264) Exception is misleading when no default constructor define for events

[ https://issues.apache.org/jira/browse/FLINK-10264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10264: --- Priority: Minor (was: Major) > Exception is misleading when no default constructor define

[jira] [Commented] (FLINK-22067) SavepointWindowReaderITCase.testApplyEvictorWindowStateReader

[ https://issues.apache.org/jira/browse/FLINK-22067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336933#comment-17336933 ] Flink Jira Bot commented on FLINK-22067: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-12286) The default log4j.properties will overwrite the customized log4j property file.

[ https://issues.apache.org/jira/browse/FLINK-12286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336978#comment-17336978 ] Flink Jira Bot commented on FLINK-12286: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-4990) Remove JAR option from savepoint disposal

[ https://issues.apache.org/jira/browse/FLINK-4990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336839#comment-17336839 ] Flink Jira Bot commented on FLINK-4990: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-7156) Re-enabled external jar ScalaShellITCase

[ https://issues.apache.org/jira/browse/FLINK-7156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7156: -- Labels: auto-deprioritized-major (was: stale-major) > Re-enabled external jar

[jira] [Updated] (FLINK-5925) Clean up extracted RocksDB JNI library

[ https://issues.apache.org/jira/browse/FLINK-5925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5925: -- Priority: Minor (was: Major) > Clean up extracted RocksDB JNI library >

[jira] [Updated] (FLINK-2824) Iteration feedback partitioning does not work as expected

[ https://issues.apache.org/jira/browse/FLINK-2824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2824: -- Labels: auto-deprioritized-major (was: stale-major) > Iteration feedback partitioning does

[jira] [Updated] (FLINK-4511) Schedule periodic savepoints

[ https://issues.apache.org/jira/browse/FLINK-4511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4511: -- Priority: Minor (was: Major) > Schedule periodic savepoints > >

[jira] [Updated] (FLINK-6049) Parallelize execution of (async) snapshots in AsyncCheckpointRunnable

[ https://issues.apache.org/jira/browse/FLINK-6049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6049: -- Labels: auto-deprioritized-major (was: stale-major) > Parallelize execution of (async)

[jira] [Commented] (FLINK-6607) Confusing statement in docs that Kafka 010 consumer does not require timestamp extractors

[ https://issues.apache.org/jira/browse/FLINK-6607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336750#comment-17336750 ] Flink Jira Bot commented on FLINK-6607: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-11141) Key generation for RocksDBMapState can theoretically be ambiguous

[ https://issues.apache.org/jira/browse/FLINK-11141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336979#comment-17336979 ] Flink Jira Bot commented on FLINK-11141: This issue was labeled "stale-critical" 7 ago and has

[jira] [Commented] (FLINK-6500) RowSerialization problem

[ https://issues.apache.org/jira/browse/FLINK-6500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336756#comment-17336756 ] Flink Jira Bot commented on FLINK-6500: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-8236) Allow to set the parallelism of table queries

[ https://issues.apache.org/jira/browse/FLINK-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8236: -- Labels: auto-deprioritized-major (was: stale-major) > Allow to set the parallelism of table

[jira] [Updated] (FLINK-9191) Misleading URLs for website source

[ https://issues.apache.org/jira/browse/FLINK-9191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9191: -- Priority: Minor (was: Major) > Misleading URLs for website source >

[jira] [Commented] (FLINK-12334) change to MockStreamTask breaks OneInputStreamOperatorTestHarness

[ https://issues.apache.org/jira/browse/FLINK-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336486#comment-17336486 ] Flink Jira Bot commented on FLINK-12334: This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-3709) [streaming] Graph event rates over time

[ https://issues.apache.org/jira/browse/FLINK-3709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3709: -- Priority: Minor (was: Major) > [streaming] Graph event rates over time >

[jira] [Updated] (FLINK-5334) outdated scala SBT quickstart example

[ https://issues.apache.org/jira/browse/FLINK-5334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5334: -- Priority: Minor (was: Major) > outdated scala SBT quickstart example >

[jira] [Updated] (FLINK-7640) Dashboard should display information about JobManager cluster in HA mode

[ https://issues.apache.org/jira/browse/FLINK-7640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7640: -- Priority: Minor (was: Major) > Dashboard should display information about JobManager cluster

[jira] [Commented] (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:comment-tabpanel=17336669#comment-17336669 ] Flink Jira Bot commented on FLINK-8416: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-21278) NullpointExecption error is reported when using the evictor method to filter the data before the window calculation

[ https://issues.apache.org/jira/browse/FLINK-21278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21278: --- Priority: Major (was: Critical) > NullpointExecption error is reported when using the

[jira] [Updated] (FLINK-7828) Improve object copying/reuse mode for streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-7828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7828: -- Labels: auto-deprioritized-major (was: stale-major) > Improve object copying/reuse mode for

[jira] [Updated] (FLINK-9843) Build website automatically

[ https://issues.apache.org/jira/browse/FLINK-9843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9843: -- Priority: Minor (was: Major) > Build website automatically > --- > >

[jira] [Commented] (FLINK-3264) Add load shedding policy into Kafka Consumers

[ https://issues.apache.org/jira/browse/FLINK-3264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336896#comment-17336896 ] Flink Jira Bot commented on FLINK-3264: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-7827) creating and starting a NetCat in test cases programmatically

[ https://issues.apache.org/jira/browse/FLINK-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7827: -- Labels: auto-deprioritized-major httpstreaming netcat streaming (was: httpstreaming netcat

[jira] [Updated] (FLINK-5676) Grouping on nested fields does not work

[ https://issues.apache.org/jira/browse/FLINK-5676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5676: -- Priority: Minor (was: Major) > Grouping on nested fields does not work >

[jira] [Updated] (FLINK-11484) Blink java.util.concurrent.TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-11484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11484: --- Priority: Minor (was: Major) > Blink java.util.concurrent.TimeoutException >

[jira] [Updated] (FLINK-13950) should report an error if hive table partition keys are not in the last schema fields

[ https://issues.apache.org/jira/browse/FLINK-13950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13950: --- Priority: Major (was: Critical) > should report an error if hive table partition keys are

[jira] [Updated] (FLINK-2313) Change Streaming Driver Execution Model

[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2313: -- Labels: auto-deprioritized-major (was: stale-major) > Change Streaming Driver Execution Model

[jira] [Commented] (FLINK-7573) Introduce Http protocol connector for Elasticsearch2

[ https://issues.apache.org/jira/browse/FLINK-7573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336711#comment-17336711 ] Flink Jira Bot commented on FLINK-7573: --- This issue was labeled "stale-major" 7 ago and has not

[jira] [Updated] (FLINK-8467) Restoring job that does not use checkpointing from savepoint breaks

[ https://issues.apache.org/jira/browse/FLINK-8467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8467: -- Labels: auto-deprioritized-major (was: stale-major) > Restoring job that does not use

[jira] [Commented] (FLINK-10167) SessionWindows not compatible with typed DataStreams in scala

[ https://issues.apache.org/jira/browse/FLINK-10167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336593#comment-17336593 ] Flink Jira Bot commented on FLINK-10167: This issue was labeled "stale-major" 7 ago and has not

[jira] [Commented] (FLINK-3627) Task stuck on lock in StreamSource when cancelling

[ https://issues.apache.org/jira/browse/FLINK-3627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336884#comment-17336884 ] Flink Jira Bot commented on FLINK-3627: --- This issue was labeled "stale-major" 7 ago and has not

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