[jira] [Commented] (FLINK-14002) FlinkKafkaProducer constructor that takes KafkaSerializationSchema shouldnt take default topic

[ https://issues.apache.org/jira/browse/FLINK-14002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925398#comment-16925398 ] Gyula Fora commented on FLINK-14002: Actually the default topic is used in case of K

[jira] [Commented] (FLINK-14003) Add access to customized state other than built in state types

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925394#comment-16925394 ] Shimin Yang commented on FLINK-14003: - [~carp84], sounds good. > Add access to cust

[GitHub] [flink] flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability

flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-528758790 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] pnowojski commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability

pnowojski commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-529314668 @zhijiangW sorry for misunderstanding, but I wrote that we can backport the `perfomDefaultAction` rename if it's

[GitHub] [flink] flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability

flinkbot edited a comment on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-528758790 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] zhijiangW commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability

zhijiangW commented on issue #9634: [hotfix][runtime] Streaming runtime 1.9 improvements for debuggability URL: https://github.com/apache/flink/pull/9634#issuecomment-529297356 @1u0 After confirming with @pnowojski , I think we could only make the hotfix of thread name in release-1.9, so c

[GitHub] [flink] flinkbot edited a comment on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0

flinkbot edited a comment on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647#issuecomment-529283547 ## CI report: * cab04a32f620acef83f46bc111512b748b4acce8 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/1

[jira] [Comment Edited] (FLINK-13619) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925343#comment-16925343 ] Piotr Nowojski edited comment on FLINK-13619 at 9/9/19 4:05 AM: --

[jira] [Commented] (FLINK-13619) Update FlinkKafkaProducerMigrationOperatorTest to restore from 1.9 savepoint

[ https://issues.apache.org/jira/browse/FLINK-13619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925343#comment-16925343 ] Piotr Nowojski commented on FLINK-13619: By a nature of this test, it's restorin

[jira] [Updated] (FLINK-14006) Add doc for how to using Java UDFs in Python API

[ https://issues.apache.org/jira/browse/FLINK-14006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-14006: Description: Currently, user can not find out the doc for  how to using Java UDFs in Python API.

[jira] [Created] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

sunjincheng created FLINK-14007: --- Summary: Add doc for how to using Java user-defined source/sink in Python API Key: FLINK-14007 URL: https://issues.apache.org/jira/browse/FLINK-14007 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0

flinkbot edited a comment on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647#issuecomment-529283547 ## CI report: * cab04a32f620acef83f46bc111512b748b4acce8 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/1

[jira] [Created] (FLINK-14006) Add doc for how to using Java UDFs in Python API

sunjincheng created FLINK-14006: --- Summary: Add doc for how to using Java UDFs in Python API Key: FLINK-14006 URL: https://issues.apache.org/jira/browse/FLINK-14006 Project: Flink Issue Type: Im

[GitHub] [flink] flinkbot commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0

flinkbot commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647#issuecomment-529283547 ## CI report: * cab04a32f620acef83f46bc111512b748b4acce8 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0

flinkbot commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647#issuecomment-529282630 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[GitHub] [flink] xuefuz commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0

xuefuz commented on issue #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647#issuecomment-529282367 cc: @bowenli86 @lirui-apache @zjuwangg This is an automated message from th

[GitHub] [flink] xuefuz opened a new pull request #9647: [FLINK-14005][hive] Support Hive version 2.2.0

xuefuz opened a new pull request #9647: [FLINK-14005][hive] Support Hive version 2.2.0 URL: https://github.com/apache/flink/pull/9647 ## What is the purpose of the change Support Hive 2.2.0 ## Brief change log - Added new shim for the version - Adjust inheritance

[jira] [Updated] (FLINK-14005) Support Hive version 2.2.0

[ https://issues.apache.org/jira/browse/FLINK-14005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xuefu Zhang updated FLINK-14005: Description: (was: Including 2.0.0 and 2.0.1.) > Support Hive version 2.2.0 >

[jira] [Created] (FLINK-14005) Support Hive version 2.2.0

Xuefu Zhang created FLINK-14005: --- Summary: Support Hive version 2.2.0 Key: FLINK-14005 URL: https://issues.apache.org/jira/browse/FLINK-14005 Project: Flink Issue Type: Improvement Co

[GitHub] [flink] flinkbot edited a comment on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput

flinkbot edited a comment on issue #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput URL: https://github.com/apache/flink/pull/9635#issuecomment-528762211 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the co

[GitHub] [flink] zhijiangW merged pull request #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput

zhijiangW merged pull request #9635: [hotfix][runtime] Rename StreamTask's performDefaultAction method to processInput URL: https://github.com/apache/flink/pull/9635 This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-493753515 Thanks a lot for your contribution to the Apache Flink project. I'm t

[GitHub] [flink] Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

Aitozi commented on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-529266944 Please take a look again when you have time, I have fixed following your comm

[jira] [Commented] (FLINK-13872) Translate Operations Playground to Chinese

[ https://issues.apache.org/jira/browse/FLINK-13872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925285#comment-16925285 ] Lord i Will commented on FLINK-13872: - [~fhueske] OK, i will fetch all and go ahead

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FAI

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : PEN

[jira] [Commented] (FLINK-14003) Add access to customized state other than built in state types

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925228#comment-16925228 ] Yu Li commented on FLINK-14003: --- Thanks for creating the JIRA and start the discussion [~d

[GitHub] [flink] flinkbot commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

flinkbot commented on issue #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529228507 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkb

[jira] [Updated] (FLINK-14004) Define SourceReader interface to verify the integration with StreamOneInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-14004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14004: --- Labels: pull-request-available (was: ) > Define SourceReader interface to verify the integr

[GitHub] [flink] zhijiangW opened a new pull request #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor

zhijiangW opened a new pull request #9646: [FLINK-14004][task] Define SourceReader interface to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646 ## What is the purpose of the change We already refactored the task input and output sid

[jira] [Created] (FLINK-14004) Define SourceReader interface to verify the integration with StreamOneInputProcessor

zhijiang created FLINK-14004: Summary: Define SourceReader interface to verify the integration with StreamOneInputProcessor Key: FLINK-14004 URL: https://issues.apache.org/jira/browse/FLINK-14004 Project:

[jira] [Commented] (FLINK-7151) Add a function SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-7151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925215#comment-16925215 ] Zhenqiu Huang commented on FLINK-7151: -- [~phoenixjiangnan] Please try to access it n

[GitHub] [flink] flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132 ## CI report: * fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :

[GitHub] [flink] flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132 ## CI report: * fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :

[GitHub] [flink] flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file

flinkbot edited a comment on issue #8479: [FLINK-11193][State Backends]Use user passed configuration overriding default configuration loading from file URL: https://github.com/apache/flink/pull/8479#issuecomment-526521132 ## CI report: * fdd6f0e24a689b70d15b2dc190fc2fc3b0600bfa :

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a : FAILUR

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a : FAILUR

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a : FAILUR

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521129021 Thanks a lot for your contribution to the Apache Flink project. I'm the @fl

[GitHub] [flink] godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

godfreyhe commented on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-529200827 so sorry for late reply, and thanks all guys for the suggestion. The implementati

[jira] [Commented] (FLINK-13821) Website must link to License etc

[ https://issues.apache.org/jira/browse/FLINK-13821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925166#comment-16925166 ] Robert Metzger commented on FLINK-13821: Very nice, thank you! > Website must l

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521129021 Thanks a lot for your contribution to the Apache Flink project. I'm the @fl

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487385120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE [Build](https://travis

[jira] [Commented] (FLINK-14003) Add access to customized state other than built in state types

[ https://issues.apache.org/jira/browse/FLINK-14003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16925116#comment-16925116 ] Shimin Yang commented on FLINK-14003: - [~carp84], what do you think? > Add access t

[jira] [Created] (FLINK-14003) Add access to customized state other than built in state types

Shimin Yang created FLINK-14003: --- Summary: Add access to customized state other than built in state types Key: FLINK-14003 URL: https://issues.apache.org/jira/browse/FLINK-14003 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-487385120 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commun

[GitHub] [flink] flinkbot edited a comment on issue #9645: [FLINK-12584][connectors]Add Bucket File Syetem Table Sink

flinkbot edited a comment on issue #9645: [FLINK-12584][connectors]Add Bucket File Syetem Table Sink URL: https://github.com/apache/flink/pull/9645#issuecomment-529174577 ## CI report: * d7c56060a8dd37190f70e2bef40cf37d013c7a59 : SUCCESS [Build](https://travis-ci.com/flink-ci/fl