[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot commented on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

flinkbot commented on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743#issuecomment-533978420 ## CI report: * 0ff3661a4946c47acc4ea362a869b9885e5712b6 : UNKNOWN --

[jira] [Comment Edited] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16933969#comment-16933969 ] Yadong Xie edited comment on FLINK-11374 at 9/23/19 6:38 AM: -

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot commented on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

flinkbot commented on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743#issuecomment-533974254 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community t

[GitHub] [flink] TisonKun opened a new pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

TisonKun opened a new pull request #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743 ## What is the purpose of the change Wait for completion of `MiniCluster#terminateExecutors`. ## Verifying this

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a : SUCCES

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] dianfu commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

dianfu commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326956873 ## File path: flink-python/src/main/java/org/apache/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a : SUCCES

[GitHub] [flink] dianfu commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

dianfu commented on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-533966853 @hequn8128 Very appreciated your comments. Have updated the PR. Looking forward to y

[jira] [Updated] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13869: Fix Version/s: (was: 1.9.1) > Hive functions can not work in blink planner stream mode > -

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED [Build](https://t

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : PENDING [Build](https://tr

[GitHub] [flink] flinkbot commented on issue #9742: [FLINK-14076] Always defensively wrap CheckpointException in SerializedThrowable

flinkbot commented on issue #9742: [FLINK-14076] Always defensively wrap CheckpointException in SerializedThrowable URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : UNKNOWN --

[jira] [Commented] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935547#comment-16935547 ] Jingsong Lee commented on FLINK-13869: -- Still need fix, 1.9 should work, but master

[GitHub] [flink] flinkbot commented on issue #9742: [DRAFT] Always defensively wrap CheckpointException in SerializedThrowable

flinkbot commented on issue #9742: [DRAFT] Always defensively wrap CheckpointException in SerializedThrowable URL: https://github.com/apache/flink/pull/9742#issuecomment-533956465 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326945598 ## File path: flink-python/src/test/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326946100 ## File path: flink-python/src/main/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326943917 ## File path: flink-python/src/test/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326944918 ## File path: flink-python/src/test/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326944428 ## File path: flink-python/src/test/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326938677 ## File path: flink-python/src/main/java/org/apache/fli

[GitHub] [flink] jdm2212 opened a new pull request #9742: Always defensively wrap CheckpointException in SerializedThrowable

jdm2212 opened a new pull request #9742: Always defensively wrap CheckpointException in SerializedThrowable URL: https://github.com/apache/flink/pull/9742 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server,

[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 [Build](https://travis-ci.com/flink-ci/fli

[jira] [Updated] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14010: Fix Version/s: 1.9.1 > Dispatcher & JobManagers don't give up leadership when AM is shut down > --

[jira] [Commented] (FLINK-11970) TableEnvironment#registerFunction should overwrite if the same name function existed.

[ https://issues.apache.org/jira/browse/FLINK-11970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935540#comment-16935540 ] Jeff Zhang commented on FLINK-11970: ping [~tiwalter] > TableEnvironment#registerFu

[jira] [Commented] (FLINK-13869) Hive functions can not work in blink planner stream mode

[ https://issues.apache.org/jira/browse/FLINK-13869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935538#comment-16935538 ] Jark Wu commented on FLINK-13869: - Is there any progress on this issue ? > Hive functio

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

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

[jira] [Updated] (FLINK-13271) Add documentation for all the new features of blink planner

[ https://issues.apache.org/jira/browse/FLINK-13271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13271: Priority: Major (was: Critical) > Add documentation for all the new features of blink planner > -

[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 [Build](https://travis-ci.com/flink-ci/fli

[GitHub] [flink] xuyang1706 commented on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-533951861 > Hi @xuyang1706 thanks for update, > I've left additional comments, please look they. @ex00 , thanks for your advic

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326942376 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/AlgoOperator.ja

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326942398 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/batchoperator/source/T

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[jira] [Updated] (FLINK-14030) Nonequivalent conversion happens in Table planner

[ https://issues.apache.org/jira/browse/FLINK-14030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14030: Priority: Major (was: Critical) > Nonequivalent conversion happens in Table planner > --

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326941323 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/AlgoOperator.ja

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r326941205 ## File path: flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/AlgoOperator.ja

[jira] [Commented] (FLINK-13862) Remove or rewrite Execution Plan docs

[ https://issues.apache.org/jira/browse/FLINK-13862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935530#comment-16935530 ] Jark Wu commented on FLINK-13862: - I agree with [~fhueske] that the plan visualizer is u

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935527#comment-16935527 ] Yingjie Cao commented on FLINK-14118: - [~pnowojski] Your concern is reasonable. I'd

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[jira] [Created] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

Zhu Zhu created FLINK-14164: --- Summary: Add a metric to show failover count regarding fine grained recovery Key: FLINK-14164 URL: https://issues.apache.org/jira/browse/FLINK-14164 Project: Flink Is

[GitHub] [flink] wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#discussion_r326939834 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runti

[GitHub] [flink] dianfu commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

dianfu commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326939840 ## File path: flink-python/src/main/java/org/apache/flink/

[GitHub] [flink] wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#discussion_r326939689 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runti

[GitHub] [flink] wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#discussion_r326939743 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runti

[GitHub] [flink] wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

wuchong commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#discussion_r326939628 ## File path: flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runti

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] AT-Fieldless commented on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless commented on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9718#issuecomment-533946231 Do you mean using `git -rebase` to clear the git history like this? [https://stack

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326937574 ## File path: flink-python/src/main/java/org/apache/fli

[GitHub] [flink] hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

hequn8128 commented on a change in pull request #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#discussion_r326937393 ## File path: flink-python/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend

flinkbot edited a comment on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend URL: https://github.com/apache/flink/pull/9247#issuecomment-515660312 ## CI report: * dbe883c57e689ed544de09423192843c758bfa54 : SUCCESS [Build](https://travis-ci.com/flin

[jira] [Commented] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935515#comment-16935515 ] Jark Wu commented on FLINK-13661: - You can leave your thoughts in this doc: https://doc

[GitHub] [flink] Mrart removed a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

Mrart removed a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-533847418 @rmetzger It seems a ci failed, I have not seem any log about the failed. Cloud you help me?

[jira] [Comment Edited] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935513#comment-16935513 ] ShenDa edited comment on FLINK-13661 at 9/23/19 2:27 AM: - OK tha

[GitHub] [flink] vthinkxie commented on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend

vthinkxie commented on issue #9247: [FLINK-13386][web]: Fix frictions in the new default Web Frontend URL: https://github.com/apache/flink/pull/9247#issuecomment-533943348 @dawidwys I have added watermarks in the graph and the subtask watermark in the tab ![10_24_49__09_23_2019](ht

[jira] [Commented] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935513#comment-16935513 ] ShenDa commented on FLINK-13661: OK thanks, [~jark]. Where cloud we find or join this de

[GitHub] [flink] xintongsong commented on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

xintongsong commented on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#issuecomment-533941818 Thanks for the review, @walterddr. Till has suggested that instead of maintaining a thread pool

[jira] [Commented] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935508#comment-16935508 ] Jark Wu commented on FLINK-13680: - Hi [~ClownfishYang], thanks for the work! But please

[jira] [Assigned] (FLINK-13680) Translate "Code Style - Common Rules" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13680: --- Assignee: ClownfishYang > Translate "Code Style - Common Rules" page into Chinese > ---

[jira] [Commented] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935507#comment-16935507 ] Jark Wu commented on FLINK-13661: - Hi [~DaDaShen], this is on the roadmap but there's no

[GitHub] [flink] KarmaGYZ commented on issue #9740: [hotfix][docs] URL should not point to release-1.8 docs

KarmaGYZ commented on issue #9740: [hotfix][docs] URL should not point to release-1.8 docs URL: https://github.com/apache/flink/pull/9740#issuecomment-533940003 > @KarmaGYZ I didn't include the link to release-1.6 in s3.md and s3.zh.md in this PR because I couldn't figure out what to do wi

[jira] [Commented] (FLINK-13661) Add a stream specific CREATE TABLE SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-13661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935501#comment-16935501 ] ShenDa commented on FLINK-13661: Hi  all, is there any progress or issue of combined tab

[GitHub] [flink] TisonKun commented on a change in pull request #9727: [FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

TisonKun commented on a change in pull request #9727: [FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9727#discussion_r326928459 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedChe

[GitHub] [flink] Myasuka commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

Myasuka commented on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-533896113 There have been some tests for `MapState.isEmpty` in `StateBackendTestBase.testMapState`, do you actually mean other tests for `MapSt

[GitHub] [flink] Myasuka commented on a change in pull request #9255: [FLINK-13034] Introduce isEmpty method for MapState

Myasuka commented on a change in pull request #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#discussion_r326908826 ## File path: flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/utils/TestSharedBuffer.java

[GitHub] [flink] walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#discussion_r326907710 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManag

[GitHub] [flink] walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#discussion_r326907587 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManag

[GitHub] [flink] walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

walterddr commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#discussion_r326907808 ## File path: docs/_includes/generated/yarn_config_configuration.html

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326906392 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnCluster

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326906870 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnCluster

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326905980 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326905824 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFI

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326906042 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326905907 ## File path: flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.

[GitHub] [flink] walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

walterddr commented on a change in pull request #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#discussion_r326906430 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnCluster

[jira] [Commented] (FLINK-13148) Expose WindowedStream.sideOutputLateData() from CoGroupedStreams

[ https://issues.apache.org/jira/browse/FLINK-13148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935323#comment-16935323 ] Congxian Qiu(klion26) commented on FLINK-13148: --- Hi, [~kkl0u] do you think

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326899233 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326901044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexSchedul

[GitHub] [flink] alpinegizmo commented on issue #9740: [hotfix][docs] URL should not point to release-1.8 docs

alpinegizmo commented on issue #9740: [hotfix][docs] URL should not point to release-1.8 docs URL: https://github.com/apache/flink/pull/9740#issuecomment-533881703 @KarmaGYZ I didn't include the link to release-1.6 in s3.md and s3.zh.md in this PR because I couldn't figure out what to do w

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326897974 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Commented] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16935296#comment-16935296 ] Terry Wang commented on FLINK-14076: This problem is caused by TM and JM jar packag

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326894440 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/ExecutionVertexSchedul

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326894495 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java ##

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326891379 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.ja

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326892524 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.ja

[GitHub] [flink] klion26 commented on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

klion26 commented on issue #9718: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9718#issuecomment-533865142 @AT-Fieldless thanks for your contribution, could you please clear the git history so that

[jira] [Updated] (FLINK-14163) Execution#producedPartitions may not be assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Summary: Execution#producedPartitions may not be assigned when used (was: A Task should be deployed only

[jira] [Updated] (FLINK-14163) Execution#producedPartitions is possibly not assigned when used

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Summary: Execution#producedPartitions is possibly not assigned when used (was: Execution#producedPartitio

[jira] [Updated] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Description: Currently {{Execution#producedPartitions}} is assigned after the partitions have completed t

[jira] [Updated] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Description: Currently {{Execution#producedPartitions}} is assigned after the partitions have completed t

[jira] [Updated] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Description: Currently {{Execution#producedPartitions}} is assigned after the partitions have completed t

[jira] [Updated] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

[ https://issues.apache.org/jira/browse/FLINK-14163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14163: Description: Currently {{Execution#producedPartitions}} is assigned after the partitions have completed t

[jira] [Created] (FLINK-14163) A Task should be deployed only after all its partitions have completed the registration

Zhu Zhu created FLINK-14163: --- Summary: A Task should be deployed only after all its partitions have completed the registration Key: FLINK-14163 URL: https://issues.apache.org/jira/browse/FLINK-14163 Project

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326888403 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326888403 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Created] (FLINK-14162) Unify SchedulerOperations#allocateSlotsAndDeploy implementation for all scheduling strategies

Zhu Zhu created FLINK-14162: --- Summary: Unify SchedulerOperations#allocateSlotsAndDeploy implementation for all scheduling strategies Key: FLINK-14162 URL: https://issues.apache.org/jira/browse/FLINK-14162 P

  1   2   >