[jira] [Updated] (FLINK-9813) Build xTableSource from Avro schemas

[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9813: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17457) Manage Hive metadata via Flink DDL

[ https://issues.apache.org/jira/browse/FLINK-17457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17457: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts

[ https://issues.apache.org/jira/browse/FLINK-13035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13035: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-18642) Support emitting timed out patterns in MATCH_RECOGNIZE

[ https://issues.apache.org/jira/browse/FLINK-18642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18642: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-7697) Add metrics for Elasticsearch Sink

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7697: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

[ https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17117: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-17265) uniform time and timeUnit use

[ https://issues.apache.org/jira/browse/FLINK-17265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17265: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-21424) Lookup Hive partitioned table throws exception

[ https://issues.apache.org/jira/browse/FLINK-21424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21424: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-14884) User defined function for checkpoint trigger time and interval behavior

[ https://issues.apache.org/jira/browse/FLINK-14884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14884: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-6771) Create committer guide

[ https://issues.apache.org/jira/browse/FLINK-6771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6771: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-7735) Improve date/time handling in publically-facing Expressions

[ https://issues.apache.org/jira/browse/FLINK-7735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7735: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-16465) Add more detailed instructions for TableSink

[ https://issues.apache.org/jira/browse/FLINK-16465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16465: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-6577) Expand supported types for ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6577: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-2679) Scala API does not support Try type as key

[ https://issues.apache.org/jira/browse/FLINK-2679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-2679: Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-20103) Improve test coverage with chaos testing & side-by-side tests

[ https://issues.apache.org/jira/browse/FLINK-20103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20103: -- Summary: Improve test coverage with chaos testing & side-by-side tests (was: Improve

[jira] [Updated] (FLINK-14003) Add access to customized state other than built in state types

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14003: - Issue Type: Improvement (was: Wish) As part of

[jira] [Updated] (FLINK-10929) Add support for Apache Arrow

[ https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-10929: - Issue Type: New Feature (was: Wish) As part of

[jira] [Updated] (FLINK-22232) Improve test coverage for network stack

[ https://issues.apache.org/jira/browse/FLINK-22232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22232: -- Description: This is a clone of FLINK-20103 to improve test coverage in the shorter

[jira] [Updated] (FLINK-18260) Asynchronous Sinks

[ https://issues.apache.org/jira/browse/FLINK-18260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18260: - Issue Type: New Feature (was: Wish) As part of

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319212#comment-17319212 ] Wenhao Ji commented on FLINK-11654: --- Hi, [~aljoscha] and [~freezhan]. Do we have any update on this

[jira] [Updated] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6757: Issue Type: New Feature (was: Wish) As part of

[jira] [Updated] (FLINK-15462) Support Prestosql JDBC source/sink

[ https://issues.apache.org/jira/browse/FLINK-15462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-15462: - Issue Type: New Feature (was: Wish) As part of

[jira] [Created] (FLINK-22232) Improve test coverage for network stack

Roman Khachatryan created FLINK-22232: - Summary: Improve test coverage for network stack Key: FLINK-22232 URL: https://issues.apache.org/jira/browse/FLINK-22232 Project: Flink Issue

[jira] [Updated] (FLINK-19507) Native support for Apache Pulsar

[ https://issues.apache.org/jira/browse/FLINK-19507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19507: - Issue Type: New Feature (was: Wish) As part of

[jira] [Assigned] (FLINK-22029) Remove "Task", "Wish" and "Test" Issue Types

[ https://issues.apache.org/jira/browse/FLINK-22029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-22029: Assignee: Konstantin Knauf > Remove "Task", "Wish" and "Test" Issue Types >

[jira] [Commented] (FLINK-22163) DataTypes implementation for flink-csv with ZonedDateTime support

[ https://issues.apache.org/jira/browse/FLINK-22163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319266#comment-17319266 ] Timo Walther commented on FLINK-22163: -- [~flacombe] not sure how well {{CsvRowSerializationSchema}}

[GitHub] [flink] flinkbot commented on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

flinkbot commented on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817676016 ## CI report: * d25d03d4b3793064e7ff77ae7c03bfb60e43536f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

flinkbot commented on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817675895 ## CI report: * 567f33cdbb0bcba800140cecb357c294800e7dfc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15567: [FLINK-22215][runtime] RECOVERING state is renamed to RESTORING

flinkbot edited a comment on pull request #15567: URL: https://github.com/apache/flink/pull/15567#issuecomment-817660891 ## CI report: * 93afd72f497847dff4a1048e7ed942303d0e20d1 Azure:

[GitHub] [flink] flinkbot commented on pull request #15568: [FLINK-17371][table-runtime] Add cases for decimal casting

flinkbot commented on pull request #15568: URL: https://github.com/apache/flink/pull/15568#issuecomment-817675780 ## CI report: * 0fadc09a8fa301dc7a46c5893d16390f76379853 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

flinkbot edited a comment on pull request #15140: URL: https://github.com/apache/flink/pull/15140#issuecomment-795409010 ## CI report: * 4d34b9b0dc39a7b9dda50630a12f5faf3da17776 Azure:

[jira] [Updated] (FLINK-22163) DataTypes implementation for flink-csv with ZonedDateTime support

[ https://issues.apache.org/jira/browse/FLINK-22163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Johannes Moser updated FLINK-22163: --- Parent: FLINK-12251 Issue Type: Sub-task (was: Wish) > DataTypes implementation

[jira] [Commented] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319257#comment-17319257 ] Till Rohrmann commented on FLINK-21844: --- [~austince], [~chesnay] do we already have a follow up

[GitHub] [flink] flinkbot commented on pull request #15571: [FLINK-22166][table] Empty values with sort willl fail

flinkbot commented on pull request #15571: URL: https://github.com/apache/flink/pull/15571#issuecomment-817673407 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-14966) Online document typo, package name org.apache.flinktypes.xxxx should be corrected as org.apache.flink.types.xxxx . From online documents flink-docs-release-1.9 (Applicat

[ https://issues.apache.org/jira/browse/FLINK-14966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14966: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-9071) Dataflow programming model documentation example is referencing deprecated RollingSink

[ https://issues.apache.org/jira/browse/FLINK-9071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9071: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-7958) Allow reporters to override the default delimiter

[ https://issues.apache.org/jira/browse/FLINK-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7958: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-19010) Add a system metric to show the checkpoint restore time

[ https://issues.apache.org/jira/browse/FLINK-19010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19010: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-16571) Throw exception when current key is out of range

[ https://issues.apache.org/jira/browse/FLINK-16571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16571: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-6035) Sinks need optional name parameter: .collect(name), .count(name)

[ https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6035: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-4874) Document how to enable Flink web interface in local execution

[ https://issues.apache.org/jira/browse/FLINK-4874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4874: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-12922) Remove method parameter from OperatorCodeGenerator

[ https://issues.apache.org/jira/browse/FLINK-12922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12922: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-21372) Arranging cluster tests, on RISC-V

[ https://issues.apache.org/jira/browse/FLINK-21372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21372: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-22163) DataTypes implementation for flink-csv with ZonedDateTime support

[ https://issues.apache.org/jira/browse/FLINK-22163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22163: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-21474) Migrate ParquetTableSource to use DynamicTableSource Interface

[ https://issues.apache.org/jira/browse/FLINK-21474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21474: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-9631) use Files.createDirectories instead of directory.mkdirs

[ https://issues.apache.org/jira/browse/FLINK-9631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9631: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-22046) org.apache.flink.cep.nfa.State#toString() may has abnormal format

[ https://issues.apache.org/jira/browse/FLINK-22046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-22046: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-3245) KMeans Data Generator writes not the same centroids as it was used for the dataset

[ https://issues.apache.org/jira/browse/FLINK-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-3245: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-9813) Build xTableSource from Avro schemas

[ https://issues.apache.org/jira/browse/FLINK-9813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9813: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-7955) Rowtime attribute cannot be aggregated in group window of stream Table API

[ https://issues.apache.org/jira/browse/FLINK-7955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7955: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-8875) Watermark tab on Web Interface should display low watermark in ISO8601

[ https://issues.apache.org/jira/browse/FLINK-8875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8875: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-14034) In FlinkKafkaProducer, KafkaTransactionState should be made public or invoke should be made final

[ https://issues.apache.org/jira/browse/FLINK-14034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14034: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-13259) Typos about "access"

[ https://issues.apache.org/jira/browse/FLINK-13259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13259: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-5783) flink-connector-kinesis java.lang.NoClassDefFoundError: org/apache/http/conn/ssl/SSLSocketFactory

[ https://issues.apache.org/jira/browse/FLINK-5783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-5783: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-7957) Add MetricGroup#getLogicalScope

[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7957: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-21720) Rework Documentation Style Guide for the new build system

[ https://issues.apache.org/jira/browse/FLINK-21720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21720: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-20004) UpperLimitExceptionParameter description is misleading

[ https://issues.apache.org/jira/browse/FLINK-20004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-20004: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-18209) Replace "charged" words in the Flink codebase.

[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18209: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-9024) IntelliJ IDEA support run and debug Flink code

[ https://issues.apache.org/jira/browse/FLINK-9024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9024: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-21487) Replace TaskExecutor with TaskManager in ConfigOption description

[ https://issues.apache.org/jira/browse/FLINK-21487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21487: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-14001) add a API to enable user to get the operator code generated by Flink engine

[ https://issues.apache.org/jira/browse/FLINK-14001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14001: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-6375) Fix LongValue hashCode

[ https://issues.apache.org/jira/browse/FLINK-6375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6375: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-9596) Ability to configure logging using single log4j file

[ https://issues.apache.org/jira/browse/FLINK-9596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9596: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-12700) Nodejs installation suggestions

[ https://issues.apache.org/jira/browse/FLINK-12700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-12700: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-14650) Thread safety issue in the piece of code example of dev/stream/testing document

[ https://issues.apache.org/jira/browse/FLINK-14650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-14650: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-6717) NullPointerException from MessageAcknowledgingSourceBase

[ https://issues.apache.org/jira/browse/FLINK-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6717: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-19565) java.util.Collections$UnmodifiableList to field org.apache.flink.runtime.jobgraph.JobVertex.operatorIDs of type java.util.ArrayList in instance of org.apache.flink.runti

[ https://issues.apache.org/jira/browse/FLINK-19565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19565: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-8618) Add S3 to the list of sinks on the delivery guarantees page

[ https://issues.apache.org/jira/browse/FLINK-8618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8618: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-9347) BlobServerConnection throws misleading exception for empty files

[ https://issues.apache.org/jira/browse/FLINK-9347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9347: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-21943) Redundant checkNotNull

[ https://issues.apache.org/jira/browse/FLINK-21943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-21943: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-7029) Documentation for WindowFunction is confusing

[ https://issues.apache.org/jira/browse/FLINK-7029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7029: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

[ https://issues.apache.org/jira/browse/FLINK-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-7963: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-4989) Completed job -> Properties: Misleading label

[ https://issues.apache.org/jira/browse/FLINK-4989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4989: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-8513) Add documentation for connecting to non-AWS S3 endpoints

[ https://issues.apache.org/jira/browse/FLINK-8513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-8513: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-9709) Docs: Unnecessary transition in flink job state visualization

[ https://issues.apache.org/jira/browse/FLINK-9709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-9709: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-16715) Always use the configuration argument in YarnClusterDescriptor#startAppMaster to make it more self-contained

[ https://issues.apache.org/jira/browse/FLINK-16715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-16715: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-6028) Unnamed operations in main method logged as "main(null:-1)"

[ https://issues.apache.org/jira/browse/FLINK-6028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6028: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-1939) Add Parquet Documentation to Wiki

[ https://issues.apache.org/jira/browse/FLINK-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-1939: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-19451) Add HELM chart distribution to StateFun release process

[ https://issues.apache.org/jira/browse/FLINK-19451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19451: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-18896) Translate "stateful-functions" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18896: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-6577) Expand supported types for ConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-6577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6577: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-6758) Loaded configuration values are logged twice

[ https://issues.apache.org/jira/browse/FLINK-6758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6758: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-19877) AlterDatabaseOperation is missing ignoreIfNotExists

[ https://issues.apache.org/jira/browse/FLINK-19877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19877: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-17969) Enhance Flink (Task) logging to include job name as context diagnostic information

[ https://issues.apache.org/jira/browse/FLINK-17969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17969: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-19846) Grammar mistakes in annotations and log

[ https://issues.apache.org/jira/browse/FLINK-19846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19846: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-18275) Register the DataStream as table how to write multiple fields

[ https://issues.apache.org/jira/browse/FLINK-18275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-18275: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-13035) LocalStreamEnvironment shall launch actuall task solts

[ https://issues.apache.org/jira/browse/FLINK-13035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-13035: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-4627) Use Flink's PropertiesUtil in Kinesis connector to extract typed values from config properties

[ https://issues.apache.org/jira/browse/FLINK-4627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-4627: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-6576) Allow ConfigOptions to validate the configured value

[ https://issues.apache.org/jira/browse/FLINK-6576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-6576: Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028 the

[jira] [Updated] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-17469: - Priority: Minor (was: Trivial) In https://issues.apache.org/jira/browse/FLINK-22028

[jira] [Updated] (FLINK-22166) Empty values with sort willl fail

[ https://issues.apache.org/jira/browse/FLINK-22166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22166: --- Labels: pull-request-available (was: ) > Empty values with sort willl fail >

[GitHub] [flink] JingsongLi opened a new pull request #15571: [FLINK-22166][table] Empty values with sort willl fail

JingsongLi opened a new pull request #15571: URL: https://github.com/apache/flink/pull/15571 ## What is the purpose of the change `SELECT * FROM (VALUES 1, 2, 3) AS T (a) WHERE a = 1 and a = 2 ORDER BY a` will fail. ## Brief change log `FlinkLogicalValues`

[jira] [Assigned] (FLINK-22028) Remove "Trivial" Ticket Priority

[ https://issues.apache.org/jira/browse/FLINK-22028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-22028: Assignee: Konstantin Knauf > Remove "Trivial" Ticket Priority >

[jira] [Created] (FLINK-22231) Add Rule to deprioritize Critical/Blocker Non-Bugs

Konstantin Knauf created FLINK-22231: Summary: Add Rule to deprioritize Critical/Blocker Non-Bugs Key: FLINK-22231 URL: https://issues.apache.org/jira/browse/FLINK-22231 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

flinkbot commented on pull request #15570: URL: https://github.com/apache/flink/pull/15570#issuecomment-817666089 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-22016) PushFilterIntoTableSourceScanRule fails to deal with NULLs

[ https://issues.apache.org/jira/browse/FLINK-22016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22016: --- Labels: pull-request-available (was: ) > PushFilterIntoTableSourceScanRule fails to deal

[GitHub] [flink] cshuo commented on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

cshuo commented on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817664506 cc @JingsongLi -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] TsReaper opened a new pull request #15570: [FLINK-22016][table-planner-blink] RexNodeExtractor#visitLiteral now deal with NULL literals correctly

TsReaper opened a new pull request #15570: URL: https://github.com/apache/flink/pull/15570 ## What is the purpose of the change `RexLiteral` could not contain null values in the past according to @dawidwys , however this is currently not true and will cause filter push down rules

[GitHub] [flink] zentol commented on a change in pull request #15553: [FLINK-22069] Reduce various logging issues

zentol commented on a change in pull request #15553: URL: https://github.com/apache/flink/pull/15553#discussion_r611484428 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/externalresource/ExternalResourceUtils.java ## @@ -116,10 +117,25 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #15566: [FLINK-21798][test] Fail on double-freeing memory segment for CI tests.

flinkbot edited a comment on pull request #15566: URL: https://github.com/apache/flink/pull/15566#issuecomment-817640645 ## CI report: * cd38fff04c018505d9e62818d6571b2d656f7258 Azure:

<    1   2   3   4   5   6   7   8   >