[GitHub] [flink] flinkbot edited a comment on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-662526701 ## CI report: * Unknown: [CANCELED](TBD) * d2275584151f5a0a342af15e1d06f33da1237d62 UNKNOWN * d49f2f7ffe75a2e39dc3b8925831c60b56683952 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #9188: URL: https://github.com/apache/flink/pull/9188#issuecomment-667675114 ## CI report: * fc4dfc21708ce2a5f96883943aabc3f763a936c3 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/178156194) *

[GitHub] [flink] flinkbot edited a comment on pull request #9008: [FLINK-12942][docs-zh] Translate Elasticsearch Connector page into Ch…

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #9008: URL: https://github.com/apache/flink/pull/9008#issuecomment-667675075 ## CI report: * 5c26184832b9ed1b3aa75e4af2d3b645aba3cf9a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-662526701 ## CI report: * Unknown: [CANCELED](TBD) * d2275584151f5a0a342af15e1d06f33da1237d62 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] kbohinski commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
kbohinski commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-668388353 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #9188: URL: https://github.com/apache/flink/pull/9188#issuecomment-667675114 ## CI report: * fc4dfc21708ce2a5f96883943aabc3f763a936c3 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/178156194) *

[GitHub] [flink] flinkbot edited a comment on pull request #9008: [FLINK-12942][docs-zh] Translate Elasticsearch Connector page into Ch…

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #9008: URL: https://github.com/apache/flink/pull/9008#issuecomment-667675075 ## CI report: * 4aeb231dd64d18cfb39dad3558516ec9228d980c Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/178156187) *

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] klion26 commented on pull request #13045: [FLINK-18748][checkpointing] trigger unperiodic checkpoint immediately

2020-08-03 Thread GitBox
klion26 commented on pull request #13045: URL: https://github.com/apache/flink/pull/13045#issuecomment-668383757 @DG-Wangtao thanks for the work. LGTM from my side. This is an automated message from the Apache Git Service.

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] XuQianJin-Stars commented on pull request #9008: [FLINK-12942][docs-zh] Translate Elasticsearch Connector page into Ch…

2020-08-03 Thread GitBox
XuQianJin-Stars commented on pull request #9008: URL: https://github.com/apache/flink/pull/9008#issuecomment-668378044 > @XuQianJin-Stars thanks for the contribution. Seems there are some conflicts now, could you please rebase the master to resolve the conflict? well, let me rebase

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-18806) Taskmanager doesn't start up with error in config

2020-08-03 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170542#comment-17170542 ] Yangze Guo commented on FLINK-18806: FYI: That has been fixed in FLINK-18639. > Taskmanager doesn't

[jira] [Commented] (FLINK-16361) FLIP-84: Improve & Refactor API of TableEnvironment & Table

2020-08-03 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170540#comment-17170540 ] godfrey he commented on FLINK-16361: Hi [~dian.fu], all the subtasks are finished in 1.11, except

[jira] [Closed] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-08-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18756. --- Resolution: Fixed Implemented in master (1.12.0): 8df10fa589b0897071321aeb3a4db2936e69b778 > Support IF

[GitHub] [flink] wuchong merged pull request #13037: [FLINK-18756][table-api] Support IF NOT EXISTS for CREATE TABLE statement

2020-08-03 Thread GitBox
wuchong merged pull request #13037: URL: https://github.com/apache/flink/pull/13037 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13009: URL: https://github.com/apache/flink/pull/13009#issuecomment-665109698 ## CI report: * d7133401edf323e5be894758398098e70cf70506 Azure:

[jira] [Updated] (FLINK-18803) JobGraph cannot be GC when submit via RemoteStreamEnvironment in attach mode

2020-08-03 Thread Libin Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Libin Qin updated FLINK-18803: -- Description: When submit job using  RemoteStreamEnvironment in attach mode. The client submission

[jira] [Created] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2020-08-03 Thread ming li (Jira)
ming li created FLINK-18808: --- Summary: Task-level numRecordsOut metric may be underestimated Key: FLINK-18808 URL: https://issues.apache.org/jira/browse/FLINK-18808 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18808) Task-level numRecordsOut metric may be underestimated

2020-08-03 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ming li updated FLINK-18808: Environment: (was: !image-2020-08-04-11-26-21-490.png!) > Task-level numRecordsOut metric may be

[GitHub] [flink] flinkbot edited a comment on pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13009: URL: https://github.com/apache/flink/pull/13009#issuecomment-665109698 ## CI report: * d7133401edf323e5be894758398098e70cf70506 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-17726) Scheduler should take care of tasks directly canceled by TaskManager

2020-08-03 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170531#comment-17170531 ] Zhu Zhu commented on FLINK-17726: - Hi [~nicholasjiang], is there any updates for the design? >

[jira] [Commented] (FLINK-18641) "Failure to finalize checkpoint" error in MasterTriggerRestoreHook

2020-08-03 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170530#comment-17170530 ] Jiangjie Qin commented on FLINK-18641: -- [~pnowojski] [~SleePy] Somehow the PR info was not updated

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-16579) Upgrade Calcite version to 1.23 for Flink SQL

2020-08-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170525#comment-17170525 ] Leonard Xu commented on FLINK-16579: +1 for this. > Upgrade Calcite version to 1.23 for Flink SQL >

[GitHub] [flink-web] KarmaGYZ edited a comment on pull request #365: Add blog post for External Resources

2020-08-03 Thread GitBox
KarmaGYZ edited a comment on pull request #365: URL: https://github.com/apache/flink-web/pull/365#issuecomment-668356135 cc @tillrohrmann @MarkSfik This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-16824) Creating Temporal Table Function via DDL

2020-08-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16824: --- Assignee: Leonard Xu (was: Leonardo Aoun) > Creating Temporal Table Function via DDL >

[jira] [Assigned] (FLINK-16824) Creating Temporal Table Function via DDL

2020-08-03 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16824: --- Assignee: Leonardo Aoun > Creating Temporal Table Function via DDL >

[GitHub] [flink-web] KarmaGYZ commented on pull request #365: Add blog post for External Resources

2020-08-03 Thread GitBox
KarmaGYZ commented on pull request #365: URL: https://github.com/apache/flink-web/pull/365#issuecomment-668356135 cc @tillrohrmann This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink-web] KarmaGYZ opened a new pull request #365: Add blog post for External Resources

2020-08-03 Thread GitBox
KarmaGYZ opened a new pull request #365: URL: https://github.com/apache/flink-web/pull/365 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 6697110fb14fef778707f74b66227df2953c487c Azure:

[jira] [Commented] (FLINK-16824) Creating Temporal Table Function via DDL

2020-08-03 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170524#comment-17170524 ] Leonard Xu commented on FLINK-16824: I'd like to support this feature, [~jark] could you assign this

[GitHub] [flink] flinkbot edited a comment on pull request #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12966: URL: https://github.com/apache/flink/pull/12966#issuecomment-662861328 ## CI report: * 6697110fb14fef778707f74b66227df2953c487c Azure:

[jira] [Commented] (FLINK-15792) Make Flink logs accessible via kubectl logs per default

2020-08-03 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170521#comment-17170521 ] Yang Wang commented on FLINK-15792: --- [~rmetzger] Thanks for your input. I will update the old attached

[GitHub] [flink] RocMarshal commented on pull request #13056: [FLINK-18798][docs-zh] Translate "Debugging Windows & Event Time" page of "Debugging & Monitoring" into Chinese

2020-08-03 Thread GitBox
RocMarshal commented on pull request #13056: URL: https://github.com/apache/flink/pull/13056#issuecomment-668313570 Hi, @klion26 . Could you help me to review this PR if you have free time? Thank you. This is an

[jira] [Commented] (FLINK-16361) FLIP-84: Improve & Refactor API of TableEnvironment & Table

2020-08-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170509#comment-17170509 ] Dian Fu commented on FLINK-16361: - Hi [~godfreyhe], it seems that all the subtasks have already been

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] hackergin commented on a change in pull request #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-08-03 Thread GitBox
hackergin commented on a change in pull request #11896: URL: https://github.com/apache/flink/pull/11896#discussion_r464431110 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/format/single/SingleValueFormatFactory.java ## @@ -0,0 +1,112

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 1a2f39a71a931295f82a9bdbd36f2707f42298dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-18675) Checkpoint not maintaining minimum pause duration between checkpoints

2020-08-03 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170497#comment-17170497 ] Congxian Qiu(klion26) commented on FLINK-18675: --- [~raviratnakar] I think the problem here

[jira] [Commented] (FLINK-16768) HadoopS3RecoverableWriterITCase.testRecoverWithStateWithMultiPart hangs

2020-08-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170492#comment-17170492 ] Dian Fu commented on FLINK-16768: -

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-08-03 Thread Tao Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170491#comment-17170491 ] Tao Yang commented on FLINK-18681: -- Hi, [~xintongsong], [~apach...@163.com], sorry for responding so

[GitHub] [flink] flinkbot edited a comment on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442 ## CI report: * 1a2f39a71a931295f82a9bdbd36f2707f42298dd Azure:

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

2020-08-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18807: Labels: test-stability (was: ) > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with

[GitHub] [flink] flinkbot edited a comment on pull request #12929: [FLINK-18631] [serialization] Serializer for scala sealed trait hierarchies

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-660169673 ## CI report: * feb4cadb5b16140e0477944d4ecf99cc208a4d38 Azure:

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

2020-08-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18807: Description:

[jira] [Created] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

2020-08-03 Thread Dian Fu (Jira)
Dian Fu created FLINK-18807: --- Summary: FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 6milliseconds while awaiting EndTxn(COMMIT)" Key: FLINK-18807 URL:

[jira] [Updated] (FLINK-18807) FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout expired after 60000milliseconds while awaiting EndTxn(COMMIT)"

2020-08-03 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-18807: Component/s: Tests > FlinkKafkaProducerITCase.testScaleUpAfterScalingDown failed with "Timeout > expired

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink-web] sunjincheng121 commented on pull request #364: Add blog post for Pandas support in PyFlink.

2020-08-03 Thread GitBox
sunjincheng121 commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-668296976 Thanks for the detail review @morsapaes @dianfu . Hi Dian, before merging we can have a little bit discussion about virtual env part, because,if `python` command

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] zentol commented on a change in pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
zentol commented on a change in pull request #12917: URL: https://github.com/apache/flink/pull/12917#discussion_r464710835 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolTestBase.java ## @@ -0,0 +1,96 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink-statefun] sjwiesman opened a new pull request #128: [hotfix] fix python sdk example

2020-08-03 Thread GitBox
sjwiesman opened a new pull request #128: URL: https://github.com/apache/flink-statefun/pull/128 The python delayed message example code was incorrect. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12929: [FLINK-18631] [serialization] Serializer for scala sealed trait hierarchies

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-660169673 ## CI report: * feb4cadb5b16140e0477944d4ecf99cc208a4d38 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-03 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170437#comment-17170437 ] Roman Khachatryan commented on FLINK-18796: --- I'm not sure whether it's actually a problem,

[GitHub] [flink] flinkbot edited a comment on pull request #12929: [FLINK-18631] [serialization] Serializer for scala sealed trait hierarchies

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-660169673 ## CI report: * c2a61b6c21c4b47c83bde923101c01b6c169e30d Azure:

[GitHub] [flink] shuttie commented on pull request #12929: [FLINK-18631] [serialization] Serializer for scala sealed trait hierarchies

2020-08-03 Thread GitBox
shuttie commented on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-668238686 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170419#comment-17170419 ] Chesnay Schepler commented on FLINK-18796: -- Why would this be a problem _now_? We've used this

[GitHub] [flink] flinkbot edited a comment on pull request #13045: [FLINK-18748][checkpointing] trigger unperiodic checkpoint immediately

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13045: URL: https://github.com/apache/flink/pull/13045#issuecomment-667703208 ## CI report: * bc1a115c8825526c96674b35effceabc7542d0c2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[jira] [Updated] (FLINK-5552) Introduce JVM-wide JMX server

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5552: Summary: Introduce JVM-wide JMX server (was: Make the JMX port available through RESTful

[jira] [Closed] (FLINK-5552) Introduce JVM-wide JMX server

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5552. --- Fix Version/s: 1.12.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #11586: [FLINK-5552][runtime] make JMXServer static per JVM

2020-08-03 Thread GitBox
zentol merged pull request #11586: URL: https://github.com/apache/flink/pull/11586 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-16566) Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos integration

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16566. Fix Version/s: 1.12.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #13046: [FLINK-16566][mesos] Change the log level of the launching command and dynamic properties from DEBUG to INFO in Mesos

2020-08-03 Thread GitBox
zentol merged pull request #13046: URL: https://github.com/apache/flink/pull/13046 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-18663) RestServerEndpoint may prevent server shutdown

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-18663: - Summary: RestServerEndpoint may prevent server shutdown (was: Fix Flink On YARN AM not

[jira] [Closed] (FLINK-18663) Fix Flink On YARN AM not exit

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-18663. Fix Version/s: 1.11.2 1.12.0 1.10.2

[GitHub] [flink] zentol merged pull request #13020: [FLINK-18663][rest] Fix the exception occurred on AbstractHandler#handleException but not handled

2020-08-03 Thread GitBox
zentol merged pull request #13020: URL: https://github.com/apache/flink/pull/13020 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Closed] (FLINK-16619) Misleading SlotManagerImpl logging for slot reports of unknown task manager

2020-08-03 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16619. Fix Version/s: 1.11.2 1.12.0 1.10.2

[GitHub] [flink] zentol merged pull request #13049: [FLINK-16619][coordination] Log reception of slot reports only once

2020-08-03 Thread GitBox
zentol merged pull request #13049: URL: https://github.com/apache/flink/pull/13049 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13018: [FLINK-18709][Coordination] Implement PhysicalSlotProvider

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13018: URL: https://github.com/apache/flink/pull/13018#issuecomment-665565029 ## CI report: * 82cf917b212932113f018bd05fc02c3f6379 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13055: FLINK-18677: [fix] Added handling of suspended or lost connections

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13055: URL: https://github.com/apache/flink/pull/13055#issuecomment-668083003 ## CI report: * ed6fb2c77645701eb585d2700c852657b1f66fc9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] kbohinski commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
kbohinski commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-668187486 Ah sorry, thought it had to do with azure command. Sorry & thx! This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13009: URL: https://github.com/apache/flink/pull/13009#issuecomment-665109698 ## CI report: * d7133401edf323e5be894758398098e70cf70506 Azure:

[GitHub] [flink] rmetzger commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
rmetzger commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-668167696 This is the error the CI system is reporting ``` 2020-07-23T23:08:09.6743463Z java.lang.AssertionError: The API was modified in a compatible way, but the snapshot was not

[GitHub] [flink] dawidwys commented on pull request #13050: [FLINK-18750][table] SqlValidatorException thrown when select from a …

2020-08-03 Thread GitBox
dawidwys commented on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668164712 Are we planning to bump Calcite version for 1.12? @wuchong @twalthr If we do, I'd prefer we do not add this workaround. If we don't the PR looks good to me

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * da90885d695cf70c147481bbaa8c8be005a13a4c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13009: URL: https://github.com/apache/flink/pull/13009#issuecomment-665109698 ## CI report: * 044578bc01da8b57e29a483ee2560a0e8f61148a Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #13018: [FLINK-18709][Coordination] Implement PhysicalSlotProvider

2020-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #13018: URL: https://github.com/apache/flink/pull/13018#discussion_r464561183 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImplTest.java ## @@ -78,12 +76,11 @@ public

[GitHub] [flink] kbohinski commented on pull request #12962: [FLINK-18694] Add unaligned checkpoint config to web ui

2020-08-03 Thread GitBox
kbohinski commented on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-668147556 Hey @rmetzger not sure what to do with build output. This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #13020: [FLINK-18663][rest] Fix the exception occurred on AbstractHandler#handleException but not handled

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13020: URL: https://github.com/apache/flink/pull/13020#issuecomment-665606861 ## CI report: * 0d374f52f0c0c40585dc9bad5962aa52cb602b21 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #13009: URL: https://github.com/apache/flink/pull/13009#issuecomment-665109698 ## CI report: * 044578bc01da8b57e29a483ee2560a0e8f61148a Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r464556912 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] zhuzhurk commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r464556766 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] zhuzhurk commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r464556118 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-08-03 Thread GitBox
flinkbot edited a comment on pull request #12917: URL: https://github.com/apache/flink/pull/12917#issuecomment-659940433 ## CI report: * da7fb96fc00acda2a4c103f5f177efb9bd9be8be UNKNOWN * ae4c6182cbbf1441b85df2d82dfd36c3daf7db33 Azure:

[GitHub] [flink] zhuzhurk commented on a change in pull request #13009: [FLINK-18690][runtime] Implement LocalInputPreferredSlotSharingStrategy

2020-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #13009: URL: https://github.com/apache/flink/pull/13009#discussion_r464542910 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -0,0 +1,297 @@ +/* + *

  1   2   3   >