[jira] [Updated] (FLINK-3814) Update code style guide regarding Preconditions

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

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Grouping on nested fields does not work

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Automatically creating savepoints >

[jira] [Updated] (FLINK-3273) Remove Scala dependency from flink-streaming-java

[ https://issues.apache.org/jira/browse/FLINK-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3273: -- Priority: Minor (was: Major) > Remove Scala dependency from flink-streaming-java >

[jira] [Commented] (FLINK-13847) Update release scripts to also update docs/_config.yml

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

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

[jira] [Commented] (FLINK-4947) Make all configuration possible via flink-conf.yaml and CLI.

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

[jira] [Commented] (FLINK-3642) Disentangle ExecutionConfig

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

[jira] [Updated] (FLINK-10616) Jepsen test fails while tearing down Hadoop

[ https://issues.apache.org/jira/browse/FLINK-10616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10616: --- Priority: Minor (was: Major) > Jepsen test fails while tearing down Hadoop >

[jira] [Commented] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError

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

[jira] [Commented] (FLINK-13695) Integrate checkpoint notifications into StreamTask's lifecycle

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

[jira] [Commented] (FLINK-10297) PostVersionedIOReadableWritable ignores result of InputStream.read(...)

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

[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: --- Labels: auto-deprioritized-major (was: stale-major) > Collection data sink does not

[jira] [Updated] (FLINK-3240) Remove or document DataStream(.global|.forward)

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

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

[jira] [Commented] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

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

[jira] [Commented] (FLINK-12118) Documentation in left navigation is not in step with its content

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-2197: -- Labels: auto-deprioritized-major (was: stale-major) > Scala API is not working when using

[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: --- Priority: Minor (was: Major) > Introduce range partition in blink >

[jira] [Updated] (FLINK-5351) Make the TypeExtractor support functions with more than 2 inputs

[ https://issues.apache.org/jira/browse/FLINK-5351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5351: -- Priority: Minor (was: Major) > Make the TypeExtractor support functions with more than 2

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

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

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

[jira] [Commented] (FLINK-9413) Tasks can fail with PartitionNotFoundException if consumer deployment takes too long

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

[jira] [Commented] (FLINK-8379) Improve type checking for DataView

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

[jira] [Updated] (FLINK-16616) Drop BucketingSink

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

[jira] [Updated] (FLINK-4902) Flink Task Chain not getting input in a distributed manner

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

[jira] [Updated] (FLINK-6272) Rolling file sink saves incomplete lines on failure

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-3983: -- Priority: Minor (was: Major) > Allow users to set any (relevant) configuration parameter of

[jira] [Commented] (FLINK-10224) Web frontend does not handle scientific notation properly

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

[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: -- Priority: Minor (was: Major) > UNNEST causes cyclic type checking exception >

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

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

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

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

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

[ https://issues.apache.org/jira/browse/FLINK-8294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8294: -- Priority: Minor (was: Major) > Missing examples/links in Data Sink docs >

[jira] [Updated] (FLINK-4785) Flink string parser doesn't handle string fields containing two consecutive double quotes

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

[jira] [Updated] (FLINK-3984) Event time of stream transformations is undocumented

[ https://issues.apache.org/jira/browse/FLINK-3984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3984: -- Priority: Minor (was: Major) > Event time of stream transformations is undocumented >

[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: -- Priority: Minor (was: Major) > ClosureCleaner.clean fails for scala's JavaConverters wrapper

[jira] [Commented] (FLINK-5719) Let LatencyMarkers completely bypass operators / chains

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

[jira] [Commented] (FLINK-4001) Add event time support to filesystem connector

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

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

[jira] [Updated] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions

[ https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5094: -- Priority: Minor (was: Major) > Support RichReduceFunction and RichFoldFunction as incremental

[jira] [Commented] (FLINK-13395) Add source and sink connector for Alibaba Log Service

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

[jira] [Updated] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

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

[jira] [Commented] (FLINK-16881) use Catalog's total size info in planner

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-20427: --- Priority: Major (was: Critical) > Remove CheckpointConfig.setPreferCheckpointForRecovery

[jira] [Updated] (FLINK-9123) Scala version of ProcessFunction doesn't work

[ https://issues.apache.org/jira/browse/FLINK-9123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9123: -- Priority: Minor (was: Major) > Scala version of ProcessFunction doesn't work >

[jira] [Updated] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

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

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

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

[jira] [Updated] (FLINK-11942) Flink kinesis connector throws kinesis producer daemon fatalError

[ https://issues.apache.org/jira/browse/FLINK-11942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11942: --- Priority: Minor (was: Major) > Flink kinesis connector throws kinesis producer daemon

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

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

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

[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: -- Priority: Major (was: Critical) > DAG can not show properly in IE >

[jira] [Updated] (FLINK-5094) Support RichReduceFunction and RichFoldFunction as incremental window aggregation functions

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

[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: --- Priority: Minor (was: Major) > Support handling late events in Table API & SQL >

[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: -- Labels: auto-deprioritized-major redis (was: redis stale-major) > Fix RedisConnector

[jira] [Updated] (FLINK-13695) Integrate checkpoint notifications into StreamTask's lifecycle

[ https://issues.apache.org/jira/browse/FLINK-13695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-13695: --- Priority: Major (was: Critical) > Integrate checkpoint notifications into StreamTask's

[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: -- Priority: Minor (was: Major) > Add a streaming (exactly-once) JDBC connector >

[jira] [Updated] (FLINK-4621) Improve decimal literals of SQL API

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

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Harden End-to-end tests against

[jira] [Commented] (FLINK-7624) Add kafka-topic for "KafkaProducer" metrics

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

[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: -- Labels: auto-deprioritized-major (was: stale-major) > Unifying lifecycle management 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: -- Labels: auto-deprioritized-major (was: stale-major) > The groupReduceOn* methods which take

[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: --- Labels: auto-deprioritized-major (was: stale-major) > AvroInputFormat should support

[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: -- Priority: Minor (was: Major) > Add docs about how to react to cancellation >

[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: -- Priority: Minor (was: Major) > RocksDBListState stores whole list in single byte[] >

[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: -- Priority: Minor (was: Major) > Allow to set the parallelism of table queries >

[jira] [Updated] (FLINK-2220) Join on Pojo without hashCode() silently fails

[ https://issues.apache.org/jira/browse/FLINK-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-2220: -- Priority: Minor (was: Major) > Join on Pojo without hashCode() silently fails >

[jira] [Commented] (FLINK-19156) Migration of transactionIdHint in Kafka is never applied

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-3627: -- Priority: Minor (was: Major) > Task stuck on lock in StreamSource when cancelling >

[jira] [Updated] (FLINK-11783) Deadlock during Join operation

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

[jira] [Commented] (FLINK-14521) CoLocationGroup is not set into JobVertex if the stream node is chained with others

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-8416: -- Labels: auto-deprioritized-major (was: stale-major) > Kinesis consumer doc examples should

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

[jira] [Updated] (FLINK-6199) Single outstanding Async I/O operation per key

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

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

[jira] [Updated] (FLINK-9052) Flink complains when scala.Option is used inside POJO

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

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

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

[jira] [Updated] (FLINK-8844) Export job jar file name or job version property via REST API

[ https://issues.apache.org/jira/browse/FLINK-8844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8844: -- Priority: Minor (was: Major) > Export job jar file name or job version property via REST API

[jira] [Commented] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

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

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

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

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

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

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

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

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

[jira] [Commented] (FLINK-12298) Make column functions accept custom Range class rather than Expression

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

[jira] [Updated] (FLINK-8663) Execution of DataStreams result in non functionality of size of Window for countWindow

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-3983: -- Labels: auto-deprioritized-major (was: stale-major) > Allow users to set any (relevant)

[jira] [Commented] (FLINK-10276) Job Manager and Task Manager Metrics Reporter Ports Configuration

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

[jira] [Updated] (FLINK-9907) add CRC32 checksum in table Api and sql

[ https://issues.apache.org/jira/browse/FLINK-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9907: -- Priority: Minor (was: Major) > add CRC32 checksum in table Api and sql >

[jira] [Commented] (FLINK-12303) Scala 2.12 lambdas does not work in event classes inside streams.

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

[jira] [Updated] (FLINK-8179) Convert CharSequence to String when registering / converting a Table

[ https://issues.apache.org/jira/browse/FLINK-8179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8179: -- Priority: Minor (was: Major) > Convert CharSequence to String when registering / converting a

[jira] [Commented] (FLINK-11196) Extend S3 EntropyInjector to use key replacement (instead of key removal) when creating checkpoint metadata files

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

[jira] [Commented] (FLINK-11783) Deadlock during Join operation

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

[jira] [Commented] (FLINK-17912) KafkaShuffleITCase.testAssignedToPartitionEventTime: "Watermark should always increase"

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

[jira] [Updated] (FLINK-9268) RockDB errors from WindowOperator

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

[jira] [Commented] (FLINK-6354) Add documentation for migration away from Checkpointed interface

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

[jira] [Updated] (FLINK-12525) Impose invariant StreamExecutionEnvironment.setBufferTimeout > 0

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

[jira] [Updated] (FLINK-7271) ExpressionReducer does not optimize string-to-time conversion

[ https://issues.apache.org/jira/browse/FLINK-7271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7271: -- Priority: Minor (was: Major) > ExpressionReducer does not optimize string-to-time conversion

[jira] [Updated] (FLINK-8179) Convert CharSequence to String when registering / converting a Table

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

[jira] [Updated] (FLINK-5429) Code generate types between operators in Table API

[ https://issues.apache.org/jira/browse/FLINK-5429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5429: -- Priority: Minor (was: Major) > Code generate types between operators in Table API >

[jira] [Commented] (FLINK-9698) "case class must be static and globally accessible" is too constrained

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

[jira] [Updated] (FLINK-11063) Make flink-table Scala-free

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

<    5   6   7   8   9   10   11   12   13   14   >