[jira] [Commented] (FLINK-6477) The first time to click Taskmanager cannot get the actual data

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

[jira] [Updated] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

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

[jira] [Commented] (FLINK-5178) allow BlobCache to use a distributed file system irrespective of the HA mode

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

[jira] [Assigned] (FLINK-7607) Web Frontend Hangs with Large Numbers of Tasks

[ https://issues.apache.org/jira/browse/FLINK-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7607: - Assignee: (was: Steven Langbroek) > Web Frontend Hangs with Large Numbers of Tasks

[jira] [Updated] (FLINK-4648) Implement bipartite graph generators

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

[jira] [Updated] (FLINK-4966) BetweennessCentrality

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

[jira] [Commented] (FLINK-9161) Support STRUCT syntax to create named STRUCT in SQL

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

[jira] [Commented] (FLINK-7342) Add support for Regular Expression Operators (RLIKE)

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

[jira] [Assigned] (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:all-tabpanel ] Flink Jira Bot reassigned FLINK-10049: -- Assignee: (was: vinoyang) > Correctly handle NULL arguments in SQL built-in

[jira] [Commented] (FLINK-8953) Resolve unresolved field references in FieldComputer expressions

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

[jira] [Assigned] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-6857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6857: - Assignee: (was: zhangminglei) > Add global default Kryo serializer configuration to

[jira] [Updated] (FLINK-8536) Improve CSVTableSourceFactory to support all descriptor properties

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

[jira] [Updated] (FLINK-2186) Rework CSV import to support very wide files

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

[jira] [Commented] (FLINK-8435) Adding BloomFilter/HyperLogLog state as Managed once

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

[jira] [Commented] (FLINK-1913) Document how to access data in HCatalog

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

[jira] [Assigned] (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:all-tabpanel ] Flink Jira Bot reassigned FLINK-10008: -- Assignee: (was: Ruidong Li) > Improve the LOG function in Table to support bases

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

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

[jira] [Updated] (FLINK-5177) Improve nullability handling

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

[jira] [Assigned] (FLINK-6976) Add STR_TO_DATE supported in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-6976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6976: - Assignee: (was: Zhanchun Zhang) > Add STR_TO_DATE supported in TableAPI >

[jira] [Assigned] (FLINK-7373) Using URLClassLoader to load UDF triggers HepPlanner unexpected ClassNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-7373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7373: - Assignee: (was: Rong Rong) > Using URLClassLoader to load UDF triggers HepPlanner

[jira] [Updated] (FLINK-7360) Support Scala map type in Table API

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

[jira] [Updated] (FLINK-20374) Wrong result when shuffling changelog stream on non-primary-key columns

[ https://issues.apache.org/jira/browse/FLINK-20374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20374: --- Labels: stale-critical (was: ) > Wrong result when shuffling changelog stream on

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

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

[jira] [Assigned] (FLINK-1913) Document how to access data in HCatalog

[ https://issues.apache.org/jira/browse/FLINK-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-1913: - Assignee: (was: Zhenqiu Huang) > Document how to access data in HCatalog >

[jira] [Commented] (FLINK-9247) Allow creating table sources/sinks from an Avro schema

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

[jira] [Assigned] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

[ https://issues.apache.org/jira/browse/FLINK-9294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9294: - Assignee: (was: Rong Rong) > Improve type inference for UDFs with composite

[jira] [Assigned] (FLINK-9673) Improve State efficiency of bounded OVER window operators

[ https://issues.apache.org/jira/browse/FLINK-9673?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9673: - Assignee: (was: vinoyang) > Improve State efficiency of bounded OVER window

[jira] [Assigned] (FLINK-5078) Introduce annotations for classes copied from Calcite

[ https://issues.apache.org/jira/browse/FLINK-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-5078: - Assignee: (was: Timo Walther) > Introduce annotations for classes copied from

[jira] [Assigned] (FLINK-6081) Offset/Fetch support for SQL Streaming

[ https://issues.apache.org/jira/browse/FLINK-6081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6081: - Assignee: (was: radu) > Offset/Fetch support for SQL Streaming >

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

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-6757: - Assignee: (was: Márton Balassi) > Investigate Apache Atlas integration >

[jira] [Commented] (FLINK-22365) Images are not displayed in "Data Sources" documentation page

[ https://issues.apache.org/jira/browse/FLINK-22365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334359#comment-17334359 ] Flink Jira Bot commented on FLINK-22365: This critical issue is unassigned and itself and all of

[jira] [Updated] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

[ https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9334: -- Labels: auto-unassigned (was: stale-assigned) > Docs to have a code snippet of Kafka

[jira] [Commented] (FLINK-10594) Support SUBSETS

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

[jira] [Commented] (FLINK-21948) Show Watermarks in Human Friendly Format in the Web User Interface

[ https://issues.apache.org/jira/browse/FLINK-21948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334344#comment-17334344 ] Flink Jira Bot commented on FLINK-21948: This major issue is unassigned and itself and all of

[jira] [Commented] (FLINK-8920) Split code generated input unboxing code

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

[jira] [Commented] (FLINK-21539) 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails during download

[ https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334348#comment-17334348 ] Flink Jira Bot commented on FLINK-21539: This major issue is unassigned and itself and all of

[jira] [Commented] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

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

[jira] [Assigned] (FLINK-8986) End-to-end test: REST

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

[jira] [Commented] (FLINK-9170) HCatolog integration with Table/SQL API

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

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

[ https://issues.apache.org/jira/browse/FLINK-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7403: - Assignee: (was: Hequn Cheng) > Remove expandLocalRef() before code generation >

[jira] [Commented] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

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

[jira] [Commented] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17334352#comment-17334352 ] Flink Jira Bot commented on FLINK-20696: This major issue is unassigned and itself and all of

[jira] [Assigned] (FLINK-7946) Add an option to truncate IDs to 8 characters

[ https://issues.apache.org/jira/browse/FLINK-7946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7946: - Assignee: (was: Chesnay Schepler) > Add an option to truncate IDs to 8 characters >

[jira] [Updated] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

[ https://issues.apache.org/jira/browse/FLINK-4004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-4004: -- Labels: auto-unassigned (was: stale-assigned) > Do not pass custom flink kafka connector

[jira] [Updated] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

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

[jira] [Updated] (FLINK-5325) Introduce interface for CloseableRegistry to separate user from system-facing functionality

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

[jira] [Updated] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

[ https://issues.apache.org/jira/browse/FLINK-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-5127: -- Labels: auto-unassigned (was: stale-assigned) > Reduce the amount of intermediate data in

[jira] [Commented] (FLINK-12590) Replace http links in documentation

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

[jira] [Updated] (FLINK-10040) Decompose RocksDBKeyedStateBackend

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

[jira] [Assigned] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-9556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9556: - Assignee: (was: Timo Walther) > Scala TypeAnalyzer does not consider

[jira] [Assigned] (FLINK-8436) Allow implementing both RetractTableSink and BatchTableSink in one class

[ https://issues.apache.org/jira/browse/FLINK-8436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8436: - Assignee: (was: Timo Walther) > Allow implementing both RetractTableSink and

[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 ] Flink Jira Bot updated FLINK-8513: -- Labels: auto-unassigned (was: stale-assigned) > Add documentation for connecting to non-AWS

[jira] [Commented] (FLINK-7545) Support MEMBER OF Operator for Multiset SQL type

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

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

[ https://issues.apache.org/jira/browse/FLINK-10200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-10200: -- Assignee: (was: Stefan Richter) > Consolidate FileBasedStateOutputStream and

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

[ https://issues.apache.org/jira/browse/FLINK-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7697: - Assignee: (was: xueyu) > Add metrics for Elasticsearch Sink >

[jira] [Commented] (FLINK-5127) Reduce the amount of intermediate data in vertex-centric iterations

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

[jira] [Updated] (FLINK-6969) Add support for deferred computation for group window aggregates

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

[jira] [Commented] (FLINK-11818) Provide pipe transformation function for DataSet API

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

[jira] [Updated] (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 updated FLINK-9391: -- Labels: auto-unassigned (was: stale-assigned) > Support UNNEST in Table API >

[jira] [Updated] (FLINK-6424) Add basic helper functions for map type

[ https://issues.apache.org/jira/browse/FLINK-6424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-6424: -- Labels: auto-unassigned (was: stale-assigned) > Add basic helper functions for map type >

[jira] [Commented] (FLINK-9535) log4j.properties specified in env.java.options doesn't get picked.

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

[jira] [Assigned] (FLINK-4498) Better Cassandra sink documentation

[ https://issues.apache.org/jira/browse/FLINK-4498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-4498: - Assignee: (was: Michael Fong) > Better Cassandra sink documentation >

[jira] [Assigned] (FLINK-9157) Support Apache HCatalog in SQL client

[ https://issues.apache.org/jira/browse/FLINK-9157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9157: - Assignee: (was: Dmitrii Kober) > Support Apache HCatalog in SQL client >

[jira] [Updated] (FLINK-8474) Add documentation for HBaseTableSource

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

[jira] [Updated] (FLINK-9845) Make InternalTimerService's timer processing interruptible/abortable

[ https://issues.apache.org/jira/browse/FLINK-9845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-9845: -- Labels: auto-unassigned (was: stale-assigned) > Make InternalTimerService's timer processing

[jira] [Assigned] (FLINK-9334) Docs to have a code snippet of Kafka partition discovery

[ https://issues.apache.org/jira/browse/FLINK-9334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9334: - Assignee: (was: leesf) > Docs to have a code snippet of Kafka partition discovery >

[jira] [Updated] (FLINK-3473) Add partial aggregate support in Flink

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

[jira] [Updated] (FLINK-5104) Implement BipartiteGraph validator

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

[jira] [Updated] (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 updated FLINK-9399: -- Labels: auto-unassigned (was: stale-assigned) > TPCHQuery3 example fails due to Serialization

[jira] [Assigned] (FLINK-9114) Enable user-provided, custom CheckpointRecoveryFactory for non-HA deployments

[ https://issues.apache.org/jira/browse/FLINK-9114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9114: - Assignee: (was: Jacob Park) > Enable user-provided, custom

[jira] [Assigned] (FLINK-9239) Reintroduce example program in quickstarts

[ https://issues.apache.org/jira/browse/FLINK-9239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9239: - Assignee: (was: zhangminglei) > Reintroduce example program in quickstarts >

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

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

[jira] [Commented] (FLINK-7546) Support SUBMULTISET_OF Operator for Multiset SQL type

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

[jira] [Assigned] (FLINK-5089) Introduce Loop functions and Enforce Nesting on Data Streams

[ https://issues.apache.org/jira/browse/FLINK-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-5089: - Assignee: (was: Paris Carbone) > Introduce Loop functions and Enforce Nesting on

[jira] [Assigned] (FLINK-8387) Do not allow filter(false)

[ https://issues.apache.org/jira/browse/FLINK-8387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-8387: - Assignee: (was: Timo Walther) > Do not allow filter(false) >

[jira] [Updated] (FLINK-5242) Implement Scala API for BipartiteGraph

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

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20696: --- Labels: stale-major (was: ) > Yarn Session Blob Directory is not deleted. >

[jira] [Assigned] (FLINK-7275) Differentiate between normal and power-user cli options in Gelly examples

[ https://issues.apache.org/jira/browse/FLINK-7275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7275: - Assignee: (was: Greg Hogan) > Differentiate between normal and power-user cli

[jira] [Assigned] (FLINK-4705) Instrument FixedLengthRecordSorter

[ https://issues.apache.org/jira/browse/FLINK-4705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-4705: - Assignee: (was: Greg Hogan) > Instrument FixedLengthRecordSorter >

[jira] [Commented] (FLINK-3805) BloomFilter initialized with no memory available

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

[jira] [Assigned] (FLINK-7492) Memsql Connector

[ https://issues.apache.org/jira/browse/FLINK-7492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-7492: - Assignee: (was: Zhenqiu Huang) > Memsql Connector > > >

[jira] [Commented] (FLINK-9294) Improve type inference for UDFs with composite parameter or result type

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

[jira] [Assigned] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-11912: -- Assignee: (was: Shuyi Chen) > Expose per partition Kafka lag metric in Flink

[jira] [Updated] (FLINK-6976) Add STR_TO_DATE supported in TableAPI

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

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

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

[jira] [Assigned] (FLINK-9531) Improve logging during type extraction of the Row type

[ https://issues.apache.org/jira/browse/FLINK-9531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-9531: - Assignee: (was: Timo Walther) > Improve logging during type extraction of the Row

[jira] [Updated] (FLINK-3431) Add retrying logic for RocksDB snapshots

[ https://issues.apache.org/jira/browse/FLINK-3431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-3431: -- Labels: auto-unassigned (was: stale-assigned) > Add retrying logic for RocksDB snapshots >

[jira] [Commented] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

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

[jira] [Commented] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

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

[jira] [Updated] (FLINK-6857) Add global default Kryo serializer configuration to StreamExecutionEnvironment

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

[jira] [Updated] (FLINK-21467) Document possible recommended usage of Bounded{One/Multi}Input.endInput and emphasize that they could be called multiple times

[ https://issues.apache.org/jira/browse/FLINK-21467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21467: --- Labels: stale-major (was: ) > Document possible recommended usage of

[jira] [Updated] (FLINK-21539) 'SQL Client end-to-end test (Blink planner) Elasticsearch (v6.3.1)' fails during download

[ https://issues.apache.org/jira/browse/FLINK-21539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21539: --- Labels: stale-major test-stability (was: test-stability) > 'SQL Client end-to-end test

[jira] [Assigned] (FLINK-5105) Improve ReduceState: value put into ReducingState should always be a copy

[ https://issues.apache.org/jira/browse/FLINK-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-5105: - Assignee: (was: Fabian Hueske) > Improve ReduceState: value put into ReducingState

[jira] [Assigned] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

[ https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot reassigned FLINK-3850: - Assignee: (was: Nikolay Vasilishin) > Add forward field annotations to DataSet

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

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

[jira] [Updated] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

[ https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-7423: -- Labels: auto-unassigned (was: stale-assigned) > Always reuse an instance to get elements

[jira] [Commented] (FLINK-3857) Add reconnect attempt to Elasticsearch host

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

[jira] [Commented] (FLINK-3997) PRNG Skip-ahead

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

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

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

[jira] [Commented] (FLINK-7277) Weighted PageRank

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

<    1   2   3   4   5   6   7   8   9   10   >