[jira] [Resolved] (FLINK-16822) The config set by SET command does not work

[ https://issues.apache.org/jira/browse/FLINK-16822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16822. - Resolution: Fixed > The config set by SET command does not work >

[jira] [Comment Edited] (FLINK-16822) The config set by SET command does not work

[ https://issues.apache.org/jira/browse/FLINK-16822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084121#comment-17084121 ] Jark Wu edited comment on FLINK-16822 at 4/16/20, 5:58 AM: --- Fixed in - master

[GitHub] [flink] wuchong merged pull request #11763: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig

wuchong merged pull request #11763: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig URL: https://github.com/apache/flink/pull/11763 This is an automated

[GitHub] [flink] zhengcanbin commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

zhengcanbin commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#discussion_r409299161 ## File path:

[GitHub] [flink] zhengcanbin commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

zhengcanbin commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#discussion_r409299161 ## File path:

[GitHub] [flink] flinkbot commented on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts

flinkbot commented on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts URL: https://github.com/apache/flink/pull/11765#issuecomment-614430999 ## CI report: * 22eef4c43cd4fd0a6ddffb3cbef00a2fe522dac6 UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython

flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython URL: https://github.com/apache/flink/pull/11718#issuecomment-612935976 ## CI report: * 5fd615137856ca12486f4b5de540f52fbc348c47 Travis:

[GitHub] [flink] flinkbot commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

flinkbot commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter URL: https://github.com/apache/flink/pull/11766#issuecomment-614431072 ## CI report: * 3d58ff0f0f2f4caac54b5bc38dac153ae4f4ecf2 UNKNOWN Bot commands The @flinkbot

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 46b64a4339ed27315eee1eb2d8d877c8dfaae993

[jira] [Commented] (FLINK-17108) Exception: Cannot determine simple type name "com"

[ https://issues.apache.org/jira/browse/FLINK-17108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084563#comment-17084563 ] xiemeilong commented on FLINK-17108: Is there any workaround for this? > Exception: Cannot

[GitHub] [flink] wangyang0918 commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

wangyang0918 commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#discussion_r409297786 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: *

[jira] [Updated] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-16662: Priority: Blocker (was: Major) > Blink Planner failed to generate JobGraph for POJO DataStream

[jira] [Closed] (FLINK-17171) Blink planner fails to compile Table program with POJO source

[ https://issues.apache.org/jira/browse/FLINK-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-17171. --- Resolution: Duplicate > Blink planner fails to compile Table program with POJO source >

[GitHub] [flink] wangyang0918 commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

wangyang0918 commented on a change in pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715#discussion_r409295087 ## File path:

[GitHub] [flink] flinkbot commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

flinkbot commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter URL: https://github.com/apache/flink/pull/11766#issuecomment-614425628 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-16812) support array types in PostgresRowConverter

[ https://issues.apache.org/jira/browse/FLINK-16812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16812: --- Labels: pull-request-available (was: ) > support array types in PostgresRowConverter >

[GitHub] [flink] bowenli86 commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

bowenli86 commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter URL: https://github.com/apache/flink/pull/11766#issuecomment-614424059 @wuchong @huafengw pls take a look This is an

[GitHub] [flink] bowenli86 opened a new pull request #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

bowenli86 opened a new pull request #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter URL: https://github.com/apache/flink/pull/11766 ## What is the purpose of the change commit 1: fix bug that StringUtils.arrayToString() should consider Object[] lastly,

[GitHub] [flink] flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

flinkbot edited a comment on issue #11010: [FLINK-15836][k8s] Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts

flinkbot commented on issue #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts URL: https://github.com/apache/flink/pull/11765#issuecomment-614423109 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] dianfu commented on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython

dianfu commented on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython URL: https://github.com/apache/flink/pull/11718#issuecomment-614422801 @HuangXingBo Thanks a lot for the update. The test time increases a lot, could you take a look?

[GitHub] [flink] KurtYoung opened a new pull request #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts

KurtYoung opened a new pull request #11765: [FLINK-8864][sql-client] Add cli command history in sql client and make it available after restarts URL: https://github.com/apache/flink/pull/11765 Save the cli command history to a hidden file and make it available after sql cli restarts

[jira] [Assigned] (FLINK-8864) Add CLI query history in SQL Client

[ https://issues.apache.org/jira/browse/FLINK-8864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-8864: - Assignee: Kurt Young (was: Sergey Nuyanzin) > Add CLI query history in SQL Client >

[jira] [Created] (FLINK-17175) StringUtils.arrayToString() should consider Object[] lastly

Bowen Li created FLINK-17175: Summary: StringUtils.arrayToString() should consider Object[] lastly Key: FLINK-17175 URL: https://issues.apache.org/jira/browse/FLINK-17175 Project: Flink Issue

[jira] [Updated] (FLINK-16812) support array types in PostgresRowConverter

[ https://issues.apache.org/jira/browse/FLINK-16812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16812: - Summary: support array types in PostgresRowConverter (was: introduce Postgres row converter to

[jira] [Updated] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

[ https://issues.apache.org/jira/browse/FLINK-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yiwen Tu updated FLINK-17174: - Description: I read data from kafka source name and the source table has the fields of 'ts' which has

[jira] [Commented] (FLINK-17171) Blink planner fails to compile Table program with POJO source

[ https://issues.apache.org/jira/browse/FLINK-17171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084544#comment-17084544 ] Kurt Young commented on FLINK-17171: Similar with FLINK-16662? > Blink planner fails to compile

[jira] [Created] (FLINK-17174) Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query

Yiwen Tu created FLINK-17174: Summary: Conversion to relational algebra failed to preserve datatypes when using Table API but succeed when using SQL query Key: FLINK-17174 URL:

[GitHub] [flink] zenfenan commented on issue #11737: [FLINK-16968][stats][metrics] Add StatsDReporterFactory

zenfenan commented on issue #11737: [FLINK-16968][stats][metrics] Add StatsDReporterFactory URL: https://github.com/apache/flink/pull/11737#issuecomment-614418684 @zentol Haha.. Cool then. I have updated the instructions as well. Can we close this one?

[jira] [Commented] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084540#comment-17084540 ] Kurt Young commented on FLINK-16662: [~zhanglibing1...@126.com] I've assigned this to you.  > Blink

[jira] [Assigned] (FLINK-16662) Blink Planner failed to generate JobGraph for POJO DataStream converting to Table (Cannot determine simple type name)

[ https://issues.apache.org/jira/browse/FLINK-16662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-16662: -- Assignee: LionelZ > Blink Planner failed to generate JobGraph for POJO DataStream converting

[GitHub] [flink] zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

zhijiangW commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint URL: https://github.com/apache/flink/pull/11687#discussion_r409283520 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409266063 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409265142 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409276883 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409260255 ## File path: flink-python/src/main/java/org/apache/flink/client/python/PythonDriver.java

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409259043 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409253106 ## File path: flink-python/pyflink/java_rpc_server.py ## @@ -0,0 +1,32 @@

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409262193 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409262374 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409262922 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409262680 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409257458 ## File path: flink-python/pyflink/java_rpc_server.py ## @@ -0,0 +1,32 @@

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409257180 ## File path: flink-python/pyflink/java_rpc_server.py ## @@ -0,0 +1,32 @@

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409278316 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409276408 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409261220 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409265616 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409276497 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409258002 ## File path: flink-python/pyflink/table/tests/test_table_environment_api.py ##

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409265928 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409263779 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409277200 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409280559 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409258531 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409264137 ## File path:

[GitHub] [flink] dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

dianfu commented on a change in pull request #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL. URL: https://github.com/apache/flink/pull/11749#discussion_r409259319 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225 ## CI report: * 8e8aca52ebd0560d829ef3945884817668976804

[jira] [Updated] (FLINK-15836) Throw fatal error in KubernetesResourceManager when the pods watcher is closed with exception

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15836: -- Summary: Throw fatal error in KubernetesResourceManager when the pods watcher is closed with

[jira] [Updated] (FLINK-15836) Start a new pods watcher in KubernetesResourceManager when the old one is closed with exception

[ https://issues.apache.org/jira/browse/FLINK-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-15836: -- Description: As the discussion in the PR[1], if the {{watchReconnectLimit}} is configured by users

[GitHub] [flink] xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

xintongsong commented on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-614413676 Thanks @tillrohrmann. Comments addressed.

[jira] [Assigned] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13636: --- Assignee: Yu Xia (was: WangHengWei) > Translate "Flink DataStream API Programming Guide" page

[jira] [Commented] (FLINK-13636) Translate "Flink DataStream API Programming Guide" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084530#comment-17084530 ] Jark Wu commented on FLINK-13636: - Assigned to you [~pipiyu] > Translate "Flink DataStream API

[jira] [Commented] (FLINK-16345) Computed column can not refer time attribute column

[ https://issues.apache.org/jira/browse/FLINK-16345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084529#comment-17084529 ] Jark Wu commented on FLINK-16345: - Hi [~xingoo], sorry, I couldn't reproduce your problem using your

[GitHub] [flink] godfreyhe commented on a change in pull request #11671: [FLINK-17052] [client] Introduce PlanGenerator

godfreyhe commented on a change in pull request #11671: [FLINK-17052] [client] Introduce PlanGenerator URL: https://github.com/apache/flink/pull/11671#discussion_r409272606 ## File path: flink-libraries/flink-gelly/src/test/java/org/apache/flink/graph/generator/TestUtils.java

[GitHub] [flink] flinkbot edited a comment on issue #11763: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig

flinkbot edited a comment on issue #11763: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig URL: https://github.com/apache/flink/pull/11763#issuecomment-614382282 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225 ## CI report: * 8e8aca52ebd0560d829ef3945884817668976804

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409271481 ## File path:

[GitHub] [flink] zjuwangg commented on issue #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil

zjuwangg commented on issue #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil URL: https://github.com/apache/flink/pull/11748#issuecomment-614404606 Thanks @wuchong This is an

[jira] [Resolved] (FLINK-17152) FunctionDefinitionUtil generate wrong resultType and acc type of AggregateFunctionDefinition

[ https://issues.apache.org/jira/browse/FLINK-17152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-17152. - Resolution: Fixed Fixed in - master (1.11.0): 4563176fbf8d4f27d2ebd20d5fd42c8c085582b2 - 1.10.1:

[GitHub] [flink] flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args

flinkbot edited a comment on issue #11545: [FLINK-16742][runtime][dist] Extend and use BashJavaUtils to start JM JVM process and pass JVM memory args URL: https://github.com/apache/flink/pull/11545#issuecomment-604848813 ## CI report: * 46b64a4339ed27315eee1eb2d8d877c8dfaae993

[GitHub] [flink] wuchong merged pull request #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil

wuchong merged pull request #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil URL: https://github.com/apache/flink/pull/11748 This is an automated message from the Apache Git

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409264636 ## File path:

[GitHub] [flink] zjuwangg commented on issue #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil

zjuwangg commented on issue #11748: [FLINK-17152]fix wrong Aggfunction resultType and accType in FunctionDefinitionUtil URL: https://github.com/apache/flink/pull/11748#issuecomment-614399852 cc @JingsongLi to have a review too.

[GitHub] [flink] wuchong commented on a change in pull request #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context

wuchong commented on a change in pull request #11726: [FLINK-17128][table] Add isBounded to TableSinkFactory#Context URL: https://github.com/apache/flink/pull/11726#discussion_r409263876 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409262886 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython

flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython URL: https://github.com/apache/flink/pull/11718#issuecomment-612935976 ## CI report: * f08d03b3f2416ab3a6493f3a7a2c29c92c0830e6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11758: [BP-1.10][16576][state backends] Fix the problem of wrong mapping between stateId and metaInfo in HeapRestoreOperation

flinkbot edited a comment on issue #11758: [BP-1.10][16576][state backends] Fix the problem of wrong mapping between stateId and metaInfo in HeapRestoreOperation URL: https://github.com/apache/flink/pull/11758#issuecomment-614054255 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh

flinkbot edited a comment on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh URL: https://github.com/apache/flink/pull/11764#issuecomment-614393395 ## CI report: * 59e7e206fbc4bc1074df99204cd52689c0038e7d Travis:

[GitHub] [flink] wuchong commented on issue #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig

wuchong commented on issue #11544: [FLINK-16822] [sql-client] `table.xx` property set from CLI should also be set into TableEnvironment's TableConfig URL: https://github.com/apache/flink/pull/11544#issuecomment-614398332 @godfreyhe , sorry, I wanted to say 1.10 branch.

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409261313 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args

xintongsong commented on a change in pull request #11675: [FLINK-16745] Use JobManagerProcessUtils to start JM container and pass JVM memory args URL: https://github.com/apache/flink/pull/11675#discussion_r409260812 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409260284 ## File path:

[jira] [Commented] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084514#comment-17084514 ] Yun Tang commented on FLINK-16770: -- Update some progress: After discussed with [~pnowojski] and

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Avoid caching buffers for blocked input channels before barrier alignment URL: https://github.com/apache/flink/pull/11351#discussion_r409259909 ## File path:

[jira] [Updated] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-16770: - Attachment: (was: image-2020-04-16-11-11-40-811.png) > Resuming Externalized Checkpoint (rocks,

[jira] [Updated] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-16770: - Attachment: image-2020-04-16-11-24-54-549.png > Resuming Externalized Checkpoint (rocks, incremental,

[jira] [Commented] (FLINK-16733) Refactor YarnClusterDescriptor

[ https://issues.apache.org/jira/browse/FLINK-16733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084513#comment-17084513 ] Xintong Song commented on FLINK-16733: -- [~rongr] I do not have a concrete plan. At high level, my

[GitHub] [flink] hequn8128 merged pull request #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF

hequn8128 merged pull request #11656: [FLINK-16983][python] Support RowType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11656 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot commented on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh

flinkbot commented on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh URL: https://github.com/apache/flink/pull/11764#issuecomment-614393395 ## CI report: * 59e7e206fbc4bc1074df99204cd52689c0038e7d UNKNOWN Bot commands

[jira] [Commented] (FLINK-16983) Support RowType in vectorized Python UDF

[ https://issues.apache.org/jira/browse/FLINK-16983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084512#comment-17084512 ] Hequn Cheng commented on FLINK-16983: - Resolved in 1.11.0 via

[GitHub] [flink] flinkbot edited a comment on issue #11758: [BP-1.10][16576][state backends] Fix the problem of wrong mapping between stateId and metaInfo in HeapRestoreOperation

flinkbot edited a comment on issue #11758: [BP-1.10][16576][state backends] Fix the problem of wrong mapping between stateId and metaInfo in HeapRestoreOperation URL: https://github.com/apache/flink/pull/11758#issuecomment-614054255 ## CI report: *

[GitHub] [flink] TisonKun closed pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint

TisonKun closed pull request #11715: [FLINK-16598][k8s] Respect the rest-port exposed by the external Service when retrieving Endpoint URL: https://github.com/apache/flink/pull/11715 This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython

flinkbot edited a comment on issue #11718: [FLINK-17118][python] Support Primitive DataTypes in Cython URL: https://github.com/apache/flink/pull/11718#issuecomment-612935976 ## CI report: * f08d03b3f2416ab3a6493f3a7a2c29c92c0830e6 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity.

flinkbot edited a comment on issue #11320: [FLINK-16437][runtime] Make SlotManager allocate resource from ResourceManager at the worker granularity. URL: https://github.com/apache/flink/pull/11320#issuecomment-595174225 ## CI report: * 8e8aca52ebd0560d829ef3945884817668976804

[GitHub] [flink] flinkbot commented on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh

flinkbot commented on issue #11764: [FLINK-17023][scripts] Fix format checking of extractExecutionParams in config.sh URL: https://github.com/apache/flink/pull/11764#issuecomment-614391908 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per query in SQL

[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084509#comment-17084509 ] Benchao Li commented on FLINK-17173: Hi [~danny0405], it's a very useful feature, +1 for this. I

[jira] [Updated] (FLINK-17023) The format checking of extractExecutionParams in config.sh is incorrect

[ https://issues.apache.org/jira/browse/FLINK-17023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17023: --- Labels: pull-request-available (was: ) > The format checking of extractExecutionParams in

[jira] [Updated] (FLINK-16770) Resuming Externalized Checkpoint (rocks, incremental, scale up) end-to-end test fails with no such file

[ https://issues.apache.org/jira/browse/FLINK-16770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-16770: - Attachment: image-2020-04-16-11-11-40-811.png > Resuming Externalized Checkpoint (rocks, incremental,

  1   2   3   4   5   6   7   8   >