[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: [FAILURE](https://dev.azure.com/apache-fl

[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: * 1790d93b79cfdfc3f65a7805e444699736f80d93 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-18800) Avro serialization schema doesn't support Kafka key/value serialization

2020-08-03 Thread Mohammad Hossein Gerami (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mohammad Hossein Gerami updated FLINK-18800: Description: {color:#ff8b00}[AvroSerializationSchema|[https://ci.apache.or

[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: * 02633f3d642efda655c420da187d232616c55c0a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[jira] [Updated] (FLINK-18071) CoordinatorEventsExactlyOnceITCase.checkListContainsSequence fails on CI

2020-08-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-18071: --- Priority: Critical (was: Blocker) > CoordinatorEventsExactlyOnceITCase.checkListContainsSeq

[GitHub] [flink] wuchong commented on a change in pull request #12880: [FLINK-18555][table sql/api] Make TableConfig options can be configur…

2020-08-03 Thread GitBox
wuchong commented on a change in pull request #12880: URL: https://github.com/apache/flink/pull/12880#discussion_r464833799 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/TableConfigOptions.java ## @@ -51,4 +52,24 @@ private Tabl

[GitHub] [flink] wuchong commented on a change in pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-08-03 Thread GitBox
wuchong commented on a change in pull request #12908: URL: https://github.com/apache/flink/pull/12908#discussion_r464809980 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryBase.java #

[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: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Closed] (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:all-tabpanel ] Dian Fu closed FLINK-16361. --- Fix Version/s: (was: 1.12.0) 1.11.0 Resolution: Fixed > FLIP-84: Improve & Ref

[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&focusedCommentId=17170589#comment-17170589 ] Dian Fu commented on FLINK-16361: - Thanks for the confirmation. Then I'm closing this ti

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

2020-08-03 Thread GitBox
dianfu closed pull request #364: URL: https://github.com/apache/flink-web/pull/364 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 t

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

2020-08-03 Thread GitBox
dianfu commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-668405192 @sunjincheng121 As discussed offline, I'll remove the part about how to setup Python virtual environment during merging. ---

[jira] [Closed] (FLINK-17290) Translate Streaming Analytics training lesson to Chinese

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

[GitHub] [flink] wuchong merged pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-08-03 Thread GitBox
wuchong merged pull request #12237: URL: https://github.com/apache/flink/pull/12237 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] wuchong commented on pull request #12237: [FLINK-17290] [chinese-translation, Documentation / Training] Transla…

2020-08-03 Thread GitBox
wuchong commented on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-668404560 Thanks for the great work, @klion26 @twentyworld . Merging... This is an automated message from the Apac

[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 Azure: [PENDING]

[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: * e274e166aed3ffacc4ac58409aaf3384c937cb66 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[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) * 02633f3d642efda655

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

[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, pleas

[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) * 02633f3d642efda655

[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) * 5c26184832b9ed1b3a

[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: [FAILURE](https://dev.azure.com/apache-fl

[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. 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: [FAILURE](https://dev.azure.com/apache-fl

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170542#comment-17170542 ] Yangze Guo commented on FLINK-18806: FYI: That has been fixed in FLINK-18639. > Tas

[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&focusedCommentId=17170540#comment-17170540 ] godfrey he commented on FLINK-16361: Hi [~dian.fu], all the subtasks are finished in

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170531#comment-17170531 ] Zhu Zhu commented on FLINK-17726: - Hi [~nicholasjiang], is there any updates for the des

[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&focusedCommentId=17170530#comment-17170530 ] Jiangjie Qin commented on FLINK-18641: -- [~pnowojski] [~SleePy] Somehow the PR info

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170525#comment-17170525 ] Leonard Xu commented on FLINK-16579: +1 for this. > Upgrade Calcite version to 1.23

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

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

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17170524#comment-17170524 ] Leonard Xu commented on FLINK-16824: I'd like to support this feature, [~jark] could

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17170521#comment-17170521 ] Yang Wang commented on FLINK-15792: --- [~rmetzger] Thanks for your input. I will update

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

[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&focusedCommentId=17170509#comment-17170509 ] Dian Fu commented on FLINK-16361: - Hi [~godfreyhe], it seems that all the subtasks have

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170497#comment-17170497 ] Congxian Qiu(klion26) commented on FLINK-18675: --- [~raviratnakar] I think t

[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&focusedCommentId=17170492#comment-17170492 ] Dian Fu commented on FLINK-16768: - https://dev.azure.com/apache-flink/apache-flink/_buil

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170491#comment-17170491 ] Tao Yang commented on FLINK-18681: -- Hi, [~xintongsong], [~apach...@163.com], sorry for

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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 "Timeou

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5142&view=logs&j=c5f00

[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: https://issues.apach

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

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

[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: [FAILURE](https://dev.azure.com/apache-fl

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

[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&focusedCommentId=17170437#comment-17170437 ] Roman Khachatryan commented on FLINK-18796: --- I'm not sure whether it's actuall

[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: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17170419#comment-17170419 ] Chesnay Schepler commented on FLINK-18796: -- Why would this be a problem _now_?

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

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

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

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

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

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

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

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

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

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

[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: [FAILURE](https://dev.azure.com/apache-fl

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: [FAILURE](https://dev.azure.com/apache-fl

  1   2   3   >