[jira] [Commented] (FLINK-4050) FlinkKafkaProducer API Refactor

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

[jira] [Commented] (FLINK-12114) Try to perform UDF By Reflection

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

[jira] [Updated] (FLINK-8718) Non-parallel DataStreamSource does not set max parallelism

[ https://issues.apache.org/jira/browse/FLINK-8718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8718: -- Priority: Minor (was: Major) > Non-parallel DataStreamSource does not set max parallelism >

[jira] [Commented] (FLINK-7673) Flink Kinesis connector - remove dependency on the ASL code

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

[jira] [Updated] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

[ https://issues.apache.org/jira/browse/FLINK-18049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18049: --- Priority: Major (was: Critical) > The Flink kafka consumer job will be interrupted if the

[jira] [Updated] (FLINK-8784) Share network buffer pool among different partition operators

[ https://issues.apache.org/jira/browse/FLINK-8784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8784: -- Priority: Minor (was: Major) > Share network buffer pool among different partition operators

[jira] [Commented] (FLINK-19115) Null value fields cannot be ignored in ElasticSearch Sink

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

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Clean up extracted RocksDB JNI library

[jira] [Commented] (FLINK-5850) implement OAuth 2.0 check in Web Backend API

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

[jira] [Updated] (FLINK-6532) Mesos version check

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

[jira] [Updated] (FLINK-2497) Rework streaming iteration flow control

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

[jira] [Commented] (FLINK-3884) Snapshot quickstart projects don't include snapshot repository

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

[jira] [Updated] (FLINK-15024) System classloader memory leak after loading too many codegen classes.

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

[jira] [Updated] (FLINK-6316) Kinesis connector docs should mention that FlinkKinesisConsumer does not provide strong ordering guarantees on resharding

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

[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[]

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

[jira] [Updated] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

[ https://issues.apache.org/jira/browse/FLINK-21928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21928: --- Priority: Major (was: Critical) > DuplicateJobSubmissionException after JobManager

[jira] [Updated] (FLINK-8585) Efficiently handle read-only and non array ByteBuffers in DataInputDeserializer

[ https://issues.apache.org/jira/browse/FLINK-8585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8585: -- Labels: auto-deprioritized-major (was: stale-major) > Efficiently handle read-only and non

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-5151: -- Labels: auto-deprioritized-major (was: stale-major) > Add discussion about object mutations

[jira] [Commented] (FLINK-8294) Missing examples/links in Data Sink docs

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

[jira] [Updated] (FLINK-9802) Harden End-to-end tests against download failures

[ https://issues.apache.org/jira/browse/FLINK-9802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9802: -- Priority: Minor (was: Major) > Harden End-to-end tests against download failures >

[jira] [Updated] (FLINK-10989) OrcRowInputFormat uses two different file systems

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

[jira] [Updated] (FLINK-11002) Trigger.clear() will not be called after purged window

[ https://issues.apache.org/jira/browse/FLINK-11002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11002: --- Priority: Minor (was: Major) > Trigger.clear() will not be called after purged window >

[jira] [Updated] (FLINK-11220) Can not Select row time field in JOIN query

[ https://issues.apache.org/jira/browse/FLINK-11220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11220: --- Priority: Minor (was: Major) > Can not Select row time field in JOIN query >

[jira] [Updated] (FLINK-7001) Improve performance of Sliding Time Window with pane optimization

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

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

[jira] [Commented] (FLINK-2620) StreamPartitioner is not properly initialized for shuffle and rebalance

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

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

[ https://issues.apache.org/jira/browse/FLINK-8302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8302: -- Labels: auto-deprioritized-major features pull-request-available (was: features

[jira] [Updated] (FLINK-6790) Flink Kafka Consumer Cannot Round Robin Fetch Records

[ https://issues.apache.org/jira/browse/FLINK-6790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6790: -- Priority: Minor (was: Major) > Flink Kafka Consumer Cannot Round Robin Fetch Records >

[jira] [Updated] (FLINK-16574) StreamingFileSink should rename files or fail if destination file already exists

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

[jira] [Commented] (FLINK-2709) line editing in scala shell

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

[jira] [Commented] (FLINK-5463) RocksDB.disposeInternal does not react to interrupts, blocks task cancellation

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

[jira] [Updated] (FLINK-16333) After exiting from the command line client, the process still exists

[ https://issues.apache.org/jira/browse/FLINK-16333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16333: --- Priority: Major (was: Critical) > After exiting from the command line client, the process

[jira] [Commented] (FLINK-3514) Add support for slowly changing streaming broadcast variables

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

[jira] [Updated] (FLINK-4620) Automatically creating savepoints

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

[jira] [Updated] (FLINK-7894) Improve metrics around fine-grained recovery and associated checkpointing behaviors

[ https://issues.apache.org/jira/browse/FLINK-7894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7894: -- Priority: Minor (was: Major) > Improve metrics around fine-grained recovery and associated

[jira] [Updated] (FLINK-5683) Fix RedisConnector documentation (Java)

[ https://issues.apache.org/jira/browse/FLINK-5683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5683: -- Priority: Minor (was: Major) > Fix RedisConnector documentation (Java) >

[jira] [Updated] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6626: -- Priority: Minor (was: Major) > Unifying lifecycle management of SubmittedJobGraph- and >

[jira] [Updated] (FLINK-21397) BufferUnderflowException when read parquet

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

[jira] [Updated] (FLINK-5409) Separate Job API from the Runtime

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

[jira] [Commented] (FLINK-4233) Simplify leader election / leader session ID assignment

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

[jira] [Updated] (FLINK-5730) Users can concurrently modify state metadata of RocksDB asynchronous snapshots

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

[jira] [Commented] (FLINK-21397) BufferUnderflowException when read parquet

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

[jira] [Updated] (FLINK-6547) Improve toString methods of Table API expressions

[ https://issues.apache.org/jira/browse/FLINK-6547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6547: -- Priority: Minor (was: Major) > Improve toString methods of Table API expressions >

[jira] [Updated] (FLINK-3588) Add a streaming (exactly-once) JDBC connector

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

[jira] [Updated] (FLINK-5065) Resource leaks in case of lost checkpoint messages

[ https://issues.apache.org/jira/browse/FLINK-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5065: -- Priority: Minor (was: Major) > Resource leaks in case of lost checkpoint messages >

[jira] [Updated] (FLINK-10988) Improve debugging / visibility of job state

[ https://issues.apache.org/jira/browse/FLINK-10988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10988: --- Priority: Minor (was: Major) > Improve debugging / visibility of job state >

[jira] [Commented] (FLINK-7496) Support greedy quantifier followed by an optional pattern

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

[jira] [Updated] (FLINK-8282) Transformation with TwoInputStreamOperator fails

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

[jira] [Updated] (FLINK-8470) DelayTrigger and DelayAndCountTrigger in Flink Streaming Window API

[ https://issues.apache.org/jira/browse/FLINK-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8470: -- Priority: Minor (was: Major) > DelayTrigger and DelayAndCountTrigger in Flink Streaming

[jira] [Updated] (FLINK-8358) Hostname used by DataDog metric reporter is not configurable

[ https://issues.apache.org/jira/browse/FLINK-8358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8358: -- Priority: Minor (was: Major) > Hostname used by DataDog metric reporter is not configurable >

[jira] [Commented] (FLINK-18049) The Flink kafka consumer job will be interrupted if the upstream kafka producer change the AVRO schema

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

[jira] [Updated] (FLINK-6480) Add executor service parameter Snapshotable::snapshot(...)

[ https://issues.apache.org/jira/browse/FLINK-6480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6480: -- Priority: Minor (was: Major) > Add executor service parameter Snapshotable::snapshot(...) >

[jira] [Updated] (FLINK-5301) Can't upload job via Web UI when using a proxy

[ https://issues.apache.org/jira/browse/FLINK-5301?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5301: -- Priority: Minor (was: Major) > Can't upload job via Web UI when using a proxy >

[jira] [Commented] (FLINK-7782) Flink CEP not recognizing pattern

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

[jira] [Commented] (FLINK-21884) Reduce TaskManager failure detection time

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

[jira] [Commented] (FLINK-1814) Revisit the documentation to add new operator

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

[jira] [Updated] (FLINK-5260) Add docs about how to react to cancellation

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

[jira] [Commented] (FLINK-19211) SQL Read Decimal In Parquet Error

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

[jira] [Commented] (FLINK-2197) Scala API is not working when using batch and streaming API in the same program

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

[jira] [Updated] (FLINK-14412) Rename ML Pipeline to MLPipeline

[ https://issues.apache.org/jira/browse/FLINK-14412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-14412: --- Priority: Minor (was: Major) > Rename ML Pipeline to MLPipeline >

[jira] [Updated] (FLINK-7947) Let ParameterTool return a dedicated GlobalJobParameters object

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

[jira] [Commented] (FLINK-553) Add getGroupKey() method to group-at-time operators

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

[jira] [Updated] (FLINK-21120) Add support for ignore abnormal watermark

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

[jira] [Commented] (FLINK-2747) TypeExtractor does not correctly analyze Scala Immutables (AnyVal)

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-5422: -- Priority: Minor (was: Major) > Check for name collisions in the Rolling/BucketingSink >

[jira] [Updated] (FLINK-10452) Expose Additional Metrics to Reason about Statesize

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

[jira] [Commented] (FLINK-10949) When use flink-1.6.2's intervalJoin funtion, the thread is stucked in rockdb's seek for too long time

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

[jira] [Updated] (FLINK-8377) Document DataViews for user-defined aggregate functions

[ https://issues.apache.org/jira/browse/FLINK-8377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8377: -- Priority: Minor (was: Major) > Document DataViews for user-defined aggregate functions >

[jira] [Commented] (FLINK-21928) DuplicateJobSubmissionException after JobManager failover

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

[jira] [Commented] (FLINK-10497) More fine grained control over access to REST endpoints

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

[jira] [Commented] (FLINK-12577) Flink uses Kryo serializer if given a SpecificRecord type

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

[jira] [Updated] (FLINK-8556) Add proxy feature to Kinesis Connector to acces its endpoint

[ https://issues.apache.org/jira/browse/FLINK-8556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8556: -- Labels: auto-deprioritized-major features pull-request-available (was: features

[jira] [Updated] (FLINK-1493) Support for streaming jobs preserving global ordering of records

[ https://issues.apache.org/jira/browse/FLINK-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-1493: -- Priority: Minor (was: Major) > Support for streaming jobs preserving global ordering of

[jira] [Updated] (FLINK-2899) The groupReduceOn* methods which take types as a parameter fail with TypeErasure

[ https://issues.apache.org/jira/browse/FLINK-2899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2899: -- Priority: Minor (was: Major) > The groupReduceOn* methods which take types as a parameter

[jira] [Updated] (FLINK-8932) Mesos taskmanager should reserve port for query server

[ https://issues.apache.org/jira/browse/FLINK-8932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8932: -- Priority: Minor (was: Major) > Mesos taskmanager should reserve port for query server >

[jira] [Updated] (FLINK-21307) Revisit activation model of FlinkSecurityManager

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

[jira] [Commented] (FLINK-8417) Support STSAssumeRoleSessionCredentialsProvider in FlinkKinesisConsumer

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

[jira] [Updated] (FLINK-3445) make JDBCInputFormat implement ResultTypeQueryable

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

[jira] [Updated] (FLINK-10077) Web UI should respond when there is no elected Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-10077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10077: --- Labels: auto-deprioritized-major (was: stale-major) > Web UI should respond when there is

[jira] [Updated] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

[ https://issues.apache.org/jira/browse/FLINK-20215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20215: --- Labels: auto-deprioritized-critical (was: stale-critical) > Keep the "Access the Flink UI

[jira] [Updated] (FLINK-5279) Improve error message when trying to access keyed state in non-keyed operator

[ https://issues.apache.org/jira/browse/FLINK-5279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5279: -- Labels: auto-deprioritized-major (was: stale-major) > Improve error message when trying to

[jira] [Updated] (FLINK-12674) BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented

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

[jira] [Updated] (FLINK-7954) sideoutput in async function

[ https://issues.apache.org/jira/browse/FLINK-7954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7954: -- Priority: Minor (was: Major) > sideoutput in async function > >

[jira] [Commented] (FLINK-5993) Add section about Azure deployment

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

[jira] [Updated] (FLINK-8534) if insert too much BucketEntry into one bucket in join of iteration will cause a error (Caused : java.io.FileNotFoundException release file error)

[ https://issues.apache.org/jira/browse/FLINK-8534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8534: -- Labels: auto-deprioritized-major (was: stale-major) > if insert too much BucketEntry into one

[jira] [Updated] (FLINK-10031) Support handling late events in Table API & SQL

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

[jira] [Commented] (FLINK-7239) GroupWindow and OverWindow aggregates do not check correctly for updating input

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

[jira] [Updated] (FLINK-3203) DistributedCache crashing when run in OGS

[ https://issues.apache.org/jira/browse/FLINK-3203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3203: -- Priority: Minor (was: Major) > DistributedCache crashing when run in OGS >

[jira] [Updated] (FLINK-10381) concurrent submit job get ProgramAbortException

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

[jira] [Updated] (FLINK-7646) Restart failed jobs with configurable parallelism range

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

[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: -- Priority: Minor (was: Major) > Add a SBT Quickstart > > >

[jira] [Commented] (FLINK-20215) Keep the "Access the Flink UI " document same in “Kubernetes Setup” and "Native Kubernetes Setup Beta"

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

[jira] [Updated] (FLINK-4823) org.apache.flink.types.NullFieldException: Field 0 is null, but expected to hold a value

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

[jira] [Updated] (FLINK-3624) Use camelCase naming of JSON attributes generated by the REST API instead of dash

[ https://issues.apache.org/jira/browse/FLINK-3624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3624: -- Priority: Minor (was: Major) > Use camelCase naming of JSON attributes generated by the REST

[jira] [Updated] (FLINK-9760) Return a single element from extractPatterns

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

[jira] [Updated] (FLINK-4233) Simplify leader election / leader session ID assignment

[ https://issues.apache.org/jira/browse/FLINK-4233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4233: -- Priority: Minor (was: Major) > Simplify leader election / leader session ID assignment >

[jira] [Commented] (FLINK-13203) [proper fix] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

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

[jira] [Updated] (FLINK-8107) UNNEST causes cyclic type checking exception

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

[jira] [Updated] (FLINK-10199) StandaloneSessionClusterEntrypoint does not respect host/ui-port given from jobmanager.sh

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

[jira] [Updated] (FLINK-13203) [proper fix] Deadlock occurs when requiring exclusive buffer for RemoteInputChannel

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

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