[jira] [Updated] (FLINK-16425) Add rate limiting feature for kafka table source

[ https://issues.apache.org/jira/browse/FLINK-16425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16425: --- Labels: stale-major (was: ) > Add rate limiting feature for kafka table source > --

[jira] [Commented] (FLINK-16277) StreamTableEnvironment.toAppendStream fails with Decimal types

[ https://issues.apache.org/jira/browse/FLINK-16277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328030#comment-17328030 ] Flink Jira Bot commented on FLINK-16277: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16322) get wrong result after filter push down is applied in parquet table source

[ https://issues.apache.org/jira/browse/FLINK-16322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16322: --- Labels: stale-major (was: ) > get wrong result after filter push down is applied in parquet

[jira] [Commented] (FLINK-15968) LegacyTypeInfoDataTypeConverter should support conversion from BINARY/VARBINARY to BYTE_PRIMITIVE_ARRAY_TYPE_INFO

[ https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328055#comment-17328055 ] Flink Jira Bot commented on FLINK-15968: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16402) Alter table fails on Hive catalog

[ https://issues.apache.org/jira/browse/FLINK-16402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328012#comment-17328012 ] Flink Jira Bot commented on FLINK-16402: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16024: --- Labels: stale-major (was: ) > support filter pushdown in jdbc connector > -

[jira] [Commented] (FLINK-16319) Pubsub-/Broadcast implementation

[ https://issues.apache.org/jira/browse/FLINK-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328024#comment-17328024 ] Flink Jira Bot commented on FLINK-16319: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16116) Remove shading from oss filesystems build

[ https://issues.apache.org/jira/browse/FLINK-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328044#comment-17328044 ] Flink Jira Bot commented on FLINK-16116: This major issue is unassigned and itse

[jira] [Commented] (FLINK-17363) Asynchronous association dimension table timeout

[ https://issues.apache.org/jira/browse/FLINK-17363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327882#comment-17327882 ] Flink Jira Bot commented on FLINK-17363: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16401) Support map type for JsonRowSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-16401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16401: --- Labels: stale-major (was: ) > Support map type for JsonRowSerializationSchema > ---

[jira] [Updated] (FLINK-16369) Allow the StreamingFileSink to restore from a previous (old) savepoint.

[ https://issues.apache.org/jira/browse/FLINK-16369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16369: --- Labels: stale-major (was: ) > Allow the StreamingFileSink to restore from a previous (old)

[jira] [Updated] (FLINK-15951) Travis build fails on npm install

[ https://issues.apache.org/jira/browse/FLINK-15951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15951: --- Labels: stale-major (was: ) > Travis build fails on npm install > -

[jira] [Commented] (FLINK-16315) throw JsonMappingException when using BatchTableEnvironment#explain to get the plan of sql with constant string

[ https://issues.apache.org/jira/browse/FLINK-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328026#comment-17328026 ] Flink Jira Bot commented on FLINK-16315: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16296) Improve performance of BaseRowSerializer#serialize() for GenericRow

[ https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16296: --- Labels: stale-major (was: ) > Improve performance of BaseRowSerializer#serialize() for Gene

[jira] [Commented] (FLINK-16296) Improve performance of BaseRowSerializer#serialize() for GenericRow

[ https://issues.apache.org/jira/browse/FLINK-16296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328027#comment-17328027 ] Flink Jira Bot commented on FLINK-16296: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16207) In stream processing concepts section, rework distribution patterns description

[ https://issues.apache.org/jira/browse/FLINK-16207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16207: --- Labels: stale-major (was: ) > In stream processing concepts section, rework distribution pa

[jira] [Updated] (FLINK-16010) Support notFollowedBy with interval as the last part of a Pattern

[ https://issues.apache.org/jira/browse/FLINK-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16010: --- Labels: stale-major (was: ) > Support notFollowedBy with interval as the last part of a Pat

[jira] [Commented] (FLINK-16324) Checkpoint tasks progress would display 100% in web UI even not all tasks finished

[ https://issues.apache.org/jira/browse/FLINK-16324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328021#comment-17328021 ] Flink Jira Bot commented on FLINK-16324: This major issue is unassigned and itse

[jira] [Updated] (FLINK-17550) set a retract switch

[ https://issues.apache.org/jira/browse/FLINK-17550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17550: --- Labels: stale-major (was: ) > set a retract switch > > >

[jira] [Updated] (FLINK-16295) Optimize BinaryString.copy to not materialize if there is javaObject

[ https://issues.apache.org/jira/browse/FLINK-16295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16295: --- Labels: stale-major (was: ) > Optimize BinaryString.copy to not materialize if there is jav

[jira] [Updated] (FLINK-15924) Detect and log blocking main thread operations

[ https://issues.apache.org/jira/browse/FLINK-15924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15924: --- Labels: stale-major (was: ) > Detect and log blocking main thread operations >

[jira] [Updated] (FLINK-16116) Remove shading from oss filesystems build

[ https://issues.apache.org/jira/browse/FLINK-16116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16116: --- Labels: stale-major (was: ) > Remove shading from oss filesystems build > -

[jira] [Commented] (FLINK-16649) Support Java 14

[ https://issues.apache.org/jira/browse/FLINK-16649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327982#comment-17327982 ] Flink Jira Bot commented on FLINK-16649: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16010) Support notFollowedBy with interval as the last part of a Pattern

[ https://issues.apache.org/jira/browse/FLINK-16010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328051#comment-17328051 ] Flink Jira Bot commented on FLINK-16010: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16320) Can not use sub-queries in the VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-16320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328023#comment-17328023 ] Flink Jira Bot commented on FLINK-16320: This major issue is unassigned and itse

[jira] [Commented] (FLINK-20684) Add compression type option in RocksDBConfigurableOptions

[ https://issues.apache.org/jira/browse/FLINK-20684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327452#comment-17327452 ] Flink Jira Bot commented on FLINK-20684: This major issue is unassigned and itse

[jira] [Updated] (FLINK-17472) StreamExecutionEnvironment and ExecutionEnvironment in Yarn mode

[ https://issues.apache.org/jira/browse/FLINK-17472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17472: --- Labels: stale-major (was: ) > StreamExecutionEnvironment and ExecutionEnvironment in Yarn m

[jira] [Commented] (FLINK-16024) support filter pushdown in jdbc connector

[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328049#comment-17328049 ] Flink Jira Bot commented on FLINK-16024: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

[ https://issues.apache.org/jira/browse/FLINK-16693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327978#comment-17327978 ] Flink Jira Bot commented on FLINK-16693: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16215) Start redundant TaskExecutor when JM failed

[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16215: --- Labels: stale-major (was: ) > Start redundant TaskExecutor when JM failed > ---

[jira] [Updated] (FLINK-15943) Rowtime field name cannot be the same as the json field

[ https://issues.apache.org/jira/browse/FLINK-15943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15943: --- Labels: stale-major (was: ) > Rowtime field name cannot be the same as the json field > --

[jira] [Commented] (FLINK-16207) In stream processing concepts section, rework distribution patterns description

[ https://issues.apache.org/jira/browse/FLINK-16207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328039#comment-17328039 ] Flink Jira Bot commented on FLINK-16207: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16320) Can not use sub-queries in the VALUES clause

[ https://issues.apache.org/jira/browse/FLINK-16320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16320: --- Labels: stale-major (was: ) > Can not use sub-queries in the VALUES clause > -

[jira] [Commented] (FLINK-17437) Use StringData instead of BinaryStringData in code generation

[ https://issues.apache.org/jira/browse/FLINK-17437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327866#comment-17327866 ] Flink Jira Bot commented on FLINK-17437: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328052#comment-17328052 ] Flink Jira Bot commented on FLINK-16009: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15922) Show "Warn - received late message for checkpoint" only when checkpoint actually expired

[ https://issues.apache.org/jira/browse/FLINK-15922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15922: --- Labels: stale-major usability (was: usability) > Show "Warn - received late message for che

[jira] [Updated] (FLINK-15968) LegacyTypeInfoDataTypeConverter should support conversion from BINARY/VARBINARY to BYTE_PRIMITIVE_ARRAY_TYPE_INFO

[ https://issues.apache.org/jira/browse/FLINK-15968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15968: --- Labels: stale-major (was: ) > LegacyTypeInfoDataTypeConverter should support conversion fro

[jira] [Commented] (FLINK-17233) Remove copied methods from Calcite introduced by fixing TIMESTAMPDIFF

[ https://issues.apache.org/jira/browse/FLINK-17233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327901#comment-17327901 ] Flink Jira Bot commented on FLINK-17233: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15927) TaskExecutor should treat it as a fatal error is Task cannot be failed

[ https://issues.apache.org/jira/browse/FLINK-15927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15927: --- Labels: stale-major (was: ) > TaskExecutor should treat it as a fatal error is Task cannot

[jira] [Commented] (FLINK-16780) improve Flink lookup join

[ https://issues.apache.org/jira/browse/FLINK-16780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327965#comment-17327965 ] Flink Jira Bot commented on FLINK-16780: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15906: --- Labels: stale-major (was: ) > physical memory exceeded causing being killed by yarn > -

[jira] [Commented] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328048#comment-17328048 ] Flink Jira Bot commented on FLINK-16027: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16224) Refine Hadoop Delegation Token based testing framework

[ https://issues.apache.org/jira/browse/FLINK-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16224: --- Labels: stale-major (was: ) > Refine Hadoop Delegation Token based testing framework >

[jira] [Commented] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328050#comment-17328050 ] Flink Jira Bot commented on FLINK-16023: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

[ https://issues.apache.org/jira/browse/FLINK-16446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16446: --- Labels: stale-major (was: ) > Add rate limiting feature for FlinkKafkaConsumer > --

[jira] [Updated] (FLINK-17575) KafkaException: Received exception when fetching the next record from XXX-14. If needed, please seek past the record to continue consumption.

[ https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17575: --- Labels: stale-major (was: ) > KafkaException: Received exception when fetching the next rec

[jira] [Commented] (FLINK-16119) Port base RelNode classes from Scala to Java

[ https://issues.apache.org/jira/browse/FLINK-16119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328042#comment-17328042 ] Flink Jira Bot commented on FLINK-16119: This major issue is unassigned and itse

[jira] [Updated] (FLINK-19418) Inline PRIMARY KEY constraint should be invalid

[ https://issues.apache.org/jira/browse/FLINK-19418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf updated FLINK-19418: - Affects Version/s: 1.12.3 1.13.0 > Inline PRIMARY KEY constraint

[jira] [Updated] (FLINK-16112) KafkaDeserializationSchema#isEndOfStream is ill-defined

[ https://issues.apache.org/jira/browse/FLINK-16112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16112: --- Labels: stale-major (was: ) > KafkaDeserializationSchema#isEndOfStream is ill-defined > ---

[jira] [Updated] (FLINK-15861) Change TableEnvironmentImpl to StreamTableEnvironmentImpl in python blink batch mode

[ https://issues.apache.org/jira/browse/FLINK-15861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15861: --- Labels: stale-major (was: ) > Change TableEnvironmentImpl to StreamTableEnvironmentImpl in

[jira] [Updated] (FLINK-16028) hbase connector's 'connector.table-name' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16028: --- Labels: stale-major (was: ) > hbase connector's 'connector.table-name' property should be o

[jira] [Updated] (FLINK-16212) Describe how Flink is a unified batch/stream processing system in concepts documentation

[ https://issues.apache.org/jira/browse/FLINK-16212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16212: --- Labels: stale-major (was: ) > Describe how Flink is a unified batch/stream processing syste

[jira] [Updated] (FLINK-16023) jdbc connector's 'connector.table' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16023: --- Labels: stale-major (was: ) > jdbc connector's 'connector.table' property should be optiona

[jira] [Commented] (FLINK-16266) es6 & 7 table sql connector conflicts each other

[ https://issues.apache.org/jira/browse/FLINK-16266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328031#comment-17328031 ] Flink Jira Bot commented on FLINK-16266: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16009) Native support for the Variable-length and Zig-zag Variable-length integers

[ https://issues.apache.org/jira/browse/FLINK-16009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16009: --- Labels: stale-major (was: ) > Native support for the Variable-length and Zig-zag Variable-l

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328035#comment-17328035 ] Robert Metzger commented on FLINK-17274: This is a helpful observation: Maybe hi

[jira] [Updated] (FLINK-16174) Add a better tryYield() method to MailboxExecutor to return the lowest priority of the remaining mails

[ https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16174: --- Labels: stale-major (was: ) > Add a better tryYield() method to MailboxExecutor to return t

[jira] [Commented] (FLINK-15808) Upgrade Parquet to version 1.11.1

[ https://issues.apache.org/jira/browse/FLINK-15808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328073#comment-17328073 ] Flink Jira Bot commented on FLINK-15808: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16570) Difficulties to select correct metric with long name in dropdown of Flink UI task menu

[ https://issues.apache.org/jira/browse/FLINK-16570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327993#comment-17327993 ] Flink Jira Bot commented on FLINK-16570: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16719) flink-runtime-web install failure

[ https://issues.apache.org/jira/browse/FLINK-16719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327974#comment-17327974 ] Flink Jira Bot commented on FLINK-16719: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16315) throw JsonMappingException when using BatchTableEnvironment#explain to get the plan of sql with constant string

[ https://issues.apache.org/jira/browse/FLINK-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16315: --- Labels: stale-major (was: ) > throw JsonMappingException when using BatchTableEnvironment#e

[jira] [Commented] (FLINK-16502) Add documentation for all JSON function

[ https://issues.apache.org/jira/browse/FLINK-16502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328002#comment-17328002 ] Flink Jira Bot commented on FLINK-16502: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15944) Resolve the potential class conflict proplem when depend both planners

[ https://issues.apache.org/jira/browse/FLINK-15944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15944: --- Labels: stale-major (was: ) > Resolve the potential class conflict proplem when depend both

[jira] [Updated] (FLINK-16099) Translate "HiveCatalog" page of "Hive Integration" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16099: --- Labels: pull-request-available stale-major (was: pull-request-available) > Translate "HiveC

[jira] [Commented] (FLINK-15951) Travis build fails on npm install

[ https://issues.apache.org/jira/browse/FLINK-15951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328056#comment-17328056 ] Flink Jira Bot commented on FLINK-15951: This major issue is unassigned and itse

[jira] [Commented] (FLINK-16174) Add a better tryYield() method to MailboxExecutor to return the lowest priority of the remaining mails

[ https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328040#comment-17328040 ] Flink Jira Bot commented on FLINK-16174: This major issue is unassigned and itse

[jira] [Commented] (FLINK-15752) Backpressure stats sometimes broken in WebUI

[ https://issues.apache.org/jira/browse/FLINK-15752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328084#comment-17328084 ] Flink Jira Bot commented on FLINK-15752: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15987) SELECT 1.0e0 / 0.0e0 throws NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-15987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15987: --- Labels: stale-major (was: ) > SELECT 1.0e0 / 0.0e0 throws NumberFormatException > -

[jira] [Updated] (FLINK-15775) SourceFunctions are instantiated twice when pulled on from 2 Sinks

[ https://issues.apache.org/jira/browse/FLINK-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15775: --- Labels: stale-major (was: ) > SourceFunctions are instantiated twice when pulled on from 2

[jira] [Commented] (FLINK-15987) SELECT 1.0e0 / 0.0e0 throws NumberFormatException

[ https://issues.apache.org/jira/browse/FLINK-15987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328054#comment-17328054 ] Flink Jira Bot commented on FLINK-15987: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15798) Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id= -Dexecution.attached=true fails with exception

[ https://issues.apache.org/jira/browse/FLINK-15798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15798: --- Labels: stale-major (was: ) > Running ./bin/kubernetes-session.sh -Dkubernetes.cluster-id=

[jira] [Commented] (FLINK-16003) ShardConsumer errors cannot be logged

[ https://issues.apache.org/jira/browse/FLINK-16003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328053#comment-17328053 ] Flink Jira Bot commented on FLINK-16003: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16027: --- Labels: stale-major (was: ) > kafka connector's 'connector.topic' property should be option

[jira] [Commented] (FLINK-15848) Support both fixed allocator and dynamic allocator in flink

[ https://issues.apache.org/jira/browse/FLINK-15848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328070#comment-17328070 ] Flink Jira Bot commented on FLINK-15848: This major issue is unassigned and itse

[jira] [Commented] (FLINK-18158) Add a utility to create a DDL statement from avro schema

[ https://issues.apache.org/jira/browse/FLINK-18158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327797#comment-17327797 ] Flink Jira Bot commented on FLINK-18158: This major issue is unassigned and itse

[jira] [Commented] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328071#comment-17328071 ] Flink Jira Bot commented on FLINK-15826: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15766) Provide developer documentation for statefun project

[ https://issues.apache.org/jira/browse/FLINK-15766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15766: --- Labels: stale-major (was: ) > Provide developer documentation for statefun project > --

[jira] [Commented] (FLINK-15923) Remove DISCARDED in TaskAcknowledgeResult

[ https://issues.apache.org/jira/browse/FLINK-15923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328063#comment-17328063 ] Flink Jira Bot commented on FLINK-15923: This major issue is unassigned and itse

[jira] [Updated] (FLINK-16003) ShardConsumer errors cannot be logged

[ https://issues.apache.org/jira/browse/FLINK-16003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16003: --- Labels: stale-major (was: ) > ShardConsumer errors cannot be logged > -

[jira] [Commented] (FLINK-15718) Update StatefulJobSavepointMigrationITCase to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328093#comment-17328093 ] Flink Jira Bot commented on FLINK-15718: This major issue is unassigned and itse

[jira] [Commented] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

[ https://issues.apache.org/jira/browse/FLINK-17295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327896#comment-17327896 ] Flink Jira Bot commented on FLINK-17295: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15720) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint

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

[jira] [Commented] (FLINK-15906) physical memory exceeded causing being killed by yarn

[ https://issues.apache.org/jira/browse/FLINK-15906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328066#comment-17328066 ] Flink Jira Bot commented on FLINK-15906: This major issue is unassigned and itse

[jira] [Commented] (FLINK-19828) Allow loading multiple configuration files

[ https://issues.apache.org/jira/browse/FLINK-19828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327584#comment-17327584 ] Flink Jira Bot commented on FLINK-19828: This major issue is unassigned and itse

[jira] [Commented] (FLINK-15720) Update StatefulJobWBroadcastStateMigrationITCase.scala to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328092#comment-17328092 ] Flink Jira Bot commented on FLINK-15720: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15712) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint

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

[jira] [Commented] (FLINK-15712) Update FlinkKafkaConsumerBaseMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328099#comment-17328099 ] Flink Jira Bot commented on FLINK-15712: This major issue is unassigned and itse

[jira] [Commented] (FLINK-15717) Update StatefulJobSavepointMigrationITCase.scala to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328094#comment-17328094 ] Flink Jira Bot commented on FLINK-15717: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15725) Update FlinkKinesisConsumerMigrationTest to restore from 1.10 savepoint

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

[jira] [Commented] (FLINK-15934) RocksDB rocksdb_delete_helper return false

[ https://issues.apache.org/jira/browse/FLINK-15934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328059#comment-17328059 ] Flink Jira Bot commented on FLINK-15934: This major issue is unassigned and itse

[jira] [Updated] (FLINK-19016) Checksum mismatch when restore from RocksDB

[ https://issues.apache.org/jira/browse/FLINK-19016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-19016: --- Affects Version/s: 1.13.1 1.13.0 1.12.2 > Checksum mis

[jira] [Commented] (FLINK-15944) Resolve the potential class conflict proplem when depend both planners

[ https://issues.apache.org/jira/browse/FLINK-15944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328057#comment-17328057 ] Flink Jira Bot commented on FLINK-15944: This major issue is unassigned and itse

[jira] [Updated] (FLINK-19871) add hash(primary key) sink partitioner for writing records to Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-19871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-19871: --- Labels: stale-major (was: ) > add hash(primary key) sink partitioner for writing records to

[jira] [Commented] (FLINK-15715) Update ContinuousFileProcessingMigrationTest to restore from 1.10 savepoint

[ https://issues.apache.org/jira/browse/FLINK-15715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328096#comment-17328096 ] Flink Jira Bot commented on FLINK-15715: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15663) Kerberos Support in Kubernetes mode

[ https://issues.apache.org/jira/browse/FLINK-15663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15663: --- Labels: stale-major (was: ) > Kerberos Support in Kubernetes mode > ---

[jira] [Commented] (FLINK-19860) Consider skipping restart and traverse regions which are already being restarted in RestartPipelinedRegionFailoverStrategy

[ https://issues.apache.org/jira/browse/FLINK-19860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327582#comment-17327582 ] Flink Jira Bot commented on FLINK-19860: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15826) Add renameFunction() to Catalog

[ https://issues.apache.org/jira/browse/FLINK-15826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15826: --- Labels: stale-major (was: ) > Add renameFunction() to Catalog > ---

[jira] [Updated] (FLINK-15709) Update CEPMigrationTest to restore from 1.10 savepoint

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

[jira] [Commented] (FLINK-15865) When to add .uid() call: inconsistent definition of operators in Flink docs

[ https://issues.apache.org/jira/browse/FLINK-15865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17328067#comment-17328067 ] Flink Jira Bot commented on FLINK-15865: This major issue is unassigned and itse

[jira] [Updated] (FLINK-15865) When to add .uid() call: inconsistent definition of operators in Flink docs

[ https://issues.apache.org/jira/browse/FLINK-15865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-15865: --- Labels: stale-major (was: ) > When to add .uid() call: inconsistent definition of operators

  1   2   3   4   5   6   7   8   9   10   >