[jira] [Created] (FLINK-12759) FLInk localmode IN MINICluster can't drow DAG visualizer plan

Wong created FLINK-12759: Summary: FLInk localmode IN MINICluster can't drow DAG visualizer plan Key: FLINK-12759 URL: https://issues.apache.org/jira/browse/FLINK-12759 Project: Flink Issue Type:

[jira] [Created] (FLINK-12758) Add flink-ml-lib module

Luo Gen created FLINK-12758: --- Summary: Add flink-ml-lib module Key: FLINK-12758 URL: https://issues.apache.org/jira/browse/FLINK-12758 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-12757) Improves the Python word_count example to use the descriptor API

Dian Fu created FLINK-12757: --- Summary: Improves the Python word_count example to use the descriptor API Key: FLINK-12757 URL: https://issues.apache.org/jira/browse/FLINK-12757 Project: Flink

[jira] [Created] (FLINK-12756) migrate HiveCatalog from TypeInformation-based old type system to DataType-based new type system

Bowen Li created FLINK-12756: Summary: migrate HiveCatalog from TypeInformation-based old type system to DataType-based new type system Key: FLINK-12756 URL: https://issues.apache.org/jira/browse/FLINK-12756

[jira] [Created] (FLINK-12755) implement HiveCatalog

Bowen Li created FLINK-12755: Summary: implement HiveCatalog Key: FLINK-12755 URL: https://issues.apache.org/jira/browse/FLINK-12755 Project: Flink Issue Type: New Feature Components:

[jira] [Created] (FLINK-12754) alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned

Bowen Li created FLINK-12754: Summary: alterTableColumnStatistics() in GenericInMemoryCatalog should ensure the table is non-partitioned Key: FLINK-12754 URL: https://issues.apache.org/jira/browse/FLINK-12754

[jira] [Created] (FLINK-12753) Implement GenericInMemoryCatalog

Bowen Li created FLINK-12753: Summary: Implement GenericInMemoryCatalog Key: FLINK-12753 URL: https://issues.apache.org/jira/browse/FLINK-12753 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12752) Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

Konstantin Knauf created FLINK-12752: Summary: Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint Key: FLINK-12752 URL: https://issues.apache.org/jira/browse/FLINK-12752

[jira] [Created] (FLINK-12751) Create file based HA support

Boris Lublinsky created FLINK-12751: --- Summary: Create file based HA support Key: FLINK-12751 URL: https://issues.apache.org/jira/browse/FLINK-12751 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12750) Gettting Started - Docker Playground - Interactive SQL Playground

Konstantin Knauf created FLINK-12750: Summary: Gettting Started - Docker Playground - Interactive SQL Playground Key: FLINK-12750 URL: https://issues.apache.org/jira/browse/FLINK-12750 Project:

[jira] [Created] (FLINK-12749) FLINK-12748 - Docker Playgrounds - Flink Cluster Playground

Konstantin Knauf created FLINK-12749: Summary: FLINK-12748 - Docker Playgrounds - Flink Cluster Playground Key: FLINK-12749 URL: https://issues.apache.org/jira/browse/FLINK-12749 Project: Flink

[jira] [Created] (FLINK-12748) Getting Started - Flink Overview

Konstantin Knauf created FLINK-12748: Summary: Getting Started - Flink Overview Key: FLINK-12748 URL: https://issues.apache.org/jira/browse/FLINK-12748 Project: Flink Issue Type:

[jira] [Created] (FLINK-12747) Getting Started - Table API Example Walkthrough

Konstantin Knauf created FLINK-12747: Summary: Getting Started - Table API Example Walkthrough Key: FLINK-12747 URL: https://issues.apache.org/jira/browse/FLINK-12747 Project: Flink

[jira] [Created] (FLINK-12746) Getting Started - Project Setup and DataStream Example Walkthrough

Konstantin Knauf created FLINK-12746: Summary: Getting Started - Project Setup and DataStream Example Walkthrough Key: FLINK-12746 URL: https://issues.apache.org/jira/browse/FLINK-12746 Project:

[jira] [Created] (FLINK-12745) Sparse and

Xu Yang created FLINK-12745: --- Summary: Sparse and Key: FLINK-12745 URL: https://issues.apache.org/jira/browse/FLINK-12745 Project: Flink Issue Type: Sub-task Reporter: Xu Yang

[jira] [Created] (FLINK-12744) ML common parameters

Xu Yang created FLINK-12744: --- Summary: ML common parameters Key: FLINK-12744 URL: https://issues.apache.org/jira/browse/FLINK-12744 Project: Flink Issue Type: Sub-task Reporter: Xu

[jira] [Created] (FLINK-12743) Introduce unbounded streaming anti/semi join operator

Jark Wu created FLINK-12743: --- Summary: Introduce unbounded streaming anti/semi join operator Key: FLINK-12743 URL: https://issues.apache.org/jira/browse/FLINK-12743 Project: Flink Issue Type: New

[jira] [Created] (FLINK-12742) Add insert into partition grammar as hive dialect

Danny Chan created FLINK-12742: -- Summary: Add insert into partition grammar as hive dialect Key: FLINK-12742 URL: https://issues.apache.org/jira/browse/FLINK-12742 Project: Flink Issue Type:

[jira] [Created] (FLINK-12741) Update docs about Kafka fault tolerant guarantees

Paul Lin created FLINK-12741: Summary: Update docs about Kafka fault tolerant guarantees Key: FLINK-12741 URL: https://issues.apache.org/jira/browse/FLINK-12741 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-33: Standardize connector metrics

Hi Becket, Thanks for the answer :) > By time-based metric, I meant the portion of time spent on producing the > record to downstream. For example, a source connector can report that it's > spending 80% of time to emit record to downstream processing pipeline. In > another case, a sink connector

[jira] [Created] (FLINK-12740) SpillableSubpartitionTest deadlocks on Travis

Chesnay Schepler created FLINK-12740: Summary: SpillableSubpartitionTest deadlocks on Travis Key: FLINK-12740 URL: https://issues.apache.org/jira/browse/FLINK-12740 Project: Flink Issue

[jira] [Created] (FLINK-12739) Flink does not build with scala 2.12

Chesnay Schepler created FLINK-12739: Summary: Flink does not build with scala 2.12 Key: FLINK-12739 URL: https://issues.apache.org/jira/browse/FLINK-12739 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12738) Remove abstract getPageSize from InputGate

zhijiang created FLINK-12738: Summary: Remove abstract getPageSize from InputGate Key: FLINK-12738 URL: https://issues.apache.org/jira/browse/FLINK-12738 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12737) Loosen Table dependencies

Dawid Wysakowicz created FLINK-12737: Summary: Loosen Table dependencies Key: FLINK-12737 URL: https://issues.apache.org/jira/browse/FLINK-12737 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Releasing Flink 1.8.1

I am here to quickly update the progress of the issue that needs to be tracked(going well): [Blocker] - FLINK-12296 [done] - FLINK-11987 [done] - FLINK-12297

Re: [DISCUSS] FLIP-41: Unify Keyed State Snapshot Binary Format for Savepoints

I want to quickly bump this discussion to gather more consensus from others on the FLIP, and see if we want to aim this for the upcoming 1.9.0 release. The proposal touches binary formats of savepoints, which is a major part of Flink's public user interface, so having explicit approval from other

[jira] [Created] (FLINK-12736) ResourceManager may release TM with allocated slots

Chesnay Schepler created FLINK-12736: Summary: ResourceManager may release TM with allocated slots Key: FLINK-12736 URL: https://issues.apache.org/jira/browse/FLINK-12736 Project: Flink

Re: [DISCUSS] Support Local Aggregation in Flink

Hi Aljoscha, What do you think about this feature and design document? Best, Vino vino yang 于2019年6月5日周三 下午4:18写道： > Hi Dian, > > I still think your implementation is similar to the window operator, you > mentioned the scalable trigger mechanism, the window API also can customize > trigger. >

Re: [DISCUSS] Support Local Aggregation in Flink

Hi Dian, I still think your implementation is similar to the window operator, you mentioned the scalable trigger mechanism, the window API also can customize trigger. Moreover, IMO, the design should guarantee a deterministic semantics, I think based on memory availability is a non-deterministic

[jira] [Created] (FLINK-12735) Make shuffle environment implementation independent with IOManager

zhijiang created FLINK-12735: Summary: Make shuffle environment implementation independent with IOManager Key: FLINK-12735 URL: https://issues.apache.org/jira/browse/FLINK-12735 Project: Flink