[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

[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

[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

[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

[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=16935547#comment-16935547 ] Jingsong Lee commented on FLINK-13869: -- Still need fix, 1.9 should work, but master code has some

[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:

[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:

[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:

[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:

[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:

[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:

[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

[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=16935540#comment-16935540 ] Jeff Zhang commented on FLINK-11970: ping [~tiwalter] > TableEnvironment#registerFunction should

[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=16935538#comment-16935538 ] Jark Wu commented on FLINK-13869: - Is there any progress on this issue ? > Hive functions can not work

[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

[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

[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:

[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:

[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

[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:

[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:

[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=16935530#comment-16935530 ] Jark Wu commented on FLINK-13862: - I agree with [~fhueske] that the plan visualizer is useful without

[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=16935527#comment-16935527 ] Yingjie Cao commented on FLINK-14118: - [~pnowojski] Your concern is reasonable. I'd like to test the

[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

[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

[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:

[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:

[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:

[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:

[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:

[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

[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?

[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:

[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:

[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

[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

[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=16935515#comment-16935515 ] Jark Wu commented on FLINK-13661: - You can leave your thoughts in this 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=16935513#comment-16935513 ] ShenDa edited comment on FLINK-13661 at 9/23/19 2:27 AM: - OK thanks, [~jark].

[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

[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=16935513#comment-16935513 ] ShenDa commented on FLINK-13661: OK thanks, [~jark]. Where cloud we find or join this design discuss? >

[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=16935508#comment-16935508 ] Jark Wu commented on FLINK-13680: - Hi [~ClownfishYang], thanks for the work! But please request the

[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=16935507#comment-16935507 ] Jark Wu commented on FLINK-13661: - Hi [~DaDaShen], this is on the roadmap but there's no design yet. We

[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

[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=16935501#comment-16935501 ] ShenDa commented on FLINK-13661: Hi  all, is there any progress or issue of combined table that combines

[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:

[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

[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:

[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:

[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_r326905980 ## File path:

[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:

[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:

[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:

[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:

[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:

[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:

[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=16935323#comment-16935323 ] Congxian Qiu(klion26) commented on FLINK-13148: --- Hi, [~kkl0u] do you think we can have

[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:

[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

[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=16935296#comment-16935296 ] Terry Wang commented on FLINK-14076: This problem is caused by TM and JM jar package environment

[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:

[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:

[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:

[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

[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:

[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

[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

[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

[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

[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

[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

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

gyfora 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_r326887841 ## File path:

[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 :

[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_r326886263 ## File path:

[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_r326886164 ## File path:

[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_r326886164 ## File path:

[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 :

[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-533853887 @flinkbot run travis

[jira] [Commented] (FLINK-14150) Unnecessary __pycache__ directories appears in pyflink.zip

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935223#comment-16935223 ] Hequn Cheng commented on FLINK-14150: - Fix in 1.10.0 via 8155d465520c4b616866d35395c3b10f7e809b78

[jira] [Closed] (FLINK-14150) Unnecessary __pycache__ directories appears in pyflink.zip

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14150. --- Resolution: Fixed > Unnecessary __pycache__ directories appears in pyflink.zip >

[jira] [Updated] (FLINK-14150) Unnecessary __pycache__ directories appears in pyflink.zip

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14150: Fix Version/s: 1.9.1 1.10.0 > Unnecessary __pycache__ directories appears in

[GitHub] [flink] hequn8128 closed pull request #9729: [FLINK-14150][python] Clean up the __pycache__ directories and other empty directories in flink-python source code folder before packaging.

hequn8128 closed pull request #9729: [FLINK-14150][python] Clean up the __pycache__ directories and other empty directories in flink-python source code folder before packaging. URL: https://github.com/apache/flink/pull/9729

  1   2   >