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

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170589#comment-17170589 ] Dian Fu commented on FLINK-16361: - Thanks for the confirmation. Then I'm closing this ticket since all

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

2020-08-04 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 &

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

2020-08-04 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:

[GitHub] [flink] azagrebin commented on pull request #13028: [FLINK-18739] Implement MergingSharedSlotProfileRetriever

2020-08-04 Thread GitBox
azagrebin commented on pull request #13028: URL: https://github.com/apache/flink/pull/13028#issuecomment-668421378 Thanks for the review @zhuzhurk I have addressed the comments This is an automated message from the Apache

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

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

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

2020-08-04 Thread GitBox
dianfu commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-668433733 @morsapaes Thanks a lot for the kind reminder. Updated the blogpost date. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #13028: [FLINK-18739] Implement MergingSharedSlotProfileRetriever

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13028: URL: https://github.com/apache/flink/pull/13028#issuecomment-666235055 ## CI report: * 926fb3518b1b611b53901b4b9fcc834a0c0f9da1 Azure:

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

2020-08-04 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: Description: At present, we only register task-level numRecordsOut metric by reusing operator output

[jira] [Commented] (FLINK-15350) develop JDBC catalogs to connect to relational databases

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170633#comment-17170633 ] Dian Fu commented on FLINK-15350: - [~phoenixjiangnan] It seems that this feature is already committed to

[jira] [Created] (FLINK-18809) Update internal aggregate functions to new type system

2020-08-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-18809: Summary: Update internal aggregate functions to new type system Key: FLINK-18809 URL: https://issues.apache.org/jira/browse/FLINK-18809 Project: Flink Issue

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

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

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

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

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170641#comment-17170641 ] Piotr Nowojski commented on FLINK-18748: Thanks for the contribution [~wayland] and for the

[jira] [Commented] (FLINK-12130) Apply command line options to configuration before installing security modules

2020-08-04 Thread silence (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170648#comment-17170648 ] silence commented on FLINK-12130: - Have we solved it? It can be reproduced in the new version(1.11) >

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

2020-08-04 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

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

2020-08-04 Thread GitBox
shuttie commented on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-668430416 @rmetzger is there any chance that this PR can be reviewed? This is an automated message from the Apache Git

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170632#comment-17170632 ] Piotr Nowojski commented on FLINK-18748: merged to master as e422d42e09^ and e422d42e09 >

[jira] [Closed] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-18748. -- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed merged to

[GitHub] [flink] flinkbot edited a comment on pull request #13054: [FLINK-15803][table] Support DataViews in FLIP-65 aggregate functions

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13054: URL: https://github.com/apache/flink/pull/13054#issuecomment-668030431 ## CI report: * abedb100f5f02dc3249f58f8fb06e6f16f7246fb Azure:

[GitHub] [flink] tillrohrmann commented on pull request #13042: [FLINK-16510] Allow overriding of graceful with forceful shutdown

2020-08-04 Thread GitBox
tillrohrmann commented on pull request #13042: URL: https://github.com/apache/flink/pull/13042#issuecomment-668452463 Fair points. If it should ever become a problem that we set a custom `SecurityManager` we might have to revisit this problem. +1 for making the mechanism available

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

2020-08-04 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-04 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-04 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-web] dianfu closed pull request #364: Add blog post for Pandas support in PyFlink.

2020-08-04 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

[jira] [Commented] (FLINK-17001) Support LIKE clause in CREATE TABLE

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170627#comment-17170627 ] Dian Fu commented on FLINK-17001: - [~dwysakowicz] It seems that this feature is already merged in 1.11.

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

2020-08-04 Thread Etienne Chauchot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170643#comment-17170643 ] Etienne Chauchot commented on FLINK-17073: -- Hi Roman, thanks for your feedback. Yes indeed it

[GitHub] [flink] tillrohrmann commented on a change in pull request #13055: [FLINK-18677] Added handling of suspended or lost connections

2020-08-04 Thread GitBox
tillrohrmann commented on a change in pull request #13055: URL: https://github.com/apache/flink/pull/13055#discussion_r464889065 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionConnectionHandlingTest.java ## @@ -0,0

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

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

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

2020-08-04 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:

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

2020-08-04 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

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

2020-08-04 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-04 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 #12966: [FLINK-17427][table sql/planner]Support SupportsPartitionPushDown in …

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

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

2020-08-04 Thread GitBox
morsapaes commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-668417608 Thanks, @dianfu !  Just a reminder for the future to update the blogpost date (and, if possible, also the name of the file/images).

[GitHub] [flink] pnowojski merged pull request #13045: [FLINK-18748][checkpointing] trigger unperiodic checkpoint immediately

2020-08-04 Thread GitBox
pnowojski merged pull request #13045: URL: https://github.com/apache/flink/pull/13045 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

[jira] [Commented] (FLINK-11890) Replace Table API string-based expressions by a Java DSL

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170635#comment-17170635 ] Dian Fu commented on FLINK-11890: - [~dwysakowicz] It seems that the feature is already finished and we

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

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

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

2020-08-04 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] wuchong commented on a change in pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-08-04 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

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

2020-08-04 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) >

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

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #9188: URL: https://github.com/apache/flink/pull/9188#issuecomment-667675114 ## CI report: * 02633f3d642efda655c420da187d232616c55c0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13028: [FLINK-18739] Implement MergingSharedSlotProfileRetriever

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13028: URL: https://github.com/apache/flink/pull/13028#issuecomment-666235055 ## CI report: * eb0a8e585b2aba939c4a43ba409566f3df287848 Azure:

[jira] [Updated] (FLINK-15366) Improve FlinkCalcMergeRule to merge calc nodes better

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-15366: --- Parent: FLINK-16824 Issue Type: Sub-task (was: Bug) > Improve FlinkCalcMergeRule to merge

[jira] [Updated] (FLINK-18548) Dimension table do not support computed column

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Parent: FLINK-16824 Issue Type: Sub-task (was: Improvement) > Dimension table do not

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

2020-08-04 Thread GitBox
rmetzger commented on pull request #12929: URL: https://github.com/apache/flink/pull/12929#issuecomment-668435866 Sorry for the delay. I try to find somebody who can take a look. This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #13054: [FLINK-15803][table] Support DataViews in FLIP-65 aggregate functions

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13054: URL: https://github.com/apache/flink/pull/13054#issuecomment-668030431 ## CI report: * abedb100f5f02dc3249f58f8fb06e6f16f7246fb Azure:

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

2020-08-04 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 #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630661048 ## CI report: * f040c9efbb64404807c9fb94b5329c7c6c7aa865 Azure:

[GitHub] [flink] shuiqiangchen commented on a change in pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
shuiqiangchen commented on a change in pull request #13029: URL: https://github.com/apache/flink/pull/13029#discussion_r464914190 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -0,0 +1,523 @@

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

2020-08-04 Thread wangtaiyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170669#comment-17170669 ] wangtaiyang commented on FLINK-18681: - RM log is attached > The jar package version conflict causes

[GitHub] [flink] shuiqiangchen commented on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
shuiqiangchen commented on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-668490867 @hequn8128 Thank you for your comments, I have updated the code, please take a look at it. This is an

[GitHub] [flink] AHeise commented on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
AHeise commented on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-668501769 > Could you summarize what the problem was that caused the performance regression? For some reason, not setting a parent classloader in the wrapper is much slower. I

[jira] [Updated] (FLINK-18426) Incompatible deprecated key type for registration cluster options

2020-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18426: Fix Version/s: (was: 1.11.1) 1.11.0 > Incompatible deprecated key type for

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 1a3c5b93a697dea00a2e8237deb03b5848ffb1a9 UNKNOWN * be7e94a339fb20d1cee374495d8d8c1ac0af3c7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * 47ea974f8307084c080c6d343bf7b22296ed8b44 Azure:

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

2020-08-04 Thread GitBox
wuchong commented on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-668505104 Btw, could you add an integration test for this? This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #13054: [FLINK-15803][table] Support DataViews in FLIP-65 aggregate functions

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13054: URL: https://github.com/apache/flink/pull/13054#issuecomment-668030431 ## CI report: * abedb100f5f02dc3249f58f8fb06e6f16f7246fb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * 12aef53ea5dd1cbd52ad5dfd2351eff66e159669 Azure:

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

2020-08-04 Thread GitBox
twentyworld commented on pull request #12237: URL: https://github.com/apache/flink/pull/12237#issuecomment-668474902 thanks a lot for all of you guys’ comments. This is an automated message from the Apache Git Service. To

[GitHub] [flink-statefun] igalshilman commented on a change in pull request #128: [hotfix] fix python sdk example

2020-08-04 Thread GitBox
igalshilman commented on a change in pull request #128: URL: https://github.com/apache/flink-statefun/pull/128#discussion_r464908122 ## File path: docs/sdk/python.md ## @@ -132,23 +132,23 @@ The delayed message is non-blocking so functions will continue to process record The

[GitHub] [flink] flinkbot commented on pull request #13057: [hotfix][docsFix typo and correct the grammar

2020-08-04 Thread GitBox
flinkbot commented on pull request #13057: URL: https://github.com/apache/flink/pull/13057#issuecomment-668483814 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #13057: [hotfix][docs]Fix typo and correct the grammar

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13057: URL: https://github.com/apache/flink/pull/13057#issuecomment-668487041 ## CI report: * 768fa60772f66987aae6dce8c021144c56149548 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13054: [FLINK-15803][table] Support DataViews in FLIP-65 aggregate functions

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13054: URL: https://github.com/apache/flink/pull/13054#issuecomment-668030431 ## CI report: * abedb100f5f02dc3249f58f8fb06e6f16f7246fb Azure:

[jira] [Closed] (FLINK-18793) Fix Typo for api.common.eventtime.WatermarkStrategy Description

2020-08-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-18793. - Fix Version/s: (was: 1.11.1) 1.11.2 1.12.0

[jira] [Updated] (FLINK-18426) Incompatible deprecated key type for registration cluster options

2020-08-04 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-18426: Fix Version/s: (was: 1.11.0) 1.11.1 > Incompatible deprecated key type for

[GitHub] [flink] AHeise edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
AHeise edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-668501769 > Could you summarize what the problem was that caused the performance regression? For some reason, not setting a parent classloader in the wrapper is much slower.

[GitHub] [flink] AHeise commented on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
AHeise commented on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-668503396 There was also a [classloader leak in ORC](https://issues.apache.org/jira/browse/ORC-653), for which I added a workaround.

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * 47ea974f8307084c080c6d343bf7b22296ed8b44 Azure:

[jira] [Updated] (FLINK-18548) support flexible syntax for Temporal table

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Summary: support flexible syntax for Temporal table (was: Dimension table do not support computed

[GitHub] [flink] echauchot commented on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-08-04 Thread GitBox
echauchot commented on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-668518373 @ifndef-SleePy I applied your suggestions of the design doc PTAL. Also is the test I added enough ? This

[GitHub] [flink] flinkbot edited a comment on pull request #13027: [FLINK-16245] Decoupling user classloader from context classloader.

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13027: URL: https://github.com/apache/flink/pull/13027#issuecomment-666225612 ## CI report: * c03925d4b90fc68ef1d8a6d4189960724cd398cd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 1a3c5b93a697dea00a2e8237deb03b5848ffb1a9 UNKNOWN * be7e94a339fb20d1cee374495d8d8c1ac0af3c7b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13029: URL: https://github.com/apache/flink/pull/13029#issuecomment-666332680 ## CI report: * 1a3c5b93a697dea00a2e8237deb03b5848ffb1a9 UNKNOWN * 943ff7e98177dec676272e44eae6e8fb1a1fcd2a Azure:

[GitHub] [flink] wangyang0918 opened a new pull request #13058: [FLINK-18749][k8s] Correct dependencies in Kubernetes pom

2020-08-04 Thread GitBox
wangyang0918 opened a new pull request #13058: URL: https://github.com/apache/flink/pull/13058 ## What is the purpose of the change Inspired when developing this https://github.com/apache/flink/pull/12995/commits/8519f65321ba24c5164196a67a05d98fb268f490, i find some unused

[GitHub] [flink] wangyang0918 commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-04 Thread GitBox
wangyang0918 commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-668467089 cc @tillrohrmann, i have rebased the latest master and could you have a look at your convenience. This

[GitHub] [flink] flinkbot edited a comment on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-630661048 ## CI report: * f040c9efbb64404807c9fb94b5329c7c6c7aa865 Azure:

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

2020-08-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170657#comment-17170657 ] Roman Khachatryan commented on FLINK-17073: --- Hi Etienne,  You're right, I missed option 3.b

[GitHub] [flink] tillrohrmann commented on pull request #12240: [FLINK-15792][k8s] Make Flink logs accessible via kubectl logs per default

2020-08-04 Thread GitBox
tillrohrmann commented on pull request #12240: URL: https://github.com/apache/flink/pull/12240#issuecomment-668476098 Thanks for rebasing the PR @wangyang0918. Me or someone from my team will take a look at it shortly. This

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

2020-08-04 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 #12917: [FLINK-18355][tests] Simplify tests of SlotPoolImpl

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

[GitHub] [flink] hequn8128 commented on a change in pull request #13029: [FLINK-18763][python] Support basic TypeInformation for Python DataSt…

2020-08-04 Thread GitBox
hequn8128 commented on a change in pull request #13029: URL: https://github.com/apache/flink/pull/13029#discussion_r464911311 ## File path: flink-python/pyflink/common/typeinfo.py ## @@ -0,0 +1,523 @@

[GitHub] [flink] diohabara opened a new pull request #13057: [hotfix][docsFix typo and correct the grammar

2020-08-04 Thread GitBox
diohabara opened a new pull request #13057: URL: https://github.com/apache/flink/pull/13057 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] flinkbot commented on pull request #13057: [hotfix][docsFix typo and correct the grammar

2020-08-04 Thread GitBox
flinkbot commented on pull request #13057: URL: https://github.com/apache/flink/pull/13057#issuecomment-668487041 ## CI report: * 768fa60772f66987aae6dce8c021144c56149548 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #12962: URL: https://github.com/apache/flink/pull/12962#issuecomment-662526701 ## CI report: * d2275584151f5a0a342af15e1d06f33da1237d62 UNKNOWN * d49f2f7ffe75a2e39dc3b8925831c60b56683952 Azure:

[GitHub] [flink] tillrohrmann closed pull request #13041: FLINK-18793 Fix Typo for api.common.eventtime.WatermarkStrategy Description

2020-08-04 Thread GitBox
tillrohrmann closed pull request #13041: URL: https://github.com/apache/flink/pull/13041 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

[jira] [Updated] (FLINK-18793) Fix Typo for api.common.eventtime.WatermarkStrategy Description

2020-08-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-18793: -- Issue Type: Improvement (was: Bug) > Fix Typo for api.common.eventtime.WatermarkStrategy

[jira] [Updated] (FLINK-18548) support flexible syntax for Temporal table

2020-08-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18548: --- Description: The reason why Flink does not support computed column in dimension(temporal) table is

[jira] [Created] (FLINK-18810) Golang remote functions SDK

2020-08-04 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-18810: --- Summary: Golang remote functions SDK Key: FLINK-18810 URL: https://issues.apache.org/jira/browse/FLINK-18810 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot edited a comment on pull request #13040: [FLINK-17073] [checkpointing] checkpointing backpressure if there are too many checkpoints to clean

2020-08-04 Thread GitBox
flinkbot edited a comment on pull request #13040: URL: https://github.com/apache/flink/pull/13040#issuecomment-667140037 ## CI report: * 31abcb25fdf72394dbfa91d0ba9e151968375ad7 UNKNOWN * 12aef53ea5dd1cbd52ad5dfd2351eff66e159669 Azure:

[jira] [Updated] (FLINK-18749) Correct dependencies in Kubernetes pom

2020-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18749: --- Labels: pull-request-available (was: ) > Correct dependencies in Kubernetes pom >

[jira] [Commented] (FLINK-18749) Correct dependencies in Kubernetes pom

2020-08-04 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170725#comment-17170725 ] Yang Wang commented on FLINK-18749: --- [~trohrmann] Yes, it is also a issue for master branch. I have

[GitHub] [flink] flinkbot commented on pull request #13058: [FLINK-18749][k8s] Correct dependencies in Kubernetes pom

2020-08-04 Thread GitBox
flinkbot commented on pull request #13058: URL: https://github.com/apache/flink/pull/13058#issuecomment-668534179 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

2020-08-04 Thread sunjincheng (Jira)
sunjincheng created FLINK-18816: --- Summary: Correct API usage in Pyflink Dependency Management page Key: FLINK-18816 URL: https://issues.apache.org/jira/browse/FLINK-18816 Project: Flink Issue

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

2020-08-04 Thread GitBox
danny0405 commented on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645 > Could you name a few of these breaking changes? I know about the dropped windows but what else? I listed some features i though important (very probably breaking)

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

2020-08-04 Thread GitBox
danny0405 edited a comment on pull request #13050: URL: https://github.com/apache/flink/pull/13050#issuecomment-668928645 > Could you name a few of these breaking changes? I know about the dropped windows but what else? I listed some features i though important (very probably

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

2020-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18764: --- Labels: pull-request-available (was: ) > Support from_collection for Python DataStream API

[GitHub] [flink] shuiqiangchen opened a new pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
shuiqiangchen opened a new pull request #13061: URL: https://github.com/apache/flink/pull/13061 ## What is the purpose of the change Introduced a new class named DataStream including its common interfaces. And support to get a DataStream through

[jira] [Comment Edited] (FLINK-18819) All the PubSub tests are failing

2020-08-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171237#comment-17171237 ] Dian Fu edited comment on FLINK-18819 at 8/5/20, 2:49 AM: -- It's probably caused

[jira] [Commented] (FLINK-18749) Correct dependencies in Kubernetes pom

2020-08-04 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171223#comment-17171223 ] Yang Wang commented on FLINK-18749: --- Hi [~trohrmann], I notice that you have changed the {{Fix

[GitHub] [flink] flinkbot commented on pull request #13061: [FLINK-18764][python] Add DataStream class and support from_collectio…

2020-08-04 Thread GitBox
flinkbot commented on pull request #13061: URL: https://github.com/apache/flink/pull/13061#issuecomment-668934853 ## CI report: * 8ccc4bad17d568058446ad6816a6d181f090ecf0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

  1   2   3   >