[jira] [Commented] (FLINK-11030) Cannot use Avro logical types with ConfluentRegistryAvroDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-11030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947398#comment-16947398 ] Jayant Ameta commented on FLINK-11030: -- Is there any update/workaround for this? >

[jira] [Updated] (FLINK-11405) rest api can show more exceptions by query parameter

[ https://issues.apache.org/jira/browse/FLINK-11405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-11405: --- Summary: rest api can show more exceptions by query parameter (was: rest api can more exceptions by query p

[GitHub] [flink] wittyameta commented on issue #7584: [FLINK-11030] Make SpecificData of AvroDeserializationScheme configurable

wittyameta commented on issue #7584: [FLINK-11030] Make SpecificData of AvroDeserializationScheme configurable URL: https://github.com/apache/flink/pull/7584#issuecomment-539861176 Is there any workaround for this? This is an

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947388#comment-16947388 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Ah, you are right. I apparently

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] sunhaibotb commented on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

sunhaibotb commented on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-539841326 @flinkbot run travis This

[jira] [Commented] (FLINK-14335) Java version of ExampleIntegrationTest in testing docs is incorrect

[ https://issues.apache.org/jira/browse/FLINK-14335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947374#comment-16947374 ] Yangze Guo commented on FLINK-14335: I'd like help to fix it. Could you assigned thi

[GitHub] [flink] flinkbot edited a comment on issue #9858: [Flink 14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [Flink 14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot commented on issue #9858: [Flink 14208][python] Optimize Python UDFs with parameters of constant values

flinkbot commented on issue #9858: [Flink 14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : UNKNOWN Bot commands T

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r332811245 ## File path: flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java ## @

[GitHub] [flink] flinkbot commented on issue #9858: [Flink 14208] Optimize Python UDFs with parameters of constant values

flinkbot commented on issue #9858: [Flink 14208] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539824651 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revie

[GitHub] [flink] HuangXingBo opened a new pull request #9858: Flink 14208

HuangXingBo opened a new pull request #9858: Flink 14208 URL: https://github.com/apache/flink/pull/9858 ## What is the purpose of the change This pull request optimize Python UDFS with parameters of constant values.The constant parameters are not needed to be transferred between the

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

flinkbot edited a comment on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-536259382 ## CI report: * be81d3cce668cce8d87bb76da9dc74b182d0a681 : CANCELED [Build](http

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[jira] [Commented] (FLINK-14328) JobCluster cannot reach TaskManager in K8s

[ https://issues.apache.org/jira/browse/FLINK-14328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947339#comment-16947339 ] Yang Wang commented on FLINK-14328: --- The jobmanager and taskmanager are both using ip,

[GitHub] [flink] xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

xuyang1706 commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-539809679 > Thanks for the quick response. @xuyang1706. I think I kinda understand what you were trying to achieve now. i

[GitHub] [flink] JingsongLi commented on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on issue #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#issuecomment-539808495 Thanks @sjwiesman for your review~ Updated.

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r332816094 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r332816007 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,

[jira] [Updated] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

[ https://issues.apache.org/jira/browse/FLINK-14347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14347: Issue Type: Test (was: Bug) > YARNSessionFIFOITCase.checkForProhibitedLogContents found a log wit

[jira] [Updated] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

[ https://issues.apache.org/jira/browse/FLINK-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-14348: Issue Type: Test (was: Bug) > YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to d

[jira] [Created] (FLINK-14348) YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files

Caizhi Weng created FLINK-14348: --- Summary: YarnFileStageTestS3ITCase. testRecursiveUploadForYarnS3a fails to delete files Key: FLINK-14348 URL: https://issues.apache.org/jira/browse/FLINK-14348 Project:

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r332813597 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r332813498 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,

[jira] [Created] (FLINK-14347) YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string

Caizhi Weng created FLINK-14347: --- Summary: YARNSessionFIFOITCase.checkForProhibitedLogContents found a log with prohibited string Key: FLINK-14347 URL: https://issues.apache.org/jira/browse/FLINK-14347

[GitHub] [flink] JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL

JingsongLi commented on a change in pull request #9799: [FLINK-13360][documentation] Add documentation for HBase connector for Table API & SQL URL: https://github.com/apache/flink/pull/9799#discussion_r332812854 ## File path: docs/dev/table/connect.md ## @@ -1075,6 +1075,

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase

hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase URL: https://github.com/apache/flink/pull/9855#discussion_r332800607 ## File path: flink-python/pyflink/gen_protos.py ## @@ -39,20

[GitHub] [flink] flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size

flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659 ## CI report: * 667c738c79302b11cad210edbfb007866be29fdf : FAILURE [Build](https

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] liupc commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

liupc commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539796118 > @zentol I think it's because option `--prefix` is used in `gen_procos.py` and it can be used only for pip 8.0+.

[GitHub] [flink] sunhaibotb commented on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

sunhaibotb commented on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539791916 Can you help me review this PR? Thanks. @pnowojski -

[GitHub] [flink] hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase

hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase URL: https://github.com/apache/flink/pull/9855#discussion_r332801148 ## File path: flink-python/pyflink/fn_execution/tests/test_flink_fn_exe

[GitHub] [flink] hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase

hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase URL: https://github.com/apache/flink/pull/9855#discussion_r332800607 ## File path: flink-python/pyflink/gen_protos.py ## @@ -39,20

[GitHub] [flink] hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase

hequn8128 commented on a change in pull request #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase URL: https://github.com/apache/flink/pull/9855#discussion_r332505512 ## File path: flink-python/pyflink/gen_protos.py ## @@ -39,20

[GitHub] [flink] flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size

flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659 ## CI report: * 667c738c79302b11cad210edbfb007866be29fdf : FAILURE [Build](https

[jira] [Commented] (FLINK-14339) The checkpoint ID count wrong on restore savepoint log

[ https://issues.apache.org/jira/browse/FLINK-14339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947311#comment-16947311 ] Congxian Qiu(klion26) commented on FLINK-14339: --- This logs the next checkp

[jira] [Comment Edited] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947309#comment-16947309 ] Wei-Che Wei edited comment on FLINK-14302 at 10/9/19 1:52 AM:

[jira] [Commented] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947307#comment-16947307 ] sunjincheng commented on FLINK-13011: - Notice: The package size limit of pypi alread

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947309#comment-16947309 ] Wei-Che Wei commented on FLINK-14302: - Hi [~becket_qin] I think the error was from

[GitHub] [flink] flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size

flinkbot edited a comment on issue #9587: [FLINK-13685][yarn] Validate YARN deployment against YARN scheduler maximum vcore size URL: https://github.com/apache/flink/pull/9587#issuecomment-526997659 ## CI report: * 667c738c79302b11cad210edbfb007866be29fdf : FAILURE [Build](https

[GitHub] [flink] flinkbot edited a comment on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al…

flinkbot edited a comment on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al… URL: https://github.com/apache/flink/pull/9857#issuecomment-539755548 ## CI report: * 3add3daff919c3fb87b54d8dfa7b94925d4e1f47 : SUCCESS [Build](https

[GitHub] [flink] mr-cloud commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment.

mr-cloud commented on issue #9841: [FLINK-14319][api] Register user jar files in execution environment. URL: https://github.com/apache/flink/pull/9841#issuecomment-539769653 Thanks. The PR is closed for now. And I proposed a plan detail for design and testing. Let's discuss first. Please r

[jira] [Commented] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947284#comment-16947284 ] Leo Zhang commented on FLINK-14319: --- Thanks. The PR is closed for now. And I proposed

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Description:  I see that there are some use cases in which people want to implement their own SQL app

[GitHub] [flink] walterddr commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

walterddr commented on issue #9355: [FLINK-13577][ml] Add an util class to build result row and generate … URL: https://github.com/apache/flink/pull/9355#issuecomment-539766632 Thanks for the quick response. @xuyang1706. I think I kinda understand what you were trying to achieve now. i thi

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947278#comment-16947278 ] sunjincheng commented on FLINK-14019: - Add discussion ML:  http://apache-flink-mail

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Docs Text: (was: Design - 1 - 2 - 3) Description:  I see that there are some use cases in whic

[GitHub] [flink] flinkbot edited a comment on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al…

flinkbot edited a comment on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al… URL: https://github.com/apache/flink/pull/9857#issuecomment-539755548 ## CI report: * 3add3daff919c3fb87b54d8dfa7b94925d4e1f47 : PENDING [Build](https

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[jira] [Updated] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leo Zhang updated FLINK-14319: -- Docs Text: Design - 1 - 2 - 3 Labels: (was: pull-request-available) > Register user jar file

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:08 AM: -

[GitHub] [flink] flinkbot commented on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al…

flinkbot commented on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al… URL: https://github.com/apache/flink/pull/9857#issuecomment-539755548 ## CI report: * 3add3daff919c3fb87b54d8dfa7b94925d4e1f47 : UNKNOWN Bot comman

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:08 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:07 AM: -

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:06 AM: -

[jira] [Comment Edited] (FLINK-14319) Register user jar files in {Stream}ExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16944911#comment-16944911 ] Leo Zhang edited comment on FLINK-14319 at 10/9/19 12:05 AM: -

[GitHub] [flink] flinkbot commented on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al…

flinkbot commented on issue #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al… URL: https://github.com/apache/flink/pull/9857#issuecomment-539752771 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the comm

[jira] [Commented] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947258#comment-16947258 ] Marcos Klein commented on FLINK-14300: -- Hi [~pnowojski], I have create a Pull Reque

[jira] [Commented] (FLINK-14332) add flink-metrics-signalfx to flink-metrics

[ https://issues.apache.org/jira/browse/FLINK-14332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947257#comment-16947257 ] Luke Sun commented on FLINK-14332: -- * updated the description * updated docs * flink-

[GitHub] [flink] mklein0 opened a new pull request #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al…

mklein0 opened a new pull request #9857: [FLINK-14300][Runtime / Task] Cleanup operator threads in case StreamTask fails to al… URL: https://github.com/apache/flink/pull/9857 …locate operatorChain ## What is the purpose of the change This pull request fixes a thread leak on th

[jira] [Updated] (FLINK-14332) add flink-metrics-signalfx to flink-metrics

[ https://issues.apache.org/jira/browse/FLINK-14332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Sun updated FLINK-14332: - Description: To support the [SignalFX|[https://www.signalfx.com/]] API and library dependencies: * com

[jira] [Updated] (FLINK-14300) StreamTask#invoke leaks threads if OperatorChain fails to be constructed

[ https://issues.apache.org/jira/browse/FLINK-14300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14300: --- Labels: pull-request-available (was: ) > StreamTask#invoke leaks threads if OperatorChain f

[jira] [Updated] (FLINK-14332) add flink-metrics-signalfx to flink-metrics

[ https://issues.apache.org/jira/browse/FLINK-14332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Sun updated FLINK-14332: - Description: To support the [SignalFX|[https://www.signalfx.com/]] API and library dependencies: * com

[GitHub] [flink] lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

lukess commented on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-539751699 @rmetzger I updated the description, docs, and flink-dist for opt/ release. May I know how to cleanup warnings from autom

[GitHub] [flink] flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx

flinkbot edited a comment on issue #9848: [FLINK-14332] [flink-metrics-signalfx] add flink-metrics-signalfx URL: https://github.com/apache/flink/pull/9848#issuecomment-538885706 ## CI report: * dd22d245973b8caf25f8f26a392a1ca95f863736 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[GitHub] [flink] flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl

flinkbot edited a comment on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-531747685 ## CI report: * bd2624914db1147588ea838ae542333c310290cc : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/127790175)

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947123#comment-16947123 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Thanks for the explanation. I am

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946973#comment-16946973 ] vinoyang commented on FLINK-13025: -- Hi guys, based on the [~aljoscha]'s comment, the PR

[GitHub] [flink] flinkbot edited a comment on issue #9856: [FLINK-14337][hs] Better handling of failed fetches

flinkbot edited a comment on issue #9856: [FLINK-14337][hs] Better handling of failed fetches URL: https://github.com/apache/flink/pull/9856#issuecomment-539528912 ## CI report: * 0766b44ae5b28c9f957524f25951c658ae0e9ff1 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/bui

[GitHub] [flink] Mrart commented on a change in pull request #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart commented on a change in pull request #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#discussion_r332569601 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flin

[jira] [Commented] (FLINK-11632) Make TaskManager automatic bind address picking more explicit (by default) and more configurable

[ https://issues.apache.org/jira/browse/FLINK-11632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946965#comment-16946965 ] Zili Chen commented on FLINK-11632: --- Thanks for your information [~trohrmann]. I wonde

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16946964#comment-16946964 ] Hequn Cheng commented on FLINK-14306: - Thank you all for your valuable feedbacks. Al

[jira] [Assigned] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14306: --- Assignee: Dian Fu > flink-python build fails with No module named pkg_resources > -

[GitHub] [flink] zentol commented on a change in pull request #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

zentol commented on a change in pull request #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#discussion_r332562245 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/fli

[jira] [Updated] (FLINK-14210) Make InfluxDBReporter timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14210: - Summary: Make InfluxDBReporter timeouts configurable (was: influxdb reporter support co

[jira] [Assigned] (FLINK-14210) Make InfluxDBReporter timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-14210: Assignee: ouyangwulin > Make InfluxDBReporter timeouts configurable > ---

[jira] [Closed] (FLINK-14210) Make InfluxDBReporter timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-14210. Resolution: Fixed master: be8fdcaea45136b15e8783831ac3d2bdb2608c3b > Make InfluxDBReporte

[jira] [Updated] (FLINK-14210) Make InfluxDBReporter timeouts configurable

[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14210: - Affects Version/s: (was: 1.10.0) (was: 1.9.0) > Make Infl

[jira] [Updated] (FLINK-14210) influxdb reporter support connect timeout and write timeout config options for decrease timeout exception

[ https://issues.apache.org/jira/browse/FLINK-14210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-14210: - Issue Type: New Feature (was: Improvement) > influxdb reporter support connect timeout

[GitHub] [flink] zentol merged pull request #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

zentol merged pull request #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on issue #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase

flinkbot edited a comment on issue #9855: [FLINK-14306][python] Add the code-generated flink_fn_execution_pb2.py to the codebase URL: https://github.com/apache/flink/pull/9855#issuecomment-539497885 ## CI report: * 55afe2dd431d404cd72a009a50fd3afb0985afd4 : SUCCESS [Build](https

[GitHub] [flink] flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering

flinkbot edited a comment on issue #9853: [FLINK-13904][checkpointing] Avoid competition of checkpoint triggering URL: https://github.com/apache/flink/pull/9853#issuecomment-539472188 ## CI report: * b10f5603fc55999adb8d5334a3d142d20322de5b : SUCCESS [Build](https://travis-ci.co

[GitHub] [flink] zentol edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

zentol edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-539548505 I think we should to both; use different stats as I see nothing in the test that requir

[GitHub] [flink] zentol commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

zentol commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-539548505 I think we should to both; use different state as I see nothing in the test that requires the

[GitHub] [flink] flinkbot edited a comment on issue #9856: [FLINK-14337][hs] Better handling of failed fetches

flinkbot edited a comment on issue #9856: [FLINK-14337][hs] Better handling of failed fetches URL: https://github.com/apache/flink/pull/9856#issuecomment-539528912 ## CI report: * 0766b44ae5b28c9f957524f25951c658ae0e9ff1 : PENDING [Build](https://travis-ci.com/flink-ci/flink/bui

[GitHub] [flink] flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes

flinkbot edited a comment on issue #9854: [FLINK-14230][task] Change the endInput call of the downstream operator to after the upstream operator closes URL: https://github.com/apache/flink/pull/9854#issuecomment-539497852 ## CI report: * 9adcb150ed88bfa077642f6f590ec4ae9183baf5 :

[GitHub] [flink] flinkbot commented on issue #9856: [FLINK-14337][hs] Better handling of failed fetches

flinkbot commented on issue #9856: [FLINK-14337][hs] Better handling of failed fetches URL: https://github.com/apache/flink/pull/9856#issuecomment-539528912 ## CI report: * 0766b44ae5b28c9f957524f25951c658ae0e9ff1 : UNKNOWN Bot commands The @flinkbot bot supports

[GitHub] [flink] flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService

flinkbot edited a comment on issue #9852: [FLINK-14343][coordination] Remove uncompleted YARNHighAvailabilityService URL: https://github.com/apache/flink/pull/9852#issuecomment-539417112 ## CI report: * 451eb3a627d34d1b3592a5d149e53e2810591465 : FAILURE [Build](https://travis-ci

[GitHub] [flink] flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early

flinkbot edited a comment on issue #9804: [FLINK-14239] Fix the max watermark in StreamSource may arrive the downstream operator early URL: https://github.com/apache/flink/pull/9804#issuecomment-536287116 ## CI report: * cb5b4da4d8b5d877e296dd84095a328208263c15 : FAILURE [Build]

[GitHub] [flink] flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

flinkbot edited a comment on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-539365871 ## CI report: * 1007e8b66d42b613ceafb86457913381a4e27b0f : FAILURE [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN * b96c63552ccd322adae7a41a410615e95b53

  1   2   3   >