[GitHub] [flink] lirui-apache commented on issue #11524: [FLINK-16803][hive] Need to make sure partition inherit table spec wh…

2020-03-26 Thread GitBox
lirui-apache commented on issue #11524: [FLINK-16803][hive] Need to make sure partition inherit table spec wh… URL: https://github.com/apache/flink/pull/11524#issuecomment-604804335 cc @JingsongLi This is an automated messag

[GitHub] [flink] flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-589009467 ## CI report: * 7a4635a9699b7b524265c41ccb0ddedf5dd30e0e Trav

[GitHub] [flink] flinkbot edited a comment on issue #11504: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11504: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11504#issuecomment-603693689 ## CI report: * e12b582ecf20820f5a79e71190785788cd99d552 Travis: [SUCCESS](https://travis-ci.com/github

[GitHub] [flink] flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380 ## CI report: * 296e62e22eb9cff454f1c6756cbd796ec20fbde2 Travis: [SUCCESS](https://trav

[jira] [Updated] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-16819: Description: Recently,  we are trying to upgrade online *sql jobs* from flink1.7 to flink1.9 , mo

[jira] [Updated] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingxing Di updated FLINK-16819: Description: Recently,  we are trying to upgrade online *sql jobs* from flink1.7 to flink1.9 , mo

[jira] [Created] (FLINK-16819) Got KryoException while using UDAF in flink1.9

2020-03-26 Thread Xingxing Di (Jira)
Xingxing Di created FLINK-16819: --- Summary: Got KryoException while using UDAF in flink1.9 Key: FLINK-16819 URL: https://issues.apache.org/jira/browse/FLINK-16819 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16709) add a set command to set job name when submit job on sql client

2020-03-26 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068249#comment-17068249 ] Jun Zhang commented on FLINK-16709: --- hi,[~jark] ,I am Sorry I should first discuss wit

[GitHub] [flink] becketqin commented on a change in pull request #10487: [FLINK-15100][connector/source] Add a base implementation for SourceReader.

2020-03-26 Thread GitBox
becketqin commented on a change in pull request #10487: [FLINK-15100][connector/source] Add a base implementation for SourceReader. URL: https://github.com/apache/flink/pull/10487#discussion_r399021138 ## File path: flink-connectors/flink-connector-base/src/main/java/org/apache/fli

[GitHub] [flink] flinkbot commented on issue #11540: [FLINK-16099] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-26 Thread GitBox
flinkbot commented on issue #11540: [FLINK-16099] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540#issuecomment-604800038 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[GitHub] [flink] flinkbot edited a comment on issue #11504: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11504: [FLINK-16767][hive] Failed to read Hive table with RegexSerDe URL: https://github.com/apache/flink/pull/11504#issuecomment-603693689 ## CI report: * e12b582ecf20820f5a79e71190785788cd99d552 Travis: [SUCCESS](https://travis-ci.com/github

[jira] [Updated] (FLINK-16099) Translate "HiveCatalog" page of "Hive Integration" into Chinese

2020-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16099: --- Labels: pull-request-available (was: ) > Translate "HiveCatalog" page of "Hive Integration"

[GitHub] [flink] flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380 ## CI report: * 296e62e22eb9cff454f1c6756cbd796ec20fbde2 Travis: [SUCCESS](https://trav

[GitHub] [flink] gaofc opened a new pull request #11540: [FLINK-16099] Translate "HiveCatalog" page of "Hive Integration" into…

2020-03-26 Thread GitBox
gaofc opened a new pull request #11540: [FLINK-16099] Translate "HiveCatalog" page of "Hive Integration" into… URL: https://github.com/apache/flink/pull/11540 … Chinese [FLINK-16099] Translate "HiveCatalog" page of "Hive Integration" into Chinese ## What is the purpose

[GitHub] [flink] docete commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
docete commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r399018226 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBC

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r398997590 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dia

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r399001234 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dia

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r399015861 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dia

[GitHub] [flink] wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
wuchong commented on a change in pull request #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#discussion_r398997030 ## File path: flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDB

[GitHub] [flink] flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11425: [FLINK-16125][kafka] Remove unnecessary zookeeper.connect property validation URL: https://github.com/apache/flink/pull/11425#issuecomment-599933380 ## CI report: * 296e62e22eb9cff454f1c6756cbd796ec20fbde2 Travis: [SUCCESS](https://trav

[jira] [Updated] (FLINK-16794) ClassNotFoundException caused by ClassLoader.getSystemClassLoader using impertinently

2020-03-26 Thread victor.jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] victor.jiang updated FLINK-16794: - Description: In some containerization environment,the context classloader is not the  SystemClas

[GitHub] [flink] flinkbot edited a comment on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible URL: https://github.com/apache/flink/pull/11539#issuecomment-604788215 ## CI report: * bfaf6ddb417806aba9b586dee0b3197d3fb50e7b Travis: [PENDING](h

[GitHub] [flink] JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

2020-03-26 Thread GitBox
JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#discussion_r399011271 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink

[jira] [Resolved] (FLINK-16647) Miss file extension when inserting to hive table with compression

2020-03-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-16647. -- Resolution: Fixed release-1.10: d33c0eb7e880f91774dbed263ffcaf9c83b23e13 fd9d68f2c6e32894f6a

[GitHub] [flink] lirui-apache commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

2020-03-26 Thread GitBox
lirui-apache commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#discussion_r399010468 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/fli

[GitHub] [flink] JingsongLi merged pull request #11505: [FLINK-16647][table-runtime-blink][hive] Miss file extension when inserting to hive table with compression

2020-03-26 Thread GitBox
JingsongLi merged pull request #11505: [FLINK-16647][table-runtime-blink][hive] Miss file extension when inserting to hive table with compression URL: https://github.com/apache/flink/pull/11505 This is an automated message f

[GitHub] [flink] JingsongLi closed pull request #11440: [FLINK-16647][table-runtime-blink][hive] Miss file extension when ins…

2020-03-26 Thread GitBox
JingsongLi closed pull request #11440: [FLINK-16647][table-runtime-blink][hive] Miss file extension when ins… URL: https://github.com/apache/flink/pull/11440 This is an automated message from the Apache Git Service. To respo

[jira] [Comment Edited] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

2020-03-26 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068212#comment-17068212 ] Paul Lin edited comment on FLINK-16693 at 3/27/20, 3:01 AM:

[jira] [Assigned] (FLINK-16771) NPE when filtering by decimal column

2020-03-26 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16771: Assignee: Rui Li > NPE when filtering by decimal column > ---

[GitHub] [flink] JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

2020-03-26 Thread GitBox
JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#discussion_r399007833 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink

[GitHub] [flink] JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

2020-03-26 Thread GitBox
JingsongLi commented on a change in pull request #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#discussion_r399008363 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink

[GitHub] [flink] lirui-apache commented on issue #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column

2020-03-26 Thread GitBox
lirui-apache commented on issue #11511: [FLINK-16771][table-planner-blink] NPE when filtering by decimal column URL: https://github.com/apache/flink/pull/11511#issuecomment-604788184 @wuchong @JingsongLi Could you take a look? Thanks. ---

[GitHub] [flink] flinkbot commented on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible

2020-03-26 Thread GitBox
flinkbot commented on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible URL: https://github.com/apache/flink/pull/11539#issuecomment-604788215 ## CI report: * bfaf6ddb417806aba9b586dee0b3197d3fb50e7b UNKNOWN Bot comm

[GitHub] [flink] flinkbot commented on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible

2020-03-26 Thread GitBox
flinkbot commented on issue #11539: [FLINK-16800][table-common] Deal with nested types in TypeMappingUtils#checkIfCompatible URL: https://github.com/apache/flink/pull/11539#issuecomment-604785266 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] XuQianJin-Stars commented on a change in pull request #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner

2020-03-26 Thread GitBox
XuQianJin-Stars commented on a change in pull request #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner URL: https://github.com/apache/flink/pull/11186#discussion_r399003672 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/pla

[GitHub] [flink] docete opened a new pull request #11539: [FLINK-16800] Deal with nested types in TypeMappingUtils#checkIfCompatible

2020-03-26 Thread GitBox
docete opened a new pull request #11539: [FLINK-16800] Deal with nested types in TypeMappingUtils#checkIfCompatible URL: https://github.com/apache/flink/pull/11539 ## What is the purpose of the change the planner uses TypeMappingUtils#checkIfCompatible to validate logical schema and

[jira] [Updated] (FLINK-16800) TypeMappingUtils#checkIfCompatible didn't deal with nested types

2020-03-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16800: --- Labels: pull-request-available (was: ) > TypeMappingUtils#checkIfCompatible didn't deal wit

[GitHub] [flink] flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-589009467 ## CI report: * 8f3212ca7ae2fff228a1ca0f4edf6423f9f7b40c Trav

[jira] [Assigned] (FLINK-16786) Fix pyarrow version incompatible problem

2020-03-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16786: --- Assignee: Rong Rong > Fix pyarrow version incompatible problem > --

[jira] [Commented] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

2020-03-26 Thread Yumin Zhou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068222#comment-17068222 ] Yumin Zhou commented on FLINK-16693: [~jark] Thanks for pointing out the deprecated

[jira] [Commented] (FLINK-16709) add a set command to set job name when submit job on sql client

2020-03-26 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068217#comment-17068217 ] godfrey he commented on FLINK-16709: Hi [~zhangjun], Thanks for the suggestion. the

[GitHub] [flink] flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-589009467 ## CI report: * 8f3212ca7ae2fff228a1ca0f4edf6423f9f7b40c Trav

[jira] [Created] (FLINK-16818) Optimize data skew when flink write data to hive dynamic partition table

2020-03-26 Thread Jun Zhang (Jira)
Jun Zhang created FLINK-16818: - Summary: Optimize data skew when flink write data to hive dynamic partition table Key: FLINK-16818 URL: https://issues.apache.org/jira/browse/FLINK-16818 Project: Flink

[jira] [Commented] (FLINK-16693) Legacy planner incompatible with Timestamp backed by LocalDateTime

2020-03-26 Thread Paul Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068212#comment-17068212 ] Paul Lin commented on FLINK-16693: -- I'd like to fix this issue, would you please assign

[GitHub] [flink] godfreyhe commented on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate

2020-03-26 Thread GitBox
godfreyhe commented on issue #11158: [FLINK-16070] [table-planner-blink] blink stream planner supports remove constant keys from an aggregate URL: https://github.com/apache/flink/pull/11158#issuecomment-604779361 @JingsongLi thanks for the review, I have added a IT case to test upsert sink

[GitHub] [flink] dianfu merged pull request #11525: [hotfix][python] Improve the imports to use full path when importing a PyFlink module

2020-03-26 Thread GitBox
dianfu merged pull request #11525: [hotfix][python] Improve the imports to use full path when importing a PyFlink module URL: https://github.com/apache/flink/pull/11525 This is an automated message from the Apache Git Servic

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * da455c908da1c388b2f8bbfb82ce378dbbfe959d Travis: [FAILURE](https://travis-ci.com/git

[jira] [Resolved] (FLINK-16128) Translate "Google Cloud PubSub" page into Chinese

2020-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16128. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master (1.11.0): 66c2913742c2d6e92042c7466a398fb

[GitHub] [flink] wuchong merged pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-03-26 Thread GitBox
wuchong merged pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151 This is an automated message from the Apache Git Service. To respond to

[jira] [Resolved] (FLINK-16127) Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-16127. - Fix Version/s: 1.11.0 Resolution: Fixed Fixed in master (1.11.0): 7feba945907e6b5a31f8dcf27958594

[GitHub] [flink] wuchong merged pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-03-26 Thread GitBox
wuchong merged pull request #11129: [FLINK-16127][docs]Translate "Fault Tolerance Guarantees" page of connectors into Chinese URL: https://github.com/apache/flink/pull/11129 This is an automated message from the Apache Git S

[jira] [Commented] (FLINK-16709) add a set command to set job name when submit job on sql client

2020-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068199#comment-17068199 ] Jark Wu commented on FLINK-16709: - Hi [~zhangjun], new APIs should be discussed publical

[jira] [Commented] (FLINK-16774) expose HBaseUpsertSinkFunction hTableName and schema for other system

2020-03-26 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068194#comment-17068194 ] Jark Wu commented on FLINK-16774: - Hi [~jackylau], how do you want to expose them ? Do y

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * b0171c3f355301c93d871dc944e7a944d20751df Travis: [FAILURE](https://travis-ci.com/git

[GitHub] [flink] rkhachatryan commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

2020-03-26 Thread GitBox
rkhachatryan commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-604770763 Thanks for your feedback @pnowojski and @Myasuka ! I've updated the PR, please take a look.

[GitHub] [flink] becketqin commented on issue #10487: [FLINK-15100][connector/source] Add a base implementation for SourceReader.

2020-03-26 Thread GitBox
becketqin commented on issue #10487: [FLINK-15100][connector/source] Add a base implementation for SourceReader. URL: https://github.com/apache/flink/pull/10487#issuecomment-604769006 @StephanEwen Thanks a lot for the thorough review. Please see the replies to your questions below:

[jira] [Commented] (FLINK-15579) UpsertStreamTableSink should work on batch mode

2020-03-26 Thread xingoo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068189#comment-17068189 ] xingoo commented on FLINK-15579: Hi [~lzljs3620320] , how can i use upsert in batch jdb

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398982368 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398957647 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398980439 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398948746 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398978292 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398974123 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398965050 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398951005 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398967041 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398943916 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398953446 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

2020-03-26 Thread GitBox
rkhachatryan commented on a change in pull request #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#discussion_r398971205 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/run

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * b0171c3f355301c93d871dc944e7a944d20751df Travis: [FAILURE](https://travis-ci.com/git

[jira] [Closed] (FLINK-16814) StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-16814. Resolution: Invalid > StringUtils.arrayToString() doesn't convert byte[] correctly > -

[GitHub] [flink] bowenli86 closed pull request #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
bowenli86 closed pull request #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537 This is an automated message from the Apache Git Service.

[jira] [Updated] (FLINK-16817) StringUtils.arrayToString() doesn't convert array of byte array correctly

2020-03-26 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16817: - Summary: StringUtils.arrayToString() doesn't convert array of byte array correctly (was: StringUtils.ar

[GitHub] [flink] flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537#issuecomment-604695580 ## CI report: * 221c4c0f605768d181c968c31e6768d5a164aff9 Travis: [FAILURE](https://t

[jira] [Commented] (FLINK-16709) add a set command to set job name when submit job on sql client

2020-03-26 Thread Jun Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068179#comment-17068179 ] Jun Zhang commented on FLINK-16709: --- hi,[~jark] could you help me review the PR and gi

[GitHub] [flink] libenchao commented on a change in pull request #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner

2020-03-26 Thread GitBox
libenchao commented on a change in pull request #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner URL: https://github.com/apache/flink/pull/11186#discussion_r398973473 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/c

[GitHub] [flink] libenchao commented on issue #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner

2020-03-26 Thread GitBox
libenchao commented on issue #11186: [FLINK-16200][sql] Support JSON_EXISTS for blink planner URL: https://github.com/apache/flink/pull/11186#issuecomment-604757565 LGTM, +1 for merging. This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537#issuecomment-604695580 ## CI report: * 221c4c0f605768d181c968c31e6768d5a164aff9 Travis: [PENDING](https://t

[GitHub] [flink] flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output URL: https://github.com/apache/flink/pull/11520#issuecomment-604351350 ## CI report: * 9d764d2844b84aa16f1c0a54830ddfe00ce7a15c Travis: [FAILURE](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * b0171c3f355301c93d871dc944e7a944d20751df Travis: [PENDING](https://travis-ci.com/git

[jira] [Created] (FLINK-16817) StringUtils.arrayToString() doesn't convert byte[][] correctly

2020-03-26 Thread Bowen Li (Jira)
Bowen Li created FLINK-16817: Summary: StringUtils.arrayToString() doesn't convert byte[][] correctly Key: FLINK-16817 URL: https://issues.apache.org/jira/browse/FLINK-16817 Project: Flink Issue

[jira] [Updated] (FLINK-16816) planner doesn't parse timestamp and date array correctly

2020-03-26 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16816: - Description: planner doesn't parse timestamp and date array correctly.   Repro:  In a input format (l

[jira] [Updated] (FLINK-16816) planner doesn't parse timestamp and date array correctly

2020-03-26 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16816: - Summary: planner doesn't parse timestamp and date array correctly (was: planner doesn't parse timestamp

[jira] [Updated] (FLINK-16816) planner doesn't parse timestamp and date array correctly

2020-03-26 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-16816: - Description: planner doesn't parse timestamp and date array correctly.   Repro:  In a input format (l

[GitHub] [flink] flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537#issuecomment-604695580 ## CI report: * bfeec83db4397d74a3465d74e23df46a6686b1b1 Travis: [FAILURE](https://t

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * bb2e061e3cd7700976925926903b3d718c8b5e20 Travis: [FAILURE](https://travis-ci.com/git

[GitHub] [flink] flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#issuecomment-590065588 ## CI report: * 738a6fd162d5ba99432438d224f3b4890961af56 UNKNOWN * 77f24b292a04fde34f

[GitHub] [flink] flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output URL: https://github.com/apache/flink/pull/11520#issuecomment-604351350 ## CI report: * 9d764d2844b84aa16f1c0a54830ddfe00ce7a15c Travis: [PENDING](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #11536: [FLINK-16807][e2e] Improve reporting for instantiation errors

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11536: [FLINK-16807][e2e] Improve reporting for instantiation errors URL: https://github.com/apache/flink/pull/11536#issuecomment-604563654 ## CI report: * 02744178a91af131c0be0337a18e7cc65303495d Travis: [SUCCESS](https://travis-ci.com/githu

[GitHub] [flink] flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537#issuecomment-604695580 ## CI report: * bfeec83db4397d74a3465d74e23df46a6686b1b1 Travis: [FAILURE](https://t

[GitHub] [flink] flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output URL: https://github.com/apache/flink/pull/11520#issuecomment-604351350 ## CI report: * fdde3c90867a2cd1a023ddf8d2338cfc169d666c Travis: [FAILURE](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11460: [FLINK-16655][FLINK-16657] Introduce embedded executor and use it for Web Submission URL: https://github.com/apache/flink/pull/11460#issuecomment-601593052 ## CI report: * 733f24266f67d179404dad70159ab345536abf19 Travis: [CANCELED](http

[GitHub] [flink] flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11538: [FLINK-16813][jdbc] JDBCInputFormat doesn't correctly map Short URL: https://github.com/apache/flink/pull/11538#issuecomment-604708338 ## CI report: * bb2e061e3cd7700976925926903b3d718c8b5e20 Travis: [FAILURE](https://travis-ci.com/git

[GitHub] [flink] flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#issuecomment-596351676 ## CI report: * 715889a35cfcc3aaf1b17f39dadaa86f755cc75d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11537: [FLINK-16814][core] StringUtils.arrayToString() doesn't convert byte[] correctly URL: https://github.com/apache/flink/pull/11537#issuecomment-604695580 ## CI report: * bfeec83db4397d74a3465d74e23df46a6686b1b1 Travis: [FAILURE](https://t

[GitHub] [flink] flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11520: [FLINK-16798][scripts] Properly forward BashJavaUtils logging output URL: https://github.com/apache/flink/pull/11520#issuecomment-604351350 ## CI report: * fdde3c90867a2cd1a023ddf8d2338cfc169d666c Travis: [FAILURE](https://travis-ci.com

[jira] [Created] (FLINK-16816) planner doesn't parse timestamp array correctly

2020-03-26 Thread Bowen Li (Jira)
Bowen Li created FLINK-16816: Summary: planner doesn't parse timestamp array correctly Key: FLINK-16816 URL: https://issues.apache.org/jira/browse/FLINK-16816 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #11535: [FLINK-16175][table sql/ api][WIP]Add config option to switch case sensitive for column names in SQL

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11535: [FLINK-16175][table sql/ api][WIP]Add config option to switch case sensitive for column names in SQL URL: https://github.com/apache/flink/pull/11535#issuecomment-604493528 ## CI report: * ba3da8c0b8fced60866d527d098f9914e51b35a9 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11497: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11497: [FLINK-16262][Connectors] Set the context classloader for parallel stream in FlinkKafkaProducer URL: https://github.com/apache/flink/pull/11497#issuecomment-603106447 ## CI report: * 414aaf5b862918d15b915c2ca9bb8d979f1d9121 Travis: [SUC

[GitHub] [flink] flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters

2020-03-26 Thread GitBox
flinkbot edited a comment on issue #11195: [FLINK-16222][runtime] Use plugins mechanism for initializing MetricReporters URL: https://github.com/apache/flink/pull/11195#issuecomment-590065588 ## CI report: * 738a6fd162d5ba99432438d224f3b4890961af56 UNKNOWN * 77f24b292a04fde34f

<    1   2   3   4   5   6   7   >