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

2020-12-09 Thread jiawen xiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247069#comment-17247069 ] jiawen xiao commented on FLINK-20386: - ok,i will do a test for other unsigned types.

[GitHub] [flink] twalthr commented on a change in pull request #14329: [FLINK-18890][table] Update LookupTableSource to the new type system

2020-12-09 Thread GitBox
twalthr commented on a change in pull request #14329: URL: https://github.com/apache/flink/pull/14329#discussion_r539949533 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeExtractor.java ## @@ -377,6 +397,11 @@ private

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * f4f1cf14d4d413c4c87881516215c7d5be64 UNKNOWN * 5ba8c4410ef2616561f46462d156949e8c6b Azure: [PENDING](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-20531) Flink docs are not building anymore due to builder change

2020-12-09 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247061#comment-17247061 ] Robert Metzger commented on FLINK-20531: Problem is still not resolved. Medium

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * f4f1cf14d4d413c4c87881516215c7d5be64 UNKNOWN * 5ba8c4410ef2616561f46462d156949e8c6b Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] fsk119 commented on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

2020-12-09 Thread GitBox
fsk119 commented on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-742297048 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please l

[jira] [Commented] (FLINK-20509) Refactor verifyPlan method in TableTestBase

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247050#comment-17247050 ] Jark Wu commented on FLINK-20509: - What do you think about renaming {{planBefore}}, {{pl

[jira] [Commented] (FLINK-20509) Refactor verifyPlan method in TableTestBase

2020-12-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247046#comment-17247046 ] godfrey he commented on FLINK-20509: after an offline discussion with [~jark], we re

[jira] [Assigned] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20540: --- Assignee: zhangzhao > Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via

[jira] [Commented] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

2020-12-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247045#comment-17247045 ] Leonard Xu commented on FLINK-20540: Happy to hear you're willing to contribute, I t

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[jira] [Created] (FLINK-20556) org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.

2020-12-09 Thread Zezheng Qin (Jira)
Zezheng Qin created FLINK-20556: --- Summary: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. Key: FLINK-20556 URL: https://issues.apache.org

[jira] [Commented] (FLINK-20540) Failed connecting to jdbc:postgresql://flink-postgres.cdn-flink:5432flink via JDBC

2020-12-09 Thread zhangzhao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247042#comment-17247042 ] zhangzhao commented on FLINK-20540: --- Ok, i will submit 2 pull requests to fix document

[jira] [Updated] (FLINK-20555) 404 url dependency error in Flink Website

2020-12-09 Thread DaiXinyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] DaiXinyu updated FLINK-20555: - Issue Type: Bug (was: New Feature) > 404 url dependency error in Flink Website > --

[jira] [Updated] (FLINK-20555) 404 url dependency error in Flink Website

2020-12-09 Thread DaiXinyu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] DaiXinyu updated FLINK-20555: - Description: in [Download page|https://flink.apache.org/downloads.html#apache-flink-1112] !image-2020-1

[jira] [Created] (FLINK-20555) 404 url dependency error in Flink Website

2020-12-09 Thread DaiXinyu (Jira)
DaiXinyu created FLINK-20555: Summary: 404 url dependency error in Flink Website Key: FLINK-20555 URL: https://issues.apache.org/jira/browse/FLINK-20555 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20552: --- Assignee: mei jie > JdbcDynamicTableSink doesn't sink buffered data on checkpoint > ---

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247034#comment-17247034 ] Jark Wu commented on FLINK-20552: - +1 to [~Leonard Xu]'s proposal. We should also add a

[jira] [Closed] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20506. --- Resolution: Fixed Merged to master via 0a6e457e6b2bff9acc25e45c3083fc12a95fd717 > Support FlatMap Operation

[GitHub] [flink] flinkbot edited a comment on pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

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

[GitHub] [flink] dianfu closed pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

2020-12-09 Thread GitBox
dianfu closed pull request #14352: URL: https://github.com/apache/flink/pull/14352 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-09 Thread mei jie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247031#comment-17247031 ] mei jie commented on FLINK-20552: - Hi, [~Leonard Xu] I will fix this by the method you

[GitHub] [flink] dianfu commented on a change in pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

2020-12-09 Thread GitBox
dianfu commented on a change in pull request #14352: URL: https://github.com/apache/flink/pull/14352#discussion_r539861089 ## File path: flink-python/pyflink/table/table.py ## @@ -780,6 +780,29 @@ def map(self, func: Union[str, Expression]) -> 'Table': else:

[jira] [Updated] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

2020-12-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-20552: --- Summary: JdbcDynamicTableSink doesn't sink buffered data on checkpoint (was: Jdbc connector don't s

[jira] [Commented] (FLINK-20547) Batch job fails due to the exception in network stack

2020-12-09 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247029#comment-17247029 ] Yingjie Cao commented on FLINK-20547: - I also encountered this issue these days when

[jira] [Closed] (FLINK-20514) Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20514. --- Assignee: Huang Xingbo Resolution: Fixed Merged to master via 47ee32b2a880938086bd362beb82b5fe055a2032

[GitHub] [flink] dianfu closed pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

2020-12-09 Thread GitBox
dianfu closed pull request #14331: URL: https://github.com/apache/flink/pull/14331 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] flinkbot edited a comment on pull request #14328: [FLINK-19659][table-planner] Array type supports equals and not_equal…

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

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

2020-12-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20483. --- Resolution: Fixed Merged to master via a67a20d51b73ecfa917a581a8b3c096d8908964a > Support Pandas UDF for Ma

[GitHub] [flink] dianfu closed pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
dianfu closed pull request #14347: URL: https://github.com/apache/flink/pull/14347 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [flink] flinkbot edited a comment on pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14352: URL: https://github.com/apache/flink/pull/14352#issuecomment-742231209 ## CI report: * 840b814bfb02267c41f25cda226b4c0e1442d2d9 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 tolerable failed checkpoints config to web ui

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

[GitHub] [flink] flinkbot commented on pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

2020-12-09 Thread GitBox
flinkbot commented on pull request #14352: URL: https://github.com/apache/flink/pull/14352#issuecomment-742231209 ## CI report: * 840b814bfb02267c41f25cda226b4c0e1442d2d9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #14307: [FLINK-20209][web] Add tolerable failed checkpoints config to web ui

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

[GitHub] [flink] godfreyhe commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539834621 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/ValuesTest.xml ## @@ -34,9 +34,9 @

[jira] [Commented] (FLINK-20509) Refactor verifyPlan method in TableTestBase

2020-12-09 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247004#comment-17247004 ] godfrey he commented on FLINK-20509: what if we use `verifyPlan` with JSON_EXEC_PLAN

[jira] [Commented] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247002#comment-17247002 ] Leonard Xu commented on FLINK-20552: Hi, [~meijies]  Thanks for the report, A simpl

[jira] [Commented] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

2020-12-09 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247000#comment-17247000 ] ming li commented on FLINK-20554: - Hi, [~yunta], What do you think? > The Checkpointed

[GitHub] [flink] flinkbot edited a comment on pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

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

[jira] [Updated] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

2020-12-09 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ming li updated FLINK-20554: Description: The {{Checkpointed Data Size}} of the {{Latest Completed Checkpoint}} always shows '-' in th

[jira] [Commented] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread zhuxiaoshang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246999#comment-17246999 ] zhuxiaoshang commented on FLINK-20552: -- Maybe OutputFormatSinkFunction should imple

[GitHub] [flink] flinkbot edited a comment on pull request #14307: [FLINK-20209][web] Add tolerable failed checkpoints config to web ui

2020-12-09 Thread GitBox
flinkbot edited a comment on pull request #14307: URL: https://github.com/apache/flink/pull/14307#issuecomment-738548986 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis`

[jira] [Created] (FLINK-20554) The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI

2020-12-09 Thread ming li (Jira)
ming li created FLINK-20554: --- Summary: The Checkpointed Data Size of the Latest Completed Checkpoint is incorrectly displayed on the Overview page of the UI Key: FLINK-20554 URL: https://issues.apache.org/jira/browse/FL

[GitHub] [flink] flinkbot commented on pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

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

[jira] [Updated] (FLINK-20506) Support FlatMap Operation in Python Table API

2020-12-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20506: --- Labels: pull-request-available (was: ) > Support FlatMap Operation in Python Table API > --

[jira] [Updated] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread mei jie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mei jie updated FLINK-20552: Description: JdbcBatchingOutputFormat is wrapped to OutputFormatSinkFunction``` when createSinkTransforma

[GitHub] [flink] HuangXingBo opened a new pull request #14352: [FLINK-20506][python] Support FlatMap Operation in Python Table API

2020-12-09 Thread GitBox
HuangXingBo opened a new pull request #14352: URL: https://github.com/apache/flink/pull/14352 ## What is the purpose of the change *This pull request will support FlatMap Operation in Python Table API* ## Brief change log - *Add `flat_map` api in Python `Table`*

[GitHub] [flink] coolderli commented on pull request #14307: [FLINK-20209][web] Add tolerable failed checkpoints config to web ui

2020-12-09 Thread GitBox
coolderli commented on pull request #14307: URL: https://github.com/apache/flink/pull/14307#issuecomment-742223504 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Updated] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20552: Component/s: Table SQL / Ecosystem > Jdbc connector don't sink buffer data when checkpoint > -

[jira] [Updated] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20552: Labels: starter (was: ) > Jdbc connector don't sink buffer data when checkpoint > ---

[GitHub] [flink] coolderli commented on pull request #14307: [FLINK-20209][web] Add tolerable failed checkpoints config to web ui

2020-12-09 Thread GitBox
coolderli commented on pull request #14307: URL: https://github.com/apache/flink/pull/14307#issuecomment-742223340 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, plea

[jira] [Assigned] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-20546: --- Assignee: zoucao > Misuse of the method in KafkaDynamicTableFactoryTest > -

[jira] [Updated] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20546: Component/s: Table SQL / Ecosystem > Misuse of the method in KafkaDynamicTableFactoryTest > --

[jira] [Created] (FLINK-20553) Add end-to-end test case for new Kafka source

2020-12-09 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-20553: - Summary: Add end-to-end test case for new Kafka source Key: FLINK-20553 URL: https://issues.apache.org/jira/browse/FLINK-20553 Project: Flink Issue Type: I

[jira] [Created] (FLINK-20552) Jdbc connector don't sink buffer data when checkpoint

2020-12-09 Thread mei jie (Jira)
mei jie created FLINK-20552: --- Summary: Jdbc connector don't sink buffer data when checkpoint Key: FLINK-20552 URL: https://issues.apache.org/jira/browse/FLINK-20552 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

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

[jira] [Commented] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

2020-12-09 Thread zoucao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246996#comment-17246996 ] zoucao commented on FLINK-20546: hi [~jark],thanks for your reply, Firstly. Of course I

[GitHub] [flink] godfreyhe commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r53982 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodePlanDumper.java ## @@ -0,0 +1,391 @

[GitHub] [flink] HuangXingBo commented on pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
HuangXingBo commented on pull request #14347: URL: https://github.com/apache/flink/pull/14347#issuecomment-742213876 @dianfu Thanks a lot for the review. I have addressed the comments at the latest commit. This is an automat

[GitHub] [flink] godfreyhe commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539817633 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/ValuesTest.xml ## @@ -34,9 +34,9 @

[jira] [Updated] (FLINK-20551) Make SQL documentation Blink only

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20551: Component/s: Table SQL / Ecosystem Documentation > Make SQL documentation Blink only > -

[jira] [Commented] (FLINK-20546) Misuse of the method in KafkaDynamicTableFactoryTest

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246993#comment-17246993 ] Jark Wu commented on FLINK-20546: - I think you are right. We can fix this. Do you want t

[GitHub] [flink] Jiayi-Liao edited a comment on pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat

2020-12-09 Thread GitBox
Jiayi-Liao edited a comment on pull request #11480: URL: https://github.com/apache/flink/pull/11480#issuecomment-742210155 @rkhachatryan I notice that the community is doing the unification of streaming and batch. But this #DataSinkTask can only be used in DataSet job, I'm not sure that th

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246991#comment-17246991 ] Jark Wu commented on FLINK-18202: - #2 sounds good to me. I think maintainability and sta

[GitHub] [flink] godfreyhe commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539814663 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/FlinkRelNode.scala ## @@ -89,19 +89,31 @@

[GitHub] [flink] Jiayi-Liao commented on pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat

2020-12-09 Thread GitBox
Jiayi-Liao commented on pull request #11480: URL: https://github.com/apache/flink/pull/11480#issuecomment-742210155 @rkhachatryan I notice that the community is doing the unification of streaming and batch. But this #DataSinkTask can only be used in DataSet job, I'm not sure that this work

[GitHub] [flink] godfreyhe commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539813438 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodePlanDumper.java ## @@ -0,0 +1,391 @

[GitHub] [flink] godfreyhe commented on a change in pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInputEdge(int, ExecEdge) methods for ExecNode

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14337: URL: https://github.com/apache/flink/pull/14337#discussion_r539812153 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java ## @@ -31,6 +32,18 @@

[GitHub] [flink] godfreyhe commented on a change in pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInputEdge(int, ExecEdge) methods for ExecNode

2020-12-09 Thread GitBox
godfreyhe commented on a change in pull request #14337: URL: https://github.com/apache/flink/pull/14337#discussion_r539812153 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java ## @@ -31,6 +32,18 @@

[jira] [Commented] (FLINK-17948) Use new type system for SQL Client collect sink

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246985#comment-17246985 ] Jark Wu commented on FLINK-17948: - A user also reported TIMESTAMP WITH LOCAL TIME ZONE t

[jira] [Updated] (FLINK-17948) Use new type system for SQL Client collect sink

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17948: Summary: Use new type system for SQL Client collect sink (was: Sql client lost precision for Timestamp an

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[jira] [Updated] (FLINK-17948) Sql client lost precision for Timestamp and Decimal Data type

2020-12-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17948: Fix Version/s: 1.13.0 > Sql client lost precision for Timestamp and Decimal Data type > --

[GitHub] [flink] wenlong88 commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
wenlong88 commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539792067 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/FlinkRelNode.scala ## @@ -89,19 +89,31 @@

[GitHub] [flink] wenlong88 commented on a change in pull request #14337: [FLINK-20512][table-planner-blink] Introduce getDesc(), getOutputType(), replaceInputEdge(int, ExecEdge) methods for ExecNode

2020-12-09 Thread GitBox
wenlong88 commented on a change in pull request #14337: URL: https://github.com/apache/flink/pull/14337#discussion_r539797832 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNode.java ## @@ -31,6 +32,18 @@

[GitHub] [flink] wenlong88 commented on a change in pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

2020-12-09 Thread GitBox
wenlong88 commented on a change in pull request #14315: URL: https://github.com/apache/flink/pull/14315#discussion_r539785239 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/ExecNodePlanDumper.java ## @@ -0,0 +1,391 @

[GitHub] [flink] flinkbot edited a comment on pull request #14331: [FLINK-20514][python] Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate

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

[GitHub] [flink] flinkbot edited a comment on pull request #14315: [FLINK-20478][table-planner-blink] Adjust the explain result for blink planner

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

[GitHub] [flink] dianfu commented on a change in pull request #14347: [FLINK-20483][python] Support Pandas UDF for Map Operation in Python Table API

2020-12-09 Thread GitBox
dianfu commented on a change in pull request #14347: URL: https://github.com/apache/flink/pull/14347#discussion_r539779543 ## File path: flink-python/pyflink/table/tests/test_row_based_operation.py ## @@ -49,6 +49,35 @@ def test_map(self): actual = source_sink_utils.re

[jira] [Commented] (FLINK-20416) Need a cached catalog for batch SQL job

2020-12-09 Thread Rui Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246973#comment-17246973 ] Rui Li commented on FLINK-20416: I believe this is in general a useful feature, but I ag

[GitHub] [flink-statefun] Windber opened a new pull request #185: [hotfix] Fix typos in StatefulFunctionModule.java

2020-12-09 Thread GitBox
Windber opened a new pull request #185: URL: https://github.com/apache/flink-statefun/pull/185 hi, find a tiny typo in StatefulFunctionModule.java and fix it: MEGA-INF -> META-INF This is an automated message from the Apac

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

2020-12-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Affects Version/s: 1.11.3 1.12.0 > The SourceOperatorStreamTask should im

[jira] [Resolved] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

2020-12-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20492. -- Resolution: Fixed > The SourceOperatorStreamTask should implement cancelTask() and finishTask(

[jira] [Commented] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

2020-12-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246933#comment-17246933 ] Jiangjie Qin commented on FLINK-20492: -- Per discussion in the [PR|https://github.co

[GitHub] [flink] becketqin closed pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

2020-12-09 Thread GitBox
becketqin closed pull request #14314: URL: https://github.com/apache/flink/pull/14314 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

[GitHub] [flink] becketqin commented on pull request #14314: [FLINK-20492][runtime] Add implementations of cancelTask() and finish…

2020-12-09 Thread GitBox
becketqin commented on pull request #14314: URL: https://github.com/apache/flink/pull/14314#issuecomment-742157315 Merged to master: 168124f99c75e873adc81437c700f85f703e2248 Merged to release-1.12: c22bb49443e6d70be5d312acee065fc9b4d95bb2

[GitHub] [flink] flinkbot edited a comment on pull request #13964: [FLINK-19314][coordination] Add DeclarativeSlotPoolBridge

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

[GitHub] [flink] sjwiesman commented on pull request #14350: [FLINK-20422] Remove site.baseurl from remaining .html templates

2020-12-09 Thread GitBox
sjwiesman commented on pull request #14350: URL: https://github.com/apache/flink/pull/14350#issuecomment-742080380 I'm not entirely sure how to review this. It builds so +1 from me This is an automated message from the Apache

[GitHub] [flink] sjwiesman commented on a change in pull request #14350: [FLINK-20422] Remove site.baseurl from remaining .html templates

2020-12-09 Thread GitBox
sjwiesman commented on a change in pull request #14350: URL: https://github.com/apache/flink/pull/14350#discussion_r539667952 ## File path: docs/_config.yml ## @@ -88,6 +88,7 @@ previous_docs: exclude: - "build_docs.sh" - "check_links.sh" + - "spider.log" Review commen

[jira] [Closed] (FLINK-20456) Make streaming SQL concepts more approachable

2020-12-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-20456. Resolution: Fixed > Make streaming SQL concepts more approachable > --

[jira] [Commented] (FLINK-20456) Make streaming SQL concepts more approachable

2020-12-09 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246840#comment-17246840 ] Seth Wiesman commented on FLINK-20456: -- fixed in master: 6539e25cc291aa97f9ea62d8d7

[GitHub] [flink] sjwiesman closed pull request #14292: [FLINK-20456][docs] Make streaming SQL concepts more approachable

2020-12-09 Thread GitBox
sjwiesman closed pull request #14292: URL: https://github.com/apache/flink/pull/14292 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

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

2020-12-09 Thread GitBox
sjwiesman commented on pull request #14292: URL: https://github.com/apache/flink/pull/14292#issuecomment-742074292 thanks for the review, will merge. This is an automated message from the Apache Git Service. To respond to th

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

2020-12-09 Thread GitBox
sjwiesman commented on a change in pull request #14292: URL: https://github.com/apache/flink/pull/14292#discussion_r539660475 ## File path: docs/redirects/temporal_table.md ## @@ -0,0 +1,24 @@ +--- +title: Temporal Tables +layout: redirect +redirect: /dev/table/streaming/versio

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

2020-12-09 Thread GitBox
sjwiesman commented on a change in pull request #14292: URL: https://github.com/apache/flink/pull/14292#discussion_r539658939 ## File path: docs/redirects/temporal_table.md ## @@ -0,0 +1,24 @@ +--- +title: Temporal Tables +layout: redirect +redirect: /dev/table/streaming/versio

[GitHub] [flink] rkhachatryan commented on a change in pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat

2020-12-09 Thread GitBox
rkhachatryan commented on a change in pull request #11480: URL: https://github.com/apache/flink/pull/11480#discussion_r539642775 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java ## @@ -295,7 +298,9 @@ public void cancel() throws Ex

[jira] [Updated] (FLINK-16597) Handle exception thrown from close method in OutputFormat

2020-12-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-16597: -- Fix Version/s: 1.13.0 > Handle exception thrown from close method in OutputFormat > --

[jira] [Updated] (FLINK-16597) Handle exception thrown from close method in OutputFormat

2020-12-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-16597: -- Affects Version/s: 1.11.0 1.12.0 > Handle exception thrown from

[GitHub] [flink] rkhachatryan commented on a change in pull request #11480: [FLINK-16597] handle exception thrown from close method in OutputFormat

2020-12-09 Thread GitBox
rkhachatryan commented on a change in pull request #11480: URL: https://github.com/apache/flink/pull/11480#discussion_r539647610 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/operators/DataSinkTaskTest.java ## @@ -276,6 +277,25 @@ public void testSortingDa

  1   2   3   4   >