[jira] [Closed] (FLINK-14285) Simplify Dispatcher factories by removing generics

[ https://issues.apache.org/jira/browse/FLINK-14285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14285. - Resolution: Done Done via 282dd840fe80bd71830d1c493cdb7e1d0ad5cc6e > Simplify Dispatcher

[jira] [Created] (FLINK-14342) Remove method FunctionDefinition#getLanguage

Dian Fu created FLINK-14342: --- Summary: Remove method FunctionDefinition#getLanguage Key: FLINK-14342 URL: https://issues.apache.org/jira/browse/FLINK-14342 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-14286) Remove Akka specific parsing logic from LeaderConnectionInfo

[ https://issues.apache.org/jira/browse/FLINK-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14286. - Resolution: Done Done via 1082c7a470355b938ad0f7de2fa73ca5461c1bc0 > Remove Akka specific

[GitHub] [flink] tillrohrmann closed pull request #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo

tillrohrmann closed pull request #9812: [FLINK-14286] Remove Akka specific parsing from LeaderConnectionInfo URL: https://github.com/apache/flink/pull/9812 This is an automated message from the Apache Git Service. To

[GitHub] [flink] tillrohrmann closed pull request #9807: [FLINK-14280] Introduce DispatcherRunner

tillrohrmann closed pull request #9807: [FLINK-14280] Introduce DispatcherRunner URL: https://github.com/apache/flink/pull/9807 This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] tillrohrmann closed pull request #9810: [FLINK-14284] Add shut down future to Dispatcher

tillrohrmann closed pull request #9810: [FLINK-14284] Add shut down future to Dispatcher URL: https://github.com/apache/flink/pull/9810 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] tillrohrmann closed pull request #9811: [FLINK-14285] Remove generics from Dispatcher factories

tillrohrmann closed pull request #9811: [FLINK-14285] Remove generics from Dispatcher factories URL: https://github.com/apache/flink/pull/9811 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tillrohrmann closed pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy

tillrohrmann closed pull request #9809: [FLINK-14282] Simplify DispatcherResourceManagerComponent hierarchy URL: https://github.com/apache/flink/pull/9809 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] tillrohrmann closed pull request #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture

tillrohrmann closed pull request #9808: [FLINK-14281] Add DispatcherRunner#getShutDownFuture URL: https://github.com/apache/flink/pull/9808 This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

liupengcheng created FLINK-14341: Summary: Flink-python builds with failure: no such option: --prefix Key: FLINK-14341 URL: https://issues.apache.org/jira/browse/FLINK-14341 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable

flinkbot edited a comment on issue #9824: [FLINK-14302] FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS URL: https://github.com/apache/flink/pull/9824#issuecomment-536928428 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

flinkbot edited a comment on issue #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#issuecomment-533554096 ## CI report: * 51167d9aaf8082150738dc5bd8b9e2319dd01570 : SUCCESS

[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 #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction

flinkbot edited a comment on issue #9823: [FLINK-14273][Table]Add accumulator type to actual type list in AggSqlFunction URL: https://github.com/apache/flink/pull/9823#issuecomment-536781542 ## CI report: * 2b5531b068338321eb04cdf71714eae0d088ec0e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient

flinkbot edited a comment on issue #9820: [FLINK-14290] Decouple plan translation from job execution/ClusterClient URL: https://github.com/apache/flink/pull/9820#issuecomment-536452582 ## CI report: * ff3ef7ae21616fb0295e3bdc53fa349c8f136a4b : FAILURE

[GitHub] [flink] yanghua commented on a change in pull request #9720: [FLINK-13025] Elasticsearch 7.x support

yanghua commented on a change in pull request #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#discussion_r332339180 ## File path: flink-connectors/flink-sql-connector-elasticsearch7/src/main/resources/META-INF/NOTICE ## @@

[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 #9355: [FLINK-13577][ml] Add an util class to build result row and generate …

flinkbot edited a comment 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-518089359 ## CI report: * f8f3792f7ce55735f05200c90431b20b99a42d18 : FAILURE

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r332335659 ## File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh ## @@

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r332333021 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -99,6

[GitHub] [flink] klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

klion26 commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r33284 ## File path: flink-dist/src/main/flink-bin/bin/flink-daemon.sh ## @@

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment.

flinkbot edited a comment on issue #9781: [FLINK-14098] Support multiple statements for TableEnvironment. URL: https://github.com/apache/flink/pull/9781#issuecomment-535813967 ## CI report: * ed0e04d1cd481b096d68d0c9bf36a997dcca2550 : FAILURE

[GitHub] [flink] HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-539322429 @walterddr Thanks for the comments and suggestions. For the changing of CatalogFunctionImpl constructor, let's wait for @bowenli86 's

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r332333999 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

sunjincheng121 commented on a change in pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748#discussion_r332333999 ## File path:

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332334043 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332334052 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic cron ARM CI job definition

flinkbot edited a comment on issue #9416: [FLINK-13646][build system] Add basic cron ARM CI job definition URL: https://github.com/apache/flink/pull/9416#issuecomment-520285701 ## CI report: * dbf749f0d0c3167265287b182dd1ea7b4aed84c1 : FAILURE

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332333004 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala

[GitHub] [flink] flinkbot edited a comment on issue #9819: [FLINK-14246][runtime] Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG

flinkbot edited a comment on issue #9819: [FLINK-14246][runtime] Annotate all MiniCluster tests in flink-runtime with AlsoRunWithSchedulerNG URL: https://github.com/apache/flink/pull/9819#issuecomment-536429067 ## CI report: * 94653a90b144e39f05a3e86de50225a0d538fed0 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332331898 ## File path: flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlParserImplTest.java

[jira] [Commented] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946472#comment-16946472 ] Congxian Qiu(klion26) commented on FLINK-14340: --- [~sewen] as you introduced the

[jira] [Updated] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

[ https://issues.apache.org/jira/browse/FLINK-14340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-14340: -- Description: Currently, when Flink read/write to HDFS, we do not set the

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946470#comment-16946470 ] Xintong Song commented on FLINK-14123: -- [~liupengcheng], The reason we have smaller default value

[jira] [Created] (FLINK-14340) Specify an unique DFSClient name for Hadoop FileSystem

Congxian Qiu(klion26) created FLINK-14340: - Summary: Specify an unique DFSClient name for Hadoop FileSystem Key: FLINK-14340 URL: https://issues.apache.org/jira/browse/FLINK-14340 Project:

[GitHub] [flink] flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al…

flinkbot edited a comment on issue #9300: [FLINK-13513][ml] Add the FlatMapper and related classes for later al… URL: https://github.com/apache/flink/pull/9300#issuecomment-516849331 ## CI report: * 9b5b5ff5df053498e491d43a04f44d5ba452579c : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

flinkbot edited a comment on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227 ## CI report: * b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9829: [FLINK-14184] [core] Add LocalContextListener

flinkbot edited a comment on issue #9829: [FLINK-14184] [core] Add LocalContextListener URL: https://github.com/apache/flink/pull/9829#issuecomment-536999846 ## CI report: * 4a2644b80db9de689dd8dfe742010a6c5367ee80 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE

[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

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

wsry 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-539302270 > What if we didn't share the stats between servers? @zentol From the previous comment

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[jira] [Commented] (FLINK-13808) Checkpoints expired by timeout may leak RocksDB files

[ https://issues.apache.org/jira/browse/FLINK-13808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946458#comment-16946458 ] Congxian Qiu(klion26) commented on FLINK-13808: --- Thanks for the reply [~sewen]  I agree

[GitHub] [flink] zjuwangg commented on issue #9689: [FLINK-7151] add a basic function ddl

zjuwangg commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-539299262 > thanks for the contribution @HuangZhenQiu and thanks for the prompt review @bowenli86 . I think overall the approach looks very good to me and I

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

flinkbot edited a comment on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-532638785 ## CI report: * 053ed30d568a00ba42d75d1a9534843c59a068af : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850#issuecomment-539298227 ## CI report: * b344a21f3d6d55e6fca5d9253b0b34ddb2c392e9 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

flinkbot edited a comment on issue #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#issuecomment-536295524 ## CI report: * 9ad039de6bbb953c7e2dd74b3118d80ae552f31e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[GitHub] [flink] wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry commented on issue #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#issuecomment-539297211 @pnowojski Thanks for your comments. I have separated the benchmark commit into a new pr

[jira] [Commented] (FLINK-14123) Change taskmanager.memory.fraction default value to 0.6

[ https://issues.apache.org/jira/browse/FLINK-14123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946446#comment-16946446 ] liupengcheng commented on FLINK-14123: -- [~xintongsong] Hi, thanks for your comment to let me know

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146 ## CI report: * baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE

[GitHub] [flink] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332322097 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl

zjuwangg commented on a change in pull request #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#discussion_r332322049 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components

zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components URL: https://github.com/apache/flink/pull/9846#discussion_r332009233 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components

zhuzhurk commented on a change in pull request #9846: [FLINK-14271][runtime] Remove legacy RestartPipelinedRegionStrategy components URL: https://github.com/apache/flink/pull/9846#discussion_r332009233 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable

flinkbot edited a comment on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9837#issuecomment-538378656 ## CI report: * e600698ff32b962308385e8d1c9f69b7c3eeaef1 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable

flinkbot edited a comment on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9838#issuecomment-538387018 ## CI report: * f6a760af29b7e7c1512463497443699ea6454926 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable

flinkbot edited a comment on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9839#issuecomment-538387060 ## CI report: * 085d38ccb49f7d3ea4acb07d44903fdc8d2c6d16 : PENDING

[GitHub] [flink] flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

flinkbot commented on issue #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850#issuecomment-539292822 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#discussion_r332319169 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[GitHub] [flink] wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#discussion_r332319145 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths

flinkbot edited a comment on issue #9803: [FLINK-14265][table-planner-blink] Don't use ContinuousFileReaderOperator to support multiple paths URL: https://github.com/apache/flink/pull/9803#issuecomment-536271535 ## CI report: * d0485eff552c55f9b987e1ad596f9f3dbe0fda69 : SUCCESS

[GitHub] [flink] wsry opened a new pull request #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario.

wsry opened a new pull request #9850: [FLINK-14118][benchmarks]Add network throughput benchmark for data skew scenario. URL: https://github.com/apache/flink/pull/9850 ## What is the purpose of the change The purpose of this pr is to add a network benchmark for data skew scenario in

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7

[jira] [Commented] (FLINK-14296) SqlNodes in the parser module should use an Optional for optional parameters

[ https://issues.apache.org/jira/browse/FLINK-14296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946423#comment-16946423 ] Jark Wu commented on FLINK-14296: - Hi [~wind_ljy], thanks for the PR, but before submitting the PR, I

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

king's uncle created FLINK-14339: Summary: The checkpoint ID count wrong on restore savepoint log Key: FLINK-14339 URL: https://issues.apache.org/jira/browse/FLINK-14339 Project: Flink Issue

[GitHub] [flink] TisonKun commented on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable

TisonKun commented on issue #9837: [FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9837#issuecomment-539289733 @flinkbot run travis This is an automated message from the

[GitHub] [flink] TisonKun commented on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable

TisonKun commented on issue #9839: [BP-1.8][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9839#issuecomment-539289749 @flinkbot run travis This is an automated message from

[GitHub] [flink] TisonKun commented on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable

TisonKun commented on issue #9838: [BP-1.9][FLINK-14315] Make heartbeat manager fields non-nullable URL: https://github.com/apache/flink/pull/9838#issuecomment-539289702 @flinkbot run travis This is an automated message from

[GitHub] [flink] flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS

[GitHub] [flink] liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-539288205 Any more suggestions? @TisonKun @aljoscha

[GitHub] [flink] liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-539287780 @tillrohrmann Hi, Can you have a look at this PR and give some suggestions?

[GitHub] [flink] flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

flinkbot edited a comment on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#issuecomment-536264046 ## CI report: * 0587de749d0d7a8c8dcc3dadeb53ae9599255abd : SUCCESS

[jira] [Updated] (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:all-tabpanel ] Jark Wu updated FLINK-14335: Fix Version/s: (was: 1.9.1) 1.9.2 > Java version of ExampleIntegrationTest in

[jira] [Updated] (FLINK-14334) ElasticSearch docs refer to non-existent ExceptionUtils.containsThrowable

[ https://issues.apache.org/jira/browse/FLINK-14334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14334: Fix Version/s: (was: 1.9.1) 1.9.2 > ElasticSearch docs refer to non-existent

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946410#comment-16946410 ] Yun Gao commented on FLINK-10672: - Hi [~angoenka] Very thanks for the input and very sorry for

[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

[jira] [Commented] (FLINK-14336) Exceptions in AsyncCheckpointRunnable#run are never logged

[ https://issues.apache.org/jira/browse/FLINK-14336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946404#comment-16946404 ] Congxian Qiu(klion26) commented on FLINK-14336: --- For now, we only have complete log in

[GitHub] [flink] flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex

flinkbot edited a comment on issue #9601: [FLINK-13894][web]Web Ui add log url for subtask of vertex URL: https://github.com/apache/flink/pull/9601#issuecomment-527404637 ## CI report: * 13d895349390698404a375fb4362a41b736ab0c6 : SUCCESS

[jira] [Commented] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

[ https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946393#comment-16946393 ] Dian Fu commented on FLINK-13999: - [~dwysakowicz] Thanks for the confirmation and suggestion! The

[GitHub] [flink] flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics

flinkbot edited a comment on issue #9801: [FLINK-13983][runtime] Launch task executor with new memory calculation logics URL: https://github.com/apache/flink/pull/9801#issuecomment-536259410 ## CI report: * 3ea28aa2186b964a7405fbd1367186db8e143836 : SUCCESS

[jira] [Created] (FLINK-14338) Upgrade Calcite version to 1.22 for Flink SQL

Danny Chen created FLINK-14338: -- Summary: Upgrade Calcite version to 1.22 for Flink SQL Key: FLINK-14338 URL: https://issues.apache.org/jira/browse/FLINK-14338 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex

flinkbot edited a comment on issue #9798: [FLINK-14176][web]Web Ui add log url for taskmanager of vertex URL: https://github.com/apache/flink/pull/9798#issuecomment-536255109 ## CI report: * 7231b0df07d82c5c758d744f51401251f6449ea9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig

flinkbot edited a comment on issue #9797: [FLINK-14059][core] Introduce option allVerticesInSameSlotSharingGroupByDefault in ExecutionConfig URL: https://github.com/apache/flink/pull/9797#issuecomment-536255105 ## CI report: * 17be7faf6d9c7dd26408c0649491c9401e65f866 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build

flinkbot edited a comment on issue #9783: [FLINK-14040][travis] Enable MiniCluster tests based on schedulerNG in Flink cron build URL: https://github.com/apache/flink/pull/9783#issuecomment-535848177 ## CI report: * 5d9e3113e10bbf0220b4f8e080ecd1cddd9c9059 : FAILURE

[jira] [Commented] (FLINK-13656) Upgrade Calcite dependency to 1.21

[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946370#comment-16946370 ] Danny Chen commented on FLINK-13656: Thanks Timo and Kurt, the sub-task has been resolved and we can

[GitHub] [flink] flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods

flinkbot edited a comment on issue #9793: [FLINK-14130][client] Remove ClusterClient.run() methods URL: https://github.com/apache/flink/pull/9793#issuecomment-536153382 ## CI report: * ea5b4330b5c9fb6eff889eb1c55c3f9a7bcfb6a9 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils

flinkbot edited a comment on issue #9792: [FLINK-14263][client] Extract static method from ClusterClient to ClientUtils URL: https://github.com/apache/flink/pull/9792#issuecomment-536151451 ## CI report: * 507c29a013e30a6993d8b123b266c44ddbdde037 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9784: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

flinkbot edited a comment on issue #9784: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9784#issuecomment-53526 ## CI report: * 198da66f5d4525d04f69bfed13eedb51652a2f38 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[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

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE

  1   2   3   4   5   6   >