[jira] [Updated] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9798: -- Labels: auto-unassigned (was: stale-assigned) > Drop canEqual() from TypeInformation,

[jira] [Commented] (FLINK-10667) Clean up Scala 2.10 remnants

[ https://issues.apache.org/jira/browse/FLINK-10667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334078#comment-17334078 ] Flink Jira Bot commented on FLINK-10667: This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-7392) Enable more predicate push-down in joins

[ https://issues.apache.org/jira/browse/FLINK-7392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7392: -- Labels: auto-unassigned (was: stale-assigned) > Enable more predicate push-down in joins >

[jira] [Assigned] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9718: - Assignee: (was: Jeff Zhang) > Add enviroment variable in start-scala-shell.sh &

[jira] [Assigned] (FLINK-11198) Access to MetricGroup in an AggregateFunction(Non Rich)

[ https://issues.apache.org/jira/browse/FLINK-11198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11198: -- Assignee: (was: Hequn Cheng) > Access to MetricGroup in an AggregateFunction(Non

[jira] [Commented] (FLINK-10258) Allow streaming sources to be present for batch executions

[ https://issues.apache.org/jira/browse/FLINK-10258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334096#comment-17334096 ] Flink Jira Bot commented on FLINK-10258: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-7144) Optimize multiple LogicalAggregate into one

[ https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334246#comment-17334246 ] Flink Jira Bot commented on FLINK-7144: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-8039) Add a type SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-8039?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334218#comment-17334218 ] Flink Jira Bot commented on FLINK-8039: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-7144) Optimize multiple LogicalAggregate into one

[ https://issues.apache.org/jira/browse/FLINK-7144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7144: - Assignee: (was: Rong Rong) > Optimize multiple LogicalAggregate into one >

[jira] [Assigned] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11102: -- Assignee: (was: boshu Zheng) > Enable check for previous data in

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

[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7957: -- Labels: auto-unassigned (was: stale-assigned) > Add MetricGroup#getLogicalScope >

[jira] [Commented] (FLINK-7403) Remove expandLocalRef() before code generation

[ https://issues.apache.org/jira/browse/FLINK-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334234#comment-17334234 ] Flink Jira Bot commented on FLINK-7403: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-10673) Table API / SQL UIDs not the only one

[ https://issues.apache.org/jira/browse/FLINK-10673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-10673: -- Assignee: (was: TANG Wen-hui) > Table API / SQL UIDs not the only one >

[jira] [Commented] (FLINK-9453) Flink 1.5 incorrectly shows statistics in web UI

[ https://issues.apache.org/jira/browse/FLINK-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334169#comment-17334169 ] Flink Jira Bot commented on FLINK-9453: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8518: - Assignee: (was: Sergey Nuyanzin) > Support DOW, EPOCH, DECADE for EXTRACT >

[jira] [Assigned] (FLINK-9391) Support UNNEST in Table API

[ https://issues.apache.org/jira/browse/FLINK-9391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9391: - Assignee: (was: Alina Ipatina) > Support UNNEST in Table API >

[jira] [Commented] (FLINK-11209) Provide more complete guidance for the log usage documentation

[ https://issues.apache.org/jira/browse/FLINK-11209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334049#comment-17334049 ] Flink Jira Bot commented on FLINK-11209: This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

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

[jira] [Commented] (FLINK-8483) Implement and expose outer joins

[ https://issues.apache.org/jira/browse/FLINK-8483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334206#comment-17334206 ] Flink Jira Bot commented on FLINK-8483: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

[ https://issues.apache.org/jira/browse/FLINK-9278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9278: -- Labels: auto-unassigned (was: stale-assigned) > Allow restore savepoint with some SQL queries

[jira] [Assigned] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9505: - Assignee: (was: Yazdan Shirvany) > End-to-end test: Flink-Example module

[jira] [Assigned] (FLINK-11470) LocalEnvironment doesn't call FileSystem.initialize()

[ https://issues.apache.org/jira/browse/FLINK-11470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11470: -- Assignee: (was: vinoyang) > LocalEnvironment doesn't call

[jira] [Commented] (FLINK-10846) Add support for IS DISTINCT FROM in code generator

[ https://issues.apache.org/jira/browse/FLINK-10846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334071#comment-17334071 ] Flink Jira Bot commented on FLINK-10846: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (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 reassigned FLINK-10203: -- Assignee: (was: Artsem Semianenka) > Support truncate method for old Hadoop

[jira] [Assigned] (FLINK-9399) TPCHQuery3 example fails due to Serialization issues

[ https://issues.apache.org/jira/browse/FLINK-9399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9399: - Assignee: (was: Timo Walther) > TPCHQuery3 example fails due to Serialization

[jira] [Commented] (FLINK-10008) Improve the LOG function in Table to support bases less than 1

[ https://issues.apache.org/jira/browse/FLINK-10008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334124#comment-17334124 ] Flink Jira Bot commented on FLINK-10008: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-8039) Add a type SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-8039?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8039: - Assignee: (was: Shuyi Chen) > Add a type SQL DDL > -- > >

[jira] [Commented] (FLINK-10119) JsonRowDeserializationSchema deserialize kafka message

[ https://issues.apache.org/jira/browse/FLINK-10119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334117#comment-17334117 ] Flink Jira Bot commented on FLINK-10119: This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-9604) Support KafkaProtoBufTableSource

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

[jira] [Assigned] (FLINK-9740) Support group windows over intervals of months

[ https://issues.apache.org/jira/browse/FLINK-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9740: - Assignee: (was: Renjie Liu) > Support group windows over intervals of months >

[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 (was: stale-assigned) > Allow for assemblePartPath override in the

[jira] [Commented] (FLINK-8686) Improve basic embedded SQL client

[ https://issues.apache.org/jira/browse/FLINK-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334199#comment-17334199 ] Flink Jira Bot commented on FLINK-8686: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-9607) Support ParquetTableSink

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

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

[ https://issues.apache.org/jira/browse/FLINK-7957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334221#comment-17334221 ] Flink Jira Bot commented on FLINK-7957: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-9529) Do not expose keyed operations on ProcessFunction.Context

[ https://issues.apache.org/jira/browse/FLINK-9529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334161#comment-17334161 ] Flink Jira Bot commented on FLINK-9529: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (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 reassigned FLINK-10162: -- Assignee: (was: xymaqingxiang) > Add host in checkpoint detail >

[jira] [Updated] (FLINK-9864) Make timestamp extraction more flexible in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-9864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9864: -- Labels: auto-unassigned (was: stale-assigned) > Make timestamp extraction more flexible in

[jira] [Assigned] (FLINK-10489) Inconsistent window information for streams with EventTime characteristic

[ https://issues.apache.org/jira/browse/FLINK-10489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-10489: -- Assignee: (was: TANG Wen-hui) > Inconsistent window information for streams with

[jira] [Assigned] (FLINK-9625) Enrich the error information to user

[ https://issues.apache.org/jira/browse/FLINK-9625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9625: - Assignee: (was: zhangminglei) > Enrich the error information to user >

[jira] [Updated] (FLINK-10518) Inefficient design in ContinuousFileMonitoringFunction

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

[jira] [Updated] (FLINK-9205) Delete non-well-defined SinkFunctions

[ https://issues.apache.org/jira/browse/FLINK-9205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9205: -- Labels: auto-unassigned (was: stale-assigned) > Delete non-well-defined SinkFunctions >

[jira] [Assigned] (FLINK-8606) Clean up Table API for Java users

[ https://issues.apache.org/jira/browse/FLINK-8606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8606: - Assignee: (was: Timo Walther) > Clean up Table API for Java users >

[jira] [Updated] (FLINK-10553) Unified sink and source table name in SQL statement

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

[jira] [Commented] (FLINK-9078) End-to-end test: Add test that verifies that a specific classloading issue with avro is fixed

[ https://issues.apache.org/jira/browse/FLINK-9078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334192#comment-17334192 ] Flink Jira Bot commented on FLINK-9078: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334069#comment-17334069 ] Flink Jira Bot commented on FLINK-10855: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8954: - Assignee: (was: Dmitry Amosov) > Escape control characters when outputting on SQL

[jira] [Commented] (FLINK-12520) Support to provide fully-qualified domain host name in TaskManagerMetricGroup

[ https://issues.apache.org/jira/browse/FLINK-12520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17333932#comment-17333932 ] Flink Jira Bot commented on FLINK-12520: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-11407) Allow providing reason messages for TypeSerializerSchemaCompatibility.incompatible()

[ https://issues.apache.org/jira/browse/FLINK-11407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11407: -- Assignee: (was: Tzu-Li (Gordon) Tai) > Allow providing reason messages for >

[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 (was: pull-request-available

[jira] [Assigned] (FLINK-9854) Allow passing multi-line input to SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-9854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9854: - Assignee: (was: vinoyang) > Allow passing multi-line input to SQL Client CLI >

[jira] [Commented] (FLINK-9609) Add bucket ready mechanism for BucketingSink when checkpoint complete

[ https://issues.apache.org/jira/browse/FLINK-9609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334150#comment-17334150 ] Flink Jira Bot commented on FLINK-9609: --- This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-11188) Bounded over should not enable state retention time

[ https://issues.apache.org/jira/browse/FLINK-11188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334052#comment-17334052 ] Flink Jira Bot commented on FLINK-11188: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-8482) Implement and expose option to use min / max / left / right timestamp for joined streamrecords

[ https://issues.apache.org/jira/browse/FLINK-8482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334207#comment-17334207 ] Flink Jira Bot commented on FLINK-8482: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

[ https://issues.apache.org/jira/browse/FLINK-9774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9774: - Assignee: (was: vinoyang) > Allow to pass a string-based cluster identifier to

[jira] [Assigned] (FLINK-11210) Enable auto state cleanup strategy for RANGE OVER

[ https://issues.apache.org/jira/browse/FLINK-11210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11210: -- Assignee: (was: Hequn Cheng) > Enable auto state cleanup strategy for RANGE OVER

[jira] [Updated] (FLINK-9505) End-to-end test: Flink-Example module [flink-examples-streaming]

[ https://issues.apache.org/jira/browse/FLINK-9505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9505: -- Labels: auto-unassigned (was: stale-assigned) > End-to-end test: Flink-Example module

[jira] [Commented] (FLINK-11139) stream non window join support state ttl

[ https://issues.apache.org/jira/browse/FLINK-11139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334060#comment-17334060 ] Flink Jira Bot commented on FLINK-11139: This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10806: --- Labels: auto-unassigned (was: stale-assigned) > Support multiple consuming offsets when

[jira] [Updated] (FLINK-10230) Support printing 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 (was: pull-request-available

[jira] [Updated] (FLINK-10978) Add FlatAggregate operator to batch Table API

[ https://issues.apache.org/jira/browse/FLINK-10978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10978: --- Labels: auto-unassigned (was: stale-assigned) > Add FlatAggregate operator to batch Table

[jira] [Commented] (FLINK-9718) Add enviroment variable in start-scala-shell.sh & flink to enable remote debug

[ https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334140#comment-17334140 ] Flink Jira Bot commented on FLINK-9718: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-10002) WebUI shows logs unfriendly, especially when the amount of logs is large

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

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334034#comment-17334034 ] Flink Jira Bot commented on FLINK-11374: This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-11372) Incorrect delegation of compatibility checks to new snapshots in CollectionSerializerConfigSnapshot

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

[jira] [Updated] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

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

[jira] [Commented] (FLINK-11421) Add compilation options to allow compiling generated code with JDK compiler

[ https://issues.apache.org/jira/browse/FLINK-11421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334029#comment-17334029 ] Flink Jira Bot commented on FLINK-11421: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-11481) Integrate HiveTableFactory with existing table factory discovery mechanism

[ https://issues.apache.org/jira/browse/FLINK-11481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334022#comment-17334022 ] Flink Jira Bot commented on FLINK-11481: This issue was marked "stale-assigned" and has not

[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 (was: stale-assigned) > Time indicators are not always

[jira] [Assigned] (FLINK-11258) Add badge to the README

[ https://issues.apache.org/jira/browse/FLINK-11258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11258: -- Assignee: (was: Fokko Driesprong) > Add badge to the README >

[jira] [Updated] (FLINK-9036) Add default value via suppliers

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

[jira] [Updated] (FLINK-9854) Allow passing multi-line input to SQL Client CLI

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

[jira] [Updated] (FLINK-9195) Delete non-well-defined output methods on DataStream

[ https://issues.apache.org/jira/browse/FLINK-9195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9195: -- Labels: auto-unassigned (was: stale-assigned) > Delete non-well-defined output methods on

[jira] [Updated] (FLINK-8954) Escape control characters when outputting on SQL Client CLI

[ https://issues.apache.org/jira/browse/FLINK-8954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-8954: -- Labels: auto-unassigned (was: stale-assigned) > Escape control characters when outputting on

[jira] [Commented] (FLINK-10017) Support keyed formats for Kafka table source sink factory

[ https://issues.apache.org/jira/browse/FLINK-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334123#comment-17334123 ] Flink Jira Bot commented on FLINK-10017: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-9870) Support field mapping and time attributes for table sinks

[ https://issues.apache.org/jira/browse/FLINK-9870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9870: - Assignee: (was: Timo Walther) > Support field mapping and time attributes for table

[jira] [Commented] (FLINK-11381) JOIN LATERAL with a table was not support

[ https://issues.apache.org/jira/browse/FLINK-11381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334033#comment-17334033 ] Flink Jira Bot commented on FLINK-11381: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-10143) date_format throws CodeGenException

[ https://issues.apache.org/jira/browse/FLINK-10143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-10143: -- Assignee: (was: TANG Wen-hui) > date_format throws CodeGenException >

[jira] [Commented] (FLINK-9798) Drop canEqual() from TypeInformation, TypeSerializer, etc.

[ https://issues.apache.org/jira/browse/FLINK-9798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334136#comment-17334136 ] Flink Jira Bot commented on FLINK-9798: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-10294) Split MiniClusterResource to be usable in runtime/streaming-java/clients

[ https://issues.apache.org/jira/browse/FLINK-10294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10294: --- Labels: auto-unassigned (was: stale-assigned) > Split MiniClusterResource to be usable in

[jira] [Assigned] (FLINK-10277) Add AppendStreamTableSink and UpsertStreamTableSink

[ https://issues.apache.org/jira/browse/FLINK-10277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-10277: -- Assignee: (was: Shimin Yang) > Add AppendStreamTableSink and

[jira] [Updated] (FLINK-10576) Introduce Machine/Node/TM health management

[ https://issues.apache.org/jira/browse/FLINK-10576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10576: --- Labels: auto-unassigned (was: stale-assigned) > Introduce Machine/Node/TM health

[jira] [Updated] (FLINK-10274) The stop-cluster.sh cannot stop cluster properly when there are multiple clusters running

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

[jira] [Assigned] (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 reassigned FLINK-10171: -- Assignee: (was: Lakshmi Rao) > Allow for assemblePartPath override in the

[jira] [Updated] (FLINK-10356) Add sanity checks to SpillingAdaptiveSpanningRecordDeserializer

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

[jira] [Assigned] (FLINK-11448) Clean-up and prepare Table API to be uncoupled from table core

[ https://issues.apache.org/jira/browse/FLINK-11448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11448: -- Assignee: (was: sunjincheng) > Clean-up and prepare Table API to be uncoupled

[jira] [Commented] (FLINK-9507) Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

[ https://issues.apache.org/jira/browse/FLINK-9507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334163#comment-17334163 ] Flink Jira Bot commented on FLINK-9507: --- This issue was marked "stale-assigned" and has not

[jira] [Updated] (FLINK-9896) Fix flink documentation error

[ https://issues.apache.org/jira/browse/FLINK-9896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9896: -- Labels: auto-unassigned (was: stale-assigned) > Fix flink documentation error >

[jira] [Assigned] (FLINK-9431) Introduce TimeEnd State to flink cep

[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9431: - Assignee: (was: Aitozi) > Introduce TimeEnd State to flink cep >

[jira] [Assigned] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API

[ https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11052: -- Assignee: (was: Hequn Cheng) > Add Bounded(Group Window) FlatAggregate operator

[jira] [Updated] (FLINK-10152) Add reverse supported in TableAPI and SQL

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

[jira] [Commented] (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:comment-tabpanel=17334103#comment-17334103 ] Flink Jira Bot commented on FLINK-10203: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-9431) Introduce TimeEnd State to flink cep

[ https://issues.apache.org/jira/browse/FLINK-9431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334171#comment-17334171 ] Flink Jira Bot commented on FLINK-9431: --- This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-11425) Support of “Hash Teams” in Hybrid Hash Join

[ https://issues.apache.org/jira/browse/FLINK-11425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11425: -- Assignee: (was: Ji Liu) > Support of “Hash Teams” in Hybrid Hash Join >

[jira] [Commented] (FLINK-10873) Remove tableEnv in DataSetConversions#toTable and DataStreamConversions#toTable

[ https://issues.apache.org/jira/browse/FLINK-10873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334068#comment-17334068 ] Flink Jira Bot commented on FLINK-10873: This issue was marked "stale-assigned" and has not

[jira] [Assigned] (FLINK-11060) Unable to set number of task manager and slot per task manager in scala shell local mode

[ https://issues.apache.org/jira/browse/FLINK-11060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11060: -- Assignee: (was: Jeff Zhang) > Unable to set number of task manager and slot per

[jira] [Updated] (FLINK-11639) Provide readSequenceFile for Hadoop new API

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

[jira] [Updated] (FLINK-11407) Allow providing reason messages for TypeSerializerSchemaCompatibility.incompatible()

[ https://issues.apache.org/jira/browse/FLINK-11407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11407: --- Labels: auto-unassigned (was: stale-assigned) > Allow providing reason messages for >

[jira] [Updated] (FLINK-10448) VALUES clause is translated into a separate operator per value

[ https://issues.apache.org/jira/browse/FLINK-10448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10448: --- Labels: auto-unassigned (was: stale-assigned) > VALUES clause is translated into a

[jira] [Commented] (FLINK-11276) Sliding Window Optimization

[ https://issues.apache.org/jira/browse/FLINK-11276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334040#comment-17334040 ] Flink Jira Bot commented on FLINK-11276: This issue was marked "stale-assigned" and has not

[jira] [Commented] (FLINK-10049) Correctly handle NULL arguments in SQL built-in functions

[ https://issues.apache.org/jira/browse/FLINK-10049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334119#comment-17334119 ] Flink Jira Bot commented on FLINK-10049: This issue was marked "stale-assigned" and has not

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