[jira] [Updated] (FLINK-20482) Support Map Operation in Python Table API

2020-12-04 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20482: - Description: Add Map Operation in Python Table API The usage: {code:java} t = ... # type: Tabl

[jira] [Updated] (FLINK-20482) Support General Python UDF for Map Operation in Python Table API

2020-12-04 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20482: - Description: Support General Python UDF for Map Operation in Python Table API The usage: {code:

[jira] [Updated] (FLINK-20482) Support General Python UDF for Map Operation in Python Table API

2020-12-04 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-20482: - Summary: Support General Python UDF for Map Operation in Python Table API (was: Support Map Ope

[jira] [Created] (FLINK-20483) Support Pandas UDF for Map Operation in Python Table API

2020-12-04 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-20483: Summary: Support Pandas UDF for Map Operation in Python Table API Key: FLINK-20483 URL: https://issues.apache.org/jira/browse/FLINK-20483 Project: Flink Issu

[GitHub] [flink] dawidwys closed pull request #14275: [FLINK-20432] Add timeouts to SQLClientSchemaRegistryITCase

2020-12-04 Thread GitBox
dawidwys closed pull request #14275: URL: https://github.com/apache/flink/pull/14275 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-20432) SQLClientSchemaRegistryITCase hangs

2020-12-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243837#comment-17243837 ] Dawid Wysakowicz commented on FLINK-20432: -- I added timeouts in hope we will ge

[jira] [Assigned] (FLINK-20479) Support Row-based Operations in Python Table API

2020-12-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20479: --- Assignee: Huang Xingbo > Support Row-based Operations in Python Table API > ---

[jira] [Assigned] (FLINK-20482) Support General Python UDF for Map Operation in Python Table API

2020-12-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20482: --- Assignee: Huang Xingbo > Support General Python UDF for Map Operation in Python Table API > ---

[jira] [Updated] (FLINK-20479) Support Row-based Operations in Python Table API

2020-12-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-20479: Description: We have support for [Row-based|https://issues.apache.org/jira/browse/FLINK-10972] Operations

[jira] [Assigned] (FLINK-20483) Support Pandas UDF for Map Operation in Python Table API

2020-12-04 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20483: --- Assignee: Huang Xingbo > Support Pandas UDF for Map Operation in Python Table API > ---

[GitHub] [flink] flinkbot edited a comment on pull request #14303: [FLINK-20379][Connector/Kafka] Improve the KafkaRecordDesrializer interface

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14303: URL: https://github.com/apache/flink/pull/14303#issuecomment-738079106 ## CI report: * d78c1394221de2af440a7a4d3e0b500d1d6f188a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink-statefun] wangzzu commented on pull request #176: [FLINK-18968] Translate README.md to Chinese

2020-12-04 Thread GitBox
wangzzu commented on pull request #176: URL: https://github.com/apache/flink-statefun/pull/176#issuecomment-738651121 @klion26 thx, the commits have been squashed. This is an automated message from the Apache Git Service. To

[jira] [Created] (FLINK-20484) Improve hive temporal table exception

2020-12-04 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-20484: -- Summary: Improve hive temporal table exception Key: FLINK-20484 URL: https://issues.apache.org/jira/browse/FLINK-20484 Project: Flink Issue Type: Bug

[GitHub] [flink-web] azagrebin opened a new pull request #398: Pipelined region scheduling blogpost

2020-12-04 Thread GitBox
azagrebin opened a new pull request #398: URL: https://github.com/apache/flink-web/pull/398 [gdoc original](https://docs.google.com/document/d/1YMjpgblsWF9wlChaWj-oW5x14vafNjczCMpx94YXt7E) This is an automated message from t

[GitHub] [flink-web] azagrebin commented on pull request #398: Pipelined region scheduling blogpost

2020-12-04 Thread GitBox
azagrebin commented on pull request #398: URL: https://github.com/apache/flink-web/pull/398#issuecomment-738657699 cc @morsapaes @rmetzger @tillrohrmann This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-20422) Remove {{ site.baseurl }} from .html files in flink documentation

2020-12-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-20422: Assignee: Dawid Wysakowicz > Remove {{ site.baseurl }} from .html files in flink

[jira] [Created] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Rui Li (Jira)
Rui Li created FLINK-20486: -- Summary: Hive temporal join shouldn't require a minimal 1h monitor interval Key: FLINK-20486 URL: https://issues.apache.org/jira/browse/FLINK-20486 Project: Flink Issue

[jira] [Created] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread Timo Walther (Jira)
Timo Walther created FLINK-20485: Summary: Map views are deserialized multiple times Key: FLINK-20485 URL: https://issues.apache.org/jira/browse/FLINK-20485 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20485: - Affects Version/s: 1.12.0 > Map views are deserialized multiple times >

[jira] [Updated] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-20485: - Description: The rework of aggregate functions in FLINK-18809 and FLINK-15803 caused a performan

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
V1ncentzzZ commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535940439 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -429,6 +429,26 @@ cla

[jira] [Updated] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20486: --- Description: Currently hive temporal join requires the monitor interval to be at least 1h, which may not fit

[GitHub] [flink] wangyang0918 commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
wangyang0918 commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r535939587 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[jira] [Commented] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243864#comment-17243864 ] Rui Li commented on FLINK-20486: cc [~Leonard Xu] > Hive temporal join shouldn't requir

[jira] [Updated] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-20486: --- Fix Version/s: 1.12.0 > Hive temporal join shouldn't require a minimal 1h monitor interval > ---

[GitHub] [flink] flinkbot edited a comment on pull request #14303: [FLINK-20379][Connector/Kafka] Improve the KafkaRecordDesrializer interface

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14303: URL: https://github.com/apache/flink/pull/14303#issuecomment-738079106 ## CI report: * d78c1394221de2af440a7a4d3e0b500d1d6f188a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243865#comment-17243865 ] jiawen xiao commented on FLINK-20481: - hi,[~zhisheng], only happen in 1.12.0 ? > ja

[jira] [Comment Edited] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243866#comment-17243866 ] zhisheng edited comment on FLINK-20481 at 12/4/20, 9:11 AM:

[jira] [Commented] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243866#comment-17243866 ] zhisheng commented on FLINK-20481: -- [~873925...@qq.com] yes, i compile the mster branch

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
V1ncentzzZ commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535940476 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -103,6 +103,26 @@ class

[jira] [Closed] (FLINK-20373) Flink table jsonArray access all

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20373. --- Resolution: Duplicate > Flink table jsonArray access all > > >

[jira] [Commented] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-12-04 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243872#comment-17243872 ] jiawen xiao commented on FLINK-20386: - hi,[~jark] .this problem is the same as FLINK

[jira] [Created] (FLINK-20487) FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION

2020-12-04 Thread jiayue.yu (Jira)
jiayue.yu created FLINK-20487: - Summary: FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION Key: FLINK-20487 URL: https://issues.apache.org/jira/browse/FLINK-20487 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243874#comment-17243874 ] jiawen xiao commented on FLINK-20481: - this issus is the same as flink-20386. I don’

[jira] [Commented] (FLINK-19946) Support sink parallelism configuration to Hbase connector

2020-12-04 Thread zhisheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243875#comment-17243875 ] zhisheng commented on FLINK-19946: -- [~jark] get it > Support sink parallelism configur

[jira] [Updated] (FLINK-20437) Port ExecNode to Java

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20437: Fix Version/s: 1.13.0 > Port ExecNode to Java > - > > Key: FLINK-20437

[GitHub] [flink] godfreyhe commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
godfreyhe commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535873501 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -429,6 +429,26 @@ clas

[jira] [Commented] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243877#comment-17243877 ] Jark Wu commented on FLINK-20386: - [~873925...@qq.com], I think we can go ahead with thi

[GitHub] [flink] godfreyhe commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
godfreyhe commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535954210 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -429,6 +429,26 @@ clas

[jira] [Assigned] (FLINK-20386) ClassCastException when lookup join a JDBC table on INT UNSIGNED column

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20386: --- Assignee: jiawen xiao > ClassCastException when lookup join a JDBC table on INT UNSIGNED column > -

[jira] [Commented] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243878#comment-17243878 ] Jark Wu commented on FLINK-20481: - Please use BIGINT in Flink SQL for INT UNSIGNED types

[jira] [Closed] (FLINK-20481) java.lang.ClassCastException: java.lang.Long cannot be cast to java.lang.Integer

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20481. --- Resolution: Duplicate > java.lang.ClassCastException: java.lang.Long cannot be cast to > java.lang.Integer

[GitHub] [flink] godfreyhe commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
godfreyhe commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535955947 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -103,6 +103,26 @@ class

[GitHub] [flink] flinkbot edited a comment on pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14301: URL: https://github.com/apache/flink/pull/14301#issuecomment-738011652 ## CI report: * 20f56d1b5af948003d4eade6dd5a9482d54b48dc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-20487) FLINK SQL GROUP BY TUMBLE AND OVER FUNCTION

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20487: Description: {code} EXCEPTION: org.apache.flink.table.api.TableException: Group Window Aggregate: Retrac

[GitHub] [flink] azagrebin closed pull request #14020: [FLINK-20078][coordination] Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-12-04 Thread GitBox
azagrebin closed pull request #14020: URL: https://github.com/apache/flink/pull/14020 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 t

[jira] [Updated] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-12-04 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-20078: Fix Version/s: 1.12.0 > Factor out an ExecutionGraph factory method for DefaultExecutionTo

[jira] [Updated] (FLINK-20487) Support to consume retractions for window aggregate operator

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20487: Issue Type: New Feature (was: Bug) > Support to consume retractions for window aggregate operator > -

[jira] [Updated] (FLINK-20487) Support to consume retractions for window aggregate operator

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20487: Summary: Support to consume retractions for window aggregate operator (was: FLINK SQL GROUP BY TUMBLE AND

[jira] [Closed] (FLINK-20078) Factor out an ExecutionGraph factory method for DefaultExecutionTopology

2020-12-04 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin closed FLINK-20078. --- Resolution: Fixed merged into master by cbdebd17017187900d13ed3a6769e08e59e56ca5 merged into

[jira] [Updated] (FLINK-20487) Support to consume retractions for window aggregate operator

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20487: Fix Version/s: 1.13.0 > Support to consume retractions for window aggregate operator > ---

[jira] [Commented] (FLINK-20487) Support to consume retractions for window aggregate operator

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243889#comment-17243889 ] Jark Wu commented on FLINK-20487: - This is a known unsupported feature. I changed the is

[jira] [Updated] (FLINK-19607) Implement streaming window TopN operator

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19607: Fix Version/s: 1.13.0 > Implement streaming window TopN operator > ---

[jira] [Updated] (FLINK-19604) FLIP-145: Support SQL windowing table-valued function

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19604: Fix Version/s: 1.13.0 > FLIP-145: Support SQL windowing table-valued function > --

[jira] [Updated] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20486: Issue Type: Bug (was: Improvement) > Hive temporal join shouldn't require a minimal 1h monitor interval >

[jira] [Updated] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20486: Priority: Critical (was: Major) > Hive temporal join shouldn't require a minimal 1h monitor interval > --

[jira] [Updated] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20485: Priority: Critical (was: Major) > Map views are deserialized multiple times > ---

[jira] [Commented] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243894#comment-17243894 ] Jark Wu commented on FLINK-20486: - Big +1. I think a feature must can be tried in testin

[jira] [Updated] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20485: Fix Version/s: 1.12.0 > Map views are deserialized multiple times > --

[jira] [Assigned] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20486: --- Assignee: Leonard Xu > Hive temporal join shouldn't require a minimal 1h monitor interval > ---

[jira] [Assigned] (FLINK-20484) Improve hive temporal table exception

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20484: --- Assignee: Leonard Xu > Improve hive temporal table exception > ---

[jira] [Updated] (FLINK-20484) Improve hive temporal table exception

2020-12-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20484: Fix Version/s: 1.12.0 > Improve hive temporal table exception > -- >

[GitHub] [flink] flinkbot edited a comment on pull request #14301: [FLINK-20468][minicluster] Enable leadership control in MiniCluster to test JM failover

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14301: URL: https://github.com/apache/flink/pull/14301#issuecomment-738011652 ## CI report: * 20f56d1b5af948003d4eade6dd5a9482d54b48dc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20484) Improve hive temporal table exception

2020-12-04 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243902#comment-17243902 ] Rui Li commented on FLINK-20484: In addition to the config validation on hive side, it s

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
V1ncentzzZ commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535971502 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentITCase.scala ## @@ -429,6 +429,26 @@ cla

[GitHub] [flink] V1ncentzzZ commented on a change in pull request #14165: [FLINK-19687][table] Support to get execution plan from StatementSet

2020-12-04 Thread GitBox
V1ncentzzZ commented on a change in pull request #14165: URL: https://github.com/apache/flink/pull/14165#discussion_r535971804 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/api/TableEnvironmentTest.scala ## @@ -103,6 +103,26 @@ class

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

2020-12-04 Thread Partha Pradeep Mishra (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243907#comment-17243907 ] Partha Pradeep Mishra commented on FLINK-20376: --- [~klion26]  Tried savepoi

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * e470bcdae1694f36a466767a457a54006432e5a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243915#comment-17243915 ] Thomas Wozniakowski commented on FLINK-19970: - Results over a longer period,

[jira] [Updated] (FLINK-19970) State leak in CEP Operators (expired events/keys not removed from state)

2020-12-04 Thread Thomas Wozniakowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Wozniakowski updated FLINK-19970: Attachment: screenshot-2.png > State leak in CEP Operators (expired events/keys no

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * e470bcdae1694f36a466767a457a54006432e5a8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20488) Supporting changes (UI, conf) for timing out aligned checkpoints

2020-12-04 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20488: - Summary: Supporting changes (UI, conf) for timing out aligned checkpoints Key: FLINK-20488 URL: https://issues.apache.org/jira/browse/FLINK-20488 Project: F

[GitHub] [flink] rkhachatryan commented on a change in pull request #13827: [FLINK-19681][checkpointing] Timeout aligned checkpoints based on checkpointStartDelay

2020-12-04 Thread GitBox
rkhachatryan commented on a change in pull request #13827: URL: https://github.com/apache/flink/pull/13827#discussion_r527794600 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/SingleCheckpointBarrierHandler.java ## @@ -235,6 +257,23 @@ i

[jira] [Created] (FLINK-20489) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2

2020-12-04 Thread Partha Pradeep Mishra (Jira)
Partha Pradeep Mishra created FLINK-20489: - Summary: Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2 Key: FLINK-20489 URL: https://issues.apache.org/jira/browse/FLINK-2048

[jira] [Updated] (FLINK-20489) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.10.2

2020-12-04 Thread Partha Pradeep Mishra (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Partha Pradeep Mishra updated FLINK-20489: -- Description: 1) Trying to restore saved savepoint of Flink 1.9 in version 1.10

[jira] [Commented] (FLINK-20209) Add missing checkpoint configuration to Flink UI

2020-12-04 Thread Peidian Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243930#comment-17243930 ] Peidian Li commented on FLINK-20209: [~klion26] Thank you for your information. I wi

[GitHub] [flink] alpinegizmo commented on a change in pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

2020-12-04 Thread GitBox
alpinegizmo commented on a change in pull request #14292: URL: https://github.com/apache/flink/pull/14292#discussion_r535987359 ## File path: docs/dev/table/streaming/time_attributes.md ## @@ -22,213 +22,42 @@ specific language governing permissions and limitations under the L

[GitHub] [flink] twalthr opened a new pull request #14309: [FLINK-20485][table] Improve performance of data views

2020-12-04 Thread GitBox
twalthr opened a new pull request #14309: URL: https://github.com/apache/flink/pull/14309 ## What is the purpose of the change This improves the performance when using map views in aggregate functions with retraction and distinct aggregates. ## Brief change log - It red

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

2020-12-04 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243939#comment-17243939 ] Matthias commented on FLINK-11374: -- [~lining] [~vthinkxie] It looks like one subtask is

[jira] [Updated] (FLINK-20485) Map views are deserialized multiple times

2020-12-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20485: --- Labels: pull-request-available (was: ) > Map views are deserialized multiple times > --

[jira] [Updated] (FLINK-19704) Flink checkpoint will fail when keytab dir meets a failure, and flink should handle it.

2020-12-04 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-19704: - Affects Version/s: 1.12.0 > Flink checkpoint will fail when keytab dir meets a failure, and flink should

[GitHub] [flink] flinkbot commented on pull request #14309: [FLINK-20485][table] Improve performance of data views

2020-12-04 Thread GitBox
flinkbot commented on pull request #14309: URL: https://github.com/apache/flink/pull/14309#issuecomment-738723328 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 pro

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536022184 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536023584 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536024540 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536025669 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] tillrohrmann commented on a change in pull request #14305: [FLINK-20355][docs] Add new native K8s documentation page

2020-12-04 Thread GitBox
tillrohrmann commented on a change in pull request #14305: URL: https://github.com/apache/flink/pull/14305#discussion_r536026162 ## File path: docs/deployment/resource-providers/native_kubernetes.md ## @@ -24,394 +23,244 @@ specific language governing permissions and limitation

[GitHub] [flink] leonardBang opened a new pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread GitBox
leonardBang opened a new pull request #14310: URL: https://github.com/apache/flink/pull/14310 ## What is the purpose of the change * Currently we limits the monitor interval should be at least 1 hour to avoid produce pressure to hive meta store, this should be safe in production, bu

[jira] [Updated] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20486: --- Labels: pull-request-available (was: ) > Hive temporal join shouldn't require a minimal 1h

[GitHub] [flink] flinkbot commented on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread GitBox
flinkbot commented on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-738731861 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 pro

[GitHub] [flink] flinkbot commented on pull request #14309: [FLINK-20485][table] Improve performance of data views

2020-12-04 Thread GitBox
flinkbot commented on pull request #14309: URL: https://github.com/apache/flink/pull/14309#issuecomment-738733577 ## CI report: * 2cc967f7c4d001bcd2c1960018893f49e34f65b5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[jira] [Commented] (FLINK-20478) Adjust the explain result

2020-12-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243950#comment-17243950 ] Timo Walther commented on FLINK-20478: -- I also find "Physical Execution Plan" not v

[jira] [Commented] (FLINK-20486) Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243952#comment-17243952 ] Leonard Xu commented on FLINK-20486: Thanks [~lirui] for the report, I agree that un

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

2020-12-04 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243951#comment-17243951 ] Huang Xingbo commented on FLINK-20476: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Commented] (FLINK-20478) Adjust the explain result

2020-12-04 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243957#comment-17243957 ] godfrey he commented on FLINK-20478: Thanks for the feedback [~twalthr], This issue

[jira] [Updated] (FLINK-6444) Add a check that '@VisibleForTesting' methods are only used in tests

2020-12-04 Thread Matthias (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-6444: Labels: pull-request-available starter (was: pull-request-available) > Add a check that '@VisibleForTestin

[GitHub] [flink] SteNicholas commented on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

2020-12-04 Thread GitBox
SteNicholas commented on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-738740542 @rkhachatryan Did you complete working for FLINK-19681? I'm waiting for you for the completion of this pull request. ---

[GitHub] [flink] flinkbot edited a comment on pull request #14309: [FLINK-20485][table] Improve performance of data views

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14309: URL: https://github.com/apache/flink/pull/14309#issuecomment-738733577 ## CI report: * 2cc967f7c4d001bcd2c1960018893f49e34f65b5 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14307: [FLINK-20209][web] Add missing checkpoint configuration to Flink UI

2020-12-04 Thread GitBox
flinkbot edited a comment on pull request #14307: URL: https://github.com/apache/flink/pull/14307#issuecomment-738548986 ## CI report: * 3b92f7190fec3320934756b997f8e97deb7b8e0d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14310: [FLINK-20486][hive] Hive temporal join shouldn't require a minimal 1h monitor interval

2020-12-04 Thread GitBox
flinkbot commented on pull request #14310: URL: https://github.com/apache/flink/pull/14310#issuecomment-738741642 ## CI report: * cded2fcb5f10c8d6bdbfdece1c591fa658377f90 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

  1   2   3   >