[jira] [Updated] (FLINK-6140) Add ability to dynamically start jobs-within-jobs (e.g. turning a DataSet into an out-of-memory Map, to be accessed by another mapper function)

[ https://issues.apache.org/jira/browse/FLINK-6140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6140: -- Priority: Minor (was: Major) > Add ability to dynamically start jobs-within-jobs (e.g.

[jira] [Updated] (FLINK-13113) Introduce range partition in blink

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

[jira] [Updated] (FLINK-12304) AvroInputFormat should support schema evolution

[ https://issues.apache.org/jira/browse/FLINK-12304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12304: --- Priority: Minor (was: Major) > AvroInputFormat should support schema evolution >

[jira] [Commented] (FLINK-6473) Add OVER window support for batch tables

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

[jira] [Commented] (FLINK-11925) KryoSerializerSnapshot doesn't completely capture state / configuration of Kryo instance

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

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

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

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

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

[jira] [Commented] (FLINK-11457) PrometheusPushGatewayReporter does not cleanup its metrics

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

[jira] [Commented] (FLINK-18741) ProcessWindowFunction's process function exception

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

[jira] [Updated] (FLINK-11320) Support user callback in Kafka sink

[ https://issues.apache.org/jira/browse/FLINK-11320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11320: --- Priority: Minor (was: Major) > Support user callback in Kafka sink >

[jira] [Updated] (FLINK-19538) Support more complex routers in remote ingress definitions

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-7239: -- Priority: Minor (was: Major) > GroupWindow and OverWindow aggregates do not check correctly

[jira] [Commented] (FLINK-10173) Elasticsearch 6 connector does not package Elasticsearch

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

[jira] [Commented] (FLINK-3228) Cannot submit multiple streaming involving JDBC drivers

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

[jira] [Commented] (FLINK-5808) Missing verification for setParallelism and setMaxParallelism

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

[jira] [Updated] (FLINK-12499) JDBCAppendTableSink support retry

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

[jira] [Commented] (FLINK-10889) Semantic inconsistency between DataSet#print and DataStream#print

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

[jira] [Updated] (FLINK-6082) Support window definition for SQL Queries based on WHERE clause with time condition

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

[jira] [Updated] (FLINK-13416) Refactor documentation of CLI optional for yarn cluster mode

[ https://issues.apache.org/jira/browse/FLINK-13416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13416: --- Priority: Minor (was: Major) > Refactor documentation of CLI optional for yarn cluster

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Simplify leader election / leader

[jira] [Commented] (FLINK-12294) Kafka connector, work with grouping partitions

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

[jira] [Commented] (FLINK-20427) Remove CheckpointConfig.setPreferCheckpointForRecovery because it can lead to data loss

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

[jira] [Commented] (FLINK-6503) Refactor KinesisDataFetcher to separate concerns for shard discovery

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

[jira] [Updated] (FLINK-6202) YarnSessionCli couldn't submit jobs when using -z option

[ https://issues.apache.org/jira/browse/FLINK-6202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6202: -- Priority: Minor (was: Major) > YarnSessionCli couldn't submit jobs when using -z option >

[jira] [Updated] (FLINK-11021) ZoneOffset objects don't appear to be serialized correctly

[ https://issues.apache.org/jira/browse/FLINK-11021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11021: --- Priority: Minor (was: Major) > ZoneOffset objects don't appear to be serialized correctly

[jira] [Updated] (FLINK-20203) Could not find any document about how to build a Flink image from local build.

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

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

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

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

[jira] [Updated] (FLINK-11906) Getting error while submitting job

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

[jira] [Updated] (FLINK-9565) Evaluating scalar UDFs in parallel

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

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-19115: --- Priority: Major (was: Critical) > Null value fields cannot be ignored in ElasticSearch

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Improve toString methods of Table API

[jira] [Commented] (FLINK-13179) Add document on how to run examples.

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

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

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

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

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

[jira] [Updated] (FLINK-11742) Push metrics to Pushgateway without "instance"

[ https://issues.apache.org/jira/browse/FLINK-11742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11742: --- Priority: Minor (was: Major) > Push metrics to Pushgateway without "instance" >

[jira] [Updated] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job

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

[jira] [Commented] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

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

[jira] [Commented] (FLINK-20012) Hive 3.1 integration exception

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

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

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

[jira] [Updated] (FLINK-18895) Not able to access Flink 1.7.2 with HDP 3.0.1 cluster

[ https://issues.apache.org/jira/browse/FLINK-18895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18895: --- Priority: Major (was: Critical) > Not able to access Flink 1.7.2 with HDP 3.0.1 cluster >

[jira] [Updated] (FLINK-17069) DefaultClusterClientServiceLoader should provide more information in case of missing dependencies

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

[jira] [Updated] (FLINK-18741) ProcessWindowFunction's process function exception

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

[jira] [Updated] (FLINK-7364) Log exceptions from user code in streaming jobs

[ https://issues.apache.org/jira/browse/FLINK-7364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7364: -- Priority: Minor (was: Major) > Log exceptions from user code in streaming jobs >

[jira] [Updated] (FLINK-6928) Kafka sink: default topic should not need to exist

[ https://issues.apache.org/jira/browse/FLINK-6928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6928: -- Priority: Minor (was: Major) > Kafka sink: default topic should not need to exist >

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

[jira] [Updated] (FLINK-6188) Some setParallelism() methods can't cope with default parallelism

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

[jira] [Updated] (FLINK-21810) PyFlink end-to-end fails with "sorted[*]: unbound variable"

[ https://issues.apache.org/jira/browse/FLINK-21810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21810: --- Labels: stale-major test-stability (was: test-stability) > PyFlink end-to-end fails with

[jira] [Updated] (FLINK-10443) Flink Yarn CLI hanging after unsuccessful deployment

[ https://issues.apache.org/jira/browse/FLINK-10443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10443: --- Priority: Minor (was: Major) > Flink Yarn CLI hanging after unsuccessful deployment >

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-3884: -- Priority: Minor (was: Major) > Snapshot quickstart projects don't include snapshot repository

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

[jira] [Updated] (FLINK-5674) Stdout not present in logs files

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

[jira] [Commented] (FLINK-14757) scala.StreamExecutionEnvironment Doesn't set return type upon adding source

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

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

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

[jira] [Commented] (FLINK-7142) Scala DataSet API ignores ResultTypeQueryable interface

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

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

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

[jira] [Commented] (FLINK-11694) Enforce space before left curly brace

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

[jira] [Commented] (FLINK-13974) isAssignable function return wrong result

[ https://issues.apache.org/jira/browse/FLINK-13974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17336424#comment-17336424 ] Flink Jira Bot commented on FLINK-13974: 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: -- Priority: Minor (was: Major) > Add proxy feature to Kinesis Connector to acces its endpoint >

[jira] [Updated] (FLINK-3692) Develop a Kafka state backend

[ https://issues.apache.org/jira/browse/FLINK-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3692: -- Priority: Minor (was: Major) > Develop a Kafka state backend > -

[jira] [Updated] (FLINK-13038) CEP WITHIN don’t support interval expression

[ https://issues.apache.org/jira/browse/FLINK-13038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13038: --- Priority: Minor (was: Major) > CEP WITHIN don’t support interval expression >

[jira] [Commented] (FLINK-3861) Add Scala's BigInteger and BigDecimal to Scala API

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

[jira] [Commented] (FLINK-21726) Fix checkpoint stuck

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

[jira] [Updated] (FLINK-11116) Overwrite outdated in-progress files in StreamingFileSink.

[ https://issues.apache.org/jira/browse/FLINK-6?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6: --- Priority: Minor (was: Major) > Overwrite outdated in-progress files in StreamingFileSink.

[jira] [Updated] (FLINK-2151) Provide interface to distinguish close() calls in error and regular cases

[ https://issues.apache.org/jira/browse/FLINK-2151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2151: -- Priority: Minor (was: Major) > Provide interface to distinguish close() calls in error and

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

[ https://issues.apache.org/jira/browse/FLINK-18262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18262: --- Priority: Major (was: Critical) > PyFlink end-to-end test stalls >

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

[jira] [Updated] (FLINK-4864) Shade Calcite dependency in flink-table

[ https://issues.apache.org/jira/browse/FLINK-4864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4864: -- Priority: Minor (was: Major) > Shade Calcite dependency in flink-table >

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

[ https://issues.apache.org/jira/browse/FLINK-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12334: --- Priority: Minor (was: Major) > change to MockStreamTask breaks

[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: --- Labels: auto-deprioritized-critical (was: stale-critical) > All host(s) tried for query

[jira] [Commented] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

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

[jira] [Updated] (FLINK-6761) Limitation for maximum state size per key in RocksDB backend

[ https://issues.apache.org/jira/browse/FLINK-6761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6761: -- Priority: Major (was: Critical) > Limitation for maximum state size per key in RocksDB

[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: -- Priority: Minor (was: Major) > Deprecate the stream open timeouts in FileInputFormat and

[jira] [Updated] (FLINK-5572) ListState in SlidingEventTimeWindow and SlidingProcessingTimeWindow optimization

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

[jira] [Updated] (FLINK-8952) Support setting the parallelism of individual operators of a query

[ https://issues.apache.org/jira/browse/FLINK-8952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8952: -- Priority: Minor (was: Major) > Support setting the parallelism of individual operators of a

[jira] [Updated] (FLINK-11916) Join with a Temporal Table should throw exception for left join

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

[jira] [Updated] (FLINK-2838) Inconsistent use of URL and Path classes for resources

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

[jira] [Commented] (FLINK-3905) Add KafkaOutputFormat (DataSet API)

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

[jira] [Updated] (FLINK-13538) Give field names in deserializers thrown exceptions

[ https://issues.apache.org/jira/browse/FLINK-13538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13538: --- Priority: Minor (was: Major) > Give field names in deserializers thrown exceptions >

[jira] [Updated] (FLINK-10305) flink-conf.yaml grows continuously

[ https://issues.apache.org/jira/browse/FLINK-10305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10305: --- Priority: Minor (was: Major) > flink-conf.yaml grows continuously >

[jira] [Commented] (FLINK-5931) Make Flink highly available even if defaultFS is unavailable

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

[jira] [Updated] (FLINK-8952) Support setting the parallelism of individual operators of a query

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

[jira] [Commented] (FLINK-12499) JDBCAppendTableSink support retry

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

[jira] [Updated] (FLINK-5589) Tumbling group windows on batch tables do not consider object reuse

[ https://issues.apache.org/jira/browse/FLINK-5589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5589: -- Priority: Minor (was: Major) > Tumbling group windows on batch tables do not consider object

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

[jira] [Updated] (FLINK-11320) Support user callback in Kafka sink

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

[jira] [Commented] (FLINK-10664) Flink: Checkpointing fails with S3 exception - Please reduce your request rate

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

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Flink Kafka Consumer Cannot Round Robin

[jira] [Updated] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

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

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

[ https://issues.apache.org/jira/browse/FLINK-5993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5993: -- Priority: Minor (was: Major) > Add section about Azure deployment >

[jira] [Updated] (FLINK-7919) Join with Solution Set fails with NPE if Solution Set has no entry

[ https://issues.apache.org/jira/browse/FLINK-7919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7919: -- Priority: Minor (was: Major) > Join with Solution Set fails with NPE if Solution Set has no

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

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

[jira] [Commented] (FLINK-15622) Clarify plugin mechanism in documentation

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

[jira] [Updated] (FLINK-7588) Document RocksDB tuning for spinning disks

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

[jira] [Updated] (FLINK-13611) Introduce analyze statistic utility to generate table & column statistics

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

[jira] [Updated] (FLINK-9689) Flink consumer deserialization example

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

[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: -- Priority: Minor (was: Major) > Rework streaming iteration flow control >

[jira] [Updated] (FLINK-11789) Checkpoint directories are not cleaned up after job termination

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

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

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

<    7   8   9   10   11   12   13   14   15   16   >