[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16904324#comment-16904324 ] hiliuxg commented on FLINK-10114: - Hi,[~yanghua] , My implement is made with  Bucketing

[jira] [Comment Edited] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16904323#comment-16904323 ] hiliuxg edited comment on FLINK-10114 at 8/10/19 5:04 AM: -- Hi,[

[jira] [Commented] (FLINK-10114) Support Orc for StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-10114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16904323#comment-16904323 ] hiliuxg commented on FLINK-10114: - I try , But the StreamingFileSink base api hard to im

[jira] [Assigned] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13562: --- Assignee: godfrey he > throws exception when FlinkRelMdColumnInterval meets two stage stream group

[jira] [Updated] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13562: Priority: Critical (was: Major) > throws exception when FlinkRelMdColumnInterval meets two stage stream g

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13503: Priority: Critical (was: Minor) > Add contract in `LookupableTableSource` to specify the behavior when >

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE [Build](https://t

[GitHub] [flink] sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-520107994 @JingsongLi Thanks for the review, I have update the PR, and I also have been shared my thro

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312684864 ## File path: flink-table/flink-table-runtime-blink/src/main/java

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312684827 ## File path: flink-table/flink-table-runtime-blink/src/main/java

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312684816 ## File path: flink-table/flink-table-planner-blink/src/main/scal

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on a change in pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#discussion_r312684777 ## File path: flink-table/flink-table-planner-blink/src/main/scal

[GitHub] [flink] winitzki commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one

winitzki commented on issue #9397: [FLINK-13658] [API / DataStream] Combine two triggers into one URL: https://github.com/apache/flink/pull/9397#issuecomment-520089406 Linked to https://issues.apache.org/jira/browse/FLINK-13658 --

[jira] [Commented] (FLINK-13677) Translate "Monitoring Back Pressure" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16904111#comment-16904111 ] fanrui commented on FLINK-13677: Hi, May I translate this? > Translate "Monitoring Back

[jira] [Created] (FLINK-13677) Translate "Monitoring Back Pressure" page into Chinese

fanrui created FLINK-13677: -- Summary: Translate "Monitoring Back Pressure" page into Chinese Key: FLINK-13677 URL: https://issues.apache.org/jira/browse/FLINK-13677 Project: Flink Issue Type: Sub-ta

[GitHub] [flink] flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper

flinkbot edited a comment on issue #9413: [FLINK-13676][ml] Add class of Vector to Columns mapper URL: https://github.com/apache/flink/pull/9413#issuecomment-519968250 ## CI report: * a585d0f8fef391d4da791b0cd1506e4f8b1acdc1 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/bui

[jira] [Updated] (FLINK-11991) Set headers to use for CSV output

[ https://issues.apache.org/jira/browse/FLINK-11991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11991: Fix Version/s: (was: 1.9.0) > Set headers to use for CSV output >

[jira] [Updated] (FLINK-13563) TumblingGroupWindow should implement toString method

[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13563: Fix Version/s: (was: 1.9.0) > TumblingGroupWindow should implement toString me

[jira] [Updated] (FLINK-13188) MockStateBackend usage in MockStateTtlTest violates Nonnull annotations

[ https://issues.apache.org/jira/browse/FLINK-13188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13188: Fix Version/s: (was: 1.9.0) > MockStateBackend usage in MockStateTtlTest viola

[jira] [Updated] (FLINK-13542) Flink Datadog metrics reporter sends empty series if there is no metrics

[ https://issues.apache.org/jira/browse/FLINK-13542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13542: Fix Version/s: (was: 1.9.0) > Flink Datadog metrics reporter sends empty serie

[jira] [Updated] (FLINK-13503) Add contract in `LookupableTableSource` to specify the behavior when lookupKeys contains null

[ https://issues.apache.org/jira/browse/FLINK-13503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13503: Fix Version/s: (was: 1.9.0) > Add contract in `LookupableTableSource` to speci

[jira] [Updated] (FLINK-13564) blink planner should also throw exception if constant with YEAR TO MONTH resolution was used for group windows

[ https://issues.apache.org/jira/browse/FLINK-13564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13564: Fix Version/s: (was: 1.9.0) > blink planner should also throw exception if con

[jira] [Updated] (FLINK-13317) Merge NetUtils and ClientUtils

[ https://issues.apache.org/jira/browse/FLINK-13317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13317: Fix Version/s: (was: 1.9.0) > Merge NetUtils and ClientUtils > ---

[jira] [Updated] (FLINK-13556) Python profile failed on Travis with setup problem

[ https://issues.apache.org/jira/browse/FLINK-13556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13556: Fix Version/s: (was: 1.9.0) > Python profile failed on Travis with setup probl

[jira] [Updated] (FLINK-13419) TableEnvironment.explain() has side-effects on ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-13419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13419: Fix Version/s: (was: 1.9.0) > TableEnvironment.explain() has side-effects on E

[jira] [Updated] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13562: Fix Version/s: (was: 1.9.0) > throws exception when FlinkRelMdColumnInterval m

[jira] [Updated] (FLINK-13238) Reduce blink planner's testing time

[ https://issues.apache.org/jira/browse/FLINK-13238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13238: Fix Version/s: (was: 1.9.0) > Reduce blink planner's testing time > --

[jira] [Updated] (FLINK-13265) Noisy hive-connector tests

[ https://issues.apache.org/jira/browse/FLINK-13265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13265: Fix Version/s: (was: 1.9.0) > Noisy hive-connector tests > ---

[jira] [Updated] (FLINK-13197) support querying Hive's view in Flink

[ https://issues.apache.org/jira/browse/FLINK-13197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13197: Fix Version/s: (was: 1.9.0) > support querying Hive's view in Flink >

[jira] [Updated] (FLINK-13092) Translate "kubernetes" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13092: Fix Version/s: (was: 1.9.0) > Translate "kubernetes" page into Chinese > -

[jira] [Updated] (FLINK-13195) Add create table support for SqlClient

[ https://issues.apache.org/jira/browse/FLINK-13195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13195: Fix Version/s: (was: 1.9.0) > Add create table support for SqlClient > ---

[jira] [Updated] (FLINK-13007) Integrate Flink's FunctionCatalog with Catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-13007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13007: Fix Version/s: (was: 1.9.0) > Integrate Flink's FunctionCatalog with Catalog A

[jira] [Updated] (FLINK-13250) Blink Planner should assign concrete resources to all nodes

[ https://issues.apache.org/jira/browse/FLINK-13250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13250: Fix Version/s: (was: 1.9.0) > Blink Planner should assign concrete resources t

[jira] [Updated] (FLINK-12761) Fine grained resource management

[ https://issues.apache.org/jira/browse/FLINK-12761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12761: Fix Version/s: (was: 1.9.0) > Fine grained resource management > -

[jira] [Updated] (FLINK-12894) add Chinese documentation of how to configure and use catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-12894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12894: Fix Version/s: 1.9.0 > add Chinese documentation of how to configure and use catal

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

[ https://issues.apache.org/jira/browse/FLINK-12755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12755: Fix Version/s: (was: 1.9.0) > implement HiveCatalog > - >

[jira] [Updated] (FLINK-12996) Add predefined type validators, strategies, and transformations

[ https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12996: Fix Version/s: (was: 1.9.0) > Add predefined type validators, strategies, and

[jira] [Updated] (FLINK-12894) add Chinese documentation of how to configure and use catalogs in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-12894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12894: Fix Version/s: (was: 1.9.0) > add Chinese documentation of how to configure an

[jira] [Updated] (FLINK-12764) Launch customized TaskExecutor for tasks whose resource needs cannot be satisfied by existing TaskExecutor-s in active container mode.

[ https://issues.apache.org/jira/browse/FLINK-12764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12764: Fix Version/s: (was: 1.9.0) > Launch customized TaskExecutor for tasks whose r

[jira] [Updated] (FLINK-12905) Convert CatalogView to org.apache.calcite.schema.Table so that planner can use unified catalog APIs

[ https://issues.apache.org/jira/browse/FLINK-12905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12905: Fix Version/s: (was: 1.9.0) > Convert CatalogView to org.apache.calcite.schema

[jira] [Updated] (FLINK-12625) Support catalogs in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-12625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12625: Fix Version/s: (was: 1.9.0) > Support catalogs in SQL Client > ---

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

[ https://issues.apache.org/jira/browse/FLINK-12753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12753: Fix Version/s: (was: 1.9.0) > Implement GenericInMemoryCatalog > -

[jira] [Updated] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12650: Fix Version/s: (was: 1.9.0) > Redirect Users to Documentation Homepage if Requ

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

[ https://issues.apache.org/jira/browse/FLINK-12754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12754: Fix Version/s: (was: 1.9.0) > alterTableColumnStatistics() in GenericInMemoryC

[jira] [Updated] (FLINK-12656) Integrate Flink with Hive user defined functions

[ https://issues.apache.org/jira/browse/FLINK-12656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12656: Fix Version/s: (was: 1.9.0) > Integrate Flink with Hive user defined functions

[jira] [Updated] (FLINK-12470) FLIP39: Flink ML pipeline and ML libs

[ https://issues.apache.org/jira/browse/FLINK-12470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12470: Fix Version/s: (was: 1.9.0) > FLIP39: Flink ML pipeline and ML libs >

[jira] [Updated] (FLINK-12429) Translate the "Generating Timestamps / Watermarks" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12429: Fix Version/s: (was: 1.9.0) > Translate the "Generating Timestamps / Watermark

[jira] [Updated] (FLINK-12492) Minor optimize the cep operator by avoiding unnecessary copy

[ https://issues.apache.org/jira/browse/FLINK-12492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12492: Fix Version/s: (was: 1.9.0) > Minor optimize the cep operator by avoiding unne

[jira] [Updated] (FLINK-12430) Translate the "Pre-defined Timestamp Extractors / Watermark Emitters" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12430: Fix Version/s: (was: 1.9.0) > Translate the "Pre-defined Timestamp Extractors

[GitHub] [flink] flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper

flinkbot edited a comment on issue #9412: [FLINK-13675][ml] Add class of Vector Slice Mapper URL: https://github.com/apache/flink/pull/9412#issuecomment-519965864 ## CI report: * e9ff64826d561117cbd984df4201d15e0523b091 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/1

[GitHub] [flink] flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper

flinkbot edited a comment on issue #9411: [FLINK-13674][ml] Add class of Vector Size Hint Mapper URL: https://github.com/apache/flink/pull/9411#issuecomment-519965855 ## CI report: * 4af38a946a55d1d6b68d7d249f87a65239c947f7 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/buil

[jira] [Updated] (FLINK-12396) KafkaITCase.testOneSourceMultiplePartitions doesn't fail properly

[ https://issues.apache.org/jira/browse/FLINK-12396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12396: Fix Version/s: (was: 1.9.0) > KafkaITCase.testOneSourceMultiplePartitions does

[GitHub] [flink] flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper

flinkbot edited a comment on issue #9409: [FLINK-13672][ml] Add class for VectorInteractionMapper URL: https://github.com/apache/flink/pull/9409#issuecomment-519961173 ## CI report: * 9b5e1620eb70dd95996ec3e8b7bebe1f38ac89a5 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/bui

[jira] [Updated] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12541: Fix Version/s: (was: 1.9.0) > Add deploy a Python Flink job and session cluste

[jira] [Updated] (FLINK-12445) YARNSessionCapacitySchedulerITCase#testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots does

[ https://issues.apache.org/jira/browse/FLINK-12445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12445: Fix Version/s: (was: 1.9.0) > YARNSessionCapacitySchedulerITCase#testVCoresAre

[GitHub] [flink] flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper

flinkbot edited a comment on issue #9410: [FLINK-13673][ml] Add class of Vector Normalize Mapper URL: https://github.com/apache/flink/pull/9410#issuecomment-519963431 ## CI report: * 06b26ce69e490794f3bcda79766f8edc9d6e48ce : FAILURE [Build](https://travis-ci.com/flink-ci/flink/buil

[jira] [Updated] (FLINK-12308) Support python language in Flink Table API

[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12308: Fix Version/s: (was: 1.9.0) 1.10.0 > Support python languag

[jira] [Updated] (FLINK-12242) Support partition related operations in GenericHiveMetastoreCatalog

[ https://issues.apache.org/jira/browse/FLINK-12242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12242: Fix Version/s: (was: 1.9.0) > Support partition related operations in GenericH

[jira] [Updated] (FLINK-12351) AsyncWaitOperator should deep copy StreamElement when object reuse is enabled

[ https://issues.apache.org/jira/browse/FLINK-12351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12351: Fix Version/s: (was: 1.9.0) 1.10.0 > AsyncWaitOperator shou

[jira] [Updated] (FLINK-11749) Returns the stored leadership info on ZooKeeperLeaderRetrievalService started

[ https://issues.apache.org/jira/browse/FLINK-11749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11749: Fix Version/s: (was: 1.9.0) > Returns the stored leadership info on ZooKeeperL

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

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11654: Fix Version/s: (was: 1.9.0) > Multiple transactional KafkaProducers writing to

[jira] [Updated] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13663: Fix Version/s: (was: 1.9.0) > SQL Client end-to-end test for modern Kafka fail

[jira] [Updated] (FLINK-12243) Support generic table stats related operations in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12243: Fix Version/s: (was: 1.9.0) > Support generic table stats related operations i

[jira] [Updated] (FLINK-13604) All kinds of problem when conversion from Logical type to DataType

[ https://issues.apache.org/jira/browse/FLINK-13604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13604: Fix Version/s: (was: 1.9.0) > All kinds of problem when conversion from Logica

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13526: Fix Version/s: (was: 1.9.0) > Switching to a non existing catalog or database

[jira] [Updated] (FLINK-13502) CatalogTableStatisticsConverter & TreeNode should be in correct package

[ https://issues.apache.org/jira/browse/FLINK-13502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13502: Fix Version/s: (was: 1.9.0) > CatalogTableStatisticsConverter & TreeNode shoul

[jira] [Updated] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

[ https://issues.apache.org/jira/browse/FLINK-13400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13400: Fix Version/s: (was: 1.9.0) > Remove Hive and Hadoop dependencies from SQL Cli

[jira] [Updated] (FLINK-13606) PrometheusReporterEndToEndITCase.testReporter unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13606: Fix Version/s: (was: 1.9.0) > PrometheusReporterEndToEndITCase.testReporter un

[jira] [Updated] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

[ https://issues.apache.org/jira/browse/FLINK-13539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13539: Fix Version/s: (was: 1.9.0) > DDL do not support CSV tableFactory because CSV

[jira] [Updated] (FLINK-13386) Frictions in the new default Web Frontend

[ https://issues.apache.org/jira/browse/FLINK-13386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13386: Fix Version/s: (was: 1.9.0) > Frictions in the new default Web Frontend >

[jira] [Updated] (FLINK-12355) KafkaITCase.testTimestamps is unstable

[ https://issues.apache.org/jira/browse/FLINK-12355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12355: Fix Version/s: (was: 1.9.0) > KafkaITCase.testTimestamps is unstable > ---

[jira] [Updated] (FLINK-12037) High parallelism E2E test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12037: Fix Version/s: (was: 1.9.0) > High parallelism E2E test failed on Travis > ---

[jira] [Updated] (FLINK-12048) ZooKeeperHADispatcherTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12048: Fix Version/s: (was: 1.9.0) > ZooKeeperHADispatcherTest failed on Travis > ---

[jira] [Updated] (FLINK-12034) KafkaITCase.testAllDeletes failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12034: Fix Version/s: (was: 1.9.0) > KafkaITCase.testAllDeletes failed on Travis > --

[jira] [Updated] (FLINK-13381) BinaryHashTableTest and BinaryExternalSorterTest is crashed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13381: Fix Version/s: (was: 1.9.0) > BinaryHashTableTest and BinaryExternalSorterTest

[jira] [Updated] (FLINK-12071) HadoopRecoverableWriterTest fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-12071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12071: Fix Version/s: (was: 1.9.0) > HadoopRecoverableWriterTest fails on Travis > --

[jira] [Updated] (FLINK-12033) KafkaITCase.testCancelingFullTopic failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12033: Fix Version/s: (was: 1.9.0) > KafkaITCase.testCancelingFullTopic failed on Tra

[jira] [Updated] (FLINK-9993) Wordcount end-to-end test in docker failed

[ https://issues.apache.org/jira/browse/FLINK-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9993: --- Fix Version/s: (was: 1.9.0) > Wordcount end-to-end test in docker failed > --

[jira] [Updated] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9429: --- Fix Version/s: (was: 1.9.0) > Quickstart E2E not working locally > --

[jira] [Updated] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12030: Fix Version/s: (was: 1.9.0) > KafkaITCase.testMultipleSourcesOnePartition is u

[jira] [Updated] (FLINK-11995) Kafka09SecuredRunITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-11995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11995: Fix Version/s: (was: 1.9.0) > Kafka09SecuredRunITCase fails due to port confli

[jira] [Updated] (FLINK-12032) KafkaProducerAtLeastOnceITCase failed to bind to address

[ https://issues.apache.org/jira/browse/FLINK-12032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12032: Fix Version/s: (was: 1.9.0) > KafkaProducerAtLeastOnceITCase failed to bind to

[jira] [Updated] (FLINK-10737) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-10737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10737: Fix Version/s: (was: 1.9.0) > FlinkKafkaProducerITCase.testScaleDownBeforeFirs

[jira] [Updated] (FLINK-11426) Kafka09ProducerITCase test case failed while starting KafkaCluster

[ https://issues.apache.org/jira/browse/FLINK-11426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11426: Fix Version/s: (was: 1.9.0) > Kafka09ProducerITCase test case failed while sta

[jira] [Updated] (FLINK-10819) JobManagerHAProcessFailureRecoveryITCase.testDispatcherProcessFailure is unstable

[ https://issues.apache.org/jira/browse/FLINK-10819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10819: Fix Version/s: (was: 1.9.0) > JobManagerHAProcessFailureRecoveryITCase.testDis

[GitHub] [flink] flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper

flinkbot edited a comment on issue #9408: [FLINK-13671][ml] Add class for VectorEleWiseProductMapper URL: https://github.com/apache/flink/pull/9408#issuecomment-519961164 ## CI report: * fbf9704fe2812d28d7a6b9ca6272a260e91089b3 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/

[jira] [Updated] (FLINK-8163) NonHAQueryableStateFsBackendITCase test getting stuck on Travis

[ https://issues.apache.org/jira/browse/FLINK-8163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8163: --- Fix Version/s: (was: 1.9.0) > NonHAQueryableStateFsBackendITCase test getting stu

[jira] [Updated] (FLINK-5125) ContinuousFileProcessingCheckpointITCase is Flaky

[ https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-5125: --- Fix Version/s: (was: 1.6.5) (was: 1.7.3)

[jira] [Updated] (FLINK-3199) Kafka09ITCase.testOneToOneSources do not finish

[ https://issues.apache.org/jira/browse/FLINK-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3199: --- Fix Version/s: (was: 1.9.0) 1.10.0 > Kafka09ITCase.testOneToOn

[jira] [Updated] (FLINK-9017) FlinkKafkaProducer011ITCase.testFlinkKafkaProducer011FailBeforeNotify times out on Travis

[ https://issues.apache.org/jira/browse/FLINK-9017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9017: --- Fix Version/s: (was: 1.9.0) > FlinkKafkaProducer011ITCase.testFlinkKafkaProducer0

[jira] [Updated] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8521: --- Fix Version/s: (was: 1.9.0) > FlinkKafkaProducer011ITCase.testRunOutOfProducersIn

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16904002#comment-16904002 ] Tzu-Li (Gordon) Tai commented on FLINK-8513: I've removed the fix versions fr

[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 ] Tzu-Li (Gordon) Tai updated FLINK-8513: --- Fix Version/s: (was: 1.8.2) (was: 1.9.0) > Add documentati

[jira] [Updated] (FLINK-13530) AbstractServerTest failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13530: Fix Version/s: (was: 1.9.0) 1.10.0 > AbstractServerTest fai

[jira] [Updated] (FLINK-12395) Add more detailed javadoc for getDescription() and getDetailedDescription() in catalog object interfaces

[ https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12395: Fix Version/s: (was: 1.9.0) 1.10.0 > Add more detailed java

[jira] [Updated] (FLINK-13034) Improve the performance when checking whether mapstate is empty for RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-13034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13034: Fix Version/s: (was: 1.9.0) > Improve the performance when checking whether ma

[jira] [Updated] (FLINK-12428) Translate the "Event Time" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12428: Fix Version/s: (was: 1.9.0) 1.10.0 > Translate the "Event T

[jira] [Updated] (FLINK-13283) JDBC source/sink should respect the conversion class of DataType

[ https://issues.apache.org/jira/browse/FLINK-13283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-13283: Fix Version/s: (was: 1.9.0) 1.10.0 > JDBC source/sink shoul

[jira] [Updated] (FLINK-12427) Translate the "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-12427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-12427: Fix Version/s: (was: 1.9.0) 1.10.0 > Translate the "Flink D

  1   2   3   >