[GitHub] [flink] flinkbot edited a comment on pull request #12561: [hotfix][docs]Fix typos in types_serialization.md and types_serializa…

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12561: URL: https://github.com/apache/flink/pull/12561#issuecomment-641467500 ## CI report: * 0ed5499a5659f5d895ef021de71ca7fa3ef6208c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #8111: URL: https://github.com/apache/flink/pull/8111#issuecomment-641645391 ## CI report: * 4b9dfa5a687f814ddf3638b031133c2c610c6abb Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/170609515) Bot

[GitHub] [flink-web] morsapaes commented on pull request #344: [blog] flink on zeppelin - part2

2020-06-09 Thread GitBox
morsapaes commented on pull request #344: URL: https://github.com/apache/flink-web/pull/344#issuecomment-641582940 Sounds good to me, @zjffdu! This is an automated message from the Apache Git Service. To respond to the

[jira] [Issue Comment Deleted] (FLINK-18208) flink es connector exists 2 Spelling mistakes

2020-06-09 Thread jackylau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jackylau updated FLINK-18208: - Comment: was deleted (was: fixed. PR: [https://github.com/apache/flink/pull/12543]) > flink es

[GitHub] [flink] flinkbot edited a comment on pull request #12562: [FLINK-18160][scripts] Do not log about HADOOP_CONF_DIR if HADOOP_CLA…

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12562: URL: https://github.com/apache/flink/pull/12562#issuecomment-641499801 ## CI report: * 7f7cd28b67295b5057dc0ad97c1d24e6291a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12413: [FLINK-16198][core] Fix FileUtilsTest fails on MacOS

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12413: URL: https://github.com/apache/flink/pull/12413#issuecomment-636264630 ## CI report: * 7e26193381e3394db486b93d6c6a75b3828a1f09 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12560: [FLINK-18097][history-server] Cleaning job files in history server

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12560: URL: https://github.com/apache/flink/pull/12560#issuecomment-641401209 ## CI report: * 3e40dddf2d2559baabc544e1254b942c853dd595 Azure:

[GitHub] [flink] sjwiesman commented on pull request #12549: [FLINK-18084][docs] Document the Application Mode

2020-06-09 Thread GitBox
sjwiesman commented on pull request #12549: URL: https://github.com/apache/flink/pull/12549#issuecomment-641600124 +1 looks good This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #12549: [FLINK-18084][docs] Document the Application Mode

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12549: URL: https://github.com/apache/flink/pull/12549#issuecomment-641241048 ## CI report: * bb195d8129e745a172d9599501d12d1a63c39c82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12545: [FLINK-18136] Don't start channel state writing for savepoints (backport to 1.11)

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12545: URL: https://github.com/apache/flink/pull/12545#issuecomment-641168101 ## CI report: * b62b57218a8473cd42806b827f3e3debeeae87be Azure:

[GitHub] [flink] zihehuang commented on pull request #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-09 Thread GitBox
zihehuang commented on pull request #8111: URL: https://github.com/apache/flink/pull/8111#issuecomment-641640608 @flinkbot attention @ljurukov @rmetzger Sorry for necroing this PR, but I am experiencing the same issue in flink 1.10

[GitHub] [flink] flinkbot commented on pull request #8111: [FLINK-10195] [RabbitMQ] - RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-06-09 Thread GitBox
flinkbot commented on pull request #8111: URL: https://github.com/apache/flink/pull/8111#issuecomment-641645391 ## CI report: * 4b9dfa5a687f814ddf3638b031133c2c610c6abb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12559: [FLINK-17982] Resolve TODOs in concepts documentation

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12559: URL: https://github.com/apache/flink/pull/12559#issuecomment-641386528 ## CI report: * 3f26c183fc37b5ed4655685e4ab1a4a40583e3cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12558: [FLINK-17976][docs][k8s/docker] Improvements about custom docker images

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12558: URL: https://github.com/apache/flink/pull/12558#issuecomment-641363903 ## CI report: * 624074492b48e925bf0c0a1aced2c15ecf08cc1d Azure:

[jira] [Commented] (FLINK-18209) Replace "charged" words in the Flink codebase.

2020-06-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129939#comment-17129939 ] Xintong Song commented on FLINK-18209: -- I'm +1 for replacing "slave", "blacklist" and "whitelist",

[GitHub] [flink] dianfu commented on a change in pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
dianfu commented on a change in pull request #12554: URL: https://github.com/apache/flink/pull/12554#discussion_r437821836 ## File path: flink-end-to-end-tests/flink-python-test/src/main/java/org/apache/flink/python/tests/TestScalarUdf.java ## @@ -0,0 +1,29 @@ +/* + *

[jira] [Commented] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-06-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129966#comment-17129966 ] Jiangjie Qin commented on FLINK-17761: -- [~liufangliang] Thanks for being interested. Sounds good to

[GitHub] [flink] DashShen opened a new pull request #12564: [hotfix][javadocs]Fix typo in KafkaResource.java

2020-06-09 Thread GitBox
DashShen opened a new pull request #12564: URL: https://github.com/apache/flink/pull/12564 Modify (**is** none is configured) to (**if** none is configured) This is an automated message from the Apache Git

[jira] [Commented] (FLINK-17976) Test native K8s integration

2020-06-09 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129965#comment-17129965 ] Yang Wang commented on FLINK-17976: --- For question #1, it is probably a bug or improvement of

[jira] [Closed] (FLINK-18133) Add documentation for the new Avro format

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18133. --- Resolution: Fixed - master (1.12.0): 821e786ce1e94e0074affcd50ecd4b87a6bd744b - 1.11.0:

[jira] [Updated] (FLINK-7479) Support physical offset in MATCH_RECOGNIZE (PREV)

2020-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7479: -- Labels: pull-request-available (was: ) > Support physical offset in MATCH_RECOGNIZE (PREV) >

[GitHub] [flink] dianfu closed pull request #4563: [FLINK-7479] [cep] Support to retrieve the past event by an offset

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

[GitHub] [flink] wuchong closed pull request #12465: [FLINK-18082][jdbc] UnsignedTypeConversionITCase stalls in ch.vorburer.mariadb4j.DB.stop

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

[jira] [Created] (FLINK-18225) Add collect method in the Python TableResult

2020-06-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-18225: --- Summary: Add collect method in the Python TableResult Key: FLINK-18225 URL: https://issues.apache.org/jira/browse/FLINK-18225 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #12567: [FLINK-15849][doc] Update SQL-CLIENT document from type to data-type

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

[jira] [Created] (FLINK-18228) Release pending pods/containers timely when pending slots changed

2020-06-09 Thread Yang Wang (Jira)
Yang Wang created FLINK-18228: - Summary: Release pending pods/containers timely when pending slots changed Key: FLINK-18228 URL: https://issues.apache.org/jira/browse/FLINK-18228 Project: Flink

[jira] [Commented] (FLINK-17976) Test native K8s integration

2020-06-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130080#comment-17130080 ] Xintong Song commented on FLINK-17976: -- And FLINK-18229 for question #2. But I guess this is rather

[GitHub] [flink] flinkbot edited a comment on pull request #12538: [FLINK-17422] Create user document for the external resource framewor…

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12538: URL: https://github.com/apache/flink/pull/12538#issuecomment-641018334 ## CI report: * 66760850c9e34be7445a9bbcd2d8a12b87a760ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12554: URL: https://github.com/apache/flink/pull/12554#issuecomment-641294850 ## CI report: * e2905d883839d1b8f32b5e9d82320e2dcbdb3e57 Azure:

[jira] [Assigned] (FLINK-7479) Support physical offset in MATCH_RECOGNIZE (PREV)

2020-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-7479: -- Assignee: (was: Dian Fu) > Support physical offset in MATCH_RECOGNIZE (PREV) >

[GitHub] [flink] flinkbot commented on pull request #12564: [hotfix][javadocs]Fix typo in KafkaResource.java

2020-06-09 Thread GitBox
flinkbot commented on pull request #12564: URL: https://github.com/apache/flink/pull/12564#issuecomment-641690061 ## CI report: * df0871ba78a0e4b68a7550ae3599d4a3c878a874 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #12565: [BP][FLINK-18018] Bundle GPU plugin in plugins/ directory

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

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * 586cad86df6ee5de33537f735fa5c65cabebe260 Azure:

[jira] [Commented] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130005#comment-17130005 ] Jark Wu commented on FLINK-18082: - I will just merge the pull request (not sure whether it can totall

[jira] [Closed] (FLINK-18082) UnsignedTypeConversionITCase stalls in ch.vorburger.mariadb4j.DB.stop

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18082. --- Fix Version/s: 1.11.0 Resolution: Fixed - master (1.12.0): 919bd548706c664e38804b009be7edf9365c7b8e

[jira] [Commented] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130026#comment-17130026 ] appleyuchi commented on FLINK-18227: !卡住.png! > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18227: --- Attachment: 卡住.png > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18227: --- Attachment: (was: 卡住.png) > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18227: --- Description: *1.*start-scala-shell.sh local then I type the example from the log after I start

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-09 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641707884 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the

[jira] [Assigned] (FLINK-17688) Support consuming Kinesis' enhanced fanout for flink-connector-kinesis

2020-06-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-17688: --- Assignee: Danny Cranmer > Support consuming Kinesis' enhanced fanout for

[jira] [Commented] (FLINK-17688) Support consuming Kinesis' enhanced fanout for flink-connector-kinesis

2020-06-09 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130040#comment-17130040 ] Tzu-Li (Gordon) Tai commented on FLINK-17688: - Thanks for taking this issue

[GitHub] [flink] flinkbot edited a comment on pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12554: URL: https://github.com/apache/flink/pull/12554#issuecomment-641294850 ## CI report: * 561fef4b26a6b3e393daaea5f97135deb19e9070 Azure:

[jira] [Created] (FLINK-18229) Pending worker requests should be properly cleared

2020-06-09 Thread Xintong Song (Jira)
Xintong Song created FLINK-18229: Summary: Pending worker requests should be properly cleared Key: FLINK-18229 URL: https://issues.apache.org/jira/browse/FLINK-18229 Project: Flink Issue

[GitHub] [flink] zhijiangW merged pull request #12545: [FLINK-18136] Don't start channel state writing for savepoints (backport to 1.11)

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

[jira] [Assigned] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-06-09 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-17761: Assignee: liufangliang > FutureCompletingBlockingQueue should have a capacity limit. >

[GitHub] [flink] Myasuka commented on pull request #12529: [FLINK-17800][roksdb] Ensure total order seek to avoid user misuse

2020-06-09 Thread GitBox
Myasuka commented on pull request #12529: URL: https://github.com/apache/flink/pull/12529#issuecomment-641682439 @StephanEwen Thanks for your review. I realized this problem when I created this PR, and I actually try to use [Parameterized test on single method with

[GitHub] [flink] flinkbot commented on pull request #12564: [hotfix][javadocs]Fix typo in KafkaResource.java

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

[GitHub] [flink] wuchong closed pull request #12523: [FLINK-18133][docs][avro] Add documentation for the new Avro format

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

[jira] [Assigned] (FLINK-16087) Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-16087: --- Assignee: RocMarshal > Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese >

[GitHub] [flink] flinkbot edited a comment on pull request #12564: [hotfix][javadocs]Fix typo in KafkaResource.java

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12564: URL: https://github.com/apache/flink/pull/12564#issuecomment-641690061 ## CI report: * df0871ba78a0e4b68a7550ae3599d4a3c878a874 Azure:

[GitHub] [flink] flinkbot commented on pull request #12565: [BP-1.11][FLINK-18018] Bundle GPU plugin in plugins/ directory

2020-06-09 Thread GitBox
flinkbot commented on pull request #12565: URL: https://github.com/apache/flink/pull/12565#issuecomment-641696166 ## CI report: * 23b6eb404e2f8abb263e97c19ea17341a4264dda UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12538: [FLINK-17422] Create user document for the external resource framewor…

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12538: URL: https://github.com/apache/flink/pull/12538#issuecomment-641018334 ## CI report: * 66760850c9e34be7445a9bbcd2d8a12b87a760ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12554: URL: https://github.com/apache/flink/pull/12554#issuecomment-641294850 ## CI report: * e2905d883839d1b8f32b5e9d82320e2dcbdb3e57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-640564258 ## CI report: * d9f08ec3f759dc19667162150bad8cf6197d0efd Azure:

[GitHub] [flink] libenchao commented on pull request #12564: [hotfix][javadocs]Fix typo in KafkaResource.java

2020-06-09 Thread GitBox
libenchao commented on pull request #12564: URL: https://github.com/apache/flink/pull/12564#issuecomment-641696051 @DashShen Thanks for your contribution, the changes LGTM, will merge. This is an automated message from the

[GitHub] [flink] danny0405 opened a new pull request #12567: [FLINK-15849][doc] Update SQL-CLIENT document from type to data-type

2020-06-09 Thread GitBox
danny0405 opened a new pull request #12567: URL: https://github.com/apache/flink/pull/12567 ## What is the purpose of the change Fix the SQL-CLI document to use `data-type` as key for schema fields. ## Brief change log - Fix sqlClient.md and sqlClient.zh.md

[jira] [Commented] (FLINK-13554) ResourceManager should have a timeout on starting new TaskExecutors.

2020-06-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130083#comment-17130083 ] Xintong Song commented on FLINK-13554: -- FYI, I've created FLINK-18229, which I believe is related

[jira] [Commented] (FLINK-16105) Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese

2020-06-09 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130100#comment-17130100 ] Benchao Li commented on FLINK-16105: [~wangsong] Thanks for taking this, assigned to you~ >

[GitHub] [flink] dianfu closed pull request #12552: [FLINK-18104][python][windows] Fix the test failures on Windows.

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

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * 7e9def2db9b7b755f7b048e4ee99339a509e390b Azure:

[jira] [Created] (FLINK-18224) Add document about sql client's tableau result mode

2020-06-09 Thread Kurt Young (Jira)
Kurt Young created FLINK-18224: -- Summary: Add document about sql client's tableau result mode Key: FLINK-18224 URL: https://issues.apache.org/jira/browse/FLINK-18224 Project: Flink Issue Type:

[GitHub] [flink] wuchong closed pull request #12427: [FLINK-16681][jdbc] Fix the bug that jdbc lost connection after a lon…

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

[GitHub] [flink] wuchong commented on pull request #11499: [FLINK-16681][Connectors/JDBC]Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to wri

2020-06-09 Thread GitBox
wuchong commented on pull request #11499: URL: https://github.com/apache/flink/pull/11499#issuecomment-641693145 Fixed by #12427. This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] pyscala opened a new pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-09 Thread GitBox
pyscala opened a new pull request #12566: URL: https://github.com/apache/flink/pull/12566 ## What is the purpose of the change Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue` ## Brief change log Add a constructor taking capacity

[jira] [Updated] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17761: --- Labels: pull-request-available (was: ) > FutureCompletingBlockingQueue should have a

[GitHub] [flink] wuchong closed pull request #11499: [FLINK-16681][Connectors/JDBC]Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

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

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18227: --- Description: *1.*start-scala-shell.sh local then I type the example from the log after I start

[jira] [Commented] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130024#comment-17130024 ] appleyuchi commented on FLINK-18227: !卡住.png! > official example stuck in flink shell(local mode) >

[jira] [Updated] (FLINK-15849) Update SQL-CLIENT document from type to data-type

2020-06-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15849: --- Labels: pull-request-available (was: ) > Update SQL-CLIENT document from type to data-type

[jira] [Closed] (FLINK-18104) Test pyflink on windows

2020-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-18104. --- Resolution: Done > Test pyflink on windows > --- > > Key: FLINK-18104 >

[jira] [Commented] (FLINK-18104) Test pyflink on windows

2020-06-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129954#comment-17129954 ] Dian Fu commented on FLINK-18104: - master: a16069da2bced3bb4f626ee5f8c860f615f0 release-1.11: 

[GitHub] [flink] KarmaGYZ opened a new pull request #12565: [BP][FLINK-18018] Bundle GPU plugin in plugins/ directory

2020-06-09 Thread GitBox
KarmaGYZ opened a new pull request #12565: URL: https://github.com/apache/flink/pull/12565 ## What is the purpose of the change Bundle GPU plugin in plugins/ directory ## Brief change log Bundle GPU plugin in plugins/ directory ## Verifying this

[GitHub] [flink] flinkbot commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

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

[GitHub] [flink] pyscala commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-09 Thread GitBox
pyscala commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641693599 Hi @becketqin ,appreciate for your time to review this PR,thanks This is an automated message from the Apache

[jira] [Closed] (FLINK-16681) Jdbc JDBCOutputFormat and JDBCLookupFunction PreparedStatement loss connection, if long time not records to write.

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16681. --- Fix Version/s: (was: 1.10.2) Resolution: Fixed - master (1.12.0):

[GitHub] [flink] flinkbot edited a comment on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-640564258 ## CI report: * 861e2a4a123eeca7e81cf1e932a3e0cdff2f1a2e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641701238 ## CI report: * 4086eac47b36d124dd13d8a15261bcc823b89e74 Azure:

[GitHub] [flink] flinkbot commented on pull request #12567: [FLINK-15849][doc] Update SQL-CLIENT document from type to data-type

2020-06-09 Thread GitBox
flinkbot commented on pull request #12567: URL: https://github.com/apache/flink/pull/12567#issuecomment-641709980 ## CI report: * 76c6bca81f3834034fb8a530cf1916fac6793d25 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Assigned] (FLINK-16105) Translate "User-defined Sources & Sinks" page of "Table API & SQL" into Chinese

2020-06-09 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benchao Li reassigned FLINK-16105: -- Assignee: wangsong (was: Benchao Li) > Translate "User-defined Sources & Sinks" page of

[jira] [Commented] (FLINK-18230) Table API has no Functions like sparkSQL explode

2020-06-09 Thread mzz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130097#comment-17130097 ] mzz commented on FLINK-18230: - As for my SQL, my idea is to flattening nest Array like sparksql.explode

[jira] [Closed] (FLINK-18093) E2E tests manually for Elasticsearch Sink

2020-06-09 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-18093. - Resolution: Fixed > E2E tests manually for Elasticsearch Sink >

[GitHub] [flink] KarmaGYZ commented on pull request #12398: [FLINK-17795][example] Add MatrixVectorMul example

2020-06-09 Thread GitBox
KarmaGYZ commented on pull request #12398: URL: https://github.com/apache/flink/pull/12398#issuecomment-641675141 @zentol Thanks for the explanation and help! This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12554: URL: https://github.com/apache/flink/pull/12554#issuecomment-641294850 ## CI report: * e2905d883839d1b8f32b5e9d82320e2dcbdb3e57 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12369: [FLINK-17678][Connectors/HBase]Support fink-sql-connector-hbase

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12369: URL: https://github.com/apache/flink/pull/12369#issuecomment-635090403 ## CI report: * 7e9def2db9b7b755f7b048e4ee99339a509e390b Azure:

[GitHub] [flink] WeiZhong94 commented on pull request #12554: [FLINK-18218][python][e2e] Add yarn perjob, java dependency management e2e tests for pyflink.

2020-06-09 Thread GitBox
WeiZhong94 commented on pull request #12554: URL: https://github.com/apache/flink/pull/12554#issuecomment-641684707 @dianfu Thanks for your review! I have addressed your comments. This is an automated message from the Apache

[GitHub] [flink] flinkbot commented on pull request #12566: [FLINK-17761][connector/common] Add a constructor taking capacity as a parameter for `FutureCompletingBlockingQueue`

2020-06-09 Thread GitBox
flinkbot commented on pull request #12566: URL: https://github.com/apache/flink/pull/12566#issuecomment-641701238 ## CI report: * 4086eac47b36d124dd13d8a15261bcc823b89e74 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-18226) ResourceManager requests unnecessary new workers if previous workers are allocated but not registered.

2020-06-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130021#comment-17130021 ] Xintong Song commented on FLINK-18226: -- Here are my proposal for solving this problem. * We should

[jira] [Created] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
appleyuchi created FLINK-18227: -- Summary: official example stuck in flink shell(local mode) Key: FLINK-18227 URL: https://issues.apache.org/jira/browse/FLINK-18227 Project: Flink Issue Type:

[jira] [Commented] (FLINK-18226) ResourceManager requests unnecessary new workers if previous workers are allocated but not registered.

2020-06-09 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17130022#comment-17130022 ] Xintong Song commented on FLINK-18226: -- cc [~trohrmann] > ResourceManager requests unnecessary new

[jira] [Updated] (FLINK-18227) official example stuck in flink shell(local mode)

2020-06-09 Thread appleyuchi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] appleyuchi updated FLINK-18227: --- Description: *1.*start-scala-shell.sh local then I type the example from the log after I start

[GitHub] [flink] flinkbot edited a comment on pull request #12565: [BP-1.11][FLINK-18018] Bundle GPU plugin in plugins/ directory

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12565: URL: https://github.com/apache/flink/pull/12565#issuecomment-641696166 ## CI report: * 23b6eb404e2f8abb263e97c19ea17341a4264dda Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12527: [FLINK-18173][build] Bundle flink-csv,flink-json,flink-avro jars in lib

2020-06-09 Thread GitBox
flinkbot edited a comment on pull request #12527: URL: https://github.com/apache/flink/pull/12527#issuecomment-640564258 ## CI report: * d9f08ec3f759dc19667162150bad8cf6197d0efd Azure:

[jira] [Created] (FLINK-18230) Table API has no Functions like sparkSQL explode

2020-06-09 Thread mzz (Jira)
mzz created FLINK-18230: --- Summary: Table API has no Functions like sparkSQL explode Key: FLINK-18230 URL: https://issues.apache.org/jira/browse/FLINK-18230 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-18104) Test pyflink on windows

2020-06-09 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129959#comment-17129959 ] Wei Zhong commented on FLINK-18104: --- Verified that:       - build PyFlink Java part on Windows, works

[jira] [Commented] (FLINK-16087) Translate "Detecting Patterns" page of "Streaming Concepts" into Chinese

2020-06-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16087?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129956#comment-17129956 ] RocMarshal commented on FLINK-16087: Hi, [~jark] I'm willing to translate this page. Could you

[jira] [Commented] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-06-09 Thread liufangliang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129969#comment-17129969 ] liufangliang commented on FLINK-17761: -- okey,thanks for your reply > FutureCompletingBlockingQueue

[jira] [Updated] (FLINK-17752) Align the timestamp format with Flink SQL types in JSON format

2020-06-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17752: Component/s: Table SQL / Ecosystem > Align the timestamp format with Flink SQL types in JSON format >

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

2020-06-09 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129967#comment-17129967 ] Lijie Wang commented on FLINK-16947: Another instance: 

[GitHub] [flink] dianfu closed pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

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

  1   2   3   4   5   6   7   8   >