[jira] [Assigned] (FLINK-18182) Upgrade AWS SDK in flink-connector-kinesis to include new region af-south-1

[ https://issues.apache.org/jira/browse/FLINK-18182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-18182: - Assignee: Danny Cranmer > Upgrade AWS SDK in flink-connector-kinesis to include new

[jira] [Updated] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-22970: - Component/s: Table SQL / API > The documentation for `TO_TIMESTAMP` UDF has an incorrect

[jira] [Commented] (FLINK-22891) FineGrainedSlotManagerDefaultResourceAllocationStrategyITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361863#comment-17361863 ] Anton Kalashnikov commented on FLINK-22891: --- [~karmagyz], I still observe this problem on the

[jira] [Commented] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361826#comment-17361826 ] Derek Moore commented on FLINK-18438: - [~JohnSiro], [~cr0566], [~xintongsong], et al., The issue a

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361827#comment-17361827 ] Jark Wu commented on FLINK-22968: - [~twalthr], do you think we still need to improve exception messages

[jira] [Commented] (FLINK-18438) TaskManager start failed

[ https://issues.apache.org/jira/browse/FLINK-18438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361927#comment-17361927 ] Derek Moore commented on FLINK-18438: - [~JohnSiro], [~cr0566], [~xintongsong]: This issue resolves

[jira] [Updated] (FLINK-22139) Flink Jobmanager & Task Manger logs are not writing to the logs files

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

[jira] [Updated] (FLINK-22558) testcontainers fail to start ResourceReaper

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

[jira] [Updated] (FLINK-15867) LAST_VALUE and FIRST_VALUE aggregate function does not support time-related types

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

[jira] [Updated] (FLINK-15832) Test jars are installed twice

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

[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

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

[jira] [Updated] (FLINK-15992) Incorrect classloader when finding TableFactory

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

[jira] [Updated] (FLINK-15964) Getting previous stage in notFollowedBy may throw exception

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

[jira] [Updated] (FLINK-15980) The notFollowedBy in the end of GroupPattern may be ignored

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

[jira] [Updated] (FLINK-15745) KafkaITCase.testKeyValueSupport failure due to assertion error.

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

[jira] [Updated] (FLINK-15747) Enable setting RocksDB log level from configuration

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

[jira] [Updated] (FLINK-15873) Matched result may not be output if existing earlier partial matches

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

[jira] [Updated] (FLINK-15973) Optimize the execution plan where it refers the Python UDF result field in the where clause

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

[jira] [Updated] (FLINK-15787) Upgrade REST API response to remove '-' from key names.

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

[jira] [Updated] (FLINK-21108) Flink runtime rest server and history server webmonitor do not require authentication.

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

[jira] [Updated] (FLINK-15845) Add java-based StreamingFileSink test using s3

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

[jira] [Updated] (FLINK-10232) Add a SQL DDL

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

[jira] [Updated] (FLINK-22255) AdaptiveScheduler improvements/bugs

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

[jira] [Updated] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

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

[jira] [Updated] (FLINK-10210) Time indicators are not always materialised for LogicalCorrelate

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

[jira] [Updated] (FLINK-10177) Use network transport type AUTO by default

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

[jira] [Updated] (FLINK-10198) Set Env object in DBOptions for RocksDB

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

[jira] [Updated] (FLINK-10183) Processing-Time based windows aren't emitted when a finite stream ends

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

[jira] [Updated] (FLINK-10162) Add host in checkpoint detail

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

[jira] [Updated] (FLINK-10146) numBuffersOut not updated properly

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

[jira] [Updated] (FLINK-10171) Allow for assemblePartPath override in the BucketingSink

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

[jira] [Updated] (FLINK-15507) Activate local recovery for RocksDB backends by default

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

[jira] [Updated] (FLINK-10203) Support truncate method for old Hadoop versions in HadoopRecoverableFsDataOutputStream

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

[jira] [Updated] (FLINK-22483) Recover checkpoints when JobMaster gains leadership

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

[jira] [Updated] (FLINK-10122) KafkaConsumer should use partitionable state over union state if partition discovery is not active

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

[jira] [Updated] (FLINK-22367) JobMasterStopWithSavepointITCase.terminateWithSavepointWithoutComplicationsShouldSucceedAndLeadJobToFinished times out

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

[jira] [Updated] (FLINK-22949) java.io.InvalidClassException With Flink Kafka Beam

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

[jira] [Updated] (FLINK-10134) UTF-16 support for TextInputFormat

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

[jira] [Updated] (FLINK-10200) Consolidate FileBasedStateOutputStream and FsCheckpointStateOutputStream

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

[jira] [Updated] (FLINK-10168) Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time

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

[jira] [Updated] (FLINK-10121) Introduce methods to remove registered operator states

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

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

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

[jira] [Updated] (FLINK-10705) Rework Flink Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10705: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

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

[jira] [Updated] (FLINK-20280) Support batch mode for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20280: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21431: --- Labels: pull-request-available stale-assigned test-stability (was: pull-request-available

[jira] [Updated] (FLINK-11937) Resolve small file problem in RocksDB incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-11937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11937: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16137) Translate all DataStream API related pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16137: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-22771) Add TestContext to Java SDK

[ https://issues.apache.org/jira/browse/FLINK-22771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22771: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16012) Reduce the default number of exclusive buffers from 2 to 1 on receiver side

[ https://issues.apache.org/jira/browse/FLINK-16012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16012: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-21420) Add path templating to the DataStream API

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

[jira] [Updated] (FLINK-16073) Translate "State & Fault Tolerance" pages into Chinese

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

[jira] [Assigned] (FLINK-21336) Activate bloom filter in RocksDB State Backend via Flink configuration

[ https://issues.apache.org/jira/browse/FLINK-21336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Qin reassigned FLINK-21336: --- Assignee: Jun Qin > Activate bloom filter in RocksDB State Backend via Flink configuration >

[jira] [Closed] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22197. Resolution: Fixed > UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint

[jira] [Commented] (FLINK-22197) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to NoSuchFileException

[ https://issues.apache.org/jira/browse/FLINK-22197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361559#comment-17361559 ] Dawid Wysakowicz commented on FLINK-22197: -- That has not happened in a while. I can't see any

[jira] [Commented] (FLINK-22971) Initialization of Testcontainers unstable on Azure

[ https://issues.apache.org/jira/browse/FLINK-22971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361564#comment-17361564 ] Xintong Song commented on FLINK-22971: -- Exactly. Thanks for the pointer. I wasn't aware of

[jira] [Assigned] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method

[ https://issues.apache.org/jira/browse/FLINK-22972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22972: Assignee: Dawid Wysakowicz > Deprecate/Remove StreamOperator#dispose method >

[jira] [Updated] (FLINK-22972) Deprecate/Remove StreamOperator#dispose method

[ https://issues.apache.org/jira/browse/FLINK-22972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22972: - Description: As discussed in the ML thread (e.g.

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:18 AM: - Hi Till and Chesnay

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in

[jira] [Commented] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361571#comment-17361571 ] pierrexiong commented on FLINK-11622: - Hi [~jark]，I found that the work was not completed yet. Can

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:38 AM: - Hi Till and Chesnay

[jira] [Commented] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361586#comment-17361586 ] Timo Walther commented on FLINK-22968: -- [~DaChun777] {{toAppendStream}} is soft-deprecated in Flink

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361588#comment-17361588 ] Roc Marshal commented on FLINK-22885: - For the time being, it would be feasible to support this DDL.

[jira] [Comment Edited] (FLINK-22968) Improve exception message when using toAppendStream[String]

[ https://issues.apache.org/jira/browse/FLINK-22968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361586#comment-17361586 ] Timo Walther edited comment on FLINK-22968 at 6/11/21, 10:12 AM: -

[jira] [Updated] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22015: --- Fix Version/s: 1.12.5 > SQL filter containing OR and IS NULL will produce an incorrect result. >

[jira] [Commented] (FLINK-22015) SQL filter containing OR and IS NULL will produce an incorrect result.

[ https://issues.apache.org/jira/browse/FLINK-22015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361592#comment-17361592 ] Kurt Young commented on FLINK-22015: also fixed in 1.12.5: faf7cc43beebce3fee528ec5637e9387b95bec99

[jira] [Commented] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu commented on FLINK-22970: minor: TO_TIMESTAMP doesn't use any time zone information. >

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-22954: -- Description: {code:java} Exception in thread "main" org.apache.flink.table.api.TableException: Table

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Affects Version/s: (was: 1.12.4) >

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Fix Version/s: (was: 1.12.5) >

[jira] [Closed] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22908. Resolution: Fixed > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Summary: FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-22954: -- Affects Version/s: 1.12.2 > Don't support consuming update and delete changes when use table function

[jira] [Updated] (FLINK-22954) Don't support consuming update and delete changes when use table function that does not contain table field

[ https://issues.apache.org/jira/browse/FLINK-22954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hehuiyuan updated FLINK-22954: -- Affects Version/s: (was: 1.12.2) 1.12.0 > Don't support consuming update

[jira] [Created] (FLINK-22971) Initialization of Testcontainers unstable on Azure

Xintong Song created FLINK-22971: Summary: Initialization of Testcontainers unstable on Azure Key: FLINK-22971 URL: https://issues.apache.org/jira/browse/FLINK-22971 Project: Flink Issue

[jira] [Comment Edited] (FLINK-22878) Allow placeholder options in format factories

[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360719#comment-17360719 ] Timo Walther edited comment on FLINK-22878 at 6/11/21, 7:52 AM: We found

[jira] [Commented] (FLINK-22878) Allow placeholder options in format factories

[ https://issues.apache.org/jira/browse/FLINK-22878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361513#comment-17361513 ] Timo Walther commented on FLINK-22878: -- [~nicholasjiang] sorry this was just a copy-paste error. It

[jira] [Commented] (FLINK-22959) Keep the job jar files on JobManager

[ https://issues.apache.org/jira/browse/FLINK-22959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361518#comment-17361518 ] Till Rohrmann commented on FLINK-22959: --- Thanks for reporting this issue [~luke123]. It is indeed

[jira] [Closed] (FLINK-18670) Add (statefun-)docker repos to community page

[ https://issues.apache.org/jira/browse/FLINK-18670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18670. Resolution: Fixed asf-site: 71244b98fe2d870d56f8068f67d3b0c115f4f1bc > Add

[jira] [Created] (FLINK-22973) Provide benchmark for unaligned checkpoints performance

Piotr Nowojski created FLINK-22973: -- Summary: Provide benchmark for unaligned checkpoints performance Key: FLINK-22973 URL: https://issues.apache.org/jira/browse/FLINK-22973 Project: Flink

[jira] [Updated] (FLINK-20388) Supports users setting operators' metrics name

[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20388: Priority: Major (was: Minor) > Supports users setting operators' metrics name >

[jira] [Updated] (FLINK-20388) Supports users setting operators' metrics name

[ https://issues.apache.org/jira/browse/FLINK-20388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20388: Labels: (was: auto-deprioritized-major) > Supports users setting operators' metrics name >

[jira] [Created] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

tinawenqiao created FLINK-22974: --- Summary: No execution checkpointing config desc in flink-conf.yaml Key: FLINK-22974 URL: https://issues.apache.org/jira/browse/FLINK-22974 Project: Flink

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:17 AM: - Hi Till & x.x.66.160

[jira] [Updated] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22965: -- Attachment: flink issue with jm log.txt > Association with remote system has failed, address is now gated >

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in

[jira] [Updated] (FLINK-22974) No execution checkpointing config desc in flink-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-22974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tinawenqiao updated FLINK-22974: Description: We found that there is no parameter description for execution checkpointing in

[jira] [Commented] (FLINK-22963) The description of taskmanager.memory.task.heap.size in the official document is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361569#comment-17361569 ] Xintong Song commented on FLINK-22963: -- [~jasonlee1017], Welcome to the community, and thanks for

[jira] [Commented] (FLINK-22617) Add log when create bulk format

[ https://issues.apache.org/jira/browse/FLINK-22617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361568#comment-17361568 ] hehuiyuan commented on FLINK-22617: --- Hi  [~luoyuxia],    , i am willing to do it. > Add log when

[jira] [Commented] (FLINK-22946) Network buffer deadlock introduced by unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-22946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361570#comment-17361570 ] Guokuai Huang commented on FLINK-22946: --- [~zjwang] [~roman_khachatryan] [~arvid heise] [~ym]

[jira] [Comment Edited] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361540#comment-17361540 ] Bhagi edited comment on FLINK-22965 at 6/11/21, 9:36 AM: - Hi Till and Chesnay

[jira] [Updated] (FLINK-22965) Association with remote system has failed, address is now gated

[ https://issues.apache.org/jira/browse/FLINK-22965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bhagi updated FLINK-22965: -- Attachment: JM-log-debug-mode.log TM-log-debug-mode.log > Association with remote system has

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-22969: --- Labels: starter (was: ) > Validate the topic is not null or empty string when create kafka

[jira] [Comment Edited] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361467#comment-17361467 ] Chesnay Schepler edited comment on FLINK-22908 at 6/11/21, 10:07 AM: -

[jira] [Closed] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-22908. Resolution: Fixed > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown

[jira] [Comment Edited] (FLINK-22970) The documentation for `TO_TIMESTAMP` UDF has an incorrect description

[ https://issues.apache.org/jira/browse/FLINK-22970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361442#comment-17361442 ] Leonard Xu edited comment on FLINK-22970 at 6/11/21, 6:22 AM: -- [~tonywei]

[jira] [Commented] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361467#comment-17361467 ] Chesnay Schepler commented on FLINK-22908: -- master: f52b2d4d78a3b6facc2af5cc589b3fcbeaa12826 >

[jira] [Reopened] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-22908: -- > FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should > wait

[jira] [Updated] (FLINK-22908) FileExecutionGraphInfoStoreTest.testPutSuspendedJobOnClusterShutdown should wait until job is running

[ https://issues.apache.org/jira/browse/FLINK-22908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-22908: - Fix Version/s: 1.12.5 >

  1   2   >