[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 stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-11864) Let compressed channel reader/writer reuse the logic of AsynchronousFileIOChannel

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

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

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

[jira] [Updated] (FLINK-11913) Cassandra connector should shade it's usage of cassandra-driver classes to avoid conflicts

[ https://issues.apache.org/jira/browse/FLINK-11913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11913: --- Labels: auto-deprioritized-major auto-deprioritized-minor cassandra

[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: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

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

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

[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 auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11794) Allow compression of row format files created by StreamingFileSink

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

[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: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available (was:

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

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

[jira] [Updated] (FLINK-11862) many differents query on same stream cause second condition of where of second query error

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

[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 auto-deprioritized-minor (was: auto-deprioritized-major

[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 auto-deprioritized-minor (was: auto-deprioritized-major

[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 auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Commented] (FLINK-25028) java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/FLINK-25028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450024#comment-17450024 ] liu zhuang commented on FLINK-25028: Hi，If you are using flink on yarn, you can add the parameter

[GitHub] [flink] flinkbot edited a comment on pull request #17765: [FLINK-24851][Connectors / Kafka] KafkaSourceBuilder: auto.offset.reset is ignored

flinkbot edited a comment on pull request #17765: URL: https://github.com/apache/flink/pull/17765#issuecomment-966280320 ## CI report: * 74d72f6d9c398105b355d07d0bba47ef6f0a1361 Azure:

[jira] [Created] (FLINK-25084) Field names must be unique. Found duplicates

Ivan Budanaev created FLINK-25084: - Summary: Field names must be unique. Found duplicates Key: FLINK-25084 URL: https://issues.apache.org/jira/browse/FLINK-25084 Project: Flink Issue Type:

[jira] [Updated] (FLINK-12027) Flink Web UI is not accessible in local mode

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

[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: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[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 stale-minor (was:

[jira] [Updated] (FLINK-8672) Support continuous processing in CSV table source

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

[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: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8794) When using BucketingSink, it happens that one of the files is always in the [.in-progress] state

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

[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 stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8570) Provide a hook in Flink KafkaConsumer(source function) implementation to override assignment of kafka partitions to individual task nodes

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

[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 stale-minor (was: auto-deprioritized-major) I am the [Flink

[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: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-12010) Kinesis Producer problems on Alpine Linux image

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

[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: -- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the [Flink

[jira] [Updated] (FLINK-8895) Job failed when one kafka broker shutdown

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

[jira] [Updated] (FLINK-11930) Split SegmentsUtil into some dedicated utilities

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

[jira] [Updated] (FLINK-11924) Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "EXISTS" at line 1, column 40.

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

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-11925: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout

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

[jira] [Updated] (FLINK-8862) Support HBase snapshot read

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

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

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

[jira] [Updated] (FLINK-12089) Broadcasting Dynamic Configuration

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

[jira] [Updated] (FLINK-12080) Add timestamp property to savepoint

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

[GitHub] [flink] flinkbot edited a comment on pull request #15999: [FLINK-22769][flink-yarn]yarnship symlinks support

flinkbot edited a comment on pull request #15999: URL: https://github.com/apache/flink/pull/15999#issuecomment-847987552 ## CI report: * 4757486900cc6a8c6a777817173d0b90ec1d29b7 Azure:

[jira] [Assigned] (FLINK-25053) Document how to use the usrlib to load code in the user code class loader

[ https://issues.apache.org/jira/browse/FLINK-25053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma reassigned FLINK-25053: - Assignee: Lijie Wang > Document how to use the usrlib to load code in the user code class

[GitHub] [flink] flinkbot edited a comment on pull request #15999: [FLINK-22769][flink-yarn]yarnship symlinks support

flinkbot edited a comment on pull request #15999: URL: https://github.com/apache/flink/pull/15999#issuecomment-847987552 ## CI report: * e66764ec5ad44839d930db6e8d4809d6ea145291 Azure:

<    1   2